diff --git a/platform/src/tcp_stream.cpp b/platform/src/tcp_stream.cpp index 70cdb1a..15a22be 100644 --- a/platform/src/tcp_stream.cpp +++ b/platform/src/tcp_stream.cpp @@ -136,6 +136,27 @@ static void call_plugin_close(struct tfe_stream_private * _stream) } } +static const char *bev_event_to_string(short events) +{ + switch (events) + { + case BEV_EVENT_READING: + return "BEV_EVENT_READING"; + case BEV_EVENT_WRITING: + return "BEV_EVENT_WRITING"; + case BEV_EVENT_EOF: + return "BEV_EVENT_EOF"; + case BEV_EVENT_ERROR: + return "BEV_EVENT_ERROR"; + case BEV_EVENT_TIMEOUT: + return "BEV_EVENT_TIMEOUT"; + case BEV_EVENT_CONNECTED: + return "BEV_EVENT_CONNECTED"; + default: + return ""; + } +} + /* ==================================================================================================================== * INTERFACE * ===================================================================================================================*/ @@ -886,7 +907,7 @@ static void __stream_bev_eventcb(struct bufferevent * bev, short events, void * TFE_LOG_DEBUG(__STREAM_LOGGER(_stream), "decrypted traffic steering, %s %s run eventcb, %s %s", _stream->str_stream_addr, bev == _stream->conn_downstream->bev ? "conn_downstream" : "conn_upstream", - events & BEV_EVENT_ERROR ? "BEV_EVENT_ERROR" : "BEV_EVENT_EOF", + bev_event_to_string(events), errno == 0 ? "" : strerror(errno) ); tfe_stream_destory(_stream); @@ -1136,7 +1157,7 @@ static void __steering_stream_bev_eventcb(struct bufferevent *bev, short events, TFE_LOG_DEBUG(__STREAM_LOGGER(_stream), "decrypted traffic steering, %s %s run eventcb, %s %s", _stream->str_stream_addr, bev == _stream->conn_fake_c->bev ? "conn_fake_c" : "conn_fake_s", - events & BEV_EVENT_ERROR ? "BEV_EVENT_ERROR" : "BEV_EVENT_EOF", + bev_event_to_string(events), errno == 0 ? "" : strerror(errno) ); tfe_stream_destory(_stream);