Searched refs:iPendingCmdQueue (Results 1 – 8 of 8) sorted by relevance
| /external/opencore/nodes/pvclientserversocketnode/src/ |
| D | pvmf_clientserver_socket_node.cpp | 64 iPendingCmdQueue.Construct(PVMF_SOCKET_NODE_COMMAND_ID_START, in PVMFClientServerSocketNode()
76 iPendingCmdQueue.clear(); in PVMFClientServerSocketNode()
108 while (!iPendingCmdQueue.empty()) in ~PVMFClientServerSocketNode()
110 CommandComplete(iPendingCmdQueue, iPendingCmdQueue.front(), PVMFFailure); in ~PVMFClientServerSocketNode()
356 ProcessCommand(iPendingCmdQueue, iPendingCmdQueue.front()); in Run()
362 return (!iPendingCmdQueue.empty() in CanProcessCommand()
364 || (iPendingCmdQueue.front().hipri() && iCancelCmdQueue.empty()))); in CanProcessCommand()
615 id = iPendingCmdQueue.AddL(aCmd); in QueueCommandL()
1067 PVMFSocketNodeCommand* cmd = iPendingCmdQueue.FindById(cmdId, 1); in DoCancelCommand()
1071 CommandComplete(iPendingCmdQueue, *cmd, PVMFErrCancelled); in DoCancelCommand()
[all …]
|
| /external/opencore/protocols/systems/3g-324m_pvterminal/h324/tsc/src/ |
| D | tscmain.cpp | 120 iPendingCmdQueue.Construct(PVMF_CMD_ID_START, PVMF_CMD_QUEUE_RESERVE); in TSC_324m()
153 iPendingCmdQueue.Construct(1, 5); in initVarsLocal()
1491 iPendingCmdQueue.clear(); in Stop()
1591 iPendingCmdQueue.clear(); in Reset()
1747 iPendingCmdQueue.StoreL(cmd); in DoRequestPort()
1933 for (uint32 i = 0; i < iPendingCmdQueue.size(); i++) in FindPendingPortCmd()
1935 if ((TPVMFGenericNodeCommand)iPendingCmdQueue[i].iCmd == aCmdType) in FindPendingPortCmd()
1937 if (aPortTag == (int32)iPendingCmdQueue[i].iParam1) in FindPendingPortCmd()
1939 cmd = iPendingCmdQueue[i]; in FindPendingPortCmd()
1957 iPendingCmdQueue.Erase(&iPendingCmdQueue[cmdIndex]); in FindPendingPortCmd()
[all …]
|
| /external/opencore/nodes/pvsocketnode/src/ |
| D | pvmf_socket_node.cpp | 293 iPendingCmdQueue.Construct(PVMF_SOCKET_NODE_COMMAND_ID_START, in PVMFSocketNode()
324 iPendingCmdQueue.clear(); in PVMFSocketNode()
367 while (!iPendingCmdQueue.empty()) in ~PVMFSocketNode()
369 CommandComplete(iPendingCmdQueue, iPendingCmdQueue.front(), PVMFFailure); in ~PVMFSocketNode()
2926 return (!iPendingCmdQueue.empty() in CanProcessCommand()
2928 || (iPendingCmdQueue.front().hipri() && iCancelCmdQueue.empty()))); in CanProcessCommand()
3267 id = iPendingCmdQueue.AddL(aCmd); in QueueCommandL()
3799 PVMFSocketNodeCommand* cmd = iPendingCmdQueue.FindById(cmdId, 1); in DoCancelCommand()
3803 CommandComplete(iPendingCmdQueue, *cmd, PVMFErrCancelled); in DoCancelCommand()
3832 for (uint32 i = 1; i < iPendingCmdQueue.size(); i++) in DoCancelAllCommands()
[all …]
|
| /external/opencore/protocols/rtsp_client_engine/src/ |
| D | pvrtsp_client_engine_node.cpp | 150 …iPendingCmdQueue.Construct(PVMF_RTSP_ENGINE_NODE_COMMAND_ID_START, PVMF_RTSP_ENGINE_NODE_COMMAND_V… in PVRTSPEngineNode()
192 iPendingCmdQueue.clear(); in PVRTSPEngineNode()
1063 if (iPendingCmdQueue.size() > 0) in Run()
1065 if (ProcessCommand(iPendingCmdQueue.front())) in Run()
1076 if ((iPendingCmdQueue.size() > 0) && IsAdded()) in Run()
1283 CommandComplete(iPendingCmdQueue, aInCmd, PVMFErrNoMemory); in ProcessCommand()
1286 iPendingCmdQueue.Erase(&aInCmd); in ProcessCommand()
1627 id = iPendingCmdQueue.AddL(aCmd); in AddCmdToQueue()
5566 while (!iPendingCmdQueue.empty()) in DoCancelAllCommands()
5567 CommandComplete(iPendingCmdQueue, iPendingCmdQueue[1], PVMFErrCancelled); in DoCancelAllCommands()
|
| /external/opencore/nodes/pvclientserversocketnode/include/ |
| D | pvmf_clientserver_socket_node.h | 342 PVMFSocketNodeCmdQ iPendingCmdQueue; variable
|
| /external/opencore/protocols/systems/3g-324m_pvterminal/h324/tsc/include/ |
| D | tscmain.h | 627 Tsc324mNodeCmdQ iPendingCmdQueue; variable
|
| /external/opencore/protocols/rtsp_client_engine/inc/ |
| D | pvrtsp_client_engine_node.h | 814 PVRTSPEngineNodeCmdQ iPendingCmdQueue; variable
|
| /external/opencore/nodes/pvsocketnode/include/ |
| D | pvmf_socket_node.h | 819 PVMFSocketNodeCmdQ iPendingCmdQueue; variable
|