diff --git a/src/api/slurm_pmi.c b/src/api/slurm_pmi.c index 04a7bd57cd63cbd6bd36d4224f8eeb5fe3613968..03f54d756d4eb451e2d722f87effdf4348a1ed58 100644 --- a/src/api/slurm_pmi.c +++ b/src/api/slurm_pmi.c @@ -155,25 +155,8 @@ int slurm_get_kvs_comm_set(struct kvs_comm_set **kvs_set_ptr, error("slurm_get_kvs_comm_set msg_type=%d", msg_rcv.msg_type); return SLURM_UNEXPECTED_MSG_ERROR; } -#if 0 -info("send kvs confirmation @ %ld", (long)time(NULL)); if (slurm_send_rc_msg(&msg_rcv, SLURM_SUCCESS) < 0) error("slurm_send_rc_msg: %m"); -info("sent kvs confirmation @ %ld", (long)time(NULL)); -#endif -#if 0 -info("send kvs confirmation @ %ld", (long)time(NULL)); -{ - return_code_msg_t rc_msg; - rc_msg.return_code = SLURM_SUCCESS; - msg_send.msg_type = RESPONSE_SLURM_RC; - msg_send.address = msg_rcv.address; - msg_send.data = &rc_msg; - if (slurm_send_node_msg(srun_fd, &msg_send) < 0) - error("slurm_send_node_msg"); -} -info("sent kvs confirmation @ %ld", (long)time(NULL)); -#endif slurm_close_accepted_conn(srun_fd); *kvs_set_ptr = msg_rcv.data; return SLURM_SUCCESS; diff --git a/src/srun/pmi.c b/src/srun/pmi.c index 2137a38a0508bf7813858e4ae1eca1a2c93f93ff..05987e3e5efec9e9dde682f2faf9b8f339b8202a 100644 --- a/src/srun/pmi.c +++ b/src/srun/pmi.c @@ -39,7 +39,7 @@ #include "src/common/xstring.h" #include "src/common/xmalloc.h" -#define _DEBUG 1 +#define _DEBUG 0 /* Global variables */ pthread_mutex_t kvs_mutex = PTHREAD_MUTEX_INITIALIZER; @@ -131,11 +131,7 @@ static void *_agent(void *x) (void) slurm_shutdown_msg_conn(task_fd); continue; } -#if 0 -info("get reply @ %ld", (long)time(NULL)); rc = slurm_receive_msg(task_fd, &msg_rcv, 0); -info("got reply, rc=%d @ %ld", rc, (long)time(NULL)); -#endif (void) slurm_shutdown_msg_conn(task_fd); if (rc < 0) { error("KVS_Barrier confirm fail from %s",