MartyBurns
commented
6 years ago When the SimEnd interaction is received by the federate code, the flag to exit should be set. This will cause the federate code to break out of the execute while loop. Also
This can be resolved by:
1) Adding to the
-
add to class definition
private static final Logger logger = LogManager.getLogger(PingBase.class); boolean exitCondition = false; // set to true when SimEnd is received boolean selfResign = false; // set by application when federate wants to resign
-- add override method
/**
* Handles a simEnd interaction. Overrides the SynchronizedFederate default behavior which is to abort
*
* @return void
*/
@Override
protected void handleIfSimEnd(int interactionClass, ReceivedInteraction theInteraction, LogicalTime theTime) {
if (SimEnd.match(interactionClass)) {
logger.info("{}: SimEnd interaction received, exiting...", getFederateId());
// this one will set flag allowing foreground federate to gracefully shut down
exitCondition = true;
}
}-- add exitGracefully method /**
- Processes graceful shut-down of hla federate
-
@return void */ public void exitGracefully() {
// if I decided to resign, notify the fed manager if (selfResign){ logger.info("I want to resign determined"); // notify FederationManager about resign super.notifyFederationOfResign(); // Wait for 10 seconds for Federation Manager to recognize that the federate has resigned. try { Thread.sleep(CpswtDefaults.SimEndWaitingTimeMillis); } catch (Exception e) { logger.error(e.getMessage()); } } logger.info("{}: SimEnd interaction received, exiting...", getFederateId()); try { // getLRC().tick(); getLRC().resignFederationExecution(ResignAction.DELETE_OBJECTS); } catch (Exception e) { logger.error("Error during resigning federate: {}", getFederateId()); logger.error(e.getMessage()); }}
In the federate implementation add in the execute method: // this is the exit condition of the following while loop // it is used to break the loop so that latejoiner federates can // notify the federation manager that they left the federation
while (exitCondition == false) {
currentTime += super.getStepSize();
atr.requestSyncStart();
enteredTimeGrantedState();
////////////////////////////////////////////////////////////////////////////////////////
// TODO send interactions that must be sent every logical time step below.
// Set the interaction's parameters.
//
// ThePing vThePing = create_ThePing();
// vThePing.sendInteraction(getLRC(), currentTime);
//
////////////////////////////////////////////////////////////////////////////////////////
CheckReceivedSubscriptions("Main Loop");
// !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
// DO NOT MODIFY FILE BEYOND THIS LINE
// !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
AdvanceTimeRequest newATR = new AdvanceTimeRequest(currentTime);
putAdvanceTimeRequest(newATR);
atr.requestSyncEnd();
atr = newATR;
// example of when this federate determines it wants to resign
if(currentTime == 10.0)
selfResign=true;
// if we want to exit, set this flag in the body of this while loop
if (selfResign){
break;
}
}
exitGracefully();
// do your own cleanups
tpr1
Version information
fa471820415e64d9deca0bc4981e754ba48c0852
Observed behavior
Currently, synchronized federate default behavior is to handle SimEnd message with this code SynchronizedFederate.java:
Expected behavior
Should allow federates derived from synchronizedfederate to gracefully exit allowing for cleanup etc..
Steps to reproduce issue
Run any federation with java federate