diff --git a/platform/src/tcp_stream.cpp b/platform/src/tcp_stream.cpp index 439908b..0e5ff46 100644 --- a/platform/src/tcp_stream.cpp +++ b/platform/src/tcp_stream.cpp @@ -717,6 +717,7 @@ 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_cmsg_set_flag(_stream->cmsg, TFE_CMSG_FLAG_USER0); } outbuf = bufferevent_get_output(peer_conn->bev); @@ -1232,8 +1233,6 @@ void ssl_downstream_create_on_success(future_result_t * result, void * user) TFE_PROXY_STAT_INCREASE(STAT_STEERING_SSL_CONN, 1); } - tfe_cmsg_set_flag(_stream->cmsg, TFE_CMSG_FLAG_USER0); - return; }