GenXdev.Helpers

1.78.2024

ProxyIncomingSocketHandlerBase.cs

using GenXdev.AsyncSockets.Handlers;
using GenXdev.Configuration;
using GenXdev.MemoryManagement;
using Ninject;
 
namespace GenXdev.AsyncSockets.Containers
{
    public abstract class ProxyIncomingSocketHandlerBase : SocketHandlerBase
    {
        [Inject]
        public ProxyIncomingSocketHandlerBase(
            IKernel Kernel
            , IMemoryManagerConfiguration MemoryConfiguration
            , IServiceMemoryManager MemoryManager
            , String ServiceName
 
#if (Logging)
, IServiceLogger Logger
#endif
, object Pool = null
)
            : base(
                Kernel
                , MemoryConfiguration
                , MemoryManager
                , ServiceName
#if (Logging)
, Logger
#endif
, Pool
        )
        {
            this.OnHandleReset += ProxyIncomingSocketHandlerBase_OnHandleReset;
        }
 
        void ProxyIncomingSocketHandlerBase_OnHandleReset(object sender, EventArgs e)
        {
            if (OutgoingHandler != null)
            {
                OutgoingHandler.Close();
                OutgoingHandler = null;
            }
        }
 
        public ProxyOutgoingSocketHandlerBase OutgoingHandler { get; set; }
    }
}