Context Navigation

Changeset 13547

Timestamp:

01/18/16 15:28:29 (9 years ago)

Author:

thasling

Message:

Added Dispose() to MessageHandler and WCF service host

Location:

branches/thasling/DistributedGA

Files:

r13541	r13547
24	24	private ConcurrentQueue<SolutionInfo> writeQueue;
25	25	private ConcurrentQueue<SolutionInfo> readQueue;
26		~~private bool collectingInFirstQueue = true; //currently first queue is filled with recieved populations~~
27	26
28	27	//uses IMessageService for recieving population from one peer at once
…	…
55	54	} catch (Exception ex) {
56	55	AddError("PeerNetworkMessageHandler.Init", ex);
	56	}
	57	}
	58
	59	public void Dispose() {
	60	try {
	61	host.Dispose();
	62	} catch (Exception ex) {
	63	AddError("PeerNetworkMessageHandler.Dispose", ex);
57	64	}
58	65	}
…	…
144	151	}
145	152	}
	153
146	154	}
147	155	}

r13541	r13547
42	42	}
43	43
	44	public void Dispose() {
	45	_ResetEvent.Set();
	46	}
	47
44	48	private int FreeTcpPort() {
45	49	TcpListener l = new TcpListener(IPAddress.Loopback, 0);
…	…
55	59	}
56	60	}
57
58	61	}
59	62	}

-                      r13524
+                      r13547
+using DistributedGA.Core.Domain;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using System.Collections.Generic;
+using DistributedGA.Core.Domain;
+namespace DistributedGA.Core.Interface
+{
+    public interface IMessageHandler
+    {
+        void Init(); //Registers at contract-server
+namespace DistributedGA.Core.Interface {
+  public interface IMessageHandler {
+    void Init(); //Registers at contract-server
         void PublishMigrationInfo(SolutionInfo[] population);
+    void PublishMigrationInfo(SolutionInfo[] population);
         SolutionInfo[] GetMigrationInfo();
+    SolutionInfo[] GetMigrationInfo();
         PeerInfo GetPeerInfo();
+    PeerInfo GetPeerInfo();
+        List<PeerInfo> GetCurrentNetwork();
+    }
+    List<PeerInfo> GetCurrentNetwork();
+    void Dispose();
+  }
+}

-                      r13524
+                      r13547
+using DistributedGA.Core.Domain;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using System;
+using DistributedGA.Core.Domain;
+namespace DistributedGA.Core.Interface
+{
+    public interface IMessageService
+    {
+        /// <summary>
+        /// Initializes a WCF service and host it with another thread
+        /// </summary>
+        /// <param name="ip">current external ip address</param>
+        /// <returns>The port, on which the service was successfully hosted</returns>
+        int Init(string ip);
+namespace DistributedGA.Core.Interface {
+  public interface IMessageService {
+    /// <summary>
+    /// Initializes a WCF service and host it with another thread
+    /// </summary>
+    /// <param name="ip">current external ip address</param>
+    /// <returns>The port, on which the service was successfully hosted</returns>
+    int Init(string ip);
+        event EventHandler<MessageRecieveEventArgs> OnPopulationRecieved;
+    }
+    void Dispose();
+    event EventHandler<MessageRecieveEventArgs> OnPopulationRecieved;
+  }
+}

Note: See TracChangeset for help on using the changeset viewer.