X-Git-Url: http://git.harvie.cz/?p=mirrors%2FPrograms.git;a=blobdiff_plain;f=c%2Fpthread_extra%2Fpthread_extra.h;h=faffb3d7165ee4897e4b80cbc032f558193ad7a8;hp=861b8474626ab37da3c969c5ee19d41aeafe27ca;hb=9e057e1d605cf0960fa40ecf6825aa89d9371f78;hpb=77c7dc7ffcaa64879e90178df5585f22790f46be

diff --git a/c/pthread_extra/pthread_extra.h b/c/pthread_extra/pthread_extra.h
index 861b847..faffb3d 100644
--- a/c/pthread_extra/pthread_extra.h
+++ b/c/pthread_extra/pthread_extra.h
@@ -44,11 +44,14 @@ int pthread_unpause(pthread_t thread);
 
 // Message queues
 
-#define PTHREAD_XMQ_FRONT true
-#define PTHREAD_XMQ_BACK false
-
-#define PTHREAD_XMQ_RECV false
-#define PTHREAD_XMQ_PEEK true
+//Flags
+typedef uint8_t pthread_mq_flags_t;
+#define PTHREAD_XMQ_NONE	0			///< No flags specified (default behaviour)
+#define PTHREAD_XMQ_FRONT	1			///< Send to front of the queue (scheduled for next receive)
+#define PTHREAD_XMQ_BACK	PTHREAD_XMQ_NONE	///< Send to back of the queue (default)
+#define PTHREAD_XMQ_PEEK	2			///< Only peek, do not remove received item
+#define PTHREAD_XMQ_RECV	PTHREAD_XMQ_NONE	///< Remove received item from queue (default)
+#define PTHREAD_XMQ_OVERW	4			///< Overwrite item if queue full
 
 typedef struct pthread_mq_t {
 	pthread_mutex_t lock;
@@ -66,8 +69,8 @@ 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);
 
 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);
+bool pthread_mq_send_generic(pthread_mq_t *mq, void * data, pthread_mq_flags_t flags, const struct timespec *restrict abs_timeout);
+bool pthread_mq_receive_generic(pthread_mq_t *mq, void * data, pthread_mq_flags_t flags, const struct timespec *restrict abs_timeout);
 
 size_t pthread_mq_waiting(pthread_mq_t *mq);
 size_t pthread_mq_vacant(pthread_mq_t *mq);