From 934d796d65201c4d29976f3a5692e378dc6798fd Mon Sep 17 00:00:00 2001 From: luwenpeng Date: Thu, 1 Jun 2023 15:48:23 +0800 Subject: [PATCH] =?UTF-8?q?feature:=20worker=20thread=E4=B8=8D=E5=86=8D?= =?UTF-8?q?=E5=8F=91=E9=80=81intercept=20metrics?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- platform/src/tcp_stream.cpp | 14 -------------- 1 file changed, 14 deletions(-) diff --git a/platform/src/tcp_stream.cpp b/platform/src/tcp_stream.cpp index d1ac18e..207efc8 100644 --- a/platform/src/tcp_stream.cpp +++ b/platform/src/tcp_stream.cpp @@ -497,20 +497,9 @@ static void __stream_bev_passthrough_readcb(struct bufferevent * bev, void * arg { TFE_PROXY_STAT_INCREASE(STAT_STREAM_BYPASS, 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); } - 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); 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); _stream->is_first_call_rxcb = 1; - tfe_set_intercept_metric(&_stream->head, 1, 0, 0, 0, 0); } 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) { 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; } else { 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; }