File tree 1 file changed +7
-7
lines changed
src/main/java/com/advos/manager 1 file changed +7
-7
lines changed Original file line number Diff line number Diff line change @@ -126,15 +126,15 @@ public void processCSRequest(Message msg) {
126
126
return ;
127
127
}
128
128
129
- if (msg .getClock () < super .getCurrentCSDetails ().getCSRequestTime ()) { // requesting node has lower clock (higher priority)
129
+ if (msg .getClock () < super .getCurrentCSDetails ().getCSRequestTime ()) {
130
+ // requesting node has lower clock (higher priority)
131
+ this .sendReplyAndRequest (msg );
132
+ } else if (msg .getClock () == super .getCurrentCSDetails ().getCSRequestTime () &&
133
+ msg .getSourceNodeId () < node .getNodeInfo ().getId ()) {
134
+ // same clock, then nodeId is tye breaker
130
135
this .sendReplyAndRequest (msg );
131
- } else if (msg .getClock () == super .getCurrentCSDetails ().getCSRequestTime ()) { // same clock
132
- if (msg .getSourceNodeId () < node .getNodeInfo ().getId ()) {
133
- this .sendReplyAndRequest (msg );
134
- } else {
135
- this .differRequest (msg );
136
- }
137
136
} else {
137
+ // any other case differ
138
138
this .differRequest (msg );
139
139
}
140
140
}
You can’t perform that action at this time.
0 commit comments