From 601a9fae87f539df841dcd14089e0e91b07cfd91 Mon Sep 17 00:00:00 2001 From: Heikki Hannikainen Date: Mon, 15 Aug 2016 20:06:23 +0300 Subject: [PATCH] incoming: Add return value checks for pthread mutex locks --- src/incoming.c | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/incoming.c b/src/incoming.c index dd0139a..a989c4f 100644 --- a/src/incoming.c +++ b/src/incoming.c @@ -404,6 +404,8 @@ static struct pbuf_t *pbuf_get(struct worker_t *self, int len) void incoming_flush(struct worker_t *self) { + int me; + /* try grab the lock.. if it fails, we'll try again, either * in 200 milliseconds or after next input */ @@ -413,7 +415,9 @@ void incoming_flush(struct worker_t *self) *self->pbuf_incoming_last = self->pbuf_incoming_local; self->pbuf_incoming_last = self->pbuf_incoming_local_last; self->pbuf_incoming_count += self->pbuf_incoming_local_count; - pthread_mutex_unlock(&self->pbuf_incoming_mutex); + if ((me = pthread_mutex_unlock(&self->pbuf_incoming_mutex))) { + hlog(LOG_ERR, "incoming: could not unlock pbuf_incoming_mutex: %s", strerror(me)); + } //hlog( LOG_DEBUG, "incoming_flush() sent out %d packets", self->pbuf_incoming_local_count );