Changeset 8242 for branches/OaaS/HeuristicLab.Clients.Hive.Slave/3.3/SlaveClientCom.cs

Timestamp:

07/05/12 17:39:12 (12 years ago)

Author:

spimming

Message:

#1888:

• slave worker role initial commit
• start client communication service optionally
• make slave client communication interchangeable ('PipeCom', 'TraceCom')

File:

• branches/OaaS/HeuristicLab.Clients.Hive.Slave/3.3/SlaveClientCom.cs (modified) (4 diffs)

branches/OaaS/HeuristicLab.Clients.Hive.Slave/3.3/SlaveClientCom.cs

@@ -20 +20 @@
 #endregion
 
-using System.ServiceModel;
+using System;
 using HeuristicLab.Clients.Hive.SlaveCore.Properties;
 using HeuristicLab.Clients.Hive.SlaveCore.ServiceContracts;
-using System;
 
 namespace HeuristicLab.Clients.Hive.SlaveCore {
+
+  public enum ClientComType { Pipe, Trace };
 
   /// <summary>
@@ -32 +33 @@
   public class SlaveClientCom {
     private static SlaveClientCom instance;
-    private static DuplexChannelFactory<ISlaveCommunication> pipeFactory;
+    //private static DuplexChannelFactory<ISlaveCommunication> pipeFactory;
+    private static IClientCom clientComInstance;
     public ISlaveCommunication ClientCom { get; set; }
 
@@ -45 +47 @@
         }
         return instance;
+      }
+    }
+
+    public static IClientCom ClientComInstance {
+      get {
+        if (clientComInstance != null) {
+          return clientComInstance;
+        }
+        throw new NullReferenceException("No instance of SlaveClientCom<T>");
       }
     }
@@ -67 +78 @@
 
     private SlaveClientCom() {
-      SetupClientCom();
-    }
+      ClientComType type = Settings.Default.ClientComType;
+      if (type == ClientComType.Pipe) {
+        clientComInstance = new PipeCom();
+      } else if (type == ClientComType.Trace) {
+        clientComInstance = new TraceCom();
+      } else {
+        throw new InvalidStateException("Invalid client communication type");
+      }
 
-    private void SetupClientCom() {
-      DummyListener dummy = new DummyListener();
-      try {
-        pipeFactory = new DuplexChannelFactory<ISlaveCommunication>(dummy, Settings.Default.SlaveCommunicationServiceEndpoint);
-      }
-      catch {
-        EventLogManager.LogMessage("Couldn't create pipe for SlaveClientCom with config!");
-
-        try {
-          pipeFactory = new DuplexChannelFactory<ISlaveCommunication>(dummy, new NetNamedPipeBinding(), new EndpointAddress("net.pipe://localhost/HeuristicLabSlaveCom"));
-        }
-        catch {
-          EventLogManager.LogMessage("Couldn't create pipe for SlaveClientCom with fixed addresse!");
-          return;
-        }
-      }
-      pipeFactory.Faulted += new System.EventHandler(pipeFactory_Faulted);
-
-      ISlaveCommunication pipeProxy = pipeFactory.CreateChannel();
-      ClientCom = pipeProxy;
-    }
-
-    void pipeFactory_Faulted(object sender, System.EventArgs e) {
-      EventLogManager.LogMessage("SlaveClientCom just faulted. Trying to repair it...");
-
-      try {
-        pipeFactory.Faulted -= new System.EventHandler(pipeFactory_Faulted);
-        SetupClientCom();
-      }
-      catch { }
+      ClientCom = clientComInstance.GetSlaveCom();
     }
 
     public static void Close() {
-      if (pipeFactory.State != CommunicationState.Closed && pipeFactory.State != CommunicationState.Faulted)
-        pipeFactory.Close();
+      ClientComInstance.Close();
     }
   }