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-04-14 09:13:08 +00:00
parent 057c9b6161
commit 895aec82c1
1 changed files with 21 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

33
server/wsproxy/upstream.cc
View File

@ -6,6 +6,7 @@
#include <f8/udplog.h>
#include <f8/timer.h>
#include <f8/msgqueue.h>
#include "ss_proto.pb.h"
#include "ss_msgid.pb.h"
@ -165,12 +166,16 @@ void UpStream::on_connect(a8::TcpClient* sender)
sender->remote_address,
sender->remote_port
});
#if 0
App::Instance()->AddIMMsg(IM_UpStreamConnect,
a8::XParams()
.SetSender(instance_id)
);
#endif
f8::MsgQueue::Instance()->PostMsg
(
IM_UpStreamConnect,
a8::Args
(
{
instance_id
}
)
);
}
void UpStream::on_disconnect(a8::TcpClient* sender)
@ -183,12 +188,16 @@ void UpStream::on_disconnect(a8::TcpClient* sender)
sender->remote_address,
sender->remote_port
});
#if 0
App::Instance()->AddIMMsg(IM_UpStreamDisconnect,
a8::XParams()
.SetSender(instance_id)
);
#endif
f8::MsgQueue::Instance()->PostMsg
(
IM_UpStreamDisconnect,
a8::Args
(
{
instance_id
}
)
);
}
void UpStream::on_socketread(a8::TcpClient* sender, char* buf, unsigned int len)