incentive/psopeeps-newserv
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

log when client channels connect successfully

Browse Source
This commit is contained in:
Martin Michelsen
2022-08-11 23:36:30 -07:00
parent d2b9023cfc
commit c592542f07
2 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/CatSession.cc
+3
View File
@@ -111,6 +111,9 @@ void CatSession::dispatch_on_channel_error(Channel& ch, short events) {
} }
void CatSession::on_channel_error(short events) { void CatSession::on_channel_error(short events) {
if (events & BEV_EVENT_CONNECTED) {
this->log.info("Channel connected");
}
if (events & BEV_EVENT_ERROR) { if (events & BEV_EVENT_ERROR) {
int err = EVUTIL_SOCKET_ERROR(); int err = EVUTIL_SOCKET_ERROR();
this->log.warning("Error %d (%s) in unlinked client stream", err, this->log.warning("Error %d (%s) in unlinked client stream", err,
src/ProxyServer.cc
+3
View File
@@ -602,6 +602,9 @@ void ProxyServer::LinkedSession::on_error(Channel& ch, short events) {
auto* session = reinterpret_cast<LinkedSession*>(ch.context_obj); auto* session = reinterpret_cast<LinkedSession*>(ch.context_obj);
bool is_server_stream = (&ch == &session->server_channel); bool is_server_stream = (&ch == &session->server_channel);
if (events & BEV_EVENT_CONNECTED) {
session->log.info("%s channel connected", is_server_stream ? "Server" : "Client");
}
if (events & BEV_EVENT_ERROR) { if (events & BEV_EVENT_ERROR) {
int err = EVUTIL_SOCKET_ERROR(); int err = EVUTIL_SOCKET_ERROR();
session->log.warning("Error %d (%s) in %s stream", session->log.warning("Error %d (%s) in %s stream",