[325928] Provide FailoverMonitor server and FailoverAgents to coordinate fail-over scenarios

https://bugs.eclipse.org/bugs/show_bug.cgi?id=325928

1 files changed, 8 insertions, 12 deletions

diff --git a/plugins/org.eclipse.net4j.tcp/src/org/eclipse/net4j/internal/tcp/TCPConnector.java b/plugins/org.eclipse.net4j.tcp/src/org/eclipse/net4j/internal/tcp/TCPConnector.java
index 08d085ffe9..74e8f4c9a8 100644
--- a/plugins/org.eclipse.net4j.tcp/src/org/eclipse/net4j/internal/tcp/TCPConnector.java
+++ b/plugins/org.eclipse.net4j.tcp/src/org/eclipse/net4j/internal/tcp/TCPConnector.java
@@ -231,8 +231,10 @@ public abstract class TCPConnector extends Connector implements ITCPConnector, I
 
       if (firstChannel)
       {
-        checkSelectionKey();
-        selector.orderWriteInterest(selectionKey, isClient(), true);
+        if (selectionKey != null)
+        {
+          selector.orderWriteInterest(selectionKey, isClient(), true);
+        }
       }
     }
   }
@@ -264,8 +266,10 @@ public abstract class TCPConnector extends Connector implements ITCPConnector, I
 
         if (writeQueue.isEmpty())
         {
-          checkSelectionKey();
-          selector.orderWriteInterest(selectionKey, isClient(), false);
+          if (selectionKey != null)
+          {
+            selector.orderWriteInterest(selectionKey, isClient(), false);
+          }
         }
       }
     }
@@ -390,14 +394,6 @@ public abstract class TCPConnector extends Connector implements ITCPConnector, I
     }
   }
 
-  private void checkSelectionKey()
-  {
-    if (selectionKey == null)
-    {
-      throw new IllegalStateException("No selection key for connector " + this); //$NON-NLS-1$
-    }
-  }
-
   /**
    * @author Eike Stepper
    */