Changeset 14060 for branches/thasling/DistributedGA/DistributedGA.Core/Implementation/WcfPeerListManager.cs

Timestamp:

07/13/16 15:37:29 (8 years ago)

Author:

thasling

Message:

#2615:
changed parameter in P2PMigrationAnalyzer, so that there is no invalid cast ExceptionThrown
other parameters still TBD
made WcfPeerListManager stateless by removing a stored ChannelFactory and creating a new one by each method call

File:

• branches/thasling/DistributedGA/DistributedGA.Core/Implementation/WcfPeerListManager.cs (modified) (5 diffs)

branches/thasling/DistributedGA/DistributedGA.Core/Implementation/WcfPeerListManager.cs

@@ -18 +18 @@
     private Object timerLock = new Object();
 
-    private ChannelFactory<IContactService> myChannelFactory;
-
-    private IContactService client;
-
     private List<PeerInfo> cachedPeerList;
 
@@ -34 +30 @@
       cachedPeerList = new List<PeerInfo>();
       rand = new Random();
-      //Init ChannelFactory and Client
-      var binding = new NetTcpBinding();
-      var endpoint = new EndpointAddress(serverString);
-      myChannelFactory = new ChannelFactory<IContactService>(binding, endpoint);
-      client = myChannelFactory.CreateChannel();
-      //Register Peer
-      client.RegisterPeer(myself);
       //Start heartbeat timer
       timer = new Timer(1000 * 20); //each 20 seconds
@@ -52 +41 @@
 
     public void SendLogToServer(string msg) {
-      client.MakeLog(myself, msg);
+      var binding = new NetTcpBinding();
+      var endpoint = new EndpointAddress(serverString);
+      using (var myChannelFactory = new ChannelFactory<IContactService>(binding, endpoint)) {
+        using (IClientChannel client = (IClientChannel)myChannelFactory.CreateChannel()) {
+          ((IContactService)client).MakeLog(myself, msg);      
+        }
+      }
     }
 
@@ -58 +53 @@
       timer.Stop();
       timer.Dispose();
-      ((IClientChannel)client).Close();
-      myChannelFactory.Close();
-      myChannelFactory = null;
     }
 
@@ -86 +78 @@
       lock (timerLock) {
         try {
-          var allPeers = client.GetPeerList(myself);
+          List<PeerInfo> allPeers = new List<PeerInfo>();
+          var binding = new NetTcpBinding();
+          var endpoint = new EndpointAddress(serverString);
+          using (var myChannelFactory = new ChannelFactory<IContactService>(binding, endpoint)) {
+            using (IClientChannel client = (IClientChannel)myChannelFactory.CreateChannel()) {
+              allPeers = ((IContactService)client).GetPeerList(myself);            
+            }
+          }
           cachedPeerList = ChoosePeersForMessaging(ref allPeers);
         }