From c4ec64929de2257104e3117f0d860f91cfbe501f Mon Sep 17 00:00:00 2001 From: ckolivas Date: Tue, 28 Oct 2014 00:41:49 +1100 Subject: [PATCH] Revert "Only allow one send_recv_proc at a time" This reverts commit 9d793945f0e9c91823429be342e139aae457060d. --- src/ckpool.c | 6 +----- 1 file changed, 1 insertion(+), 5 deletions(-) diff --git a/src/ckpool.c b/src/ckpool.c index 59b17caf..0ac0de3a 100644 --- a/src/ckpool.c +++ b/src/ckpool.c @@ -489,20 +489,16 @@ char *_send_recv_proc(proc_instance_t *pi, const char *msg, const char *file, co LOGALERT("Attempting to send message %s to dead process %s", msg, pi->processname); goto out; } - - mutex_lock(&pi->lock); sockd = open_unix_client(path); if (unlikely(sockd < 0)) { LOGWARNING("Failed to open socket %s in send_recv_proc", path); - goto out_unlock; + goto out; } if (unlikely(!send_unix_msg(sockd, msg))) LOGWARNING("Failed to send %s to socket %s", msg, path); else buf = recv_unix_msg(sockd); Close(sockd); -out_unlock: - mutex_unlock(&pi->lock); out: if (unlikely(!buf)) LOGERR("Failure in send_recv_proc from %s %s:%d", file, func, line);