ua1zbe
/
aprsc
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

incoming: Add return value checks for pthread mutex locks

This commit is contained in:
Heikki Hannikainen 2016-08-15 20:06:23 +03:00
parent 3eac956270
commit 601a9fae87
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/incoming.c
View File

@ -404,6 +404,8 @@ static struct pbuf_t *pbuf_get(struct worker_t *self, int len)
void incoming_flush(struct worker_t *self) void incoming_flush(struct worker_t *self)
{ {
int me;
/* try grab the lock.. if it fails, we'll try again, either /* try grab the lock.. if it fails, we'll try again, either
* in 200 milliseconds or after next input * 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;
self->pbuf_incoming_last = self->pbuf_incoming_local_last; self->pbuf_incoming_last = self->pbuf_incoming_local_last;
self->pbuf_incoming_count += self->pbuf_incoming_local_count; 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 ); //hlog( LOG_DEBUG, "incoming_flush() sent out %d packets", self->pbuf_incoming_local_count );