server/game2001
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

添加房间已满逻辑判断

Browse Source
This commit is contained in:
aozhiwei 2019-08-31 15:57:11 +08:00
parent 2112d6aa7c
commit e728ab7442
3 changed files with 33 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
server/gameserver/GGListener.cc
View File

@ -12,6 +12,8 @@
#include "jsondatamgr.h"
#include "cs_proto.pb.h"
#include "cs_msgid.pb.h"
#include "ss_proto.pb.h"
#include "ss_msgid.pb.h"
#include "handlermgr.h"
class GCClientSession: public a8::MixedSession
@ -137,6 +139,12 @@ void GGListener::ForceCloseClient(int sockhandle)
tcp_listener_->ForceCloseClient(sockhandle);
}
void GGListener::ForceCloseChildSocket(int sockhandle)
{
ss::SS_ForceCloseSocket msg;
SendProxyMsg(sockhandle, msg);
}
void GGListener::MarkClient(int sockhandle, bool is_active)
{
tcp_listener_->MarkClient(sockhandle, is_active);

1
server/gameserver/GGListener.h
View File

@ -39,6 +39,7 @@ public:
const char* file = nullptr, int lineno = 0, int error_param = 0);
void ForceCloseClient(int sockhandle);
void ForceCloseChildSocket(int sockhandle);
void MarkClient(int sockhandle, bool is_active);
long long GetSendNodeNum();
long long GetSentNodeNum();

25
server/gameserver/roommgr.cc
View File

@ -51,7 +51,30 @@ void RoomMgr::_CMJoin(f8::MsgHdr& hdr, const cs::CMJoin& msg)
abort();
}
if (RoomNum() >= ROOM_NUM_LIMIT) {
return;
{
cs::SMJoinedNotify notifymsg;
notifymsg.set_error_code(2);
GGListener::Instance()->SendToClient(hdr.socket_handle, hdr.seqid, notifymsg);
}
{
a8::Timer::Instance()->AddDeadLineTimer(1000 * 2,
a8::XParams()
.SetSender(hdr.socket_handle),
[] (const a8::XParams& param)
{
GGListener::Instance()->ForceCloseChildSocket(param.sender);
});
}
a8::UdpLog::Instance()->Warning("room is full! accountid:%s max_mainloop_rundelay:%d "
"room_num:%d player_num:%d online_num:%d",
{
msg.account_id(),
App::Instance()->perf.max_run_delay_time,
RoomMgr::Instance()->RoomNum(),
App::Instance()->perf.entity_num[ET_Player],
PlayerMgr::Instance()->OnlineNum(),
});
return;
}
Room* room = GetJoinableRoom(msg.account_id());
if (!room) {