X-Git-Url: https://git.harvie.cz/?a=blobdiff_plain;f=c%2Fpthread_extra%2Fpthread_extra.h;h=861b8474626ab37da3c969c5ee19d41aeafe27ca;hb=77c7dc7ffcaa64879e90178df5585f22790f46be;hp=0652e0a568e146bc71844db1477f1c11f57b5a97;hpb=ee099ba70d72016b26380b4532c0f9cfb73d484f;p=mirrors%2FPrograms.git diff --git a/c/pthread_extra/pthread_extra.h b/c/pthread_extra/pthread_extra.h index 0652e0a..861b847 100644 --- a/c/pthread_extra/pthread_extra.h +++ b/c/pthread_extra/pthread_extra.h @@ -64,11 +64,14 @@ typedef struct pthread_mq_t { bool pthread_mq_init(pthread_mq_t *mq, size_t msg_size, size_t msg_count_max); void pthread_mq_free(pthread_mq_t *mq); -size_t pthread_mq_waiting(pthread_mq_t *mq); + bool pthread_mq_reset(pthread_mq_t *mq); bool pthread_mq_send_generic(pthread_mq_t *mq, void * data, bool to_front, const struct timespec *restrict abs_timeout); bool pthread_mq_receive_generic(pthread_mq_t *mq, void * data, bool peek, const struct timespec *restrict abs_timeout); +size_t pthread_mq_waiting(pthread_mq_t *mq); +size_t pthread_mq_vacant(pthread_mq_t *mq); + // Multi mutex locking #define pthread_mutex_swap(a, b) { pthread_mutex_t *s; s = (a); a = (b); b = s; }