Git-Mirrors/haveno
1
0
Fork 0
mirror of https://github.com/haveno-dex/haveno.git synced 2025-06-06 22:29:10 -04:00
Code Issues Projects Releases Packages Wiki Activity

Move comment closer to timer creation

Browse source 
For consistency across classes.
This commit is contained in:
Ivan Vilata-i-Balaguer 2016-05-05 10:25:42 +02:00
parent b814eff5f1
commit 0d32a3b5ce
3 changed files with 6 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

4
network/src/main/java/io/bitsquare/p2p/peers/getdata/GetDataRequestHandler.java
View file

@ -67,8 +67,8 @@ public class GetDataRequestHandler {
GetDataResponse getDataResponse = new GetDataResponse(new HashSet<>(dataStorage.getMap().values()), GetDataResponse getDataResponse = new GetDataResponse(new HashSet<>(dataStorage.getMap().values()),
getDataRequest.getNonce()); getDataRequest.getNonce());
if (timeoutTimer == null) { // setup before sending to avoid race conditions if (timeoutTimer == null) {
timeoutTimer = UserThread.runAfter(() -> { timeoutTimer = UserThread.runAfter(() -> { // setup before sending to avoid race conditions
String errorMessage = "A timeout occurred for getDataResponse:" + getDataResponse + String errorMessage = "A timeout occurred for getDataResponse:" + getDataResponse +
" on connection:" + connection; " on connection:" + connection;
handleFault(errorMessage, CloseConnectionReason.SEND_MSG_TIMEOUT, connection); handleFault(errorMessage, CloseConnectionReason.SEND_MSG_TIMEOUT, connection);

4
network/src/main/java/io/bitsquare/p2p/peers/getdata/RequestDataHandler.java
View file

@ -88,8 +88,8 @@ public class RequestDataHandler implements MessageListener {
else else
getDataRequest = new GetUpdatedDataRequest(networkNode.getNodeAddress(), nonce); getDataRequest = new GetUpdatedDataRequest(networkNode.getNodeAddress(), nonce);
if (timeoutTimer == null) { // setup before sending to avoid race conditions if (timeoutTimer == null) {
timeoutTimer = UserThread.runAfter(() -> { timeoutTimer = UserThread.runAfter(() -> { // setup before sending to avoid race conditions
if (!stopped) { if (!stopped) {
String errorMessage = "A timeout occurred at sending getDataRequest:" + getDataRequest + String errorMessage = "A timeout occurred at sending getDataRequest:" + getDataRequest +
" on nodeAddress:" + nodeAddress; " on nodeAddress:" + nodeAddress;

4
network/src/main/java/io/bitsquare/p2p/peers/peerexchange/PeerExchangeHandler.java
View file

@ -85,8 +85,8 @@ class PeerExchangeHandler implements MessageListener {
if (networkNode.getNodeAddress() != null) { if (networkNode.getNodeAddress() != null) {
GetPeersRequest getPeersRequest = new GetPeersRequest(networkNode.getNodeAddress(), nonce, peerManager.getConnectedNonSeedNodeReportedPeers(nodeAddress)); GetPeersRequest getPeersRequest = new GetPeersRequest(networkNode.getNodeAddress(), nonce, peerManager.getConnectedNonSeedNodeReportedPeers(nodeAddress));
if (timeoutTimer == null) { // setup before sending to avoid race conditions if (timeoutTimer == null) {
timeoutTimer = UserThread.runAfter(() -> { timeoutTimer = UserThread.runAfter(() -> { // setup before sending to avoid race conditions
if (!stopped) { if (!stopped) {
String errorMessage = "A timeout occurred at sending getPeersRequest:" + getPeersRequest + " for nodeAddress:" + nodeAddress; String errorMessage = "A timeout occurred at sending getPeersRequest:" + getPeersRequest + " for nodeAddress:" + nodeAddress;
log.info(errorMessage + " / PeerExchangeHandler=" + log.info(errorMessage + " / PeerExchangeHandler=" +