Set attached flag on all attached channels

rb2k · Aug 7, 2009 · 8b311e4 · 8b311e4
1 parent 3ef0592
commit 8b311e4
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/java/src/com/rubyeventmachine/EmReactor.java b/java/src/com/rubyeventmachine/EmReactor.java
@@ -473,6 +473,7 @@ public long attachChannel (SocketChannel sc, boolean watch_mode) throws ClosedCh
 		} else {
 			ec = new EventableSocketChannel (sc, b, mySelector, SelectionKey.OP_READ);
 		}
+		ec.setAttached();
 
 		Connections.put (b, ec);
 		return b;

diff --git a/java/src/com/rubyeventmachine/EventableSocketChannel.java b/java/src/com/rubyeventmachine/EventableSocketChannel.java
@@ -57,6 +57,7 @@ public class EventableSocketChannel implements EventableChannel {
 	boolean bCloseScheduled;
 	boolean bConnectPending;
 	boolean bWatchOnly;
+	boolean bAttached;
 	boolean bNotifyReadable;
 	boolean bNotifyWritable;
 
@@ -70,6 +71,7 @@ public EventableSocketChannel (SocketChannel sc, long _binding, Selector sel, in
 		bCloseScheduled = false;
 		bConnectPending = false;
 		bWatchOnly = false;
+		bAttached = false;
 		bNotifyReadable = false;
 		bNotifyWritable = false;
 		outboundQ = new LinkedList<ByteBuffer>();
@@ -257,6 +259,11 @@ public void setWatchOnly() {
 	}
 	public boolean isWatchOnly() { return bWatchOnly; }
 
+	public void setAttached() {
+		bAttached = true;
+	}
+	public boolean isAttached() { return bAttached; }
+
 	public void setNotifyReadable (boolean mode) {
 		bNotifyReadable = mode;
 		updateEvents();