gfwleak/tango-tfe
Archived
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feature: worker thread不再发送intercept metrics

Browse Source
This commit is contained in:
luwenpeng
2023-06-01 15:48:23 +08:00
parent 9395538973
commit 934d796d65
1 changed files with 0 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
platform/src/tcp_stream.cpp
View File

@@ -497,20 +497,9 @@ static void __stream_bev_passthrough_readcb(struct bufferevent * bev, void * arg
{ {
TFE_PROXY_STAT_INCREASE(STAT_STREAM_BYPASS, 1); TFE_PROXY_STAT_INCREASE(STAT_STREAM_BYPASS, 1);
_stream->is_first_call_rxcb = 1; _stream->is_first_call_rxcb = 1;
tfe_set_intercept_metric(&_stream->head, 1, 0, 0, 0, 0);
tfe_cmsg_set_flag(_stream->cmsg, TFE_CMSG_FLAG_USER0); tfe_cmsg_set_flag(_stream->cmsg, TFE_CMSG_FLAG_USER0);
} }
int inbuff_len = evbuffer_get_length(__input_buffer);
if (bev == _stream->conn_downstream->bev)
{
tfe_set_intercept_metric(&_stream->head, 0, 1, inbuff_len, 0, 0);
}
else
{
tfe_set_intercept_metric(&_stream->head, 0, 0, 0, 1, inbuff_len);
}
struct evbuffer * __output_buffer = bufferevent_get_output(peer_conn->bev); struct evbuffer * __output_buffer = bufferevent_get_output(peer_conn->bev);
evbuffer_add_buffer(__output_buffer, __input_buffer); evbuffer_add_buffer(__output_buffer, __input_buffer);
} }
@@ -674,7 +663,6 @@ static void __stream_bev_readcb(struct bufferevent * bev, void * arg)
{ {
TFE_PROXY_STAT_INCREASE(STAT_STREAM_INTERCEPT, 1); TFE_PROXY_STAT_INCREASE(STAT_STREAM_INTERCEPT, 1);
_stream->is_first_call_rxcb = 1; _stream->is_first_call_rxcb = 1;
tfe_set_intercept_metric(&_stream->head, 1, 0, 0, 0, 0);
} }
outbuf = bufferevent_get_output(peer_conn->bev); outbuf = bufferevent_get_output(peer_conn->bev);
@@ -762,13 +750,11 @@ static void __stream_bev_readcb(struct bufferevent * bev, void * arg)
if (dir == CONN_DIR_DOWNSTREAM) if (dir == CONN_DIR_DOWNSTREAM)
{ {
TFE_PROXY_STAT_INCREASE(STAT_STREAM_INCPT_DOWN_BYTES, rx_offset_increase); TFE_PROXY_STAT_INCREASE(STAT_STREAM_INCPT_DOWN_BYTES, rx_offset_increase);
tfe_set_intercept_metric(&_stream->head, 0, 1, rx_offset_increase, 0, 0);
_stream->downstream_rx_offset += rx_offset_increase; _stream->downstream_rx_offset += rx_offset_increase;
} }
else else
{ {
TFE_PROXY_STAT_INCREASE(STAT_STREAM_INCPT_UP_BYTES, rx_offset_increase); TFE_PROXY_STAT_INCREASE(STAT_STREAM_INCPT_UP_BYTES, rx_offset_increase);
tfe_set_intercept_metric(&_stream->head, 0, 0, 0, 1, rx_offset_increase);
_stream->upstream_rx_offset += rx_offset_increase; _stream->upstream_rx_offset += rx_offset_increase;
} }