merged hyracks_asterix_stabilization r1778:1792 --> hyracks_lsm_tree
git-svn-id: https://hyracks.googlecode.com/svn/branches/hyracks_lsm_tree@1797 123451ca-8445-de46-9d55-352943316053
diff --git a/hyracks-ipc/src/main/java/edu/uci/ics/hyracks/ipc/impl/IPCHandle.java b/hyracks-ipc/src/main/java/edu/uci/ics/hyracks/ipc/impl/IPCHandle.java
index 749afe2..06b614d 100644
--- a/hyracks-ipc/src/main/java/edu/uci/ics/hyracks/ipc/impl/IPCHandle.java
+++ b/hyracks-ipc/src/main/java/edu/uci/ics/hyracks/ipc/impl/IPCHandle.java
@@ -63,8 +63,8 @@
}
@Override
- public synchronized long send(long requestId, Object req, Exception exception) throws IPCException {
- if (state != HandleState.CONNECTED) {
+ public long send(long requestId, Object req, Exception exception) throws IPCException {
+ if (!isConnected()) {
throw new IPCException("Handle is not in Connected state");
}
Message msg = new Message(this);
@@ -131,7 +131,7 @@
setState(HandleState.CLOSED);
}
- synchronized void processIncomingMessages() {
+ void processIncomingMessages() {
inBuffer.flip();
while (Message.hasMessage(inBuffer)) {
Message message = new Message(this);