server_common/wsproxy
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aozhiwei 2024-03-24 18:45:05 +08:00
parent ec94b9525a
commit 0ede4b54fe
2 changed files with 15 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
server/wsproxy/mastermgr.cc
View File

@ -19,15 +19,6 @@
#include "downstreammgr.h" #include "downstreammgr.h"
#include "GCListener.h" #include "GCListener.h"
struct HttpTunnelRequest
{
int socket_handle = 0;
long long context_id = 0;
f8::TimerWp timer_wp;
std::shared_ptr<f8::JsonHttpRequest> request;
};
class RequestTarget class RequestTarget
{ {
public: public:
@ -309,6 +300,8 @@ void MasterMgr::AddHttpTunnelRequest(int socket_handle, std::shared_ptr<f8::Json
{ {
if (a8::TIMER_EXEC_EVENT == event) { if (a8::TIMER_EXEC_EVENT == event) {
MasterMgr::Instance()->RemoveHttpTunnelRequest(req->socket_handle); MasterMgr::Instance()->RemoveHttpTunnelRequest(req->socket_handle);
} else if (ALLOC_TARGET_SERVER_SUCCESS_TIMER_EVENT == event) {
MasterMgr::Instance()->RemoveHttpTunnelRequest(req->socket_handle);
} }
} }
); );

13
server/wsproxy/types.h
View File

@ -1,5 +1,10 @@
#pragma once #pragma once
namespace f8
{
class JsonHttpRequest;
}
struct PerfMonitor struct PerfMonitor
{ {
int max_run_delay_time = 0; int max_run_delay_time = 0;
@ -11,3 +16,11 @@ struct PerfMonitor
long long in_data_size = 0; long long in_data_size = 0;
long long read_count = 0; long long read_count = 0;
}; };
struct HttpTunnelRequest
{
int socket_handle = 0;
long long context_id = 0;
f8::TimerWp timer_wp;
std::shared_ptr<f8::JsonHttpRequest> request;
};