Searched refs:SubscriptionElement_t (Results 1 – 8 of 8) sorted by relevance
| /FreeRTOS-Plus/Demo/coreMQTT_Windows_Simulator/MQTT_Multitask/subscription-manager/ |
| A D | subscription_manager.h | 100 } SubscriptionElement_t; typedef
117 bool addSubscription( SubscriptionElement_t * pxSubscriptionList,
133 void removeSubscription( SubscriptionElement_t * pxSubscriptionList,
147 bool handleIncomingPublishes( SubscriptionElement_t * pxSubscriptionList,
|
| A D | subscription_manager.c | 39 bool addSubscription( SubscriptionElement_t * pxSubscriptionList, in addSubscription()
101 void removeSubscription( SubscriptionElement_t * pxSubscriptionList, in removeSubscription()
125 … memset( &( pxSubscriptionList[ lIndex ] ), 0x00, sizeof( SubscriptionElement_t ) ); in removeSubscription()
134 bool handleIncomingPublishes( SubscriptionElement_t * pxSubscriptionList, in handleIncomingPublishes()
|
| /FreeRTOS-Plus/Demo/AWS/Ota_Windows_Simulator/Common/subscription-manager/ |
| A D | subscription_manager.h | 100 } SubscriptionElement_t; typedef
117 bool addSubscription( SubscriptionElement_t * pxSubscriptionList,
133 void removeSubscription( SubscriptionElement_t * pxSubscriptionList,
147 bool handleIncomingPublishes( SubscriptionElement_t * pxSubscriptionList,
|
| A D | subscription_manager.c | 39 bool addSubscription( SubscriptionElement_t * pxSubscriptionList, in addSubscription()
101 void removeSubscription( SubscriptionElement_t * pxSubscriptionList, in removeSubscription()
125 … memset( &( pxSubscriptionList[ lIndex ] ), 0x00, sizeof( SubscriptionElement_t ) ); in removeSubscription()
134 bool handleIncomingPublishes( SubscriptionElement_t * pxSubscriptionList, in handleIncomingPublishes()
|
| /FreeRTOS-Plus/Demo/coreMQTT_Windows_Simulator/MQTT_Multitask/DemoTasks/ |
| A D | mqtt-agent-task.c | 465 SubscriptionElement_t xGlobalSubscriptionList[ SUBSCRIPTION_MANAGER_MAX_SUBSCRIPTIONS ];
920 …xPublishHandled = handleIncomingPublishes( ( SubscriptionElement_t * ) pMqttAgentContext->pIncomin… in prvIncomingPublishCallback()
|
| A D | simple_sub_pub_demo.c | 278 …xSubscriptionAdded = addSubscription( ( SubscriptionElement_t * ) xGlobalMqttAgentContext.pIncomin… in prvSubscribeCommandCallback()
|
| /FreeRTOS-Plus/Demo/AWS/Ota_Windows_Simulator/Ota_Over_Mqtt_Demo/DemoTasks/ |
| A D | OtaOverMqttDemoExample.c | 464 static SubscriptionElement_t xGlobalSubscriptionList[ SUBSCRIPTION_MANAGER_MAX_SUBSCRIPTIONS ];
1118 …xPublishHandled = handleIncomingPublishes( ( SubscriptionElement_t * ) pMqttAgentContext->pIncomin… in prvIncomingPublishCallback()
1264 …subscriptionAdded = addSubscription( ( SubscriptionElement_t * ) xGlobalMqttAgentContext.pIncoming… in prvRegisterOTACallback()
2044 … removeSubscription( ( SubscriptionElement_t * ) xGlobalMqttAgentContext.pIncomingCallbackContext, in prvRunOTADemo()
|
| /FreeRTOS-Plus/Demo/AWS/Ota_Windows_Simulator/Ota_Over_Http_Demo/DemoTasks/ |
| A D | OtaOverHttpDemoExample.c | 588 static SubscriptionElement_t xGlobalSubscriptionList[ SUBSCRIPTION_MANAGER_MAX_SUBSCRIPTIONS ];
1261 …xPublishHandled = handleIncomingPublishes( ( SubscriptionElement_t * ) pMqttAgentContext->pIncomin… in prvIncomingPublishCallback()
1407 …subscriptionAdded = addSubscription( ( SubscriptionElement_t * ) xGlobalMqttAgentContext.pIncoming… in prvRegisterOTACallback()
2509 … removeSubscription( ( SubscriptionElement_t * ) xGlobalMqttAgentContext.pIncomingCallbackContext, in prvRunOTADemo()
|
Completed in 76 milliseconds