MARKUS

using System;

using System.Collections.Generic;

using System.Linq;

using System.ServiceModel;

using System.ServiceModel.Channels;

using System.ServiceModel.Description;

using System.Text;

using System.Threading.Tasks;

using System.Xml;

namespace IIpc

{

    public sealed class WcfServer : IIpcServer

    {

        [ServiceBehavior(IncludeExceptionDetailInFaults = false,InstanceContextMode = InstanceContextMode.Single)]

        private class _Server : IIpcClient

        {

            private readonly WcfServer server;

            public _Server(WcfServer server)

            {

                this.server = server;

            }

            public void SendFileDownloadReceived(double progress, bool isFinish)

            {

                this.server.OnFileDownloadReceived(new IpcDownloadStatusArgs(progress, isFinish));

            }

            public void SendThumbnailReceived(int pageno, string path,bool isLast)

            {

                this.server.OnThumbnailReceived(new IpcThumbnailEventArgs(pageno,path, isLast));

            }

        }

        private readonly ServiceHost host;

        private void OnThumbnailReceived(IpcThumbnailEventArgs e)

        {

            var handler = this.IpcThumbnailReceived;

            if (handler != null)

            {

                handler(this, e);

            }

        }

        private void OnFileDownloadReceived(IpcDownloadStatusArgs e)

        {

            var handler = this.IpcFileDownloadReceived;

            if (handler != null)

            {

                handler(this, e);

            }

        }

        /// <summary>

        /// 

        /// </summary>

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

        public WcfServer(string endpoint)

        {

            try

            {

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

                this.host.Closing += Host_Closing;

                //ServiceMetadataBehavior smb = new ServiceMetadataBehavior();

                //smb.HttpGetEnabled = false;

                //host.Description.Behaviors.Add(smb);

                //var endpoints = this.host.AddDefaultEndpoints();

                //System.Diagnostics.Debug.WriteLine(endpoints);

            }

            catch (Exception ex)

            {

                System.Diagnostics.Debug.WriteLine(ex);

            }

            //this.host = new ServiceHost(this, new Uri(string.Format("net.pipe://localhost")));

            //ServiceMetadataBehavior mBehave = new ServiceMetadataBehavior();

            //mBehave.HttpGetEnabled = false;

            //mBehave.HttpsGetEnabled = false;

            //this.host.Description.Behaviors.Add(mBehave);

            //if (endpoint != null)

            //{

            //    NetNamedPipeBinding binding = new NetNamedPipeBinding { TransferMode = TransferMode.Buffered };

            //    binding.CloseTimeout = new TimeSpan(0, 1, 0);

            //    binding.ReceiveTimeout = new TimeSpan(0, 1, 0);

            //    binding.SendTimeout = new TimeSpan(0, 1, 0);

            //    binding.OpenTimeout = new TimeSpan(0, 1, 0);

            //    binding.CreateBindingElements().Add(gBindingElement);

            //    var httpEndpoint = this.host.AddServiceEndpoint(typeof(IIpcServer), binding, endpoint);

            //}

        }

        private void Host_Closing(object sender, EventArgs e)

        {

            System.Diagnostics.Debug.WriteLine($"IIpc.WcfServer {this.host.BaseAddresses?.First()} closing");

        }

        public static BinaryMessageEncodingBindingElement gBindingElement = new BinaryMessageEncodingBindingElement

        {

            MaxReadPoolSize = Int16.MaxValue,

            MaxWritePoolSize = Int16.MaxValue,

            MaxSessionSize = Int16.MaxValue,

            ReaderQuotas = GetReaderQuotas()

        };

        public static XmlDictionaryReaderQuotas GetReaderQuotas()

        {

            return new XmlDictionaryReaderQuotas

            {

                MaxDepth = Int16.MaxValue,

                MaxStringContentLength = Int16.MaxValue,

                MaxArrayLength = Int16.MaxValue,

                MaxBytesPerRead = Int16.MaxValue,

                MaxNameTableCharCount = Int16.MaxValue

            };

        }

        public event EventHandler<IpcThumbnailEventArgs> IpcThumbnailReceived;

        public event EventHandler<IpcDownloadStatusArgs> IpcFileDownloadReceived;

        public void Start()

        {

            this.host.Open();

        }

        public bool IsDispose

        {

            get { return (this.host == null ? true : false); }

        }

        public bool IsOpen

        {

            get { return (this.host?.State == CommunicationState.Opened ? true : false); }

        }

        public void Stop()

        {

            try

            {

                System.Diagnostics.Debug.WriteLine($"IIpc.WcfServer {this.host.BaseAddresses?.First()} Stop");

                this.host.Close(new TimeSpan(1));

                System.Diagnostics.Debug.WriteLine($"IIpc.WcfServer {this.host.BaseAddresses?.First()} Stoped");

            }

            catch (Exception ex)

            {

                System.Diagnostics.Debug.WriteLine(ex.ToString());

            }

        }

        void IDisposable.Dispose()

        {

            this.Stop();

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

            System.Diagnostics.Debug.WriteLine($"IIpc.WcfServer {this.host.BaseAddresses?.First()} Dispose");

        }

    }

}