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-06-18 20:18:43 +08:00
parent 0913f39bd4
commit 69e366b9b0
4 changed files with 11 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
server/imserver/app.cc
View File

@ -641,3 +641,8 @@ long long App::NewUUID()
{
return uuid.Generate();
}
long long App::NewSeqId()
{
return ++seq_id_;
}

2
server/imserver/app.h
View File

@ -33,6 +33,7 @@ class App : public a8::Singleton<App>
a8::XParams* GetContext(long long context_id);
bool HasFlag(int flag);
long long NewUUID();
long long NewSeqId();
private:
void QuickExecute();
@ -69,6 +70,7 @@ public:
bool servicing = true;
private:
long long seq_id_ = 1000;
std::mutex *loop_mutex_ = nullptr;
std::condition_variable *loop_cond_ = nullptr;

17
server/imserver/player.cc
View File

@ -450,21 +450,10 @@ void Player::FillFriendList(::google::protobuf::RepeatedPtrField< ::cs::MFUserIn
}
}
void Player::FillIMMsgConext(f8::MsgHdr& hdr, ss::MFIMMsgConext* conext)
void Player::FillIMMsgConext(f8::MsgHdr& hdr, ss::MFIMMsgConext* context)
{
#if 0
conext->set_socket_handle(hdr.socket_handle);
conext->set_account_id(myself.base_data.account_id);
conext->set_nickname(myself.base_data.nickname);
conext->set_avatar_url(myself.base_data.avatar_url);
conext->set_sex(myself.base_data.sex);
#if 1
conext->set_online(true);
#else
conext->set_online(online);
#endif
conext->set_msgid(hdr.msgid);
#endif
FillMFUserInfo(context->mutable_user_info());
context->set_seqid(App::Instance()->NewSeqId());
}
void Player::ForwardGroupCMMsg(f8::MsgHdr& hdr, long long hash_code)

2
server/imserver/player.h
View File

@ -98,7 +98,7 @@ class Player
private:
void FillFriendList(::google::protobuf::RepeatedPtrField< ::cs::MFUserInfo >* friend_list);
void FillIMMsgConext(f8::MsgHdr& hdr, ss::MFIMMsgConext* conext);
void FillIMMsgConext(f8::MsgHdr& hdr, ss::MFIMMsgConext* context);
void FillMFUserInfo(cs::MFUserInfo* user_info);
void ForwardGroupCMMsg(f8::MsgHdr& hdr, long long hash_code);
void SaveToDB();