Changeset 13557 for branches/thasling/DistributedGA/DistributedGA.Core

Timestamp:

01/19/16 12:45:18 (8 years ago)

Author:

thasling

Message:

Implemented P2PTask-class
Changed communication protocoll http --> net.tcp
Logger is now Parameter of P2PTask

Location:

branches/thasling/DistributedGA/DistributedGA.Core/Implementation

Files:

• WcfMessageSender.cs (modified) (1 diff)
• WcfMessageService.cs (modified) (1 diff)
• WcfPeerListManager.cs (modified) (1 diff)

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

@@ -19 +19 @@
     private IMessageContract CreateServerClient(string ip, int port) {
       var serviceUrl = "DistributedGA.svc";
-      var baseUri = new Uri(string.Concat("http://", ip, ":", port, "/DistributedGA"));
+      var baseUri = new Uri(string.Concat("net.tcp://", ip, ":", port, "/DistributedGA"));
       var serviceUri = new Uri(baseUri, serviceUrl);
 
-      var binding = new BasicHttpBinding();
+      var binding = new NetTcpBinding();
       var endpoint = new EndpointAddress(serviceUri);
       var myChannelFactory = new ChannelFactory<IMessageContract>(binding, endpoint);

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

@@ -24 +24 @@
       var serviceUrl = "DistributedGA.svc";
       new Thread(() => {
-        var baseUri = new Uri(string.Concat("http://", ip, ":", port, "/DistributedGA"));
+        var baseUri = new Uri(string.Concat("net.tcp://", ip, ":", port, "/DistributedGA"));
         var serviceUri = new Uri(baseUri, serviceUrl);
-        BasicHttpBinding binding = new BasicHttpBinding();
+        NetTcpBinding binding = new NetTcpBinding();
         //using (var host = new ServiceHost(typeof(MessageContractImpl), serviceUri))
 

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

@@ -33 +33 @@
 
     private IContactService CreateClient() {
-      var binding = new BasicHttpBinding();
+      var binding = new NetTcpBinding();
       var endpoint = new EndpointAddress(serverString);
       var myChannelFactory = new ChannelFactory<IContactService>(binding, endpoint);