Changeset 2193905 for lib/data-struct/message_queue.c

Timestamp:

11/29/18 10:12:59 (2 years ago)

Author:

Jacob Van Walraven <jcv9@…>

Branches:

develop

Children:

fdf23b8

Parents:

d74ca03

Message:

Apply changes required for pull request #81

File:

• lib/data-struct/message_queue.c (modified) (2 diffs)

lib/data-struct/message_queue.c

@@ -43 +43 @@
 void libtrace_message_queue_init(libtrace_message_queue_t *mq, size_t message_len)
 {
-        /*assert(message_len);*/
         if (!message_len) {
                 fprintf(stderr, "Message length cannot be 0 in libtrace_message_queue_init()\n");
@@ -73 +72 @@
 {
         int ret;
-        /*assert(mq->message_len);*/
-        //if (!mq->message_len) {
-        //      fprintf(stderr, "Message queue must be initialised with libtrace_message_queue_init()"
-        //              "before inserting messages in libtrace_message_queue_put()\n");
-        //      /* Can we return -1 here as this could imply threads are waiting */
-        //      return -1;
-        //}
+        if (!mq->message_len) {
+                fprintf(stderr, "Message queue must be initialised with libtrace_message_queue_init()"
+                        "before inserting messages in libtrace_message_queue_put()\n");
+                return 0;
+        }
         ASSERT_RET(write(mq->pipefd[1], message, mq->message_len), == (int) mq->message_len);
         // Update after we've written