Home
last modified time | relevance | path

Searched refs:mqttContext (Results 1 – 7 of 7) sorted by relevance

/CoreMQTT-Agent-v1.1.0/test/unit-test/
Dmqtt_agent_command_functions_utest.c195 MQTT_Publish_ExpectAndReturn( &( mqttAgentContext.mqttContext ), &publishInfo, 0, MQTTSuccess ); in test_MQTTAgentCommand_Publish_QoS0_success()
220 MQTT_GetPacketId_ExpectAndReturn( &( mqttAgentContext.mqttContext ), 1 ); in test_MQTTAgentCommand_Publish_QoS1_success()
221 MQTT_Publish_ExpectAndReturn( &( mqttAgentContext.mqttContext ), &publishInfo, 1, MQTTSuccess ); in test_MQTTAgentCommand_Publish_QoS1_success()
246 …MQTT_Publish_ExpectAndReturn( &( mqttAgentContext.mqttContext ), &publishInfo, 0, MQTTSendFailed ); in test_MQTTAgentCommand_Publish_QoS0_failure()
271 MQTT_GetPacketId_ExpectAndReturn( &( mqttAgentContext.mqttContext ), 1 ); in test_MQTTAgentCommand_Publish_QoS1_failure()
272 …MQTT_Publish_ExpectAndReturn( &( mqttAgentContext.mqttContext ), &publishInfo, 1, MQTTSendFailed ); in test_MQTTAgentCommand_Publish_QoS1_failure()
294 MQTT_GetPacketId_ExpectAndReturn( &( mqttAgentContext.mqttContext ), 1 ); in test_MQTTAgentCommand_Subscribe_Success()
295 MQTT_Subscribe_ExpectAndReturn( &( mqttAgentContext.mqttContext ), in test_MQTTAgentCommand_Subscribe_Success()
320 MQTT_GetPacketId_ExpectAndReturn( &( mqttAgentContext.mqttContext ), 1 ); in test_MQTTAgentCommand_Subscribe_failure()
321 MQTT_Subscribe_ExpectAndReturn( &( mqttAgentContext.mqttContext ), in test_MQTTAgentCommand_Subscribe_failure()
[all …]
Dmqtt_agent_utest.c355 pAgentContext->mqttContext.nextPacketId = 1U; in setupAgentContext()
409 agentContext.mqttContext.nextPacketId = MQTT_PACKET_ID_INVALID; in invalidParamsTestFunc()
530 mqttAgentContext.mqttContext.nextPacketId = 0; in test_MQTTAgent_ResumeSession_Invalid_Params()
923 agentContext.mqttContext.networkBuffer.size = 6; in test_MQTTAgent_Publish_Invalid_Parameters()
964 agentContext.mqttContext.networkBuffer.size = 10; in test_MQTTAgent_Publish_No_Ack_Space()
994 agentContext.mqttContext.networkBuffer.size = 10; in test_MQTTAgent_Publish_success()
1228 mqttAgentContext.mqttContext.connectStatus = MQTTNotConnected; in test_MQTTAgent_CommandLoop_with_empty_command_queue()
1251 mqttAgentContext.mqttContext.connectStatus = MQTTConnected; in test_MQTTAgent_CommandLoop_process_commands_in_command_queue()
1294 mqttAgentContext.mqttContext.connectStatus = MQTTConnected; in test_MQTTAgent_CommandLoop_add_acknowledgment_success()
1334 mqttAgentContext.mqttContext.connectStatus = MQTTConnected; in test_MQTTAgent_CommandLoop_add_acknowledgment_failure()
[all …]
/CoreMQTT-Agent-v1.1.0/source/
Dcore_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()
103 ret = MQTT_Subscribe( &( pMqttAgentContext->mqttContext ), in MQTTAgentCommand_Subscribe()
129 pReturnFlags->packetId = MQTT_GetPacketId( &( pMqttAgentContext->mqttContext ) ); in MQTTAgentCommand_Unsubscribe()
131 ret = MQTT_Unsubscribe( &( pMqttAgentContext->mqttContext ), in MQTTAgentCommand_Unsubscribe()
157 ret = MQTT_Connect( &( pMqttAgentContext->mqttContext ), in MQTTAgentCommand_Connect()
189 ret = MQTT_Disconnect( &( pMqttAgentContext->mqttContext ) ); in MQTTAgentCommand_Disconnect()
210 ret = MQTT_Ping( &( pMqttAgentContext->mqttContext ) ); in MQTTAgentCommand_Ping()
Dcore_mqtt_agent.c470 isValid = ( uxHeaderBytes < pMqttAgentContext->mqttContext.networkBuffer.size ) && in createCommand()
582 ( pMqttAgentContext->mqttContext.connectStatus == MQTTConnected ) ) in processCommand()
584 … operationStatus = MQTT_ProcessLoop( &( pMqttAgentContext->mqttContext ), processLoopTimeoutMs ); in processCommand()
715 if( pMqttAgentContext->mqttContext.nextPacketId != MQTT_PACKET_ID_INVALID ) in createAndAddCommand()
805 pMqttContext = &( pMqttAgentContext->mqttContext ); in resendPublishes()
977 returnStatus = MQTT_Init( &( pMqttAgentContext->mqttContext ), in MQTTAgent_Init()
1046 ( pMqttAgentContext->mqttContext.nextPacketId != MQTT_PACKET_ID_INVALID ) ) in MQTTAgent_ResumeSession()
/CoreMQTT-Agent-v1.1.0/test/cbmc/proofs/MQTTAgent_CommandLoop/
DMQTTAgent_CommandLoop_harness.c36 pMqttAgentContext->mqttContext.connectStatus = MQTTConnected; in harness()
/CoreMQTT-Agent-v1.1.0/source/include/
Dcore_mqtt_agent.h186 …MQTTContext_t mqttContext; /**< MQTT connection informati… member
/CoreMQTT-Agent-v1.1.0/test/cbmc/sources/
Dmqtt_agent_cbmc_state.c139 isValid = isValidMqttFixedBuffer( &( pContext->mqttContext.networkBuffer ) ); in isValidMqttAgentContext()