Support queue registration in reconverse

src/CMakeLists.txt

@@ -1,6 +1,6 @@
 target_include_directories(reconverse PRIVATE .)
 target_sources(reconverse PRIVATE conv-conds.cpp convcore.cpp random.cpp 
-                scheduler.cpp cpuaffinity.cpp mempool.C collectives.cpp
+                scheduler.cpp scheduler_helpers.cpp cpuaffinity.cpp mempool.C collectives.cpp
                 comm_backend/comm_backend_internal.cpp threads.cpp cldb.rand.cpp cldb.cpp cmirdmautils.cpp 
                 conv-rdma.cpp conv-topology.cpp msgmgr.cpp queueing.cpp cmishmem.cpp
                 conv-taskq.cpp)

src/convcore.cpp

@@ -137,6 +137,8 @@ void converseRunPe(int rank, int everReturn) {
   CmiTaskQueueInit();
   #endif
 
+  CmiQueueRegisterInitThread();
+
   // init things like cld module, ccs, etc
   CldModuleInit(CmiMyArgv);
 
@@ -365,6 +367,9 @@ void ConverseInit(int argc, char **argv, CmiStartFn fn, int usched,
   CmiHandlerTable = new std::vector<CmiHandlerInfo> *[Cmi_mynodesize];
   CmiNodeQueue = new ConverseNodeQueue<void *>();
 
+  //register queues
+  CmiQueueRegisterInit();
+
   _smp_mutex = CmiCreateLock();
   CmiMemLock_lock = CmiCreateLock();
 

src/converse_internal.h

@@ -64,9 +64,12 @@ CmiState *CmiGetState(void);
 void CmiInitState(int pe);
 ConverseQueue<void *> *CmiGetQueue(int pe);
 void CrnInit(void);
-
 void CmiPushPE(int destRank, int messageSize, void *msg);
 
+//queue reg init
+void CmiQueueRegisterInit(void);
+void CmiQueueRegisterInitThread(void); 
+
 // node queue
 ConverseNodeQueue<void *> *CmiGetNodeQueue();