From f0e03a98c200e0687be6c13db3ea88c63dded367 Mon Sep 17 00:00:00 2001
From: Geoff Cant <nem@erlang.geek.nz>
Date: Wed, 7 Mar 2012 15:58:43 -0800
Subject: [PATCH] Fix bug starting write processes for failed write process.
 (Was starting wrong kind of process).

---
 src/logplex_shard.erl | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/logplex_shard.erl b/src/logplex_shard.erl
index 8d65f564..553dca14 100644
--- 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",