Merge pull request #422 from uiuc-hpc/fix/comm_es_tls

comm: set parsec_tls_execution_stream in comm thread

Author: bosilca

parsec/parsec.c

@@ -2891,3 +2891,8 @@ parsec_execution_stream_t *parsec_my_execution_stream(void)
 {
     return (parsec_execution_stream_t*)PARSEC_TLS_GET_SPECIFIC(parsec_tls_execution_stream);
 }
+
+void parsec_set_my_execution_stream(parsec_execution_stream_t *es)
+{
+    PARSEC_TLS_SET_SPECIFIC(parsec_tls_execution_stream, es);
+}

parsec/parsec_internal.h

@@ -656,6 +656,9 @@ parsec_release_local_OUT_dependencies(parsec_execution_stream_t* es,
                                       parsec_data_copy_t* target_dc,
                                       data_repo_entry_t* target_repo_entry);
 
+/* Set internal TLS variable parsec_tls_execution_stream */
+void parsec_set_my_execution_stream(parsec_execution_stream_t *es);
+
 #define parsec_execution_context_priority_comparator offsetof(parsec_task_t, priority)
 
 #if defined(PARSEC_SIM)

parsec/remote_dep_mpi.c

@@ -473,6 +473,7 @@ remote_dep_mpi_initialize_execution_stream(parsec_context_t *context)
     memcpy(&parsec_comm_es, context->virtual_processes[0]->execution_streams[0],
            sizeof(parsec_execution_stream_t));
     parsec_comm_es.next_task = (parsec_task_t*)0xdeadbeef;  /* should not be NULL, but it should also never be used */
+    parsec_set_my_execution_stream(&parsec_comm_es);
 }
 
 void* remote_dep_dequeue_main(parsec_context_t* context)