diff --git a/orte/mca/gpr/replica/functional_layer/gpr_replica_trig_ops_fn.c b/orte/mca/gpr/replica/functional_layer/gpr_replica_trig_ops_fn.c index 54c018fd4b..25524b2233 100644 --- a/orte/mca/gpr/replica/functional_layer/gpr_replica_trig_ops_fn.c +++ b/orte/mca/gpr/replica/functional_layer/gpr_replica_trig_ops_fn.c @@ -251,6 +251,16 @@ ADDREQ: */ req->idtag = subscription->id; + /* + * New subscription, send initial values? + */ + if(sub->active && subscription->action & ORTE_GPR_NOTIFY_PRE_EXISTING) { + + if(ORTE_SUCCESS != (rc = orte_gpr_replica_register_callback(sub, NULL))) { + ORTE_ERROR_LOG(rc); + return rc; + } + } DONESUB: /* record where the subscription went */ *subptr = sub;