Lines Matching refs:agentInterface

520     queueStatus = pAgentContext->agentInterface.send(  in addCommandToQueue()
521 pAgentContext->agentInterface.pMsgCtx, in addCommandToQueue()
717 pCommand = pMqttAgentContext->agentInterface.getCommand( blockTimeMs ); in createAndAddCommand()
737 commandReleased = pMqttAgentContext->agentInterface.releaseCommand( pCommand ); in createAndAddCommand()
772 assert( pAgentContext->agentInterface.releaseCommand != NULL ); in concludeCommand()
783 commandReleased = pAgentContext->agentInterface.releaseCommand( pCommand ); in concludeCommand()
890 else if( ( pMqttAgentContext->agentInterface.send == NULL ) || in validateStruct()
891 ( pMqttAgentContext->agentInterface.recv == NULL ) || in validateStruct()
892 ( pMqttAgentContext->agentInterface.getCommand == NULL ) || in validateStruct()
893 ( pMqttAgentContext->agentInterface.releaseCommand == NULL ) || in validateStruct()
894 ( pMqttAgentContext->agentInterface.pMsgCtx == NULL ) ) in validateStruct()
987 pMqttAgentContext->agentInterface = *pMsgInterface; in MQTTAgent_Init()
1003 if( ( pMqttAgentContext == NULL ) || ( pMqttAgentContext->agentInterface.pMsgCtx == NULL ) ) in MQTTAgent_CommandLoop()
1013 ( void ) pMqttAgentContext->agentInterface.recv( in MQTTAgent_CommandLoop()
1014 pMqttAgentContext->agentInterface.pMsgCtx, in MQTTAgent_CommandLoop()
1089 if( ( pMqttAgentContext == NULL ) || ( pMqttAgentContext->agentInterface.pMsgCtx == NULL ) ) in MQTTAgent_CancelAll()
1099 commandWasReceived = pMqttAgentContext->agentInterface.recv( in MQTTAgent_CancelAll()
1100 pMqttAgentContext->agentInterface.pMsgCtx, in MQTTAgent_CancelAll()