Home
last modified time | relevance | path

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

/CoreMQTT-Agent-v1.1.0/source/
Dcore_mqtt_agent.c283 const MQTTAgentAckInfo_t * pendingAcks; in isSpaceInPendingAckList() local
289 pendingAcks = pAgentContext->pPendingAcks; in isSpaceInPendingAckList()
296 if( pendingAcks[ i ].packetId == MQTT_PACKET_ID_INVALID ) in isSpaceInPendingAckList()
314 MQTTAgentAckInfo_t * pendingAcks = NULL; in addAwaitingOperation() local
319 pendingAcks = pAgentContext->pPendingAcks; in addAwaitingOperation()
330 ( pendingAcks[ i ].packetId == MQTT_PACKET_ID_INVALID ) ) in addAwaitingOperation()
336 if( pendingAcks[ i ].packetId == packetId ) in addAwaitingOperation()
358 pendingAcks[ unusedPos ].packetId = packetId; in addAwaitingOperation()
359 pendingAcks[ unusedPos ].pOriginalCommand = pCommand; in addAwaitingOperation()
842 MQTTAgentAckInfo_t * pendingAcks; in clearPendingAcknowledgments() local
[all …]