pmix2x: synchronize to the latest PMIx master

openpmix/openpmix@f57d9b2

Signed-off-by: Gilles Gouaillardet <[email protected]>

Author: ggouaillardet

opal/mca/pmix/pmix2x/pmix/VERSION

@@ -30,7 +30,7 @@ greek=a1
 # command, or with the date (if "git describe" fails) in the form of
 # "date<date>".
 
-repo_rev=git3b5c9b7
+repo_rev=gitf57d9b2
 
 # 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="Feb 14, 2017"
+date="Feb 20, 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/config/pmix_check_lock.m4

@@ -3,6 +3,8 @@ dnl
 dnl Copyright (c) 2017      Mellanox Technologies, Inc.
 dnl                         All rights reserved.
 dnl Copyright (c) 2017      IBM Corporation.  All rights reserved.
+dnl Copyright (c) 2017      Research Organization for Information Science
+dnl                         and Technology (RIST). All rights reserved.
 dnl $COPYRIGHT$
 dnl
 dnl Additional copyrights may follow
@@ -52,7 +54,7 @@ AC_DEFUN([PMIX_CHECK_DSTOR_LOCK],[
         if test "$_x_ac_fcntl_lock_found" == "0"; then
             AC_MSG_ERROR([dstore: no available locking mechanisms was found. Can not continue. Try disabling dstore])
         fi
+        LIBS="$orig_libs"
     fi
 
-    LIBS="$orig_libs"
 ])

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

@@ -1,6 +1,6 @@
 /* -*- Mode: C; c-basic-offset:4 ; indent-tabs-mode:nil -*- */
 /*
- * Copyright (c) 2014-2017 Intel, Inc. All rights reserved.
+ * Copyright (c) 2014-2016 Intel, Inc.  All rights reserved.
  * Copyright (c) 2014-2017 Research Organization for Information Science
  *                         and Technology (RIST). All rights reserved.
  * Copyright (c) 2014      Artem Y. Polyakov <[email protected]>.

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

@@ -477,13 +477,14 @@ static void _getnbfn(int fd, short flags, void *cbdata)
     pmix_cb_t *cb = (pmix_cb_t*)cbdata;
     pmix_cb_t *cbret;
     pmix_buffer_t *msg;
-    pmix_value_t *val;
+    pmix_value_t *val = NULL;
     pmix_info_t *info, *iptr;
     pmix_pointer_array_t results;
     pmix_status_t rc;
     pmix_nspace_t *ns, *nptr;
     size_t n, nvals;
     char *tmp;
+    bool my_nspace = false, my_rank = false;
 
     pmix_output_verbose(2, pmix_globals.debug_output,
                         "pmix: getnbfn value for proc %s:%d key %s",
@@ -596,65 +597,54 @@ static void _getnbfn(int fd, short flags, void *cbdata)
         return;
     }
 
-    /* should be in the internal hash table. */
-#if defined(PMIX_ENABLE_DSTORE) && (PMIX_ENABLE_DSTORE == 1)
+    /* check the internal storage first */
     rc = pmix_hash_fetch(&nptr->internal, cb->rank, cb->key, &val);
-    if (PMIX_SUCCESS != rc) {
-        rc = pmix_dstore_fetch(cb->nspace, cb->rank, cb->key, &val);
+    if(PMIX_SUCCESS == rc) {
+        goto respond;
     }
-    if (PMIX_SUCCESS == rc) {
-#else
-    if (PMIX_SUCCESS == (rc = pmix_hash_fetch(&nptr->internal, cb->rank, cb->key, &val))) {
+
+    my_nspace = (0 == strncmp(cb->nspace, pmix_globals.myid.nspace, PMIX_MAX_NSLEN));
+    my_rank = (pmix_globals.myid.rank == cb->rank);
+
+    /* if the key starts from "pmix", then they are looking for data
+     * that was provided at startup */
+    if (0 == strncmp(cb->key, "pmix", 4)) {
+#if defined(PMIX_ENABLE_DSTORE) && (PMIX_ENABLE_DSTORE == 1)
+        /* if this is a dstore - check there */
+        rc = pmix_dstore_fetch(cb->nspace, cb->rank, cb->key, &val);
 #endif
-        /* if this is a compressed string, then uncompress it */
-        if (PMIX_COMPRESSED_STRING == val->type) {
-            pmix_util_uncompress_string(&tmp, (uint8_t*)val->data.bo.bytes, val->data.bo.size);
-            if (NULL == tmp) {
-                PMIX_ERROR_LOG(PMIX_ERR_NOMEM);
-                rc = PMIX_ERR_NOMEM;
-                PMIX_VALUE_RELEASE(val);
-                val = NULL;
-            } else {
-                PMIX_VALUE_DESTRUCT(val);
-                PMIX_VAL_ASSIGN(val, string, tmp);
-            }
-        }
-        /* found it - we are in an event, so we can
-         * just execute the callback */
-        cb->value_cbfunc(rc, val, cb->cbdata);
-        /* cleanup */
-        if (NULL != val) {
-            PMIX_VALUE_RELEASE(val);
+        if( PMIX_SUCCESS != rc && !my_nspace ){
+            /* we are asking about the job-level info from other
+             * namespace. It seems tha we don't have it - go and
+             * ask server
+             */
+            goto request;
         }
-        PMIX_RELEASE(cb);
-        return;
+        /* we supposed to already have all local namespace data */
+        goto respond;
     }
 
-    /* if the key is in the PMIx namespace, then they are looking for data
-     * that was provided at startup */
-    if (0 == strncmp(cb->key, "pmix", 4)) {
-        /* if we don't have it, go request it */
-        goto request;
+    /* if we were asked about this rank */
+    if ( my_nspace && my_rank ){
+        /* if we asking the data about this rank - check local hash table.
+         * All the data passed through PMIx_Put settle down there
+         * if there is nothing there - it's nothing else we can do
+         */
+        rc = pmix_hash_fetch(&nptr->modex, pmix_globals.myid.rank, cb->key, &val);
+        if( PMIX_SUCCESS != rc ){
+            rc = PMIX_ERR_NOT_FOUND;
+            goto respond;
+        }
     }
 
     /* otherwise, the data must be something they "put" */
 #if defined(PMIX_ENABLE_DSTORE) && (PMIX_ENABLE_DSTORE == 1)
     rc = PMIX_ERR_PROC_ENTRY_NOT_FOUND;
-    if ((0 == strncmp(pmix_globals.myid.nspace, nptr->nspace, PMIX_MAX_NSLEN + 1)) &&
-        ((pmix_globals.myid.rank == cb->rank) || (PMIX_RANK_UNDEF == cb->rank))){
-        /* if we asking the data about this or undefined process -
-           check local hash table first. All the data passed through
-           PMIx_Put settle down there */
+    /* if rank is undefined - check local table first */
+    if ( my_nspace && (PMIX_RANK_UNDEF == cb->rank)){
+        /* if we asking about undefined process - check local hash table first
+         * local rank may have submitted this key. */
         rc = pmix_hash_fetch(&nptr->modex, pmix_globals.myid.rank, cb->key, &val);
-        assert( (PMIX_SUCCESS == rc) || (PMIX_ERR_PROC_ENTRY_NOT_FOUND == rc) ||
-                (PMIX_ERR_NOT_FOUND == rc) );
-        if( PMIX_SUCCESS != rc ){
-            if(pmix_globals.myid.rank == cb->rank){
-                rc = PMIX_ERR_NOT_FOUND;
-            }
-        }
-        /* in else case we supposed to get PMIX_ERR_PROC_ENTRY_NOT_FOUND because
-           we don't push data from the remote processes into the dstore */
     }
     /* try to take it from dstore */
     if( PMIX_ERR_PROC_ENTRY_NOT_FOUND == rc ){
@@ -670,71 +660,35 @@ static void _getnbfn(int fd, short flags, void *cbdata)
 #endif /* PMIX_ENABLE_DSTORE */
 
     if ( PMIX_SUCCESS == rc ) {
-        pmix_output_verbose(2, pmix_globals.debug_output,
-                            "pmix_get[%d]: value retrieved from dstore", __LINE__);
-        /* if this is a compressed string, then uncompress it */
-        if (PMIX_COMPRESSED_STRING == val->type) {
-            pmix_util_uncompress_string(&tmp, (uint8_t*)val->data.bo.bytes, val->data.bo.size);
-            if (NULL == tmp) {
-                PMIX_ERROR_LOG(PMIX_ERR_NOMEM);
-                rc = PMIX_ERR_NOMEM;
-                PMIX_VALUE_RELEASE(val);
-                val = NULL;
-            } else {
-                PMIX_VALUE_DESTRUCT(val);
-                PMIX_VAL_ASSIGN(val, string, tmp);
-            }
-        }
-        /* found it - we are in an event, so we can
-         * just execute the callback */
-        cb->value_cbfunc(rc, val, cb->cbdata);
-        /* cleanup */
-        if (NULL != val) {
-            PMIX_VALUE_RELEASE(val);
-        }
-        PMIX_RELEASE(cb);
-        return;
-    } else if (PMIX_ERR_NOT_FOUND == rc) {
+        goto respond;
+    } else if ( PMIX_ERR_PROC_ENTRY_NOT_FOUND == rc ){
+        goto request;
+    }else if (PMIX_ERR_NOT_FOUND == rc) {
         /* we have the modex data from this proc, but didn't find the key
          * the user requested. It's possible someone pushed something since
          * we got this data, so let's ask the server for an update. However,
          * we do have to protect against an infinite loop! */
         if (cb->checked) {
-            pmix_output_verbose(2, pmix_globals.debug_output,
-                                "Error requesting key=%s for rank = %d, namespace = %s",
-                                cb->key, cb->rank, cb->nspace);
-            cb->value_cbfunc(rc, NULL, cb->cbdata);
-            /* protect the data */
-            cb->procs = NULL;
-            cb->key = NULL;
-            cb->info = NULL;
-            PMIX_RELEASE(cb);
-            return;
+            goto respond;
         }
         pmix_output_verbose(2, pmix_globals.debug_output,
                             "Unable to locally satisfy request for key=%s for rank = %d, namespace = %s",
                             cb->key, cb->rank, cb->nspace);
         cb->checked = true; // flag that we are going to check this again
+        goto request;
     } else if (PMIX_ERR_PROC_ENTRY_NOT_FOUND != rc) {
         /* errors are fatal */
-        cb->value_cbfunc(rc, NULL, cb->cbdata);
-        /* protect the data */
-        cb->procs = NULL;
-        cb->key = NULL;
-        cb->info = NULL;
-        PMIX_RELEASE(cb);
-        return;
+        goto respond;
     }
 
-  request:
+request:
     /* if we got here, then we don't have the data for this proc. If we
      * are a server, or we are a client and not connected, then there is
      * nothing more we can do */
     if (PMIX_PROC_SERVER == pmix_globals.proc_type ||
         (PMIX_PROC_SERVER != pmix_globals.proc_type && !pmix_globals.connected)) {
-        cb->value_cbfunc(PMIX_ERR_NOT_FOUND, NULL, cb->cbdata);
-        PMIX_RELEASE(cb);
-        return;
+        rc = PMIX_ERR_NOT_FOUND;
+        goto respond;
     }
 
     /* we also have to check the user's directives to see if they do not want
@@ -746,22 +700,11 @@ static void _getnbfn(int fd, short flags, void *cbdata)
             pmix_output_verbose(2, pmix_globals.debug_output,
                                 "PMIx_Get key=%s for rank = %d, namespace = %s was not found - request was optional",
                                 cb->key, cb->rank, cb->nspace);
-            cb->value_cbfunc(PMIX_ERR_NOT_FOUND, NULL, cb->cbdata);
-            PMIX_RELEASE(cb);
-            return;
+            rc = PMIX_ERR_NOT_FOUND;
+            goto respond;
         }
     }
 
-    /* if we are seeking "pmix" data for our own nspace, then we must fail
-     * as it was provided at startup - any updates would have come via
-     * event notifications */
-    if (NULL != cb->key && 0 == strncmp(cb->key, "pmix", 4) &&
-        0 == strncmp(cb->nspace, pmix_globals.myid.nspace, PMIX_MAX_NSLEN)) {
-        cb->value_cbfunc(PMIX_ERR_NOT_FOUND, NULL, cb->cbdata);
-        PMIX_RELEASE(cb);
-        return;
-    }
-
     /* see if we already have a request in place with the server for data from
      * this nspace:rank. If we do, then no need to ask again as the
      * request will return _all_ data from that proc */
@@ -779,9 +722,8 @@ static void _getnbfn(int fd, short flags, void *cbdata)
      * about packing the key as we return everything from that proc */
     msg = _pack_get(cb->nspace, cb->rank, cb->info, cb->ninfo, PMIX_GETNB_CMD);
     if (NULL == msg) {
-        cb->value_cbfunc(PMIX_ERROR, NULL, cb->cbdata);
-        PMIX_RELEASE(cb);
-        return;
+        rc = PMIX_ERROR;
+        goto respond;
     }
 
     pmix_output_verbose(2, pmix_globals.debug_output,
@@ -794,8 +736,37 @@ static void _getnbfn(int fd, short flags, void *cbdata)
     /* send to the server */
     if (PMIX_SUCCESS != (rc = pmix_ptl.send_recv(&pmix_client_globals.myserver, msg, _getnb_cbfunc, (void*)cb))){
         pmix_list_remove_item(&pmix_client_globals.pending_requests, &cb->super);
-        cb->value_cbfunc(PMIX_ERROR, NULL, cb->cbdata);
-        PMIX_RELEASE(cb);
-        return;
+        rc = PMIX_ERROR;
+        goto respond;
     }
+
+    return;
+
+respond:
+
+    /* if a callback was provided, execute it */
+    if (NULL != cb && NULL != cb->value_cbfunc) {
+        if (NULL != val)  {
+            /* if this is a compressed string, then uncompress it */
+            if (PMIX_COMPRESSED_STRING == val->type) {
+                pmix_util_uncompress_string(&tmp, (uint8_t*)val->data.bo.bytes, val->data.bo.size);
+                if (NULL == tmp) {
+                    PMIX_ERROR_LOG(PMIX_ERR_NOMEM);
+                    rc = PMIX_ERR_NOMEM;
+                    PMIX_VALUE_RELEASE(val);
+                    val = NULL;
+                } else {
+                    PMIX_VALUE_DESTRUCT(val);
+                    PMIX_VAL_ASSIGN(val, string, tmp);
+                }
+            }
+        }
+        cb->value_cbfunc(rc, val, cb->cbdata);
+    }
+    if (NULL != val) {
+        PMIX_VALUE_RELEASE(val);
+    }
+    PMIX_RELEASE(cb);
+    return;
+
 }

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

@@ -1,6 +1,6 @@
 /* -*- Mode: C; c-basic-offset:4 ; indent-tabs-mode:nil -*- */
 /*
- * Copyright (c) 2014-2017 Intel, Inc. All rights reserved.
+ * Copyright (c) 2014-2016 Intel, Inc.  All rights reserved.
  * Copyright (c) 2014-2017 Research Organization for Information Science
  *                         and Technology (RIST). All rights reserved.
  * Copyright (c) 2014      Artem Y. Polyakov <[email protected]>.

opal/mca/pmix/pmix2x/pmix/src/dstore/pmix_esh.c

@@ -135,23 +135,11 @@ __extension__ ({                                            \
 })
 
 #ifdef ESH_PTHREAD_LOCK
-#define _ESH_LOCK(rwlock, operation)                        \
+#define _ESH_LOCK(rwlock, func)                             \
 __extension__ ({                                            \
     pmix_status_t ret = PMIX_SUCCESS;                       \
     int rc;                                                 \
-    switch (operation) {                                    \
-        case F_WRLCK:                                       \
-            rc = pthread_rwlock_wrlock(rwlock);             \
-            break;                                          \
-        case F_RDLCK:                                       \
-            rc = pthread_rwlock_rdlock(rwlock);             \
-            break;                                          \
-        case F_UNLCK:                                       \
-            rc = pthread_rwlock_unlock(rwlock);             \
-            break;                                          \
-        default:                                            \
-            rc = PMIX_ERR_BAD_PARAM;                        \
-    }                                                       \
+    rc = pthread_rwlock_##func(rwlock);                     \
     if (0 != rc) {                                          \
         switch (errno) {                                    \
             case EINVAL:                                    \
@@ -168,6 +156,10 @@ __extension__ ({                                            \
     }                                                       \
     ret;                                                    \
 })
+
+#define _ESH_WRLOCK(rwlock) _ESH_LOCK(rwlock, wrlock)
+#define _ESH_RDLOCK(rwlock) _ESH_LOCK(rwlock, rdlock)
+#define _ESH_UNLOCK(rwlock) _ESH_LOCK(rwlock, unlock)
 #endif
 
 #ifdef ESH_FCNTL_LOCK
@@ -208,11 +200,11 @@ __extension__ ({                                            \
     }                                                       \
     ret;                                                    \
 })
-#endif
 
 #define _ESH_WRLOCK(lock) _ESH_LOCK(lock, F_WRLCK)
 #define _ESH_RDLOCK(lock) _ESH_LOCK(lock, F_RDLCK)
 #define _ESH_UNLOCK(lock) _ESH_LOCK(lock, F_UNLCK)
+#endif
 
 #define ESH_INIT_SESSION_TBL_SIZE 2
 #define ESH_INIT_NS_MAP_TBL_SIZE  2

opal/mca/pmix/pmix2x/pmix/src/dstore/pmix_esh.h

@@ -3,7 +3,6 @@
  *                         All rights reserved.
  * Copyright (c) 2017      Research Organization for Information Science
  *                         and Technology (RIST). All rights reserved.
- * Copyright (c) 2017      Intel, Inc. All rights reserved.
  * $COPYRIGHT$
  *
  * Additional copyrights may follow

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

@@ -1,6 +1,6 @@
 /* -*- Mode: C; c-basic-offset:4 ; indent-tabs-mode:nil -*- */
 /*
- * Copyright (c) 2014-2017 Intel, Inc. All rights reserved.
+ * Copyright (c) 2014-2016 Intel, Inc.  All rights reserved.
  * Copyright (c) 2017      Research Organization for Information Science
  *                         and Technology (RIST). All rights reserved.
  * $COPYRIGHT$