Searched refs:pOriginalCommand (Results 1 – 4 of 4) sorted by relevance
560 mqttAgentContext.pPendingAcks[ 0 ].pOriginalCommand = &command; in test_MQTTAgent_ResumeSession_session_present_no_publish_found()591 mqttAgentContext.pPendingAcks[ 0 ].pOriginalCommand = &publishCommand; in test_MQTTAgent_ResumeSession_session_present_clear_pending_subscribe_unsubscribe()593 mqttAgentContext.pPendingAcks[ 1 ].pOriginalCommand = &subscribeCommand; in test_MQTTAgent_ResumeSession_session_present_clear_pending_subscribe_unsubscribe()595 mqttAgentContext.pPendingAcks[ MQTT_AGENT_MAX_OUTSTANDING_ACKS - 1 ].pOriginalCommand = in test_MQTTAgent_ResumeSession_session_present_clear_pending_subscribe_unsubscribe()610 TEST_ASSERT_EQUAL_PTR( NULL, mqttAgentContext.pPendingAcks[ 1 ].pOriginalCommand ); in test_MQTTAgent_ResumeSession_session_present_clear_pending_subscribe_unsubscribe()614 … pPendingAcks[ MQTT_AGENT_MAX_OUTSTANDING_ACKS - 1 ].pOriginalCommand ); in test_MQTTAgent_ResumeSession_session_present_clear_pending_subscribe_unsubscribe()618 TEST_ASSERT_EQUAL_PTR( &publishCommand, mqttAgentContext.pPendingAcks[ 0 ].pOriginalCommand ); in test_MQTTAgent_ResumeSession_session_present_clear_pending_subscribe_unsubscribe()633 mqttAgentContext.pPendingAcks[ 0 ].pOriginalCommand = &command; in test_MQTTAgent_ResumeSession_failed_publish()655 ackInfo.pOriginalCommand = &command; in test_MQTTAgent_ResumeSession_publish_resend_success()677 mqttAgentContext.pPendingAcks[ 1 ].pOriginalCommand = &command; in test_MQTTAgent_ResumeSession_no_session_present()[all …]
359 pendingAcks[ unusedPos ].pOriginalCommand = pCommand; in addAwaitingOperation()399 else if( ( pFoundAck->pOriginalCommand == NULL ) || ( pFoundAck->packetId == 0U ) ) in getAwaitingOperation()403 ( void * ) pFoundAck->pOriginalCommand ) ); in getAwaitingOperation()606 assert( pAckInfo->pOriginalCommand != NULL ); in handleAcks()612 pAckInfo->pOriginalCommand, in handleAcks()817 pOriginalPublish = ( MQTTPublishInfo_t * ) ( pFoundAck->pOriginalCommand->pArgs ); in resendPublishes()823 … concludeCommand( pMqttAgentContext, pFoundAck->pOriginalCommand, statusResult, NULL ); in resendPublishes()855 assert( pendingAcks[ i ].pOriginalCommand != NULL ); in clearPendingAcknowledgments()858 ( pendingAcks[ i ].pOriginalCommand->commandType != SUBSCRIBE ) && in clearPendingAcknowledgments()859 ( pendingAcks[ i ].pOriginalCommand->commandType != UNSUBSCRIBE ) ) in clearPendingAcknowledgments()[all …]
157 MQTTAgentCommand_t * pOriginalCommand; /**< Command expecting acknowledgment. */ member
200 pContext->pPendingAcks[ i ].pOriginalCommand = pCommand; in addPendingAcks()
