Some minor cleanups of the DVM

Signed-off-by: Ralph Castain <rhc@open-mpi.org>

opal/mca/pmix/pmix3x/pmix/src/mca/ptl/tcp/ptl_tcp.c

@@ -528,10 +528,16 @@ static pmix_status_t parse_uri_file(char *filename,
         pmix_client_globals.myserver->proc_type = PMIX_PROC_SERVER | PMIX_PROC_V20;
         pmix_output_verbose(2, pmix_ptl_base_framework.framework_output,
                             "V20 SERVER DETECTED");
-    } else if (0 == strncmp(p2, "v2.1", strlen("v2.1"))) {
+    } else if (0 == strncmp(p2, "v2.1", strlen("v2.1")) ||
+               0 == strncmp(p2, "2.1", strlen("2.1"))) {
         pmix_client_globals.myserver->proc_type = PMIX_PROC_SERVER | PMIX_PROC_V21;
         pmix_output_verbose(2, pmix_ptl_base_framework.framework_output,
                             "V21 SERVER DETECTED");
+    } else if (0 == strncmp(p2, "3", strlen("3")) ||
+               0 == strncmp(p2, "v3", strlen("v3"))) {
+        pmix_client_globals.myserver->proc_type = PMIX_PROC_SERVER | PMIX_PROC_V3;
+        pmix_output_verbose(2, pmix_ptl_base_framework.framework_output,
+                            "V3 SERVER DETECTED");
     } else {
         pmix_output_verbose(2, pmix_ptl_base_framework.framework_output,
                             "UNKNOWN SERVER VERSION DETECTED: %s", p2);

opal/mca/pmix/pmix3x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c

@@ -625,6 +625,9 @@ static pmix_status_t setup_listener(pmix_info_t info[], size_t ninfo,
             CLOSE_THE_SOCKET(lt->socket);
             goto sockerror;
         }
+        pmix_output_verbose(2, pmix_ptl_base_framework.framework_output,
+                            "WRITING SYSTEM FILE %s",
+                            mca_ptl_tcp_component.system_filename);
         fp = fopen(mca_ptl_tcp_component.system_filename, "w");
         if (NULL == fp) {
             pmix_output(0, "Impossible to open the file %s in write mode\n", mca_ptl_tcp_component.system_filename);
@@ -637,7 +640,7 @@ static pmix_status_t setup_listener(pmix_info_t info[], size_t ninfo,
 
         /* output my nspace and rank plus the URI */
         fprintf(fp, "%s\n", lt->uri);
-        /* add a flag that indicates we accept v2.1 protocols */
+        /* add a flag that indicates we accept v3.0 protocols */
         fprintf(fp, "v%s\n", PMIX_VERSION);
         fclose(fp);
         /* set the file mode */
@@ -659,6 +662,9 @@ static pmix_status_t setup_listener(pmix_info_t info[], size_t ninfo,
             CLOSE_THE_SOCKET(lt->socket);
             goto sockerror;
         }
+        pmix_output_verbose(2, pmix_ptl_base_framework.framework_output,
+                            "WRITING TOOL FILE %s",
+                            mca_ptl_tcp_component.session_filename);
         fp = fopen(mca_ptl_tcp_component.session_filename, "w");
         if (NULL == fp) {
             pmix_output(0, "Impossible to open the file %s in write mode\n", mca_ptl_tcp_component.session_filename);

opal/mca/pmix/pmix3x/pmix/src/server/pmix_server_ops.c

@@ -264,12 +264,10 @@ pmix_status_t pmix_server_commit(pmix_peer_t *peer, pmix_buffer_t *buf)
         }
     }
     /* see if anyone local is waiting on this data- could be more than one */
-    pmix_output(0, "CHECKING PENDING");
     rc = pmix_pending_resolve(nptr, info->pname.rank, PMIX_SUCCESS, NULL);
     if (PMIX_SUCCESS != rc) {
         PMIX_ERROR_LOG(rc);
     }
-    pmix_output(0, "RETURNING %d", rc);
     return rc;
 }
 

orte/orted/pmix/pmix_server.c

@@ -286,7 +286,8 @@ int pmix_server_init(void)
      * PMIx connection point - only do this for the HNP as, in
      * at least one case, a daemon can be colocated with the
      * HNP and would overwrite the server rendezvous file */
-    if (orte_pmix_server_globals.system_server && ORTE_PROC_IS_HNP) {
+    if (orte_pmix_server_globals.system_server &&
+        (ORTE_PROC_IS_HNP || ORTE_PROC_IS_MASTER)) {
         kv = OBJ_NEW(opal_value_t);
         kv->key = strdup(OPAL_PMIX_SERVER_SYSTEM_SUPPORT);
         kv->type = OPAL_BOOL;

orte/orted/pmix/pmix_server_gen.c

@@ -742,9 +742,18 @@ static void _toolconn(int sd, short args, void *cbdata)
                         ORTE_NAME_PRINT(ORTE_PROC_MY_NAME));
 
    /* if we are the HNP, we can directly assign the jobid */
-    if (ORTE_PROC_IS_HNP) {
+    if (ORTE_PROC_IS_HNP || ORTE_PROC_IS_MASTER) {
         jdata = OBJ_NEW(orte_job_t);
         rc = orte_plm_base_create_jobid(jdata);
+        if (ORTE_SUCCESS != rc) {
+            tool.jobid = ORTE_JOBID_INVALID;
+            tool.vpid = 0;
+            if (NULL != cd->toolcbfunc) {
+                cd->toolcbfunc(rc, tool, cd->cbdata);
+            }
+            OBJ_RELEASE(cd);
+            return;
+        }
         opal_hash_table_set_value_uint32(orte_job_data, jdata->jobid, jdata);
         /* setup some required job-level fields in case this
          * tool calls spawn, or uses some other functions that