server_common/f8
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-28 19:52:38 +08:00
parent c866e95bdf
commit ca263c4fa5
2 changed files with 64 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

96
cpp/tglog.cc
View File

@ -97,45 +97,22 @@ namespace f8
void TGLog::AddTrackLog(int game_id, const std::string& accountid, unsigned long ip_saddr, void TGLog::AddTrackLog(int game_id, const std::string& accountid, unsigned long ip_saddr,
int logclass1, int logclass2, a8::XObject* prop) int logclass1, int logclass2, a8::XObject* prop)
{ {
std::string logtime_str; std::string event_name = a8::Format("event_%d_%d", {logclass1, logclass2});
{ InternalAddTrackLog(game_id,
time_t nowtime = time(nullptr); accountid,
struct tm tm_time = {0}; ip_saddr,
localtime_r(&nowtime, &tm_time); event_name,
prop);
}
char buff[256]; void TGLog::AddTrackLog(int game_id, const std::string& accountid, unsigned long ip_saddr,
strftime(buff, a8::ArraySize(buff), "%F %T", &tm_time); const std::string& event_name, a8::XObject* prop)
logtime_str.append((char*)buff);
}
a8::MutableXObject* xobj = a8::MutableXObject::NewObject();
xobj->SetVal("#account_id", accountid);
xobj->SetVal("#type", "track");
xobj->SetVal("#time", logtime_str);
xobj->SetVal("#ip", a8::GetIpAddress(ip_saddr));
xobj->SetVal("#event_name", a8::Format("event_%d_%d", {logclass1, logclass2}));
xobj->SetVal("properties", *prop);
{ {
TGLogMsgNode *p = new TGLogMsgNode(); InternalAddTrackLog(game_id,
p->game_id = game_id; accountid,
xobj->ToJsonStr(p->jsonstr); ip_saddr,
impl_->msg_mutex.lock(); event_name,
if (impl_->bot_node) { prop);
impl_->bot_node->next = p;
impl_->bot_node = p;
} else {
impl_->top_node = p;
impl_->bot_node = p;
}
impl_->msg_mutex.unlock();
{
std::unique_lock<std::mutex> lk(*impl_->save_cond_mutex);
impl_->save_cond->notify_all();
}
}
delete xobj;
xobj = nullptr;
} }
void TGLog::SaveToFileThreadProc() void TGLog::SaveToFileThreadProc()
@ -202,4 +179,49 @@ namespace f8
} }
} }
void TGLog::InternalAddTrackLog(int game_id, const std::string& accountid, unsigned long ip_saddr,
const std::string& event_name, a8::XObject* prop)
{
std::string logtime_str;
{
time_t nowtime = time(nullptr);
struct tm tm_time = {0};
localtime_r(&nowtime, &tm_time);
char buff[256];
strftime(buff, a8::ArraySize(buff), "%F %T", &tm_time);
logtime_str.append((char*)buff);
}
a8::MutableXObject* xobj = a8::MutableXObject::NewObject();
xobj->SetVal("#account_id", accountid);
xobj->SetVal("#type", "track");
xobj->SetVal("#time", logtime_str);
xobj->SetVal("#ip", a8::GetIpAddress(ip_saddr));
xobj->SetVal("#event_name", event_name);
xobj->SetVal("properties", *prop);
{
TGLogMsgNode *p = new TGLogMsgNode();
p->game_id = game_id;
xobj->ToJsonStr(p->jsonstr);
impl_->msg_mutex.lock();
if (impl_->bot_node) {
impl_->bot_node->next = p;
impl_->bot_node = p;
} else {
impl_->top_node = p;
impl_->bot_node = p;
}
impl_->msg_mutex.unlock();
{
std::unique_lock<std::mutex> lk(*impl_->save_cond_mutex);
impl_->save_cond->notify_all();
}
}
delete xobj;
xobj = nullptr;
}
} }

4
cpp/tglog.h
View File

@ -16,9 +16,13 @@ namespace f8
void SetProjectInfo(const std::string& project_name, bool is_poly_log); void SetProjectInfo(const std::string& project_name, bool is_poly_log);
void AddTrackLog(int game_id, const std::string& accountid, unsigned long ip_saddr, void AddTrackLog(int game_id, const std::string& accountid, unsigned long ip_saddr,
int logclass1, int logclass2, a8::XObject* prop); int logclass1, int logclass2, a8::XObject* prop);
void AddTrackLog(int game_id, const std::string& accountid, unsigned long ip_saddr,
const std::string& event_name, a8::XObject* prop);
private: private:
void SaveToFileThreadProc(); void SaveToFileThreadProc();
void InternalAddTrackLog(int game_id, const std::string& accountid, unsigned long ip_saddr,
const std::string& event_name, a8::XObject* prop);
private: private:
std::string project_name_; std::string project_name_;