Changeset 5ba34eb for lib/data-struct/message_queue.c
- Timestamp:
- 06/23/14 23:35:44 (8 years ago)
- Branches:
- 4.0.1-hotfixes, cachetimestamps, develop, dpdk-ndag, etsilive, libtrace4, master, ndag_format, pfring, rc-4.0.1, rc-4.0.2, rc-4.0.3, rc-4.0.4, ringdecrementfix, ringperformance, ringtimestampfixes
- Children:
- 5876154
- Parents:
- ed81f74
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
lib/data-struct/message_queue.c
rfac8c46 r5ba34eb 16 16 * see: man 7 pipe notes on atomic operations 17 17 */ 18 inlinevoid libtrace_message_queue_init(libtrace_message_queue_t *mq, size_t message_len)18 void libtrace_message_queue_init(libtrace_message_queue_t *mq, size_t message_len) 19 19 { 20 20 assert(message_len); … … 41 41 * of messages. 42 42 */ 43 in line int libtrace_message_queue_put(libtrace_message_queue_t *mq, const void *message)43 int libtrace_message_queue_put(libtrace_message_queue_t *mq, const void *message) 44 44 { 45 45 int ret; … … 66 66 * of messages. 67 67 */ 68 in line int libtrace_message_queue_get(libtrace_message_queue_t *mq, void *message)68 int libtrace_message_queue_get(libtrace_message_queue_t *mq, void *message) 69 69 { 70 70 int ret; … … 90 90 * of messages. 91 91 */ 92 in line int libtrace_message_queue_try_get(libtrace_message_queue_t *mq, void *message)92 int libtrace_message_queue_try_get(libtrace_message_queue_t *mq, void *message) 93 93 { 94 94 int ret; … … 113 113 * May be negative if threads blocking and waiting for a message. 114 114 */ 115 in line int libtrace_message_queue_count(const libtrace_message_queue_t *mq)115 int libtrace_message_queue_count(const libtrace_message_queue_t *mq) 116 116 { 117 117 // This is only ok because we know int is atomic … … 119 119 } 120 120 121 inlinevoid libtrace_message_queue_destroy(libtrace_message_queue_t *mq)121 void libtrace_message_queue_destroy(libtrace_message_queue_t *mq) 122 122 { 123 123 mq->message_count = 0; … … 131 131 * @return a file descriptor for the queue, can be used with select() poll() etc. 132 132 */ 133 in line int libtrace_message_queue_get_fd(libtrace_message_queue_t *mq)133 int libtrace_message_queue_get_fd(libtrace_message_queue_t *mq) 134 134 { 135 135 return mq->pipefd[0];
Note: See TracChangeset
for help on using the changeset viewer.