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; }