Merge pull request #2632 from rhc54/topic/updates

Transfer some minor cleanups back from the PMIx reference server

orte/mca/state/base/state_base_fns.c

@@ -928,6 +928,7 @@ void orte_state_base_check_all_complete(int fd, short args, void *cbdata)
                         /* this was a debugger daemon. notify that a debugger has detached */
                         ORTE_ACTIVATE_JOB_STATE(jdata, ORTE_JOB_STATE_DEBUGGER_DETACH);
                     }
+                    opal_hash_table_set_value_uint32(orte_job_data, jdata->jobid, NULL);
                     OBJ_RELEASE(jdata);
                 }
             }

orte/mca/state/dvm/state_dvm.c

@@ -457,5 +457,10 @@ static void check_complete(int fd, short args, void *cbdata)
 static void cleanup_job(int sd, short args, void *cbdata)
 {
     orte_state_caddy_t *caddy = (orte_state_caddy_t*)cbdata;
+    orte_job_t *jdata = caddy->jdata;
+
+    /* remove this object from the job array */
+    opal_hash_table_set_value_uint32(orte_job_data, jdata->jobid, NULL);
+
     OBJ_RELEASE(caddy);
 }

orte/tools/orte-dvm/orte-dvm.c

@@ -477,6 +477,7 @@ static void send_callback(int status, orte_process_name_t *peer,
 
     OBJ_RELEASE(buffer);
     /* cleanup the job object */
+    opal_hash_table_set_value_uint32(orte_job_data, jdata->jobid, NULL);
     OBJ_RELEASE(jdata);
 }
 
@@ -530,4 +531,3 @@ static void notify_requestor(int sd, short args, void *cbdata)
      * up in the send callback */
     OBJ_RELEASE(caddy);
 }
-