X-Git-Url: https://git.harvie.cz/?a=blobdiff_plain;f=c%2Fpthread_extra%2Fpthread_msgqueue.c;h=44ad399ecb9ef195b78cae64994af93cd4c685db;hb=fe2f8298009c4e8fc3b7904b07dc2ba3afc4a045;hp=52395d6d3944b5b4c8484357992b6864bd9f844c;hpb=9e057e1d605cf0960fa40ecf6825aa89d9371f78;p=mirrors%2FPrograms.git diff --git a/c/pthread_extra/pthread_msgqueue.c b/c/pthread_extra/pthread_msgqueue.c index 52395d6..44ad399 100644 --- a/c/pthread_extra/pthread_msgqueue.c +++ b/c/pthread_extra/pthread_msgqueue.c @@ -75,6 +75,9 @@ bool pthread_mq_send_generic(pthread_mq_t *mq, void * data, pthread_mq_flags_t f } } + //Handle overwrite + assert(!(flags & PTHREAD_XMQ_OVERW) && "FIXME: Overwrite not implemented yet!"); + //Write data to queue bool to_front = (flags & PTHREAD_XMQ_FRONT); size_t idx = ( ( mq->head_idx + (to_front?mq->msg_count_max-1:mq->msg_count) ) % mq->msg_count_max );