33 void LogCollector::InsertDropInfo(const HilogMsg &msg, int droppedCount)  in InsertDropInfo()  argument
41         dropMsg->version = msg.version;  in InsertDropInfo()
42         dropMsg->type    = msg.type;  in InsertDropInfo()
43         dropMsg->level   = msg.level;  in InsertDropInfo()
45         dropMsg->tv_sec  = msg.tv_sec;  in InsertDropInfo()
46         dropMsg->tv_nsec = msg.tv_nsec;  in InsertDropInfo()
47         dropMsg->mono_sec = msg.mono_sec;  in InsertDropInfo()
48         dropMsg->pid     = msg.pid;  in InsertDropInfo()
49         dropMsg->tid     = msg.tid;  in InsertDropInfo()
50         dropMsg->domain  = msg.domain;  in InsertDropInfo()
75     HilogMsg& msg = *(reinterpret_cast<HilogMsg *>(data.data()));  in onDataRecv()  local
76     if (dataLen != msg.len) {  in onDataRecv()
80     if (IsValidDomain(static_cast<LogType>(msg.type), msg.domain) == false) {  in onDataRecv()
84     msg.pid = cred.pid;  in onDataRecv()
90         if (msg.type != static_cast<uint16_t>(LOG_APP) && flowControl && !debug) {  in onDataRecv()
91             ret = FlowCtrlDomain(msg);  in onDataRecv()
99             InsertDropInfo(msg, ret);  in onDataRecv()
101         // If insert msg fail, return 0  in onDataRecv()
102         if (InsertLogToBuffer(msg) == 0) {  in onDataRecv()
109         if (*(msg.tag + msg.tagLen - 1) != '\0') {  in onDataRecv()
113             .level = msg.level,  in onDataRecv()
114             .type = msg.type,  in onDataRecv()
115             .len = (msg.len - sizeof(HilogMsg) - 1 - 1), // don't count '\0' of tag and content  in onDataRecv()
117             .domain = msg.domain,  in onDataRecv()
118             .pid = msg.pid,  in onDataRecv()
119             .tv_sec = msg.tv_sec,  in onDataRecv()
120             .tv_nsec = msg.tv_nsec,  in onDataRecv()
121             .mono_sec = msg.mono_sec,  in onDataRecv()
122             .tag = msg.tag  in onDataRecv()
128 size_t LogCollector::InsertLogToBuffer(const HilogMsg& msg)  in InsertLogToBuffer()  argument
131     return m_hilogBuffer.Insert(msg, isFull);  in InsertLogToBuffer()