bughz/predixy
1
0
Fork 0
mirror of https://github.com/joyieldInc/predixy.git synced 2025-12-24 22:46:41 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

Merge 6eef946305 into ca1630a6b4

Browse Source
This commit is contained in:
Jack Wang 2024-02-09 07:45:14 -07:00 committed by GitHub
commit 9deab27a6f
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 14 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/ConnectConnection.h
View File

@ -13,15 +13,23 @@
#include "Request.h"
#include "ResponseParser.h"
enum ConnectConnectionListIndex
{
PostConn = 0,
PrivateConn,
ConnListSize
};
class ConnectConnection :
public ConnectSocket,
public Connection,
public ListNode<ConnectConnection>,
public ListNode<ConnectConnection, ConnectConnection*, ConnectConnectionListIndex::ConnListSize>,
public DequeNode<ConnectConnection>
{
public:
typedef ConnectConnection Value;
typedef ListNode<ConnectConnection> ListNodeType;
typedef ListNode<ConnectConnection, ConnectConnection*, ConnectConnectionListIndex::ConnListSize> ListNodeType;
typedef DequeNode<ConnectConnection> DequeNodeType;
typedef Alloc<ConnectConnection, Const::ConnectConnectionAllocCacheSize> Allocator;
public:
@ -96,7 +104,8 @@ private:
bool mReadonly;
};
typedef List<ConnectConnection> ConnectConnectionList;
typedef List<ConnectConnection, ConnectConnectionListIndex::PostConn> PostConnectConnectionList;
typedef List<ConnectConnection, ConnectConnectionListIndex::PrivateConn> PrivateConnectConnectionList;
typedef Deque<ConnectConnection> ConnectConnectionDeque;
typedef ConnectConnection::Allocator ConnectConnectionAlloc;

2
src/ConnectConnectionPool.h
View File

@ -71,7 +71,7 @@ private:
Server* mServ;
int mPendRequests;
std::vector<ConnectConnection*> mShareConns;
std::vector<ConnectConnectionList> mPrivateConns;
std::vector<PrivateConnectConnectionList> mPrivateConns;
ServerStats mStats;
std::vector<LatencyMonitor> mLatencyMonitors;
};

2
src/Handler.h
View File

@ -120,7 +120,7 @@ private:
std::vector<ConnectConnectionPool*> mConnPool;
AcceptConnectionDeque mAcceptConns;
AcceptConnectionList mPostAcceptConns;
ConnectConnectionList mPostConnectConns;
PostConnectConnectionList mPostConnectConns;
ConnectConnectionDeque mWaitConnectConns;
long mStatsVer;
HandlerStats mStats;