diff --git a/maestro/pool_manager.c b/maestro/pool_manager.c index d08a19634f15b0159a9ae126087f1bcc9a7e81ae..7ce94cc0b73c857b74ad0ebd69622fae359bb6ca 100644 --- a/maestro/pool_manager.c +++ b/maestro/pool_manager.c @@ -1111,12 +1111,17 @@ mstro_pm__handle_offer_phase2(mstro_event event, ERR("CDO id not known here for app\n"); } + // FIXME: + WARN("If this is a group CDO, members will not be OFFERED at this time\n"); + s = mstro_pm__send_ack(app_id, MSTRO__POOL__POOL_OP_ACK__POOL_OP__OFFER, cont->msg->offer->cdoid, NULL, NULL, s); if(s!=MSTRO_OK) { - ERR("Failed to send ACK for OFFER: %d (%s)\n", s, mstro_status_description(s)); + ERR("Failed to send ACK for OFFER: %d (%s)\n", + s, mstro_status_description(s)); } + /* produce offer:after event */ Mstro__Pool__Event ev = MSTRO__POOL__EVENT__INIT; @@ -1233,6 +1238,9 @@ mstro_pm__handle_require_phase2(mstro_event event, WARN("Not scheduling any action at REQUIRE time\n"); + // FIXME: + WARN("If this is a group CDO, members will not be REQUIRED at this time\n"); + s = mstro_pm__send_ack(app_id, MSTRO__POOL__POOL_OP_ACK__POOL_OP__REQUIRE, cont->msg->require->cdoid, NULL, NULL, s); @@ -1355,7 +1363,7 @@ mstro_pm__handle_retract_phase2(mstro_event event, } /* for groups, do recursion ? */ - WARN("If CDO is a group CDO, retract will only retract the group, not the members\n"); + WARN("If this is a group CDO, members will not be RETRACTED at this time\n"); /* we let the app that created the original require manage the case * that we might be sending them pre-demand transfer tickets for @@ -1367,7 +1375,15 @@ mstro_pm__handle_retract_phase2(mstro_event event, if(s!=MSTRO_OK) { ERR("CDO id not known here for app %" PRIappid "\n", app_id); } - + + s = mstro_pm__send_ack(app_id, + MSTRO__POOL__POOL_OP_ACK__POOL_OP__RETRACT, + cont->msg->retract->cdoid, NULL, NULL, s); + if(s!=MSTRO_OK) { + ERR("Failed to send RETRACT-ACK: %d (%s)\n", + s, mstro_status_description(s)); + } + /* produce require:after event */ Mstro__Pool__Event ev = MSTRO__POOL__EVENT__INIT; /* serial and handle set later */