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

1

Browse Source
This commit is contained in:
aozhiwei 2020-09-16 17:08:09 +08:00
parent 268b19d7c2
commit 3ecb0e6423
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
server/imserver/guildmgr.cc
View File

@ -104,7 +104,7 @@ void GuildMgr::_SS_IM_ForwardGuildCMMsg(f8::MsgHdr& hdr, const ss::SS_IM_Forward
cs::CMGuildInfo cmmsg; cs::CMGuildInfo cmmsg;
cmmsg.ParseFromArray(msg.payload().data(), msg.payload().size()); cmmsg.ParseFromArray(msg.payload().data(), msg.payload().size());
CMGuildInfoTask* task = new CMGuildInfoTask; CMGuildInfoTask* task = new CMGuildInfoTask;
AddAsyncTask(cmmsg.guild_id(), task); CreateAsyncTask(hdr.socket_handle, cmmsg.guild_id(), task);
} }
break; break;
case cs::CMMessageId_e::_CMGuildCreate: case cs::CMMessageId_e::_CMGuildCreate:
@ -119,7 +119,7 @@ void GuildMgr::_SS_IM_ForwardGuildCMMsg(f8::MsgHdr& hdr, const ss::SS_IM_Forward
cs::CMGuildJoin cmmsg; cs::CMGuildJoin cmmsg;
cmmsg.ParseFromArray(msg.payload().data(), msg.payload().size()); cmmsg.ParseFromArray(msg.payload().data(), msg.payload().size());
CMGuildJoinTask* task = new CMGuildJoinTask; CMGuildJoinTask* task = new CMGuildJoinTask;
//AddAsyncTask(cmmsg.guild_id(), task); CreateAsyncTask(hdr.socket_handle, cmmsg.guild_id(), task);
} }
break; break;
case cs::CMMessageId_e::_CMGuildAgree: case cs::CMMessageId_e::_CMGuildAgree:
@ -208,7 +208,7 @@ void GuildMgr::_CMGuildRank(int socket_handle, const ss::MFIMMsgConext& context,
} }
void GuildMgr::AddAsyncTask(long long guild_id, AsyncGuildTask* task) void GuildMgr::CreateAsyncTask(int socket_handle, long long guild_id, AsyncGuildTask* task)
{ {
Guild* guild = GetGuild(guild_id); Guild* guild = GetGuild(guild_id);
if (guild) { if (guild) {

2
server/imserver/guildmgr.h
View File

@ -35,7 +35,7 @@ class GuildMgr : public a8::Singleton<GuildMgr>
void _CMGuildSearch(int socket_handle, const ss::MFIMMsgConext& context, const cs::CMGuildSearch& msg); void _CMGuildSearch(int socket_handle, const ss::MFIMMsgConext& context, const cs::CMGuildSearch& msg);
void _CMGuildRank(int socket_handle, const ss::MFIMMsgConext& context, const cs::CMGuildRank& msg); void _CMGuildRank(int socket_handle, const ss::MFIMMsgConext& context, const cs::CMGuildRank& msg);
void AddAsyncTask(long long guild_id, AsyncGuildTask* task); void CreateAsyncTask(int socket_handle, long long guild_id, AsyncGuildTask* task);
void LoadGuild(long long guild_id); void LoadGuild(long long guild_id);
bool IsValidGuildId(long long guild_id); bool IsValidGuildId(long long guild_id);
Guild* GetGuild(long long group_id); Guild* GetGuild(long long group_id);