MCPcopy Create free account
hub / github.com/Tencent/mars / DumpMessage

Function DumpMessage

mars/comm/messagequeue/message_queue.cc:165–175  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

163
164
165static std::string DumpMessage(const std::list<MessageWrapper*>& _message_lst) {
166 XMessage xmsg;
167 xmsg(TSF"**************Dump MQ Message**************size:%_\n", _message_lst.size());
168 int index = 0;
169 for (auto msg : _message_lst) {
170 xmsg(TSF"postid:%_, timing:%_, record_time:%_, message:%_\n", msg->postid.ToString(), msg->timing.ToString(), msg->record_time, msg->message.ToString());
171 if (++index>50)
172 break;
173 }
174 return xmsg.String();
175}
176std::string DumpMQ(const MessageQueue_t& _msq_queue_id) {
177 ScopedLock lock(sg_messagequeue_map_mutex);
178 const MessageQueue_t& id = _msq_queue_id;

Callers 5

DumpMQFunction · 0.85
PostMessageFunction · 0.85
SingletonMessageFunction · 0.85
BroadcastMessageFunction · 0.85
FasterMessageFunction · 0.85

Calls 2

sizeMethod · 0.45
ToStringMethod · 0.45

Tested by

no test coverage detected