Merge pull request #2427 from rhc54/topic/iof

Enable buffered IOF output

Author: rhc54

.gitignore

@@ -173,6 +173,7 @@ test/simple/simpfabric
 test/simple/get_put_example
 test/simple/simpvni
 test/simple/hybrid
+test/simple/asyncio
 
 test/sshot/daemon
 test/sshot/generate

EXCEPTIONS

@@ -54,6 +54,8 @@ PMIX_IOF_OUTPUT_TO_DIRECTORY        "pmix.iof.dir"          // (char*) direct ap
 PMIX_IOF_OUTPUT_TO_FILE             "pmix.iof.file"         // (char*) direct application output into files of form
                                                             //         "<filename>.rank" with both stdout and stderr redirected into it
 PMIX_IOF_RANK_OUTPUT                "pmix.iof.rank"         // (bool) Tag output with the rank it came from
+PMIX_IOF_OUTPUT_RAW                 "pmix.iof.raw"          // (bool) Do not buffer output to be written as complete lines - output
+                                                            //        characters as the stream delivers them
 PMIX_NODE_OVERSUBSCRIBED            "pmix.ndosub"           // (bool) true if number of procs from this job on this node
                                                             //        exceeds the number of slots allocated to it
 PMIX_SINGLETON                      "pmix.singleton"        // (char*) String representation (nspace.rank) of proc ID for the singleton
@@ -179,6 +181,8 @@ PMIX_IOF_FILE_ONLY                  "pmix.iof.fonly"        // (bool) output onl
 PMIX_IOF_FILE_PATTERN               "pmix.iof.fpt"          // (bool) Specified output file is to be treated as a pattern and not
                                                             //        automatically annotated by nspace, rank, or other parameters
 PMIX_IOF_LOCAL_OUTPUT               "pmix.iof.local"        // (bool) Write output streams to local stdout/err
+PMIX_IOF_OUTPUT_RAW                 "pmix.iof.raw"          // (bool) Do not buffer output to be written as complete lines - output
+                                                            //        characters as the stream delivers them
 PMIX_IOF_MERGE_STDERR_STDOUT        "pmix.iof.mrg"          // (bool) merge stdout and stderr streams from application procs
 PMIX_IOF_OUTPUT_TO_DIRECTORY        "pmix.iof.dir"          // (char*) direct application output into files of form
                                                             //         "<directory>/<jobid>/rank.<rank>/stdout[err]"

include/pmix_common.h.in

@@ -906,6 +906,8 @@ typedef uint32_t pmix_rank_t;
                                                                     //        The original output stream(s) destination is restored upon
                                                                     //        termination of the tool.
 #define PMIX_IOF_LOCAL_OUTPUT               "pmix.iof.local"        // (bool) Write output streams to local stdout/err
+#define PMIX_IOF_OUTPUT_RAW                 "pmix.iof.raw"          // (bool) Do not buffer output to be written as complete lines - output
+                                                                    //        characters as the stream delivers them
 
 /* Attributes for controlling contents of application setup data */
 #define PMIX_SETUP_APP_ENVARS               "pmix.setup.env"        // (bool) harvest and include relevant envars

src/class/pmix_list.h

@@ -119,10 +119,12 @@ struct pmix_list_item_t {
 typedef struct pmix_list_item_t pmix_list_item_t;
 
 /* static initializer for pmix_list_t */
-#define PMIX_LIST_ITEM_STATIC_INIT                                            \
-    {                                                                         \
-        .super = PMIX_OBJ_STATIC_INIT(pmix_object_t), .pmix_list_next = NULL, \
-        .pmix_list_prev = NULL, .item_free = 0                                \
+#define PMIX_LIST_ITEM_STATIC_INIT                      \
+    {                                                   \
+        .super = PMIX_OBJ_STATIC_INIT(pmix_object_t),   \
+        .pmix_list_next = NULL,                         \
+        .pmix_list_prev = NULL,                         \
+        .item_free = 0                                  \
     }
 
 /**
@@ -164,10 +166,11 @@ struct pmix_list_t {
 typedef struct pmix_list_t pmix_list_t;
 
 /* static initializer for pmix_list_t */
-#define PMIX_LIST_STATIC_INIT                                                   \
-    {                                                                           \
-        .super = PMIX_OBJ_STATIC_INIT(pmix_object_t),                           \
-        .pmix_list_sentinel = PMIX_LIST_ITEM_STATIC_INIT, .pmix_list_length = 0 \
+#define PMIX_LIST_STATIC_INIT                               \
+    {                                                       \
+        .super = PMIX_OBJ_STATIC_INIT(pmix_object_t),       \
+        .pmix_list_sentinel = PMIX_LIST_ITEM_STATIC_INIT,   \
+        .pmix_list_length = 0                               \
     }
 
 /** Cleanly destruct a list