modules/kvs: Add fence_get_nprocs()

src/modules/kvs/fence.c

@@ -99,6 +99,11 @@ bool fence_count_reached (fence_t *f)
     return (f->count == f->nprocs);
 }
 
+int fence_get_nprocs (fence_t *f)
+{
+    return f->nprocs;
+}
+
 int fence_get_flags (fence_t *f)
 {
     return f->flags;

src/modules/kvs/fence.h

@@ -15,6 +15,7 @@ void fence_destroy (fence_t *f);
 /* if number of calls to fence_add_request_data() is == nprocs */
 bool fence_count_reached (fence_t *f);
 
+int fence_get_nprocs (fence_t *f);
 int fence_get_flags (fence_t *f);
 void fence_set_flags (fence_t *f, int flags);
 

src/modules/kvs/kvs.c

@@ -1726,8 +1726,6 @@ static void relayfence_request_cb (flux_t *h, flux_msg_handler_t *mh,
             goto error;
         }
     }
-    else
-        fence_set_flags (f, fence_get_flags (f) | flags);
 
     if (fence_add_request_data (f, ops) < 0) {
         flux_log_error (h, "%s: fence_add_request_data", __FUNCTION__);

src/modules/kvs/test/fence.c

@@ -41,6 +41,9 @@ void basic_api_tests (void)
     ok (fence_count_reached (f) == false,
         "initial fence_count_reached() is false");
 
+    ok (fence_get_nprocs (f) == 1,
+        "initial fence_get_nprocs works");
+
     ok (fence_get_flags (f) == 3,
         "initial fence_get_flags works");