Skip to content
Snippets Groups Projects
Commit ae4ac9af authored by Michael Eischer's avatar Michael Eischer
Browse files

Deduplicate order protocol stub

parent 94ed434a
No related branches found
No related tags found
No related merge requests found
......@@ -10,10 +10,7 @@ import refit.replica.REFITObserver;
import refit.replica.REFITReplicaGroups;
import refit.replica.REFITStage;
import refit.replica.multichannel.REFITChannelItem;
import refit.replica.order.REFITOrderProtocol;
import refit.replica.order.REFITOrderProtocolInstance;
import refit.replica.order.REFITOrderProtocolTransitionInstance;
import refit.replica.order.REFITOrderStageSlot;
import refit.replica.order.REFITStubOrderProtocol;
import refit.scheduler.REFITSchedulerTaskType;
public class REFITMCExecutorCouplingStage extends REFITStage {
......@@ -42,34 +39,7 @@ public class REFITMCExecutorCouplingStage extends REFITStage {
progressSender.broadcast(new REFITChannelProgress((short) 0, 0, -1, REFITConfig.MAXIMUM_EXECUTION_INSTANCES_IN_PROGRESS));
// send configuration notification with stub protocol to execution
configSender.broadcast(new REFITConfigurationNotification(
new REFITOrderProtocol() {
@Override
public REFITOrderProtocolInstance createInstance(REFITOrderStageSlot slot) {
throw new UnsupportedOperationException("Nope");
}
@Override
public REFITOrderProtocolTransitionInstance createTransitionInstance(REFITOrderStageSlot slot) {
throw new UnsupportedOperationException("Nope");
}
@Override
public boolean useLightweightCheckpoints() {
return false;
}
@Override
public boolean hasCheckpointRecipients() {
return true;
}
@Override
public boolean hasUpdateRecipients() {
return false;
}
}, -1, -1)
);
configSender.broadcast(new REFITConfigurationNotification(new REFITStubOrderProtocol(), -1, -1));
}
@Override
......
package refit.replica.order;
public class REFITStubOrderProtocol extends REFITOrderProtocol {
@Override
public REFITOrderProtocolInstance createInstance(REFITOrderStageSlot slot) {
throw new UnsupportedOperationException("Nope");
}
@Override
public REFITOrderProtocolTransitionInstance createTransitionInstance(REFITOrderStageSlot slot) {
throw new UnsupportedOperationException("Nope");
}
@Override
public boolean useLightweightCheckpoints() {
return false;
}
@Override
public boolean hasCheckpointRecipients() {
return true;
}
@Override
public boolean hasUpdateRecipients() {
return false;
}
}
......@@ -13,10 +13,7 @@ import refit.message.REFITOrderRequest;
import refit.replica.REFITBaseReplica;
import refit.replica.REFITObserver;
import refit.replica.REFITStage;
import refit.replica.order.REFITOrderProtocol;
import refit.replica.order.REFITOrderProtocolInstance;
import refit.replica.order.REFITOrderProtocolTransitionInstance;
import refit.replica.order.REFITOrderStageSlot;
import refit.replica.order.REFITStubOrderProtocol;
import refit.replica.stewardorder.REFITStewardOrderMessages.REFITStewardAccept;
import refit.replica.stewardorder.REFITStewardOrderMessages.REFITStewardAcceptShare;
import refit.replica.stewardorder.REFITStewardOrderMessages.REFITStewardProposal;
......@@ -68,34 +65,7 @@ public class REFITStewardOrderStage extends REFITStage {
@Override
public void init() {
// send configuration notification with stub protocol to execution
configSender.broadcast(new REFITConfigurationNotification(
new REFITOrderProtocol() {
@Override
public REFITOrderProtocolInstance createInstance(REFITOrderStageSlot slot) {
throw new UnsupportedOperationException("Nope");
}
@Override
public REFITOrderProtocolTransitionInstance createTransitionInstance(REFITOrderStageSlot slot) {
throw new UnsupportedOperationException("Nope");
}
@Override
public boolean useLightweightCheckpoints() {
return false;
}
@Override
public boolean hasCheckpointRecipients() {
return true;
}
@Override
public boolean hasUpdateRecipients() {
return false;
}
}, -1, -1)
);
configSender.broadcast(new REFITConfigurationNotification(new REFITStubOrderProtocol(), -1, -1));
}
@Override
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment