MARKUS

using System;

using System.Collections.Generic;

using System.Linq;

using System.ServiceModel;

using System.Text;

using System.Threading.Tasks;

namespace IIpc

{

    public sealed class WcfServer : IIpcServer

    {

        [ServiceBehavior(InstanceContextMode = InstanceContextMode.Single)]

        private class _Server : IIpcClient

        {

            private readonly WcfServer server;

            public _Server(WcfServer server)

            {

                this.server = server;

            }

            public void ParamReceived(string InstallPath, string tempStoragePath, string downloadFile, string KcomPath, string Param)

            {

                this.server.OnParamReceived(new ParamReceivedEventArgs(InstallPath, tempStoragePath, downloadFile, KcomPath, Param));

            }

            public void ProcessStart()

            {

                this.server.OnProcessStart(new EventArgs());

            }

        }

        private readonly ServiceHost host;

        public Uri Endpoint;

        public event EventHandler<ParamReceivedEventArgs> ParamReceived;

        public event EventHandler<EventArgs> ProcessStart;

        private void OnParamReceived(ParamReceivedEventArgs e)

        {

            var handler = this.ParamReceived;

            if (handler != null)

            {

                handler(this, e);

            }

        }

        private void OnProcessStart(EventArgs e)

        {

            var handler = this.ProcessStart;

            if (handler != null)

            {

                handler(this, e);

            }

        }

        /// <summary>

        /// 

        /// </summary>

        /// <param name="endpoint">지정된 끝점으로 유일하게 통신한다.</param>

        public WcfServer(string endpoint)

        {

            this.Endpoint = new Uri(string.Format("net.pipe://localhost/{0}", endpoint));

            this.host = new ServiceHost(new _Server(this), Endpoint);

            //this.host.AddServiceEndpoint(typeof(IIpcServer), new NetNamedPipeBinding(), endpoint);

        }

        public void Start()

        {

            this.host.Open();

        }

        public CommunicationState State()

        {

            return this.host.State;

        }

        public void Stop()

        {

            this.host.Close();

        }

        void IDisposable.Dispose()

        {

            this.Stop();

            (this.host as IDisposable).Dispose();

        }

    }

}