source: branches/thasling/DistributedGA/DistributedGA.Core/Implementation/WcfMessageService.cs @ 14252

using System;
using System.Net;
using System.Net.Sockets;
using System.ServiceModel;
using System.Threading;
using DistributedGA.Core.Domain;
using DistributedGA.Core.Interface;

namespace DistributedGA.Core.Implementation {
  public class WcfMessageService : IMessageService, IDisposable {
    public event EventHandler<MessageRecieveEventArgs> OnDataRecieved;

    private ManualResetEvent _ResetEvent = new ManualResetEvent(false);

    private IMessageContract messageContract = null;

    public int Init(string ip) {
      int port = 0;
      port = FreeTcpPort();

      messageContract = new MessageContractImpl();
      messageContract.MessageRecieved += new EventHandler<MessageRecieveEventArgs>(OnMessageRecieved);

      var serviceUrl = "DistributedGA.svc";
      new Thread(() => {
        var baseUri = new Uri(string.Concat("net.tcp://", ip, ":", port, "/DistributedGA"));
        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)) {
          host.AddServiceEndpoint(typeof(IMessageContract), binding, serviceUri);

          host.Open();

          _ResetEvent.WaitOne();
        }
      }).Start();
      return port;
    }

    public void Dispose() {
      _ResetEvent.Set();
      _ResetEvent.Dispose();
    }

    private int FreeTcpPort() {
      TcpListener l = new TcpListener(IPAddress.Loopback, 0);
      l.Start();
      int port = ((IPEndPoint)l.LocalEndpoint).Port;
      l.Stop();
      return port;
    }

    private void OnMessageRecieved(object sender, MessageRecieveEventArgs e) {
      if (OnDataRecieved != null) {
        OnDataRecieved(this, e);
      }
    }
  }
}