commit 35a14fd30cc86288c2f261703910201ddd7ecbd2
author Brian Silverman <brians> Mon Mar 24 16:57:44 2014 -0700
committer Brian Silverman <brians> Mon Mar 24 20:21:53 2014 -0700
tree 29daa6b02752f2375bb30ce843af80ec8054a448
parent 9eaf91a579fd23c2618bad333f23429482ac596f

added more RawQueue tests

aos/linux_code/ipc_lib/queue.cc

diff --git a/aos/linux_code/ipc_lib/queue.cc b/aos/linux_code/ipc_lib/queue.cc
index ab117d1..739f2bb 100644
--- a/aos/linux_code/ipc_lib/queue.cc
+++ b/aos/linux_code/ipc_lib/queue.cc
@@ -23,7 +23,7 @@
               "RawQueue instances go into shared memory");
 
 const bool kReadDebug = false;
-const bool kWriteDebug = false;
+const bool kWriteDebug = true;
 const bool kRefDebug = false;
 const bool kFetchDebug = false;
 const bool kReadIndexDebug = false;
@@ -146,8 +146,6 @@
 }
 
 void *RawQueue::GetMessage() {
-  // TODO(brians): Test this function.
-
   MessageHeader *header = __atomic_load_n(&free_messages_, __ATOMIC_RELAXED);
   do {
     if (__builtin_expect(header == nullptr, 0)) {
@@ -280,19 +278,9 @@
 }
 
 bool RawQueue::WriteMessage(void *msg, int options) {
-  // TODO(brians): Test this function.
   if (kWriteDebug) {
     printf("queue: %p->WriteMessage(%p, %x)\n", this, msg, options);
   }
-  if (msg == NULL || msg < reinterpret_cast<void *>(global_core->mem_struct) ||
-      msg > static_cast<void *>((
-              reinterpret_cast<char *>(global_core->mem_struct) +
-              global_core->size))) {
-    fprintf(stderr, "queue: attempt to write bad message %p to %p. aborting\n",
-            msg, this);
-    printf("see stderr\n");
-    abort();
-  }
   {
     MutexLocker locker(&data_lock_);
     bool writable_waited = false;