[Swift-commit] Cog update

[swift at ci.uchicago.edu]

------------------------------------------------------------------------
r3374 | hategan | 2012-04-12 19:34:03 -0500 (Thu, 12 Apr 2012) | 1 line

remove channel from multiplexer if there is an error
------------------------------------------------------------------------
Index: modules/karajan/src/org/globus/cog/karajan/workflow/service/channels/NIOMultiplexer.java
===================================================================
--- modules/karajan/src/org/globus/cog/karajan/workflow/service/channels/NIOMultiplexer.java	(revision 3373)
+++ modules/karajan/src/org/globus/cog/karajan/workflow/service/channels/NIOMultiplexer.java	(working copy)
@@ -93,7 +93,13 @@
 				SelectionKey key = i.next();
 				ReadableByteChannel c = (ReadableByteChannel) key.channel();
 				
-				((AbstractStreamKarajanChannel) key.attachment()).stepNIO();
+				try {
+					((AbstractStreamKarajanChannel) key.attachment()).stepNIO();
+				}
+				catch (IOException e) {
+					((AbstractStreamKarajanChannel) key.attachment()).handleChannelException(e);
+					key.cancel();
+				}
 				i.remove();
 			}
 		}