Searched refs:iQ (Results 1 – 11 of 11) sorted by relevance
| /external/opencore/pvmi/pvmf/src/ |
| D | pvmf_port_base_impl.cpp | 44 iQ.reserve(aReserve); in Construct()
64 iQ.reserve(aReserve); in SetReserve()
108 LogMediaMsgInfo(iOutgoingQueue.iQ.back(), "Out Msg Q'd", iOutgoingQueue); in PortActivity()
112 LogMediaMsgInfo(iIncomingQueue.iQ.back(), "In Msg Received ", iIncomingQueue); in PortActivity()
117 , iOutgoingQueue.iQ.size() in PortActivity()
122 , iOutgoingQueue.iQ.size() in PortActivity()
127 , iOutgoingQueue.iQ.size() in PortActivity()
132 , iOutgoingQueue.iQ.size() in PortActivity()
217 while (!iIncomingQueue.iQ.empty()) in ~PvmfPortBaseImpl()
219 PVMFSharedMediaMsgPtr msg = iIncomingQueue.iQ.front(); in ~PvmfPortBaseImpl()
[all …]
|
| /external/opencore/nodes/pvprotocolenginenode/base/src/ |
| D | pvmf_protocol_engine_port.cpp | 106 if (iOutgoingQueue.iQ.empty()) in PeekOutgoingMsg()
114 aMsg = iOutgoingQueue.iQ.front(); in PeekOutgoingMsg()
|
| /external/opencore/nodes/pvcommsionode/src/ |
| D | pv_comms_io_node_port.cpp | 771 return !iIncomingQueue.iQ.empty() in CanSendCommsData()
789 aMsg = iIncomingQueue.iQ.front(); in SendCommsData()
795 iIncomingQueue.iQ.pop(); in SendCommsData()
900 iIncomingQueue.iQ.pop(); in SendCommsData()
992 return (iIncomingQueue.iQ.size() in isIncomingFull()
1006 && iIncomingQueue.iQ.empty() in EndOfData()
1012 && iOutgoingQueue.iQ.empty()); in EndOfData()
|
| /external/opencore/nodes/pvclientserversocketnode/src/ |
| D | pvmf_clientserver_socket_port.cpp | 94 if (iIncomingQueue.iQ.empty()) in PeekIncomingMsg()
102 aMsg = iIncomingQueue.iQ.front(); in PeekIncomingMsg()
|
| /external/opencore/nodes/pvsocketnode/src/ |
| D | pvmf_socket_port.cpp | 190 if (iIncomingQueue.iQ.empty()) in PeekIncomingMsg()
198 aMsg = iIncomingQueue.iQ.front(); in PeekIncomingMsg()
|
| /external/opencore/nodes/streaming/medialayernode/src/ |
| D | pvmf_medialayer_port.cpp | 437 if (iIncomingQueue.iQ.empty()) in peekHead()
443 PVMFSharedMediaMsgPtr msg = iIncomingQueue.iQ.front(); in peekHead()
485 if (!iOutgoingQueue.iQ.empty()) in QueueOutgoingMsg()
|
| /external/opencore/nodes/pvfileoutputnode/src/ |
| D | pvmf_fileoutput_inport.cpp | 133 iLastDataTimestamp = iIncomingQueue.iQ.front()->getTimestamp(); in SkipMediaData()
142 PVMFSharedMediaMsgPtr msgPtr = iIncomingQueue.iQ.front(); in SkipMediaData()
150 iLastDataTimestamp += iIncomingQueue.iQ.front()->getDuration(); in SkipMediaData()
|
| /external/opencore/nodes/pvdummyoutputnode/src/ |
| D | pvmf_dummy_fileoutput_inport.cpp | 133 iLastDataTimestamp = iIncomingQueue.iQ.front()->getTimestamp(); in SkipMediaData()
142 PVMFSharedMediaMsgPtr msgPtr = iIncomingQueue.iQ.front(); in SkipMediaData()
150 iLastDataTimestamp += iIncomingQueue.iQ.front()->getDuration(); in SkipMediaData()
|
| /external/opencore/pvmi/pvmf/include/ |
| D | pvmf_port_base_impl.h | 71 Oscl_Queue<PVMFSharedMediaMsgPtr, OsclMemAllocator> iQ; variable
|
| /external/opencore/nodes/pvmediaoutputnode/src/ |
| D | pv_media_output_node_inport.cpp | 2468 if (iIncomingQueue.iQ.empty()) in peekHead()
2473 aMsgPtr = iIncomingQueue.iQ.front(); in peekHead()
|
| /external/opencore/protocols/rtp_payload_parser/util/output/ |
| D | pv_rtp.bin | 10996 p(� �X�q�����K�����\^3�0w;Y�����S8�!*9]�D���e�u��iQ,�
|