11
11
import java .security .MessageDigest ;
12
12
import java .security .NoSuchAlgorithmException ;
13
13
import java .time .Duration ;
14
- import java .time .Instant ;
15
14
import java .util .*;
16
15
17
16
@@ -73,7 +72,7 @@ public class HbftClient extends Client {
73
72
@ Override
74
73
public void sendRequest () {
75
74
String requestId = String .format ("%s/%d" , super .id , super .requestSequenceNumber .incrementAndGet ());
76
- Instant timestamp = this .getCurrentTime ();
75
+ long timestamp = this .getCurrentTime (). toEpochMilli ();
77
76
RequestMessage request = new RequestMessage (requestId , timestamp , super .id );
78
77
this .sentRequests .put (super .requestSequenceNumber .get (), request );
79
78
this .sentRequestsByTimestamp .put (timestamp , requestId );
@@ -94,7 +93,7 @@ public void retransmitOrPanic() {
94
93
this .broadcastRequest (timestamp , requestId );
95
94
} else if (this .shouldPanic (tolerance )) {
96
95
RequestMessage message = this .sentRequests .get (super .requestSequenceNumber .get ());
97
- PanicMessage panic = new PanicMessage (this .digest (message ), System . currentTimeMillis (), super .id );
96
+ PanicMessage panic = new PanicMessage (this .digest (message ), this . getCurrentTime (). toEpochMilli (), super .id );
98
97
super .scenario .getTransport ().multicast (this , super .scenario .getTransport ().getNodeIds (), panic );
99
98
}
100
99
this .clearTimeout (timeouts .get (super .requestSequenceNumber .get ()));
0 commit comments