diff --git a/src/modules/kvs/kvs.c b/src/modules/kvs/kvs.c index 6b3b8a2179c9..393499d06c33 100644 --- a/src/modules/kvs/kvs.c +++ b/src/modules/kvs/kvs.c @@ -2914,15 +2914,22 @@ static int checkpoint_get (flux_t *h, char *buf, size_t len, int *seq) */ static int checkpoint_put (flux_t *h, const char *rootref, int rootseq) { - flux_future_t *f = NULL; + flux_future_t *f1 = NULL; + flux_future_t *f2 = NULL; int rv = -1; - if (!(f = kvs_checkpoint_commit (h, NULL, rootref, rootseq, 0, 0)) - || flux_rpc_get (f, NULL) < 0) + /* first must ensure all content is flushed */ + if (!(f1 = flux_rpc (h, "content.flush", NULL, 0, 0)) + || flux_rpc_get (f1, NULL) < 0) + goto error; + + if (!(f2 = kvs_checkpoint_commit (h, NULL, rootref, rootseq, 0, 0)) + || flux_rpc_get (f2, NULL) < 0) goto error; rv = 0; error: - flux_future_destroy (f); + flux_future_destroy (f1); + flux_future_destroy (f2); return rv; }