Skip to content

Commit c0aef07

Browse files
committed
Minor code improvement in ConnectionManager.getServerRPCResponse
1 parent add802c commit c0aef07

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

src/main/java/com/exalttech/trex/core/ConnectionManager.java

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -826,7 +826,7 @@ private byte[] getServerRPCResponse(String request) {
826826
success = requester.send(finalRequest);
827827
} catch (ZMQException e) {
828828
if (e.getErrorCode() == ZError.EFSM) {
829-
resend(finalRequest);
829+
success = resend(finalRequest);
830830
} else {
831831
throw e;
832832
}
@@ -848,6 +848,9 @@ private byte[] getServerRPCResponse(String request) {
848848
LOG.error("Error sending request");
849849
}
850850
}
851+
} else {
852+
LOG.error("Error sending request");
853+
return null;
851854
}
852855
}
853856
return getDecompressedString(serverResponse).getBytes();
@@ -858,11 +861,11 @@ private byte[] getServerRPCResponse(String request) {
858861
}
859862
}
860863

861-
private void resend(byte[] msg) {
864+
private boolean resend(byte[] msg) {
862865
context.destroySocket(requester);
863866
requester = buildRequester();
864867
requester.connect(connectionString);
865-
requester.send(msg);
868+
return requester.send(msg);
866869
}
867870

868871
private byte[] concatByteArrays(byte[] firstDataArray, byte[] secondDataArray) {

0 commit comments

Comments
 (0)