Home
last modified time | relevance | path

Searched refs:blockTimeMs (Results 1 – 8 of 8) sorted by relevance

/FreeRTOS-Plus/Demo/Common/coreMQTT_Agent_Interface/
A Dfreertos_agent_message.c48 uint32_t blockTimeMs ) in Agent_MessageSend() argument
54 … queueStatus = xQueueSendToBack( pMsgCtx->queue, pCommandToSend, pdMS_TO_TICKS( blockTimeMs ) ); in Agent_MessageSend()
64 uint32_t blockTimeMs ) in Agent_MessageReceive() argument
70 … queueStatus = xQueueReceive( pMsgCtx->queue, pReceivedCommand, pdMS_TO_TICKS( blockTimeMs ) ); in Agent_MessageReceive()
A Dfreertos_command_pool.c105 MQTTAgentCommand_t * Agent_GetCommand( uint32_t blockTimeMs ) in Agent_GetCommand() argument
114 … structRetrieved = Agent_MessageReceive( &commandStructMessageCtx, &( structToUse ), blockTimeMs ); in Agent_GetCommand()
/FreeRTOS-Plus/Demo/Common/coreMQTT_Agent_Interface/include/
A Dfreertos_agent_message.h68 uint32_t blockTimeMs );
82 uint32_t blockTimeMs );
A Dfreertos_command_pool.h60 MQTTAgentCommand_t * Agent_GetCommand( uint32_t blockTimeMs );
/FreeRTOS-Plus/Demo/coreMQTT_Windows_Simulator/MQTT_Multitask/DemoTasks/
A Dsimple_sub_pub_demo.c378 xCommandParams.blockTimeMs = mqttexampleMAX_COMMAND_SEND_BLOCK_TIME_MS; in prvSubscribeToTopic()
469 xCommandParams.blockTimeMs = mqttexampleMAX_COMMAND_SEND_BLOCK_TIME_MS; in prvSimpleSubscribePublishTask()
A Dmqtt-agent-task.c651 xCommandParams.blockTimeMs = 0U; in prvHandleResubscribe()
902 xCommandParams.blockTimeMs = 0U; in prvMQTTClientSocketWakeupCallback()
/FreeRTOS-Plus/Demo/AWS/Ota_Windows_Simulator/Ota_Over_Mqtt_Demo/DemoTasks/
A DOtaOverMqttDemoExample.c1214 xCommandParams.blockTimeMs = 0U; in prvHandleResubscribe()
1562 xCommandParams.blockTimeMs = MQTT_AGENT_SEND_BLOCK_TIME_MS; in prvDisconnectFromMQTTBroker()
1608 xCommandParams.blockTimeMs = otaexampleMQTT_TIMEOUT_MS; in prvMQTTSubscribe()
1675 xCommandParams.blockTimeMs = otaexampleMQTT_TIMEOUT_MS; in prvMQTTPublish()
1741 xCommandParams.blockTimeMs = otaexampleMQTT_TIMEOUT_MS; in prvMQTTUnsubscribe()
/FreeRTOS-Plus/Demo/AWS/Ota_Windows_Simulator/Ota_Over_Http_Demo/DemoTasks/
A DOtaOverHttpDemoExample.c1357 xCommandParams.blockTimeMs = 0U; in prvHandleResubscribe()
1704 xCommandParams.blockTimeMs = MQTT_AGENT_SEND_BLOCK_TIME_MS; in prvDisconnectFromMQTTBroker()
2066 xCommandParams.blockTimeMs = otaexampleMQTT_TIMEOUT_MS; in prvMQTTSubscribe()
2133 xCommandParams.blockTimeMs = otaexampleMQTT_TIMEOUT_MS; in prvMQTTPublish()
2199 xCommandParams.blockTimeMs = otaexampleMQTT_TIMEOUT_MS; in prvMQTTUnsubscribe()

Completed in 672 milliseconds