From 55364a819692d63080d23e6dc30daf38f02f5524 Mon Sep 17 00:00:00 2001 From: Uros Majstorovic Date: Sat, 9 Sep 2017 12:49:56 +0200 Subject: msgq minor fix --- code/core/msgq.c | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) (limited to 'code/core/msgq.c') diff --git a/code/core/msgq.c b/code/core/msgq.c index 45df608..b928a2d 100644 --- a/code/core/msgq.c +++ b/code/core/msgq.c @@ -59,10 +59,7 @@ void ecp_conn_msgq_destroy(ECPConnMsgQ *msgq) { pthread_mutex_destroy(&msgq->mutex); } -int ecp_conn_msgq_start(ECPConnection *conn, ecp_seq_t seq) { - ECPRBRecv *buf = conn->rbuf.recv; - ECPConnMsgQ *msgq = buf ? &buf->msgq : NULL; - +int ecp_conn_msgq_start(ECPConnMsgQ *msgq, ecp_seq_t seq) { if (msgq == NULL) return ECP_ERR; msgq->seq_max = seq; -- cgit v1.2.3