Changeset 13971 for branches/thasling/DistributedGA/DistributedGA.Core/Implementation

Timestamp:

07/01/16 19:23:56 (8 years ago)

Author:

thasling

Message:

#2615:
increased message size to 20MB
made changes in some interfaces

Location:

branches/thasling/DistributedGA/DistributedGA.Core/Implementation

Files:

• MessageContractImpl.cs (modified) (1 diff)
• PeerNetworkMessageHandler.cs (modified) (1 diff)
• WcfMessageSender.cs (modified) (2 diffs)
• WcfMessageService.cs (modified) (1 diff)

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

@@ -7 +7 @@
   [ServiceBehavior(InstanceContextMode = InstanceContextMode.Single)]
   public class MessageContractImpl : IMessageContract {
-    public void SendData(PeerInfo sender, byte[][] data) {
+    public void SendData(PeerInfo sender, byte[] data) {
       MessageRecieveEventArgs args = new MessageRecieveEventArgs() { Sender = sender, data = data };
 

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

@@ -146 +146 @@
       if (e != null && e.Sender.ProblemInstance.Equals(ownInstance.ProblemInstance)) {
         lock (activeQueueLocker) {
-          foreach (byte[] item in e.data) {
-            writeQueue.Enqueue(item);
-          }
+            writeQueue.Enqueue(e.data);
         }
 

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

@@ -102 +102 @@
     private void SendDataFromQueue(PeerInfo destination, byte[][] data) {
       try {
-        int arrayLength = 3;
-        if (data.GetUpperBound(0) > arrayLength) {
-          //HACK: SEND MAX 10 items
-          byte[][] fake = new byte[arrayLength][];
-          for (int i = 0; i < arrayLength; i++) {
-            fake[i] = data[i];
-          }
-          data = fake;
-        }
+        //int arrayLength = 3;
+        //if (data.GetUpperBound(0) > arrayLength) {
+        //  //HACK: SEND MAX 10 items
+        //  byte[][] fake = new byte[arrayLength][];
+        //  for (int i = 0; i < arrayLength; i++) {
+        //    fake[i] = data[i];
+        //  }
+        //  data = fake;
+        //}
 
 
@@ -119 +119 @@
 
         var binding = new NetTcpBinding();
+        binding.MaxReceivedMessageSize = 20000000;
+        binding.MaxBufferSize = 20000000;
+        binding.MaxBufferPoolSize = 20000000;
+        binding.ReaderQuotas.MaxArrayLength = 20000000;
+        binding.ReaderQuotas.MaxDepth = 32;
+        binding.ReaderQuotas.MaxStringContentLength = 20000000;
+
         var endpoint = new EndpointAddress(serviceUri);
         using (var myChannelFactory = new ChannelFactory<IMessageContract>(binding, endpoint)) {
           using (IClientChannel client = (IClientChannel)myChannelFactory.CreateChannel()) {
-            ((IMessageContract)client).SendData(myself, data); //maybe timout exception...
+            for (int i = 0; i < data.GetUpperBound(0) + 1; i++) {
+              ((IMessageContract)client).SendData(myself, data[i]); //maybe timout exception...
+            }
           }
         }

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

@@ -27 +27 @@
         var serviceUri = new Uri(baseUri, serviceUrl);
         NetTcpBinding binding = new NetTcpBinding();
+        binding.MaxReceivedMessageSize = 20000000;
+        binding.MaxBufferSize = 20000000;
+        binding.MaxBufferPoolSize = 20000000;
+        binding.ReaderQuotas.MaxArrayLength = 20000000;
+        binding.ReaderQuotas.MaxDepth = 32;
+        binding.ReaderQuotas.MaxStringContentLength = 20000000;
 
         using (var host = new ServiceHost(messageContract, serviceUri)) {