Do not commit - IOF debug

Signed-off-by: Joshua Hursey <jhursey@us.ibm.com>
openpmix · Jan 30, 2020 · 8f6fb99 · 8f6fb99
1 parent 624f41c
commit 8f6fb99
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 0 deletions.
diff --git a/src/mca/iof/base/iof_base_output.c b/src/mca/iof/base/iof_base_output.c
@@ -62,6 +62,12 @@ int prrte_iof_base_write_output(const prrte_process_name_t *name, prrte_iof_tag_
                          (PRRTE_IOF_STDIN & stream) ? "stdin" : ((PRRTE_IOF_STDOUT & stream) ? "stdout" : ((PRRTE_IOF_STDERR & stream) ? "stderr" : "stddiag")),
                          PRRTE_NAME_PRINT(name),
                          (NULL == channel) ? -1 : channel->fd));
+    if( (PRRTE_IOF_STDIN & stream) ) {
+        prrte_output(0, "%s write:output setting up to write %d bytes to stdin for %s on fd %d",
+                     PRRTE_NAME_PRINT(PRRTE_PROC_MY_NAME), numbytes,
+                     PRRTE_NAME_PRINT(name),
+                     (NULL == channel) ? -1 : channel->fd);
+    }
 
     /* setup output object */
     output = PRRTE_NEW(prrte_iof_write_output_t);
@@ -264,6 +270,9 @@ int prrte_iof_base_write_output(const prrte_process_name_t *name, prrte_iof_tag_
         PRRTE_OUTPUT_VERBOSE((1, prrte_iof_base_framework.framework_output,
                              "%s write:output adding write event",
                              PRRTE_NAME_PRINT(PRRTE_PROC_MY_NAME)));
+        prrte_output(0, "%s write:output adding write event (fd %d)",
+                     PRRTE_NAME_PRINT(PRRTE_PROC_MY_NAME),
+                     (NULL == channel) ? -1 : channel->fd );
         PRRTE_IOF_SINK_ACTIVATE(channel);
     }
 

diff --git a/src/mca/iof/hnp/iof_hnp.c b/src/mca/iof/hnp/iof_hnp.c
@@ -261,6 +261,14 @@ static int push_stdin(const prrte_process_name_t* dst_name,
     }
 
     /* pass the data to the sink */
+    prrte_output(0,"%s iof:hnp pushing stdin for process %s: size %zu",
+                 PRRTE_NAME_PRINT(PRRTE_PROC_MY_NAME),
+                 PRRTE_NAME_PRINT(dst_name), sz);
+    prrte_output(0,"%s iof:hnp pushing stdin for process %s: size %zu - debug (%s) (%s)",
+                 PRRTE_NAME_PRINT(PRRTE_PROC_MY_NAME),
+                 PRRTE_NAME_PRINT(dst_name), sz,
+                 (NULL == proct ? "null" : "valid"),
+                 (NULL != proct && NULL != proct->stdinev ? "valid" : "null"));
 
     /* if the daemon is me, then this is a local sink */
     if (PRRTE_EQUAL == prrte_util_compare_name_fields(mask, PRRTE_PROC_MY_NAME, &proct->stdinev->daemon)) {
@@ -273,6 +281,10 @@ static int push_stdin(const prrte_process_name_t* dst_name,
          * closing the output stream
          */
         if (NULL != proct->stdinev->wev) {
+            prrte_output(0,"%s iof:hnp pushing stdin for process %s: size %zu - Local send",
+                         PRRTE_NAME_PRINT(PRRTE_PROC_MY_NAME),
+                         PRRTE_NAME_PRINT(dst_name), sz);
+
             if (PRRTE_IOF_MAX_INPUT_BUFFERS < prrte_iof_base_write_output(&proct->name, PRRTE_IOF_STDIN, data, sz, proct->stdinev->wev)) {
                 /* getting too backed up - stop the read event for now if it is still active */
 
@@ -282,6 +294,9 @@ static int push_stdin(const prrte_process_name_t* dst_name,
             }
         }
     } else {
+        prrte_output(0,"%s iof:hnp pushing stdin for process %s: size %zu - Remote peer",
+                     PRRTE_NAME_PRINT(PRRTE_PROC_MY_NAME),
+                     PRRTE_NAME_PRINT(dst_name), sz);
         PRRTE_OUTPUT_VERBOSE((1, prrte_iof_base_framework.framework_output,
                              "%s sending %d bytes from stdinev to daemon %s",
                              PRRTE_NAME_PRINT(PRRTE_PROC_MY_NAME), (int)sz,