Fix bug starting write processes for failed write process.

(Was starting wrong kind of process).
heroku · Mar 7, 2012 · f0e03a9 · f0e03a9
1 parent 2296db8
commit f0e03a9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/logplex_shard.erl b/src/logplex_shard.erl
@@ -223,7 +223,7 @@ handle_child_death(Pid) ->
             ?INFO("at=read_pool_restart oldpid=~p newpid=~p",
                   [Pid, NewPid]);
         {logplex_redis_buffer_map, {{Shard, {Url, Pid}}, Map, V}} ->
-            NewPid = add_pool(Url),
+            NewPid = add_buffer(Url),
             NewMap = dict:store(Shard, {Url, NewPid}, Map),
             logplex_shard_info:save(logplex_redis_buffer_map, NewMap, V),
             ?INFO("at=write_pool_restart oldpid=~p newpid=~p",