server_common/wsproxy
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
azw 2023-05-08 03:06:50 +00:00
parent b2045dd1f2
commit 7f0aebeac8
2 changed files with 10 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
server/wsproxy/master.cc
View File

@ -21,9 +21,7 @@ void Master::Init(int instance_id, const std::string& remote_ip, int remote_port
recv_bufflen_ = 0; recv_bufflen_ = 0;
last_pong_tick = a8::XGetTickCount(); last_pong_tick = a8::XGetTickCount();
tcp_client_ = std::make_shared<a8::TcpClient>(); tcp_client_ = std::make_shared<a8::TcpClient>(remote_ip, remote_port);
tcp_client_->remote_address = remote_ip;
tcp_client_->remote_port = remote_port;
tcp_client_->on_error = std::bind(&Master::on_error, this, std::placeholders::_1, std::placeholders::_2); tcp_client_->on_error = std::bind(&Master::on_error, this, std::placeholders::_1, std::placeholders::_2);
tcp_client_->on_connect = std::bind(&Master::on_connect, this, std::placeholders::_1); tcp_client_->on_connect = std::bind(&Master::on_connect, this, std::placeholders::_1);
tcp_client_->on_disconnect = std::bind(&Master::on_disconnect, this, std::placeholders::_1); tcp_client_->on_disconnect = std::bind(&Master::on_disconnect, this, std::placeholders::_1);
@ -72,8 +70,8 @@ void Master::on_error(a8::TcpClient* sender, int errorId)
f8::UdpLog::Instance()->Error("Master errorid=%d remote_ip:%s remote_port:%d", f8::UdpLog::Instance()->Error("Master errorid=%d remote_ip:%s remote_port:%d",
{ {
errorId, errorId,
sender->remote_address, sender->GetRemoteAddress(),
sender->remote_port sender->GetRemotePort()
}); });
} }

16
server/wsproxy/upstream.cc
View File

@ -25,9 +25,7 @@ void UpStream::Init(int instance_id, const std::string& remote_ip, int remote_po
recv_bufflen_ = 0; recv_bufflen_ = 0;
last_pong_tick = a8::XGetTickCount(); last_pong_tick = a8::XGetTickCount();
tcp_client_ = std::make_shared<a8::TcpClient>(); tcp_client_ = std::make_shared<a8::TcpClient>(remote_ip, remote_port);
tcp_client_->remote_address = remote_ip;
tcp_client_->remote_port = remote_port;
tcp_client_->on_error = std::bind(&UpStream::on_error, this, std::placeholders::_1, std::placeholders::_2); tcp_client_->on_error = std::bind(&UpStream::on_error, this, std::placeholders::_1, std::placeholders::_2);
tcp_client_->on_connect = std::bind(&UpStream::on_connect, this, std::placeholders::_1); tcp_client_->on_connect = std::bind(&UpStream::on_connect, this, std::placeholders::_1);
tcp_client_->on_disconnect = std::bind(&UpStream::on_disconnect, this, std::placeholders::_1); tcp_client_->on_disconnect = std::bind(&UpStream::on_disconnect, this, std::placeholders::_1);
@ -147,8 +145,8 @@ void UpStream::on_error(a8::TcpClient* sender, int errorId)
f8::UdpLog::Instance()->Error("target server errorid=%d remote_ip:%s remote_port:%d", f8::UdpLog::Instance()->Error("target server errorid=%d remote_ip:%s remote_port:%d",
{ {
errorId, errorId,
sender->remote_address, sender->GetRemoteAddress(),
sender->remote_port sender->GetRemotePort()
}); });
} }
@ -157,8 +155,8 @@ void UpStream::on_connect(a8::TcpClient* sender)
recv_bufflen_ = 0; recv_bufflen_ = 0;
f8::UdpLog::Instance()->Info("target server connected remote_ip:%s remote_port:%d", f8::UdpLog::Instance()->Info("target server connected remote_ip:%s remote_port:%d",
{ {
sender->remote_address, sender->GetRemoteAddress(),
sender->remote_port sender->GetRemotePort()
}); });
f8::MsgQueue::Instance()->PostMsg f8::MsgQueue::Instance()->PostMsg
( (
@ -179,8 +177,8 @@ void UpStream::on_disconnect(a8::TcpClient* sender)
"remote_ip:%s remote_port:%d", "remote_ip:%s remote_port:%d",
{ {
instance_id, instance_id,
sender->remote_address, sender->GetRemoteAddress(),
sender->remote_port sender->GetRemotePort()
}); });
f8::MsgQueue::Instance()->PostMsg f8::MsgQueue::Instance()->PostMsg
( (