Update to track PMIx master

Signed-off-by: Ralph Castain <[email protected]>

Author: Ralph Castain

opal/mca/pmix/pmix2x/pmix/VERSION

@@ -30,7 +30,7 @@ greek=
 # command, or with the date (if "git describe" fails) in the form of
 # "date<date>".
 
-repo_rev=git6ab9c8d
+repo_rev=git0de7b68
 
 # If tarball_version is not empty, it is used as the version string in
 # the tarball filename, regardless of all other versions listed in
@@ -44,7 +44,7 @@ tarball_version=
 
 # The date when this release was created
 
-date="Oct 03, 2017"
+date="Oct 05, 2017"
 
 # The shared library version of each of PMIx's public libraries.
 # These versions are maintained in accordance with the "Library

opal/mca/pmix/pmix2x/pmix/include/pmix_common.h

@@ -164,7 +164,8 @@ typedef uint32_t pmix_rank_t;
                                                                     //        MCA param select the active transport
 
 /* attributes for TCP connections */
-#define PMIX_TCP_URI                        "pmix.tcp.uri"          // (char*) URI of server to connect to
+#define PMIX_TCP_REPORT_URI                 "pmix.tcp.repuri"       // (char*) output URI - '-' => stdout, '+' => stderr, or filename
+#define PMIX_TCP_URI                        "pmix.tcp.uri"          // (char*) URI of server to connect to, or file:<name of file containing it>
 #define PMIX_TCP_IF_INCLUDE                 "pmix.tcp.ifinclude"    // (char*) comma-delimited list of devices and/or CIDR notation
 #define PMIX_TCP_IF_EXCLUDE                 "pmix.tcp.ifexclude"    // (char*) comma-delimited list of devices and/or CIDR notation
 #define PMIX_TCP_IPV4_PORT                  "pmix.tcp.ipv4"         // (int) IPv4 port to be used
@@ -1170,6 +1171,14 @@ struct pmix_info_t {
             pmix_list_append((l), &_kv->super);                \
         }                                                      \
     } while(0)
+/* define a special macro for checking if a boolean
+ * info is true - when info structs are provided, a
+ * type of PMIX_UNDEF is taken to imply a boolean "true"
+ * as the presence of the key defaults to indicating
+ * "true" */
+#define PMIX_INFO_TRUE(m)   \
+    (PMIX_UNDEF == (m)->value.type || (PMIX_BOOL == (m)->value.type && (m)->value.data.flag)) ? true : false
+
 
 /****    PMIX LOOKUP RETURN STRUCT    ****/
 typedef struct pmix_pdata {

opal/mca/pmix/pmix2x/pmix/src/client/pmix_client.c

@@ -664,15 +664,7 @@ PMIX_EXPORT pmix_status_t PMIx_Finalize(const pmix_info_t info[], size_t ninfo)
         if (NULL != info && 0 < ninfo) {
             for (n=0; n < ninfo; n++) {
                 if (0 == strcmp(PMIX_EMBED_BARRIER, info[n].key)) {
-                    /* did they specify a value? */
-                    if (PMIX_BOOL == info[n].value.type) {
-                        if (info[n].value.data.flag) {
-                            /* they do want the barrier */
-                            PMIx_Fence(NULL, 0, NULL, 0);
-                        }
-                    } else {
-                        /* providing this attribute is considered
-                         * to be "true" by default */
+                    if (PMIX_INFO_TRUE(&info[n])) {
                         PMIx_Fence(NULL, 0, NULL, 0);
                     }
                     break;

opal/mca/pmix/pmix2x/pmix/src/client/pmix_client_get.c

@@ -492,15 +492,9 @@ static void _getnbfn(int fd, short flags, void *cbdata)
     if (NULL != cb->info) {
         for (n=0; n < cb->ninfo; n++) {
             if (0 == strncmp(cb->info[n].key, PMIX_OPTIONAL, PMIX_MAX_KEYLEN)) {
-                if (PMIX_UNDEF == cb->info[n].value.type ||
-                    cb->info[n].value.data.flag) {
-                    optional = true;
-                }
+                optional = PMIX_INFO_TRUE(&cb->info[n]);
             } else if (0 == strncmp(cb->info[n].key, PMIX_IMMEDIATE, PMIX_MAX_KEYLEN)) {
-                if (PMIX_UNDEF == cb->info[n].value.type ||
-                    cb->info[n].value.data.flag) {
-                    immediate = true;
-                }
+                immediate = PMIX_INFO_TRUE(&cb->info[n]);
             } else if (0 == strncmp(cb->info[n].key, PMIX_TIMEOUT, PMIX_MAX_KEYLEN)) {
                 /* set a timer to kick us out if we don't
                  * have an answer within their window */

opal/mca/pmix/pmix2x/pmix/src/event/pmix_event_notification.c

@@ -813,11 +813,8 @@ static void _notify_client_event(int sd, short args, void *cbdata)
         /* check for caching instructions */
         for (n=0; n < cd->ninfo; n++) {
             if (0 == strncmp(cd->info[n].key, PMIX_EVENT_DO_NOT_CACHE, PMIX_MAX_KEYLEN)) {
-                if (PMIX_UNDEF == cd->info[n].value.type ||
-                    cd->info[n].value.data.flag) {
-                    holdcd = false;
-                    break;
-                }
+                holdcd = PMIX_INFO_TRUE(&cd->info[n]);
+                break;
             }
         }
     }

opal/mca/pmix/pmix2x/pmix/src/event/pmix_event_registration.c

@@ -443,45 +443,32 @@ static void reg_event_hdlr(int sd, short args, void *cbdata)
         for (n=0; n < cd->ninfo; n++) {
             if (0 == strncmp(cd->info[n].key, PMIX_EVENT_HDLR_FIRST, PMIX_MAX_KEYLEN)) {
                 /* flag if they asked to put this one first overall */
-                if (PMIX_UNDEF == cd->info[n].value.type ||
-                    cd->info[n].value.data.flag) {
-                    firstoverall = true;
-                }
+                firstoverall = PMIX_INFO_TRUE(&cd->info[n]);
             } else if (0 == strncmp(cd->info[n].key, PMIX_EVENT_HDLR_LAST, PMIX_MAX_KEYLEN)) {
                 /* flag if they asked to put this one last overall */
-                if (PMIX_UNDEF == cd->info[n].value.type ||
-                    cd->info[n].value.data.flag) {
-                    lastoverall = true;
-                }
+                lastoverall = PMIX_INFO_TRUE(&cd->info[n]);
             } else if (0 == strncmp(cd->info[n].key, PMIX_EVENT_HDLR_PREPEND, PMIX_MAX_KEYLEN)) {
                 /* flag if they asked to prepend this handler */
-                if (PMIX_UNDEF == cd->info[n].value.type ||
-                    cd->info[n].value.data.flag) {
+                if (PMIX_INFO_TRUE(&cd->info[n])) {
                     location = PMIX_EVENT_ORDER_PREPEND;
                 }
             } else if (0 == strncmp(cd->info[n].key, PMIX_EVENT_HDLR_APPEND, PMIX_MAX_KEYLEN)) {
                 /* flag if they asked to append this handler */
-                if (PMIX_UNDEF == cd->info[n].value.type ||
-                    cd->info[n].value.data.flag) {
+                if (PMIX_INFO_TRUE(&cd->info[n])) {
                     location = PMIX_EVENT_ORDER_APPEND;
                 }
             } else if (0 == strncmp(cd->info[n].key, PMIX_EVENT_HDLR_NAME, PMIX_MAX_KEYLEN)) {
                 name = cd->info[n].value.data.string;
             } else if (0 == strncmp(cd->info[n].key, PMIX_EVENT_ENVIRO_LEVEL, PMIX_MAX_KEYLEN)) {
-                if (PMIX_UNDEF == cd->info[n].value.type ||
-                    cd->info[n].value.data.flag) {
-                    cd->enviro = true;
-                }
+                cd->enviro = PMIX_INFO_TRUE(&cd->info[n]);
             } else if (0 == strncmp(cd->info[n].key, PMIX_EVENT_RETURN_OBJECT, PMIX_MAX_KEYLEN)) {
                 cbobject = cd->info[n].value.data.ptr;
             } else if (0 == strncmp(cd->info[n].key, PMIX_EVENT_HDLR_FIRST_IN_CATEGORY, PMIX_MAX_KEYLEN)) {
-                if (PMIX_UNDEF == cd->info[n].value.type ||
-                    cd->info[n].value.data.flag) {
+                if (PMIX_INFO_TRUE(&cd->info[n])) {
                     location = PMIX_EVENT_ORDER_FIRST;
                 }
             } else if (0 == strncmp(cd->info[n].key, PMIX_EVENT_HDLR_LAST_IN_CATEGORY, PMIX_MAX_KEYLEN)) {
-                if (PMIX_UNDEF == cd->info[n].value.type ||
-                    cd->info[n].value.data.flag) {
+                if (PMIX_INFO_TRUE(&cd->info[n])) {
                     location = PMIX_EVENT_ORDER_LAST;
                 }
             } else if (0 == strncmp(cd->info[n].key, PMIX_EVENT_HDLR_BEFORE, PMIX_MAX_KEYLEN)) {

opal/mca/pmix/pmix2x/pmix/src/mca/gds/ds12/gds_dstore.c

@@ -2754,7 +2754,9 @@ static pmix_status_t dstore_del_nspace(const char* nspace)
             PMIX_ERROR_LOG(rc);
             goto exit;
         }
-        PMIX_DESTRUCT(trk);
+        if (true == trk->in_use) {
+            PMIX_DESTRUCT(trk);
+        }
     }
 
     /* A lot of nspaces may be using same session info

opal/mca/pmix/pmix2x/pmix/src/mca/gds/gds.h

@@ -354,6 +354,9 @@ typedef pmix_status_t (*pmix_gds_base_module_add_nspace_fn_t)(const char *nspace
         pmix_gds_base_active_module_t *_g;                  \
         pmix_status_t _s = PMIX_SUCCESS;                    \
         (s) = PMIX_SUCCESS;                                 \
+        pmix_output_verbose(1, pmix_gds_base_output,        \
+                            "[%s:%d] GDS ADD NSPACE %s",    \
+                            __FILE__, __LINE__, (n));       \
         PMIX_LIST_FOREACH(_g, &pmix_gds_globals.actives,    \
                           pmix_gds_base_active_module_t) {  \
             if (NULL != _g->module->add_nspace) {           \
@@ -381,6 +384,9 @@ typedef pmix_status_t (*pmix_gds_base_module_del_nspace_fn_t)(const char* nspace
         pmix_gds_base_active_module_t *_g;                  \
         pmix_status_t _s = PMIX_SUCCESS;                    \
         (s) = PMIX_SUCCESS;                                 \
+        pmix_output_verbose(1, pmix_gds_base_output,        \
+                            "[%s:%d] GDS DEL NSPACE %s",    \
+                            __FILE__, __LINE__, (n));       \
         PMIX_LIST_FOREACH(_g, &pmix_gds_globals.actives,    \
                           pmix_gds_base_active_module_t) {  \
             if (NULL != _g->module->del_nspace) {           \

opal/mca/pmix/pmix2x/pmix/src/mca/psensor/file/psensor_file.c

@@ -199,11 +199,11 @@ static pmix_status_t start(pmix_peer_t *requestor, pmix_status_t error,
     /* check the directives to see if what they want monitored */
     for (n=0; n < ndirs; n++) {
         if (0 == strcmp(directives[n].key, PMIX_MONITOR_FILE_SIZE)) {
-            ft->file_size = directives[n].value.data.flag;
+            ft->file_size = PMIX_INFO_TRUE(&directives[n]);
         } else if (0 == strcmp(directives[n].key, PMIX_MONITOR_FILE_ACCESS)) {
-            ft->file_access = directives[n].value.data.flag;
+            ft->file_access = PMIX_INFO_TRUE(&directives[n]);
         } else if (0 == strcmp(directives[n].key, PMIX_MONITOR_FILE_MODIFY)) {
-            ft->file_mod = directives[n].value.data.flag;
+            ft->file_mod = PMIX_INFO_TRUE(&directives[n]);
         } else if (0 == strcmp(directives[n].key, PMIX_MONITOR_FILE_DROPS)) {
             ft->ndrops = directives[n].value.data.uint32;
         } else if (0 == strcmp(directives[n].key, PMIX_MONITOR_FILE_CHECK_TIME)) {

opal/mca/pmix/pmix2x/pmix/src/mca/ptl/base/ptl_base_listener.c

@@ -79,9 +79,8 @@ static pmix_status_t setup_listeners(pmix_info_t *info, size_t ninfo, bool *need
     /* scan the directives to see if they want only one listener setup */
     if (NULL != info) {
         for (n=0; n < ninfo; n++) {
-            if (0 == strncmp(info[n].key, PMIX_SINGLE_LISTENER, PMIX_MAX_KEYLEN) &&
-                (PMIX_UNDEF == info[n].value.type || info[n].value.data.flag)) {
-                single = true;
+            if (0 == strncmp(info[n].key, PMIX_SINGLE_LISTENER, PMIX_MAX_KEYLEN)) {
+                single = PMIX_INFO_TRUE(&info[n]);
                 break;
             }
         }