Home
last modified time | relevance | path

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

/device/board/isoftstone/yangfan/common/mqtt/mqttclient_c/src/
DMQTTClient.c35 static int sendPacket(MQTTClient* c, int length, Timer* timer) in sendPacket() function
278 if (len > 0 && (rc = sendPacket(c, len, &timer)) == SUCCESS) // send the ping packet in keepalive()
351 rc = sendPacket(c, len, timer); in cycle()
367 else if ((rc = sendPacket(c, len, timer)) != SUCCESS) // send the PUBREL packet in cycle()
492 if ((rc = sendPacket(c, len, &connect_timer)) != SUCCESS) // send the connect packet in MQTTConnectWithResults()
592 if ((rc = sendPacket(c, len, &timer)) != SUCCESS) // send the subscribe packet in MQTTAsyncSubscribe()
626 if ((rc = sendPacket(c, len, &timer)) != SUCCESS) // send the subscribe packet in MQTTSubscribeWithResults()
680 if ((rc = sendPacket(c, len, &timer)) != SUCCESS) // send the subscribe packet in MQTTAsyncUnsubscribe()
712 if ((rc = sendPacket(c, len, &timer)) != SUCCESS) // send the subscribe packet in MQTTUnsubscribe()
761 if ((rc = sendPacket(c, len, &timer)) != SUCCESS) // send the subscribe packet in MQTTAsyncPublish()
[all …]
/device/board/isoftstone/yangfan/common/mqtt/mqttclient/src/
DMQTTClient.h248 int sendPacket(int length, Timer& timer);
380 int MQTT::Client<Network, Timer, a, b>::sendPacket(int length, Timer& timer) in sendPacket() function
633 rc = sendPacket(len, timer); in cycle()
650 else if ((rc = sendPacket(len, timer)) != SUCCESS) // send the PUBREL packet in cycle()
702 if (len > 0 && (rc = sendPacket(len, timer)) == SUCCESS) // send the ping packet in keepalive()
745 if ((rc = sendPacket(len, connect_timer)) != SUCCESS) // send the connect packet in connect()
867 if ((rc = sendPacket(len, timer)) != SUCCESS) // send the subscribe packet in subscribe()
912 if ((rc = sendPacket(len, timer)) != SUCCESS) // send the unsubscribe packet in unsubscribe()
939 if ((rc = sendPacket(len, timer)) != SUCCESS) // send the publish packet in publish()
1047 rc = sendPacket(len, timer); // send the disconnect packet in disconnect()