summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorluwenpeng <[email protected]>2022-12-29 15:29:23 +0800
committerluwenpeng <[email protected]>2022-12-29 15:29:23 +0800
commitcd93796cce9f5e23af18aa521f1b3da6a0c0b0bb (patch)
treeb1d2ad83df4ae7b33c249909174bc4e97ebb63f1
parent2a2bead767da8bf204c162ea19ffdc2c290e310c (diff)
bugfix: 修正decrypted traffic steering debug log输出的BEV_EVENT
-rw-r--r--platform/src/tcp_stream.cpp25
1 files changed, 23 insertions, 2 deletions
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);