This commit is contained in:
aozhiwei 2020-09-24 16:35:40 +08:00
parent e1cef90c35
commit 182666a71e
2 changed files with 8 additions and 3 deletions

View File

@ -107,11 +107,13 @@ void Guild::Deserialize(const std::string& guild_data, const std::string& guild_
void Guild::_CMGuildInfo(f8::MsgHdr& hdr, const cs::CMGuildInfo& msg) void Guild::_CMGuildInfo(f8::MsgHdr& hdr, const cs::CMGuildInfo& msg)
{ {
ss::SS_IM_ForwardGuildCMMsg *forward_msg = (ss::SS_IM_ForwardGuildCMMsg*)hdr.user_data;
cs::SMGuildInfo respmsg; cs::SMGuildInfo respmsg;
FillGuildBasic(respmsg.mutable_info()); FillGuildBasic(respmsg.mutable_info());
#if 0 GuildMgr::Instance()->ForwardGuildSMMsg(hdr.socket_handle,
GuildMgr::Instance()->ForwardGuildSMMsg(socket_handle, context, respmsg); forward_msg->context(),
#endif respmsg);
} }
void Guild::_CMGuildJoin(f8::MsgHdr& hdr, const cs::CMGuildJoin& msg) void Guild::_CMGuildJoin(f8::MsgHdr& hdr, const cs::CMGuildJoin& msg)

View File

@ -82,6 +82,9 @@ void GuildMgr::_SS_IM_ForwardGuildCMMsg(f8::MsgHdr& hdr, const ss::SS_IM_Forward
ForwardGuildSMMsg(hdr.socket_handle, msg.context(), msg.msgid(), respmsg); ForwardGuildSMMsg(hdr.socket_handle, msg.context(), msg.msgid(), respmsg);
return; return;
} }
AsyncGuildTask *task = new AsyncGuildTask();
task->forward_msg = msg;
CreateAsyncTask(hdr.socket_handle, msg.guild_id(), task);
} }
void GuildMgr::CreateAsyncTask(int socket_handle, long long guild_id, AsyncGuildTask* task) void GuildMgr::CreateAsyncTask(int socket_handle, long long guild_id, AsyncGuildTask* task)