更新网络库

This commit is contained in:
sin365 2023-07-04 13:07:30 +08:00
parent 4379be7793
commit c7d227c305
13 changed files with 0 additions and 13 deletions

Binary file not shown.

Binary file not shown.

Binary file not shown.

View File

@ -15,20 +15,7 @@ namespace ServerCore.NetWork
: base(numConnections, receiveBufferSize) : base(numConnections, receiveBufferSize)
{ {
mServerType = serverType; mServerType = serverType;
m_clientCount = 0;
m_maxConnectNum = numConnections;
m_revBufferSize = receiveBufferSize;
// allocate buffers such that the maximum number of sockets can have one outstanding read and
//write posted to the socket simultaneously
m_bufferManager = new BufferManager(receiveBufferSize * numConnections * opsToAlloc, receiveBufferSize);
m_pool = new SocketEventPool(numConnections);
m_maxNumberAcceptedClients = new Semaphore(numConnections, numConnections);
ClientNumberChange += IOCPNetWork_ClientNumberChange; ClientNumberChange += IOCPNetWork_ClientNumberChange;
} }
private void IOCPNetWork_ClientNumberChange(int num, AsyncUserToken token) private void IOCPNetWork_ClientNumberChange(int num, AsyncUserToken token)