Home
last modified time | relevance | path

Searched refs:packetId (Results 1 – 11 of 11) sorted by relevance

/CoreMQTT-Agent-v1.1.0/test/unit-test/
HDmqtt_agent_command_functions_utest.c176 TEST_ASSERT_EQUAL( 0, returnFlags.packetId ); in test_MQTTAgentCommand_ProcessLoop()
201 TEST_ASSERT_EQUAL( 0, returnFlags.packetId ); in test_MQTTAgentCommand_Publish_QoS0_success()
227 TEST_ASSERT_EQUAL( 1, returnFlags.packetId ); in test_MQTTAgentCommand_Publish_QoS1_success()
252 TEST_ASSERT_EQUAL( 0, returnFlags.packetId ); in test_MQTTAgentCommand_Publish_QoS0_failure()
278 TEST_ASSERT_EQUAL( 1, returnFlags.packetId ); in test_MQTTAgentCommand_Publish_QoS1_failure()
304 TEST_ASSERT_EQUAL( 1, returnFlags.packetId ); in test_MQTTAgentCommand_Subscribe_Success()
330 TEST_ASSERT_EQUAL( 1, returnFlags.packetId ); in test_MQTTAgentCommand_Subscribe_failure()
356 TEST_ASSERT_EQUAL( 1, returnFlags.packetId ); in test_MQTTAgentCommand_Unsubscribe()
382 TEST_ASSERT_EQUAL( 1, returnFlags.packetId ); in test_MQTTAgentCommand_Unsubscribe_failure()
402 TEST_ASSERT_EQUAL( 0, returnFlags.packetId ); in test_MQTTAgentCommand_Disconnect()
[all …]
HDmqtt_agent_utest.c223 uint16_t packetId, in stubPublishCallback() argument
227 ( void ) packetId; in stubPublishCallback()
559 mqttAgentContext.pPendingAcks[ 0 ].packetId = 1U; 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()
592 mqttAgentContext.pPendingAcks[ 1 ].packetId = pubPacketId + 1; 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()
609 TEST_ASSERT_EQUAL( MQTT_PACKET_ID_INVALID, mqttAgentContext.pPendingAcks[ 1 ].packetId ); in test_MQTTAgent_ResumeSession_session_present_clear_pending_subscribe_unsubscribe()
612 pPendingAcks[ MQTT_AGENT_MAX_OUTSTANDING_ACKS - 1 ].packetId ); in test_MQTTAgent_ResumeSession_session_present_clear_pending_subscribe_unsubscribe()
617 TEST_ASSERT_EQUAL( pubPacketId, mqttAgentContext.pPendingAcks[ 0 ].packetId ); in test_MQTTAgent_ResumeSession_session_present_clear_pending_subscribe_unsubscribe()
632 mqttAgentContext.pPendingAcks[ 0 ].packetId = 1U; in test_MQTTAgent_ResumeSession_failed_publish()
[all …]
/CoreMQTT-Agent-v1.1.0/test/cbmc/stubs/
HDincoming_publish_callback_stub.c32 uint16_t packetId, in IncomingPublishCallbackStub() argument
37 __CPROVER_assert( packetId != 0U, in IncomingPublishCallbackStub()
HDcore_mqtt_stubs.c162 uint16_t packetId ) in MQTT_Publish() argument
178 uint16_t packetId; in MQTT_PublishToResend() local
188 packetId = MQTT_PACKET_ID_INVALID; in MQTT_PublishToResend()
196 __CPROVER_assume( packetId < MAX_PACKET_ID ); in MQTT_PublishToResend()
202 return packetId; in MQTT_PublishToResend()
HDagent_command_functions_stub.c36 uint16_t packetId; in MQTTAgentCommand_Stub() local
41 __CPROVER_assume( packetId > 0U ); in MQTTAgentCommand_Stub()
43 pReturnFlags->packetId = packetId; in MQTTAgentCommand_Stub()
/CoreMQTT-Agent-v1.1.0/source/
HDcore_mqtt_agent.c67 uint16_t packetId,
296 if( pendingAcks[ i ].packetId == MQTT_PACKET_ID_INVALID ) in isSpaceInPendingAckList()
309 uint16_t packetId, in addAwaitingOperation() argument
318 assert( packetId != MQTT_PACKET_ID_INVALID ); in addAwaitingOperation()
330 ( pendingAcks[ i ].packetId == MQTT_PACKET_ID_INVALID ) ) in addAwaitingOperation()
336 if( pendingAcks[ i ].packetId == packetId ) in addAwaitingOperation()
349 "Existing entry found for same packet: PacketId=%u\n", packetId ) ); in addAwaitingOperation()
358 pendingAcks[ unusedPos ].packetId = packetId; in addAwaitingOperation()
364 "No memory available: PacketId=%u\n", packetId ) ); in addAwaitingOperation()
388 if( pAgentContext->pPendingAcks[ i ].packetId == incomingPacketId ) in getAwaitingOperation()
[all …]
HDcore_mqtt_agent_command_functions.c73 pReturnFlags->packetId = MQTT_GetPacketId( &( pMqttAgentContext->mqttContext ) ); in MQTTAgentCommand_Publish()
77 ret = MQTT_Publish( &( pMqttAgentContext->mqttContext ), pPublishInfo, pReturnFlags->packetId ); in MQTTAgentCommand_Publish()
101 pReturnFlags->packetId = MQTT_GetPacketId( &( pMqttAgentContext->mqttContext ) ); in MQTTAgentCommand_Subscribe()
106 pReturnFlags->packetId ); in MQTTAgentCommand_Subscribe()
129 pReturnFlags->packetId = MQTT_GetPacketId( &( pMqttAgentContext->mqttContext ) ); in MQTTAgentCommand_Unsubscribe()
134 pReturnFlags->packetId ); in MQTTAgentCommand_Unsubscribe()
/CoreMQTT-Agent-v1.1.0/test/cbmc/sources/
HDmqtt_agent_cbmc_state.c171 uint16_t packetId; in addPendingAcks() local
183 __CPROVER_assume( packetId < MAX_PACKET_ID ); in addPendingAcks()
185 pContext->pPendingAcks[ i ].packetId = packetId; in addPendingAcks()
/CoreMQTT-Agent-v1.1.0/test/cbmc/include/
HDincoming_publish_callback_stub.h41 uint16_t packetId,
/CoreMQTT-Agent-v1.1.0/source/include/
HDcore_mqtt_agent.h156 uint16_t packetId; /**< Packet ID of the pending acknowledgment. */ member
175 uint16_t packetId,
HDcore_mqtt_agent_command_functions.h107 uint16_t packetId; /**< @brief Packet ID of packet sent by command. */ member