Searched refs:m_msgQueue (Results 1 – 4 of 4) sorted by relevance
| /ohos5.0/foundation/multimedia/av_codec/services/engine/codec/video/hcodec/ |
| H A D | msg_handle_loop.cpp | 54 if (m_msgQueue.find(msgProcessTime) != m_msgQueue.end()) { in SendAsyncMsg()
58 m_msgQueue[msgProcessTime] = MsgInfo {type, ASYNC_MSG_ID, msg}; in SendAsyncMsg()
68 if (m_msgQueue.find(time) != m_msgQueue.end()) { in SendSyncMsg()
72 m_msgQueue[time] = MsgInfo {type, id, msg}; in SendSyncMsg()
122 return m_threadNeedStop || !m_msgQueue.empty(); in MainLoop()
125 LOGI("stopped, remain %zu msg unprocessed", m_msgQueue.size()); in MainLoop()
128 TimeUs processUs = m_msgQueue.begin()->first; in MainLoop()
134 info = m_msgQueue.begin()->second; in MainLoop()
135 m_msgQueue.erase(m_msgQueue.begin()); in MainLoop()
|
| H A D | msg_handle_loop.h | 59 std::map<TimeUs, MsgInfo> m_msgQueue; // msg will be sorted by timeUs variable
|
| /ohos5.0/foundation/multimedia/image_framework/plugins/common/libs/image/libextplugin/src/hardware/imagecodec/ |
| H A D | msg_handle_loop.cpp | 55 if (m_msgQueue.find(msgProcessTime) != m_msgQueue.end()) { in SendAsyncMsg()
59 m_msgQueue[msgProcessTime] = MsgInfo {type, ASYNC_MSG_ID, msg}; in SendAsyncMsg()
69 if (m_msgQueue.find(time) != m_msgQueue.end()) { in SendSyncMsg()
73 m_msgQueue[time] = MsgInfo {type, id, msg}; in SendSyncMsg()
124 return m_threadNeedStop || !m_msgQueue.empty(); in MainLoop()
127 LOGD("stopped, remain %{public}zu msg unprocessed", m_msgQueue.size()); in MainLoop()
130 TimeUs processUs = m_msgQueue.begin()->first; in MainLoop()
136 info = m_msgQueue.begin()->second; in MainLoop()
137 m_msgQueue.erase(m_msgQueue.begin()); in MainLoop()
|
| /ohos5.0/foundation/multimedia/image_framework/plugins/common/libs/image/libextplugin/include/hardware/imagecodec/ |
| H A D | msg_handle_loop.h | 58 std::map<TimeUs, MsgInfo> m_msgQueue; // msg will be sorted by timeUs variable
|