msgQ: Move into namespace conv
authorRamprasad Venkataraman <ramv@illinois.edu>
Fri, 22 Jun 2012 18:07:03 +0000 (13:07 -0500)
committerRamprasad Venkataraman <ramv@illinois.edu>
Sun, 28 Oct 2012 01:13:09 +0000 (20:13 -0500)
src/conv-core/msgq.h
tests/charm++/queue/msgqtest.C

index 2ab1d8e9d8cdf8841f27aeff8d4259147f3a74c5..95cb4d74072e9fb3726a348876db425c626bf204 100644 (file)
@@ -11,6 +11,8 @@
 #include <map>
 #endif
 
 #include <map>
 #endif
 
+namespace conv {
+
 typedef void msg_t;
 
 template <typename P>
 typedef void msg_t;
 
 template <typename P>
@@ -144,5 +146,7 @@ void msgQ<P>::enumerate(msg_t **first, msg_t **last) const
     }
 }
 
     }
 }
 
+} // end namespace conv
+
 #endif // MSG_Q_H
 
 #endif // MSG_Q_H
 
index a5558632c4e21b60fc77d15726815f5dc08ea178..9aa477cd0954f81c0de25b33530bae0d3a1958dd 100644 (file)
@@ -21,7 +21,7 @@ using std::sprintf;
 // length of 0
 bool test_empty()
 {
 // length of 0
 bool test_empty()
 {
-  msgQ<int> q;
+  conv::msgQ<int> q;
   bool result = (0 == q.size()) && (q.empty());
   return result;
 }
   bool result = (0 == q.size()) && (q.empty());
   return result;
 }
@@ -32,7 +32,7 @@ bool test_empty()
 // The queue is not allowed to dereference the void* we give it
 bool test_one()
 {
 // The queue is not allowed to dereference the void* we give it
 bool test_one()
 {
-  msgQ<int> q;
+  conv::msgQ<int> q;
   void *p = 0;
   q.enq(p);
   bool result = (1 == q.size()) && (!q.empty());
   void *p = 0;
   q.enq(p);
   bool result = (1 == q.size()) && (!q.empty());
@@ -47,7 +47,7 @@ bool test_one()
 // Put two in, see if we get the same two back. Order unspecified
 bool test_two()
 {
 // Put two in, see if we get the same two back. Order unspecified
 bool test_two()
 {
-  msgQ<int> q;
+  conv::msgQ<int> q;
   void *i = 0, *j = (char *)1;
   void *r, *s;
   q.enq(i);
   void *i = 0, *j = (char *)1;
   void *r, *s;
   q.enq(i);
@@ -62,7 +62,7 @@ bool test_two()
 
 bool test_fifo()
 {
 
 bool test_fifo()
 {
-  msgQ<int> q;
+  conv::msgQ<int> q;
   void *i = (char *)1, *j = (char *)2, *k = (char *)3;
   void *r, *s, *t;
   q.enq(i);
   void *i = (char *)1, *j = (char *)2, *k = (char *)3;
   void *r, *s, *t;
   q.enq(i);
@@ -77,7 +77,7 @@ bool test_fifo()
 
 bool test_lifo()
 {
 
 bool test_lifo()
 {
-  msgQ<int> q;
+  conv::msgQ<int> q;
   void *i = (char *)1, *j = (char *)2, *k = (char *)3;
   void *r, *s, *t;
   q.enq(i, 0, false);
   void *i = (char *)1, *j = (char *)2, *k = (char *)3;
   void *r, *s, *t;
   q.enq(i, 0, false);
@@ -92,7 +92,7 @@ bool test_lifo()
 
 bool test_enqueue_mixed()
 {
 
 bool test_enqueue_mixed()
 {
-  msgQ<int> q;
+  conv::msgQ<int> q;
   void *i = (char *)1, *j = (char *)2, *k = (char *)3;
   void *r, *s, *t;
   q.enq(i);
   void *i = (char *)1, *j = (char *)2, *k = (char *)3;
   void *r, *s, *t;
   q.enq(i);
@@ -117,7 +117,7 @@ static bool findEntry(void ** const e, int num, void * const t)
 
 bool test_enumerate()
 {
 
 bool test_enumerate()
 {
-  msgQ<int> q;
+  conv::msgQ<int> q;
   void *i = (char *)1, *j = (char *)2, *k = (char *)3;
   q.enq(i);
   q.enq(j);
   void *i = (char *)1, *j = (char *)2, *k = (char *)3;
   q.enq(i);
   q.enq(j);
@@ -131,7 +131,7 @@ bool test_enumerate()
 
 bool test_stl_ififo()
 {
 
 bool test_stl_ififo()
 {
-  msgQ<int> q;
+  conv::msgQ<int> q;
   void *i = (char *)1, *j = (char *)2, *k = (char *)3, *l = (char*)4;
   unsigned int a = -1, b = 0, c = 1, d = -1;
   q.enq(i, d, true);
   void *i = (char *)1, *j = (char *)2, *k = (char *)3, *l = (char*)4;
   unsigned int a = -1, b = 0, c = 1, d = -1;
   q.enq(i, d, true);
@@ -159,10 +159,10 @@ std::vector<unsigned int> prios(qSizeMax + numMsgs);
 
 double timePerOp_stlQ(int qBaseSize = 256)
 {
 
 double timePerOp_stlQ(int qBaseSize = 256)
 {
-  msgQ<int> q;
+  conv::msgQ<int> q;
 
   for (int i = 0; i < qBaseSize; i++)
 
   for (int i = 0; i < qBaseSize; i++)
-      q.enq((msg_t*)&msgs[i], prios[i]);
+      q.enq((conv::msg_t*)&msgs[i], prios[i]);
 
   double startTime = CmiWallTimer();
   for (int i = 0; i < numIters; i++)
 
   double startTime = CmiWallTimer();
   for (int i = 0; i < numIters; i++)
@@ -170,7 +170,7 @@ double timePerOp_stlQ(int qBaseSize = 256)
     for (int strt = qBaseSize; strt < qBaseSize + numMsgs; strt += qBatchSize)
     {
       for (int j = strt; j < strt + qBatchSize; j++)
     for (int strt = qBaseSize; strt < qBaseSize + numMsgs; strt += qBatchSize)
     {
       for (int j = strt; j < strt + qBatchSize; j++)
-        q.enq((msg_t*)&msgs[j], prios[j]);
+        q.enq((conv::msg_t*)&msgs[j], prios[j]);
       void *m;
       for (int j = 0; j < qBatchSize; j++)
         q.deq();
       void *m;
       for (int j = 0; j < qBatchSize; j++)
         q.deq();
@@ -227,7 +227,7 @@ bool perftest_general_ififo()
 // Template for new harness-driven tests
 bool test_foo()
 {
 // Template for new harness-driven tests
 bool test_foo()
 {
-  msgQ<int> q;
+  conv::msgQ<int> q;
 
   bool result = ;
   return result;
 
   bool result = ;
   return result;