Home
last modified time | relevance | path

Searched refs:pPendingAcks (Results 1 – 4 of 4) sorted by relevance

/CoreMQTT-Agent-v1.1.0/test/unit-test/
HDmqtt_agent_utest.c559 mqttAgentContext.pPendingAcks[ 0 ].packetId = 1U; in test_MQTTAgent_ResumeSession_session_present_no_publish_found()
560 mqttAgentContext.pPendingAcks[ 0 ].pOriginalCommand = &command; in test_MQTTAgent_ResumeSession_session_present_no_publish_found()
590 mqttAgentContext.pPendingAcks[ 0 ].packetId = pubPacketId; in test_MQTTAgent_ResumeSession_session_present_clear_pending_subscribe_unsubscribe()
591 mqttAgentContext.pPendingAcks[ 0 ].pOriginalCommand = &publishCommand; in test_MQTTAgent_ResumeSession_session_present_clear_pending_subscribe_unsubscribe()
592 mqttAgentContext.pPendingAcks[ 1 ].packetId = pubPacketId + 1; 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()
594 mqttAgentContext.pPendingAcks[ MQTT_AGENT_MAX_OUTSTANDING_ACKS - 1 ].packetId = pubPacketId + 2; 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()
609 TEST_ASSERT_EQUAL( MQTT_PACKET_ID_INVALID, mqttAgentContext.pPendingAcks[ 1 ].packetId ); 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()
[all …]
/CoreMQTT-Agent-v1.1.0/test/cbmc/sources/
HDmqtt_agent_cbmc_state.c185 pContext->pPendingAcks[ i ].packetId = packetId; in addPendingAcks()
200 pContext->pPendingAcks[ i ].pOriginalCommand = pCommand; in addPendingAcks()
/CoreMQTT-Agent-v1.1.0/source/
HDcore_mqtt_agent.c289 pendingAcks = pAgentContext->pPendingAcks; in isSpaceInPendingAckList()
319 pendingAcks = pAgentContext->pPendingAcks; in addAwaitingOperation()
388 if( pAgentContext->pPendingAcks[ i ].packetId == incomingPacketId ) in getAwaitingOperation()
390 pFoundAck = &( pAgentContext->pPendingAcks[ i ] ); in getAwaitingOperation()
846 pendingAcks = pMqttAgentContext->pPendingAcks; in clearPendingAcknowledgments()
1110 pendingAcks = pMqttAgentContext->pPendingAcks; in MQTTAgent_CancelAll()
/CoreMQTT-Agent-v1.1.0/source/include/
HDcore_mqtt_agent.h188 …MQTTAgentAckInfo_t pPendingAcks[ MQTT_AGENT_MAX_OUTSTANDING_ACKS ]; /**< List of pending acknowled… member