hack to request all existing values for jobids other

than our own - required for mpi2 dynamic processes

This commit was SVN r7336.

ompi/mca/pml/base/pml_base_module_exchange.c

@@ -423,20 +423,38 @@ static int mca_pml_base_modex_subscribe(orte_process_name_t* name)
         return rc;
     }
 
-    if (ORTE_SUCCESS != (rc = orte_gpr.subscribe_1(&sub_id, trig_name, sub_name,
-                                         ORTE_GPR_NOTIFY_ADD_ENTRY |
-                                         ORTE_GPR_NOTIFY_VALUE_CHG |
-                                         ORTE_GPR_NOTIFY_STARTS_AFTER_TRIG,
-                                         ORTE_GPR_KEYS_OR | ORTE_GPR_TOKENS_OR,
-                                         segment,
-                                         NULL,  /* look at all containers on this segment */
-                                         OMPI_MODEX_KEY,
-                                         mca_pml_base_modex_registry_callback, NULL))) {
-        ORTE_ERROR_LOG(rc);
-        free(sub_name);
-        free(trig_name);
-        free(segment);
-        return rc;
+    if (jobid != orte_process_info.my_name->jobid) {
+        if (ORTE_SUCCESS != (rc = orte_gpr.subscribe_1(&sub_id, NULL, NULL,
+                                             ORTE_GPR_NOTIFY_ADD_ENTRY |
+                                             ORTE_GPR_NOTIFY_VALUE_CHG |
+                                             ORTE_GPR_NOTIFY_PRE_EXISTING,
+                                             ORTE_GPR_KEYS_OR | ORTE_GPR_TOKENS_OR,
+                                             segment,
+                                             NULL,  /* look at all containers on this segment */
+                                             OMPI_MODEX_KEY,
+                                             mca_pml_base_modex_registry_callback, NULL))) {
+            ORTE_ERROR_LOG(rc);
+            free(sub_name);
+            free(trig_name);
+            free(segment);
+            return rc;
+        }
+    } else {
+        if (ORTE_SUCCESS != (rc = orte_gpr.subscribe_1(&sub_id, trig_name, sub_name,
+                                             ORTE_GPR_NOTIFY_ADD_ENTRY |
+                                             ORTE_GPR_NOTIFY_VALUE_CHG |
+                                             ORTE_GPR_NOTIFY_STARTS_AFTER_TRIG,
+                                             ORTE_GPR_KEYS_OR | ORTE_GPR_TOKENS_OR,
+                                             segment,
+                                             NULL,  /* look at all containers on this segment */
+                                             OMPI_MODEX_KEY,
+                                             mca_pml_base_modex_registry_callback, NULL))) {
+            ORTE_ERROR_LOG(rc);
+            free(sub_name);
+            free(trig_name);
+            free(segment);
+            return rc;
+        }
     }
     free(sub_name);
     free(trig_name);