Searched refs:pPublishInfo (Results 1 – 11 of 11) sorted by relevance
| /CoreMQTT-Agent-v1.1.0/test/cbmc/stubs/ |
| HD | core_mqtt_stubs.c | 90 MQTTPublishInfo_t * pPublishInfo; in MQTT_ProcessLoop() local
130 pPublishInfo = malloc( sizeof( MQTTPublishInfo_t ) ); in MQTT_ProcessLoop()
131 __CPROVER_assume( pPublishInfo != NULL ); in MQTT_ProcessLoop()
134 pPublishInfo->pTopicName = malloc( topicNameLength ); in MQTT_ProcessLoop()
135 __CPROVER_assume( pPublishInfo->pTopicName != NULL ); in MQTT_ProcessLoop()
136 pPublishInfo->topicNameLength = topicNameLength; in MQTT_ProcessLoop()
139 pPublishInfo->pPayload = malloc( payloadLength ); in MQTT_ProcessLoop()
140 pPublishInfo->payloadLength = ( pPublishInfo->pPayload != NULL ) ? payloadLength : 0; in MQTT_ProcessLoop()
142 pDeserializedInfo->pPublishInfo = pPublishInfo; in MQTT_ProcessLoop()
161 const MQTTPublishInfo_t * pPublishInfo, in MQTT_Publish() argument
[all …]
|
| HD | incoming_publish_callback_stub.c | 33 MQTTPublishInfo_t * pPublishInfo ) in IncomingPublishCallbackStub() argument
39 __CPROVER_assert( pPublishInfo != NULL, in IncomingPublishCallbackStub()
|
| HD | agent_message_stubs.c | 41 MQTTPublishInfo_t * pPublishInfo; in allocateCommand() local
64 pPublishInfo = malloc( sizeof( MQTTPublishInfo_t ) ); in allocateCommand()
65 command->pArgs = ( void * ) pPublishInfo; in allocateCommand()
|
| HD | agent_command_functions_stub.c | 76 MQTTPublishInfo_t * pPublishInfo; in MQTTAgentCommand_Publish() local
84 pPublishInfo = ( MQTTPublishInfo_t * ) pPublishArg; in MQTTAgentCommand_Publish()
85 pReturnFlags->addAcknowledgment = ( pPublishInfo->qos > MQTTQoS0 ) ? true : false; in MQTTAgentCommand_Publish()
86 pReturnFlags->runProcessLoop = ( pPublishInfo->qos > MQTTQoS0 ) ? true : false; in MQTTAgentCommand_Publish()
|
| /CoreMQTT-Agent-v1.1.0/test/cbmc/proofs/MQTTAgent_Publish/ |
| HD | MQTTAgent_Publish_harness.c | 31 MQTTPublishInfo_t * pPublishInfo; in harness() local
42 pPublishInfo = malloc( sizeof( MQTTPublishInfo_t ) ); in harness()
46 pPublishInfo, in harness()
|
| /CoreMQTT-Agent-v1.1.0/source/ |
| HD | core_mqtt_agent_command_functions.c | 61 const MQTTPublishInfo_t * pPublishInfo; in MQTTAgentCommand_Publish() local
69 pPublishInfo = ( const MQTTPublishInfo_t * ) ( pPublishArg ); in MQTTAgentCommand_Publish()
71 if( pPublishInfo->qos != MQTTQoS0 ) in MQTTAgentCommand_Publish()
76 …LogInfo( ( "Publishing message to %.*s.\n", ( int ) pPublishInfo->topicNameLength, pPublishInfo->p… in MQTTAgentCommand_Publish()
77 ret = MQTT_Publish( &( pMqttAgentContext->mqttContext ), pPublishInfo, pReturnFlags->packetId ); in MQTTAgentCommand_Publish()
80 pReturnFlags->addAcknowledgment = ( pPublishInfo->qos != MQTTQoS0 ) && ( ret == MQTTSuccess ); in MQTTAgentCommand_Publish()
|
| HD | core_mqtt_agent.c | 426 const MQTTPublishInfo_t * pPublishInfo; in createCommand() local
452 pPublishInfo = ( const MQTTPublishInfo_t * ) pMqttInfoParam; in createCommand()
457 uxHeaderBytes += pPublishInfo->topicNameLength; in createCommand()
464 if( pPublishInfo->qos != MQTTQoS0 ) in createCommand()
655 …gentContext->pIncomingCallback( pAgentContext, packetIdentifier, pDeserializedInfo->pPublishInfo ); in mqttEventCallback()
1181 MQTTPublishInfo_t * pPublishInfo, in MQTTAgent_Publish() argument
1188 validateParams( PUBLISH, pPublishInfo ); in MQTTAgent_Publish()
1194 … pPublishInfo, /* pMqttInfoParam */ in MQTTAgent_Publish()
|
| /CoreMQTT-Agent-v1.1.0/test/cbmc/sources/ |
| HD | mqtt_agent_cbmc_state.c | 173 MQTTPublishInfo_t * pPublishInfo; in addPendingAcks() local
194 pPublishInfo = malloc( sizeof( MQTTPublishInfo_t ) ); in addPendingAcks()
195 __CPROVER_assume( pPublishInfo != NULL ); in addPendingAcks()
196 pCommand->pArgs = pPublishInfo; in addPendingAcks()
|
| /CoreMQTT-Agent-v1.1.0/test/cbmc/include/ |
| HD | incoming_publish_callback_stub.h | 42 MQTTPublishInfo_t * pPublishInfo );
|
| /CoreMQTT-Agent-v1.1.0/source/include/ |
| HD | core_mqtt_agent.h | 176 MQTTPublishInfo_t * pPublishInfo );
629 MQTTPublishInfo_t * pPublishInfo,
|
| /CoreMQTT-Agent-v1.1.0/test/unit-test/ |
| HD | mqtt_agent_utest.c | 224 MQTTPublishInfo_t * pPublishInfo ) in stubPublishCallback() argument
228 ( void ) pPublishInfo; in stubPublishCallback()
|
