Michael Blow has uploaded a new change for review.
https://asterix-gerrit.ics.uci.edu/2289
Change subject: [NO ISSUE] Enable RPC to reconnect IPC handles
......................................................................
[NO ISSUE] Enable RPC to reconnect IPC handles
Change-Id: Ieea8ebedc58dbfd65dbc1cb13721eeb83b6a475a
---
M
hyracks-fullstack/hyracks/hyracks-ipc/src/main/java/org/apache/hyracks/ipc/api/RPCInterface.java
1 file changed, 0 insertions(+), 5 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/89/2289/1
diff --git
a/hyracks-fullstack/hyracks/hyracks-ipc/src/main/java/org/apache/hyracks/ipc/api/RPCInterface.java
b/hyracks-fullstack/hyracks/hyracks-ipc/src/main/java/org/apache/hyracks/ipc/api/RPCInterface.java
index ba1c9a4..7dae541 100644
---
a/hyracks-fullstack/hyracks/hyracks-ipc/src/main/java/org/apache/hyracks/ipc/api/RPCInterface.java
+++
b/hyracks-fullstack/hyracks/hyracks-ipc/src/main/java/org/apache/hyracks/ipc/api/RPCInterface.java
@@ -21,8 +21,6 @@
import java.util.HashMap;
import java.util.Map;
-import org.apache.hyracks.ipc.exceptions.IPCException;
-
public class RPCInterface implements IIPCI {
private final Map<Long, Request> reqMap;
@@ -34,9 +32,6 @@
Request req;
long mid;
synchronized (this) {
- if (!handle.isConnected()) {
- throw new IPCException("Cannot send on a closed handle");
- }
req = new Request(handle, this);
mid = handle.send(-1, request, null);
reqMap.put(mid, req);
--
To view, visit https://asterix-gerrit.ics.uci.edu/2289
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: Ieea8ebedc58dbfd65dbc1cb13721eeb83b6a475a
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Michael Blow <[email protected]>
