Sự kiện kết nối

Namespace: Nalix.Network.Connections
Assembly: Nalix.Network

Các sự kiện mạng trên IConnection (MessageProcessing, MessageProcessed và ConnectionClosed) được mang bởi các instance ConnectionEventArgs lấy từ pool và được lập lịch qua bộ điều phối đa làn nội bộ AsyncCallback (CallbackLane.Process, CallbackLane.Post và InvokeHighPriority).

Nguồn mã#

• src/Nalix.Abstractions/Networking/IConnectionEventArgs.cs
• src/Nalix.Network/Connections/Connection.EventArgs.cs
• src/Nalix.Network/Connections/Connection.cs
• src/Nalix.Network/Internal/Transport/AsyncCallback.cs
• src/Nalix.Network/Options/NetworkCallbackOptions.cs

Pipeline thực thi sự kiện#

sequenceDiagram
    participant S as SocketConnection / UdpListenerBase
    participant C as Connection (LocalPool)
    participant AC as AsyncCallback
    participant TP as ThreadPool
    participant H as Protocol / Event Handler

    S->>C: OnFrameReceived(lease) -> AcquireEventArgs() + Initialize(lease, connection)
    alt AsyncCallback.CanRunInline(MessageProcessing) == true
        C->>AC: InvokeInline(bridge, sender, args)
        AC->>H: Raise MessageProcessing synchronously on I/O thread
        AC->>C: Dispose ConnectionEventArgs
    else Queued via AsyncCallback.Invoke(CallbackLane.Process / Post)
        C->>AC: Invoke(bridge, sender, args, CallbackLane.Process)
        alt Process / Post Lane (Under Global & Per-IP Cap)
            AC->>TP: UnsafeQueueUserWorkItem(PooledConnectEventContext)
            TP->>H: Raise MessageProcessing (or MessageProcessed on OnFrameSent)
            H-->>TP: Complete
            TP->>C: ReleasePendingPacket() + Dispose ConnectionEventArgs
        else Throttled (Over Cap)
            AC->>C: ReleasePendingPacket() + Dispose ConnectionEventArgs
        end
    end

ConnectionEventArgs (public sealed class)#

namespace Nalix.Network.Connections;

public sealed class ConnectionEventArgs : EventArgs, IConnectionEventArgs, IPoolable, IPoolRentable
{
    public IBufferLease? Lease { get; }
    public IConnection Connection { get; }
    public INetworkEndpoint NetworkEndpoint { get; }

    public IBufferLease? ExchangeLease([Borrowed] IBufferLease? newLease);
    public void OnRent();
    public void ResetForPool();
    public void Dispose();
}

• ExchangeLease(newLease): Hoán đổi nguyên tử IBufferLease? bên dưới (được TcpListenerBase / WebSocketListenerBase dùng sau khi FramePipeline.ProcessInbound giải mã hoặc giải nén khung đến tại chỗ) và trả về lease trước đó để bên gọi dispose.
• Pool hai tầng: Connection và WebSocketConnection duy trì một LocalPool lock-free 8 slot cho ConnectionEventArgs và PooledConnectEventContext, và chuyển sang ObjectPoolManager.Shared khi pool cục bộ của kết nối đã đầy.

Ba làn điều phối trong AsyncCallback#

Kế toán công bằng theo IP (FairnessMapSize = 16384)#

AsyncCallback băm IConnectionEventArgs.NetworkEndpoint vào các mảng long[FairnessMapSize] có kích thước cố định (s_perIpProcessMap và s_perIpPostMap, mặc định 16,384 slot), đóng gói ((long)(uint)hash << 32) | count vào mỗi slot 64-bit để theo dõi số callback đang chờ theo từng IP từ xa mà không cấp phát heap. Các callback chậm vượt quá MaxCallbackExecutionMs (50 ms) được đếm trong AsyncCallbackMetrics.SlowCallbacks và ghi log qua chẩn đoán có giới hạn tần suất.

API liên quan#

• Connection
• Socket Connection
• Network Callback Options