Home
last modified time | relevance | path

Searched refs:IncomingMsgQueueSize (Results 1 – 25 of 33) sorted by relevance

12

/external/opencore/nodes/pvloopbacknode/src/
Dpvmf_loopback_ioport.cpp145 if (aActivity.iPort->IncomingMsgQueueSize() == 1) in HandlePortActivity()
204 && IncomingMsgQueueSize() > 0) in Run()
212 && IncomingMsgQueueSize() > 0) in Run()
Dpvmf_loopback_node.cpp366 if (iIOPort->IncomingMsgQueueSize() > 0 in Run()
/external/opencore/nodes/pvmediaoutputnode/src/
Dpv_media_output_node_inport.cpp871 if (IncomingMsgQueueSize() > 0) in statusUpdate()
1654 while ((IncomingMsgQueueSize() > 0) || (iCurrentMediaMsg.GetRep() != NULL)) in Run()
1682 IncomingMsgQueueSize())); in Run()
1688 IncomingMsgQueueSize())); in Run()
1745 IncomingMsgQueueSize())); in Run()
1753 IncomingMsgQueueSize())); in Run()
1762 IncomingMsgQueueSize())); in Run()
1824 if (IncomingMsgQueueSize() > 0) in HandlePortActivity()
1856 IncomingMsgQueueSize())); in HandlePortActivity()
1862 IncomingMsgQueueSize())); in HandlePortActivity()
[all …]
/external/opencore/nodes/pvmp4ffcomposernode/src/
Dpvmp4ffcn_port.cpp437 if (IncomingMsgQueueSize() > 0) in ProcessIncomingMsgReady()
474 if (IncomingMsgQueueSize() == 1) in HandlePortActivity()
511 if (!iEndOfDataReached && (IncomingMsgQueueSize() > 0)) in Run()
532 if (IncomingMsgQueueSize() > 0 && iNode->IsProcessIncomingMsgReady()) in Run()
550 if (IncomingMsgQueueSize() == 0 && OutgoingMsgQueueSize() == 0) in Run()
/external/opencore/nodes/pvprotocolenginenode/base/src/
Dpvmf_protocol_engine_node.cpp1308 …aActivity.iPort, aActivity.iType, aActivity.iPort->IncomingMsgQueueSize(), aActivity.iPort->Outgoi… in HandlePortActivity()
1386 if ((aActivity.iPort->IncomingMsgQueueSize() == 1) || in HandlePortActivity()
1445 …activity.iPort, activity.iType, activity.iPort->IncomingMsgQueueSize(), activity.iPort->OutgoingMs… in ProcessPortActivity()
1506 if (aStatus != PVMFErrBusy && aActivity.iPort->IncomingMsgQueueSize() > 0) in QueueActivityIncomingMessage()
1524 aPort, aPort->IncomingMsgQueueSize(), iProcessingState)); in ProcessIncomingMsg()
1529 if (aPort->IncomingMsgQueueSize() == 0) return PVMFSuccess; in ProcessIncomingMsg()
1719 … aMsg->getSeqNum(), dataSize, aPort, aPort->IncomingMsgQueueSize(), iInterfaceState)); in LogIncomingMessage()
1848 if (iPortInForData->IncomingMsgQueueSize() > 0) in ProcessOutgoingQueueReady()
1934 if (iPortVector[i]->IncomingMsgQueueSize() > 0 in HandleRunFlush()
2096 if (iPortInForData->IncomingMsgQueueSize() > 0) in OutputBufferAvailable()
[all …]
/external/opencore/pvmi/pvmf/include/
Dpvmf_port_interface.h204 virtual uint32 IncomingMsgQueueSize() = 0;
Dpvmf_port_base_impl.h161 OSCL_IMPORT_REF virtual uint32 IncomingMsgQueueSize();
/external/opencore/protocols/systems/tools/general/common/src/
Dpvmf_buffer_data_sink.cpp38 while (IncomingMsgQueueSize()) in HandlePortActivity()
/external/opencore/nodes/pvprotocolenginenode/protocol_common/src/
Dpvmf_protocol_engine_node_common.cpp243 if (iPortInForData->IncomingMsgQueueSize() == 0) return; in checkEOSMsgFromInputPort()
246 while (iPortInForData->IncomingMsgQueueSize() > 0) in checkEOSMsgFromInputPort()
402 if (iPortInForData->IncomingMsgQueueSize() > 0) return true; in ignoreThisTimeout()
/external/opencore/nodes/streaming/jitterbuffernode/src/
Dpvmf_jitter_buffer_node.cpp1594 if (iPortVector[i]->IncomingMsgQueueSize() > 0 || in Run()
1666 … aPortParams->iProcessIncomingMessages, aPortParams->irPort.IncomingMsgQueueSize())); in ProcessPortActivity()
1668 (aPortParams->irPort.IncomingMsgQueueSize() > 0)) in ProcessPortActivity()
1683 … aPortParams->iProcessIncomingMessages, aPortParams->irPort.IncomingMsgQueueSize())); in ProcessPortActivity()
1686 (aPortParams->irPort.IncomingMsgQueueSize() > 0)) in ProcessPortActivity()
2011 if (portContainerPtr->irPort.IncomingMsgQueueSize() > 0) in CheckForPortRescheduling()
2054 if (portContainerPtr->irPort.IncomingMsgQueueSize() > 0) in CheckForPortRescheduling()
2098 if ((portContainerPtr->irPort.IncomingMsgQueueSize() > 0) || in CheckForPortActivityQueues()
/external/opencore/nodes/pvcommsionode/src/
Dpv_comms_io_node_port.cpp703 if (IncomingMsgQueueSize() == 0 && OutgoingMsgQueueSize() == 0 in Run()
1078 while (IncomingMsgQueueSize()) in CopyBuffer()
/external/opencore/nodes/pvvideoparsernode/src/
Dpvmf_videoparser_node.cpp941 if (aActivity.iPort->IncomingMsgQueueSize() == 1) in HandlePortActivity()
1004 && activity.iPort->IncomingMsgQueueSize() > 0) in ProcessPortActivity()
/external/opencore/nodes/pvclientserversocketnode/src/
Dpvmf_clientserver_socket_node.cpp855 && iPVMFPort->IncomingMsgQueueSize() > 0) in DoFlush()
1387 && iSockConfig->iPVMFPort && iSockConfig->iPVMFPort->IncomingMsgQueueSize() > 0 in CanProcessIncomingMsg()
2000 if (iPVMFPort->IncomingMsgQueueSize() > 0) in SequenceComplete()
/external/opencore/nodes/streaming/medialayernode/src/
Dpvmf_medialayer_node.cpp1563 …able: Mime=%s, QSize =%d", portContainerPtr->iMimeType.get_cstr(), aPort->IncomingMsgQueueSize())); in freechunkavailable()
1938 if (status == PVMFSuccess && aPortContainer->iPort->IncomingMsgQueueSize() > 0) in ProcessPortActivity()
2746 if (portContainerPtr->iPort->IncomingMsgQueueSize() > 0) in CheckForPortRescheduling()
2814 if ((portContainerPtr->iPort->IncomingMsgQueueSize() > 0) || in CheckForPortActivityQueues()
2941 if (iPortVector[i]->IncomingMsgQueueSize() > 0 || in Run()
/external/opencore/nodes/pvdummyoutputnode/src/
Dpvmf_dummy_fileoutput_node.cpp626 if (aActivity.iPort->IncomingMsgQueueSize() == 1) in HandlePortActivity()
858 if (activity.iPort->IncomingMsgQueueSize() > 0) in ProcessPortActivity()
Dpvmf_dummy_fileoutput_inport.cpp131 if (IncomingMsgQueueSize() > 0) in SkipMediaData()
/external/opencore/nodes/pvomxbasedecnode/src/
Dpvmf_omx_basedec_node.cpp651 … && (!iInputCommands.empty() || (iInPort && (iInPort->IncomingMsgQueueSize() > 0)) || in Run()
706 if (iInPort && (iInPort->IncomingMsgQueueSize() > 0) && (iDataIn.GetRep() == NULL) && in Run()
766 …(((iInPort->IncomingMsgQueueSize() > 0) || (iDataIn.GetRep() != NULL)) && (iNumOutstandingInputBuf… in Run()
866 (iInPort->IncomingMsgQueueSize() == 0) && in Run()
873 OSCL_ASSERT(iInPort->IncomingMsgQueueSize() == 0 && iOutPort->OutgoingMsgQueueSize() == 0); in Run()
5274 …%s::PortActivity: IncomingMsgQueueSize=%d", iName.Str(), aActivity.iPort->IncomingMsgQueueSize())); in HandlePortActivity()
5275 if (aActivity.iPort->IncomingMsgQueueSize() == 1) in HandlePortActivity()
/external/opencore/nodes/pvdummyinputnode/src/
Dpvmf_dummy_fileinput_node.cpp1189 while (iPortVector[0]->IncomingMsgQueueSize() > 0) in Run()
1217 if (iPortVector[0]->IncomingMsgQueueSize() > 0 in Run()
/external/opencore/nodes/pvfileoutputnode/src/
Dpvmf_fileoutput_node.cpp710 if (aActivity.iPort->IncomingMsgQueueSize() == 1) in HandlePortActivity()
1190 if (activity.iPort->IncomingMsgQueueSize() > 0) in ProcessPortActivity()
Dpvmf_fileoutput_inport.cpp131 if (IncomingMsgQueueSize() > 0) in SkipMediaData()
/external/opencore/nodes/pvmediainputnode/src/
Dpvmf_media_input_node_outport.cpp691 if (IncomingMsgQueueSize() == 0 && OutgoingMsgQueueSize() == 0) in Run()
/external/opencore/pvmi/pvmf/src/
Dpvmf_port_base_impl.cpp922 OSCL_EXPORT_REF uint32 PvmfPortBaseImpl::IncomingMsgQueueSize() in IncomingMsgQueueSize() function in PvmfPortBaseImpl
/external/opencore/protocols/systems/3g-324m_pvterminal/h223/src/
Dlowerlayer.cpp829 while (IncomingMsgQueueSize()) in HandlePortActivity()
/external/opencore/nodes/pvomxencnode/src/
Dpvmf_omx_enc_node.cpp962 … && (!iInputCommands.empty() || (iInPort && (iInPort->IncomingMsgQueueSize() > 0)) || in Run()
1013 …if (iInPort && (iInPort->IncomingMsgQueueSize() > 0) && (iDataIn.GetRep() == NULL) && !iEndOfDataR… in Run()
1054 …(((iInPort->IncomingMsgQueueSize() > 0) || (iDataIn.GetRep() != NULL)) && (iNumOutstandingInputBuf… in Run()
1155 (iInPort->IncomingMsgQueueSize() == 0) && in Run()
1167 OSCL_ASSERT(iInPort->IncomingMsgQueueSize() == 0 && iOutPort->OutgoingMsgQueueSize() == 0); in Run()
7766 …%s::PortActivity: IncomingMsgQueueSize=%d", iNodeTypeId, aActivity.iPort->IncomingMsgQueueSize())); in HandlePortActivity()
7767 if (aActivity.iPort->IncomingMsgQueueSize() == 1) in HandlePortActivity()
/external/opencore/nodes/pvsocketnode/src/
Dpvmf_socket_node.cpp888 && aSockConfig.iPVMFPort && aSockConfig.iPVMFPort->IncomingMsgQueueSize() > 0 in CanProcessIncomingMsg()
2846 if (iPortVector[i]->IncomingMsgQueueSize() > 0) in SequenceComplete()
3743 && iPortVector[i]->IncomingMsgQueueSize() > 0) in DoFlush()

12