lock_ctx 19 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock.h pmix_status_t pmix_gds_ds12_lock_init(pmix_common_dstor_lock_ctx_t *lock_ctx, lock_ctx 22 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock.h void pmix_ds12_lock_finalize(pmix_common_dstor_lock_ctx_t *lock_ctx); lock_ctx 23 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock.h pmix_status_t pmix_ds12_lock_rd_get(pmix_common_dstor_lock_ctx_t lock_ctx); lock_ctx 24 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock.h pmix_status_t pmix_ds12_lock_wr_get(pmix_common_dstor_lock_ctx_t lock_ctx); lock_ctx 25 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock.h pmix_status_t pmix_ds12_lock_rw_rel(pmix_common_dstor_lock_ctx_t lock_ctx); lock_ctx 88 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c ds12_lock_fcntl_ctx_t *lock_ctx; lock_ctx 94 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c lock_ctx = (ds12_lock_fcntl_ctx_t*)malloc(sizeof(ds12_lock_fcntl_ctx_t)); lock_ctx 95 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c if (NULL == lock_ctx) { lock_ctx 100 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c *ctx = lock_ctx; lock_ctx 101 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c memset(lock_ctx, 0, sizeof(ds12_lock_fcntl_ctx_t)); lock_ctx 102 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c lock_ctx->lockfd = -1; lock_ctx 107 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c if(0 > asprintf(&lock_ctx->lockfile, "%s/dstore_sm.lock", base_path)) { lock_ctx 113 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c "%s:%d:%s _lockfile_name: %s", __FILE__, __LINE__, __func__, lock_ctx->lockfile)); lock_ctx 116 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c lock_ctx->lockfd = open(lock_ctx->lockfile, O_CREAT | O_RDWR | O_EXCL, 0600); lock_ctx 120 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c if (lock_ctx->lockfd < 0) { lock_ctx 121 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c unlink(lock_ctx->lockfile); lock_ctx 122 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c lock_ctx->lockfd = open(lock_ctx->lockfile, O_CREAT | O_RDWR, 0600); lock_ctx 123 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c if (lock_ctx->lockfd < 0) { lock_ctx 130 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c if (0 > chown(lock_ctx->lockfile, uid, (gid_t) -1)) { lock_ctx 135 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c if (0 > chmod(lock_ctx->lockfile, S_IRUSR | S_IWGRP | S_IRGRP)) { lock_ctx 143 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c lock_ctx->lockfd = open(lock_ctx->lockfile, O_RDONLY); lock_ctx 144 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c if (0 > lock_ctx->lockfd) { lock_ctx 154 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c if (NULL != lock_ctx) { lock_ctx 155 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c if (NULL != lock_ctx->lockfile) { lock_ctx 156 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c free(lock_ctx->lockfile); lock_ctx 158 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c if (0 > lock_ctx->lockfd) { lock_ctx 159 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c close(lock_ctx->lockfd); lock_ctx 161 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c unlink(lock_ctx->lockfile); lock_ctx 164 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c free(lock_ctx); lock_ctx 165 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c lock_ctx = NULL; lock_ctx 172 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c void pmix_ds12_lock_finalize(pmix_common_dstor_lock_ctx_t *lock_ctx) lock_ctx 174 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c ds12_lock_fcntl_ctx_t *fcntl_lock = (ds12_lock_fcntl_ctx_t*)*lock_ctx; lock_ctx 187 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c *lock_ctx = NULL; lock_ctx 190 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c pmix_status_t pmix_ds12_lock_rd_get(pmix_common_dstor_lock_ctx_t lock_ctx) lock_ctx 191 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c { ds12_lock_fcntl_ctx_t *fcntl_lock = (ds12_lock_fcntl_ctx_t*)lock_ctx; lock_ctx 205 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c pmix_status_t pmix_ds12_lock_wr_get(pmix_common_dstor_lock_ctx_t lock_ctx) lock_ctx 206 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c { ds12_lock_fcntl_ctx_t *fcntl_lock = (ds12_lock_fcntl_ctx_t*)lock_ctx; lock_ctx 220 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c pmix_status_t pmix_ds12_lock_rw_rel(pmix_common_dstor_lock_ctx_t lock_ctx) lock_ctx 221 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_fcntl.c { ds12_lock_fcntl_ctx_t *fcntl_lock = (ds12_lock_fcntl_ctx_t*)lock_ctx; lock_ctx 75 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c ds12_lock_pthread_ctx_t *lock_ctx = (ds12_lock_pthread_ctx_t*)ctx; lock_ctx 81 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c lock_ctx = (ds12_lock_pthread_ctx_t*)malloc(sizeof(ds12_lock_pthread_ctx_t)); lock_ctx 82 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c if (NULL == lock_ctx) { lock_ctx 87 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c memset(lock_ctx, 0, sizeof(ds12_lock_pthread_ctx_t)); lock_ctx 88 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c *ctx = (pmix_common_dstor_lock_ctx_t*)lock_ctx; lock_ctx 90 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c lock_ctx->segment = (pmix_pshmem_seg_t *)malloc(sizeof(pmix_pshmem_seg_t)); lock_ctx 91 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c if (NULL == lock_ctx->segment) { lock_ctx 100 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c if(0 > asprintf(&lock_ctx->lockfile, "%s/dstore_sm.lock", base_path)) { lock_ctx 106 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c "%s:%d:%s _lockfile_name: %s", __FILE__, __LINE__, __func__, lock_ctx->lockfile)); lock_ctx 109 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c if (PMIX_SUCCESS != (rc = pmix_pshmem.segment_create(lock_ctx->segment, lock_ctx 110 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c lock_ctx->lockfile, size))) { lock_ctx 114 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c memset(lock_ctx->segment->seg_base_addr, 0, size); lock_ctx 116 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c if (0 > chown(lock_ctx->lockfile, (uid_t) uid, (gid_t) -1)){ lock_ctx 122 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c if (0 > chmod(lock_ctx->lockfile, S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP )) { lock_ctx 128 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c lock_ctx->rwlock = (pthread_rwlock_t *)lock_ctx->segment->seg_base_addr; lock_ctx 149 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c if (0 != pthread_rwlock_init(lock_ctx->rwlock, &attr)) { lock_ctx 161 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c lock_ctx->segment->seg_size = size; lock_ctx 162 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c snprintf(lock_ctx->segment->seg_name, PMIX_PATH_MAX, "%s", lock_ctx->lockfile); lock_ctx 163 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c if (PMIX_SUCCESS != (rc = pmix_pshmem.segment_attach(lock_ctx->segment, lock_ctx 168 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c lock_ctx->rwlock = (pthread_rwlock_t *)lock_ctx->segment->seg_base_addr; lock_ctx 174 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c if (NULL != lock_ctx) { lock_ctx 175 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c if (lock_ctx->segment) { lock_ctx 177 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c if (lock_ctx->segment->seg_cpid == getpid()) { lock_ctx 178 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c pmix_pshmem.segment_unlink(lock_ctx->segment); lock_ctx 180 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c pmix_pshmem.segment_detach(lock_ctx->segment); lock_ctx 181 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c lock_ctx->rwlock = NULL; lock_ctx 183 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c if (NULL != lock_ctx->lockfile) { lock_ctx 184 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c free(lock_ctx->lockfile); lock_ctx 186 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c free(lock_ctx); lock_ctx 193 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c void pmix_ds12_lock_finalize(pmix_common_dstor_lock_ctx_t *lock_ctx) lock_ctx 196 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c (ds12_lock_pthread_ctx_t*)*lock_ctx; lock_ctx 228 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c *lock_ctx = NULL; lock_ctx 231 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c pmix_status_t pmix_ds12_lock_rd_get(pmix_common_dstor_lock_ctx_t lock_ctx) lock_ctx 233 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c ds12_lock_pthread_ctx_t *pthread_lock = (ds12_lock_pthread_ctx_t*)lock_ctx; lock_ctx 246 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c pmix_status_t pmix_ds12_lock_wr_get(pmix_common_dstor_lock_ctx_t lock_ctx) lock_ctx 248 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c ds12_lock_pthread_ctx_t *pthread_lock = (ds12_lock_pthread_ctx_t*)lock_ctx; lock_ctx 261 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c pmix_status_t pmix_ds12_lock_rw_rel(pmix_common_dstor_lock_ctx_t lock_ctx) lock_ctx 263 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_lock_pthread.c ds12_lock_pthread_ctx_t *pthread_lock = (ds12_lock_pthread_ctx_t*)lock_ctx; lock_ctx 19 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock.h pmix_status_t pmix_gds_ds21_lock_init(pmix_common_dstor_lock_ctx_t *lock_ctx, lock_ctx 22 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock.h void pmix_ds21_lock_finalize(pmix_common_dstor_lock_ctx_t *lock_ctx); lock_ctx 23 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock.h pmix_status_t pmix_ds21_lock_rd_get(pmix_common_dstor_lock_ctx_t lock_ctx); lock_ctx 24 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock.h pmix_status_t pmix_ds21_lock_wr_get(pmix_common_dstor_lock_ctx_t lock_ctx); lock_ctx 25 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock.h pmix_status_t pmix_ds21_lock_rd_rel(pmix_common_dstor_lock_ctx_t lock_ctx); lock_ctx 26 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock.h pmix_status_t pmix_ds21_lock_wr_rel(pmix_common_dstor_lock_ctx_t lock_ctx); lock_ctx 124 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock_pthread.c lock_ctx_t *lock_ctx = (lock_ctx_t*)*ctx; lock_ctx 129 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock_pthread.c lock_ctx = (lock_ctx_t*)malloc(sizeof(lock_ctx_t)); lock_ctx 130 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock_pthread.c if (NULL == lock_ctx) { lock_ctx 135 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock_pthread.c memset(lock_ctx, 0, sizeof(lock_ctx_t)); lock_ctx 136 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock_pthread.c PMIX_CONSTRUCT(&lock_ctx->lock_traker, pmix_list_t); lock_ctx 137 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock_pthread.c *ctx = lock_ctx; lock_ctx 140 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock_pthread.c lock_tracker = &lock_ctx->lock_traker; lock_ctx 273 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock_pthread.c void pmix_ds21_lock_finalize(pmix_common_dstor_lock_ctx_t *lock_ctx) lock_ctx 276 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock_pthread.c pmix_list_t *lock_tracker = &((lock_ctx_t*)*lock_ctx)->lock_traker; lock_ctx 291 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock_pthread.c *lock_ctx = NULL; lock_ctx 294 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock_pthread.c pmix_status_t pmix_ds21_lock_wr_get(pmix_common_dstor_lock_ctx_t lock_ctx) lock_ctx 297 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock_pthread.c pmix_list_t *lock_tracker = &((lock_ctx_t*)lock_ctx)->lock_traker; lock_ctx 341 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock_pthread.c pmix_status_t pmix_ds21_lock_wr_rel(pmix_common_dstor_lock_ctx_t lock_ctx) lock_ctx 344 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock_pthread.c pmix_list_t *lock_tracker = &((lock_ctx_t*)lock_ctx)->lock_traker; lock_ctx 375 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock_pthread.c pmix_status_t pmix_ds21_lock_rd_get(pmix_common_dstor_lock_ctx_t lock_ctx) lock_ctx 378 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock_pthread.c pmix_list_t *lock_tracker = &((lock_ctx_t*)lock_ctx)->lock_traker; lock_ctx 415 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock_pthread.c pmix_status_t pmix_ds21_lock_rd_rel(pmix_common_dstor_lock_ctx_t lock_ctx) lock_ctx 418 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_lock_pthread.c pmix_list_t *lock_tracker = &((lock_ctx_t*)lock_ctx)->lock_traker;