/* depends on queuing policy specifies in endpoint */
msgq->queue[msgq->in] = msgb;
msgq->nr_pending++;
- msgq->in = (++msgq->in) & (FWP_MSGQ_SIZE - 1);
+ msgq->in = (msgq->in + 1) & (FWP_MSGQ_SIZE - 1);
sem_post(&msgq->msg_sem);
/* release queue mutex */
msgb = msgq->queue[msgq->out];
msgq->nr_pending--;
- msgq->out = (++msgq->out) & (FWP_MSGQ_SIZE - 1);
+ msgq->out = (msgq->out + 1) & (FWP_MSGQ_SIZE - 1);
/* release queue mutex */
pthread_mutex_unlock(&msgq->lock);
while (msgq->in != msgq->out){
msgb = msgq->queue[msgq->out];
msgq->nr_pending--;
- msgq->out = (++msgq->out) & (FWP_MSGQ_SIZE - 1);
+ msgq->out = (msgq->out + 1) & (FWP_MSGQ_SIZE - 1);
fwp_msgb_free(msgb);
}