Lines Matching defs:c

290 static int _reset_send_buffer(iotx_mc_client_t *c)  in _reset_send_buffer()
310 static int _reset_recv_buffer(iotx_mc_client_t *c) in _reset_recv_buffer()
330 static int _alloc_send_buffer(iotx_mc_client_t *c, int len) in _alloc_send_buffer()
363 static int _alloc_recv_buffer(iotx_mc_client_t *c, int len) in _alloc_recv_buffer()
406 static int iotx_mc_send_packet(iotx_mc_client_t *c, char *buf, int length, in iotx_mc_send_packet()
479 static int iotx_mc_decode_packet(iotx_mc_client_t *c, int *value, int timeout) in iotx_mc_decode_packet()
512 static int _handle_event(iotx_mqtt_event_handle_pt handle, iotx_mc_client_t *c, in _handle_event()
525 static int iotx_mc_read_packet(iotx_mc_client_t *c, iotx_time_t *timer, in iotx_mc_read_packet()
642 static int iotx_mc_handle_recv_CONNACK(iotx_mc_client_t *c) in iotx_mc_handle_recv_CONNACK()
686 static int iotx_mc_wait_CONNACK(iotx_mc_client_t *c) in iotx_mc_wait_CONNACK()
817 static int iotx_mc_push_pubInfo_to(iotx_mc_client_t *c, int len, in iotx_mc_push_pubInfo_to()
895 static int iotx_mc_mask_pubInfo_from(iotx_mc_client_t *c, uint16_t msgId) in iotx_mc_mask_pubInfo_from()
928 static int MQTTRePublish(iotx_mc_client_t *c, char *buf, int len) in MQTTRePublish()
1032 static int iotx_mc_handle_recv_PUBACK(iotx_mc_client_t *c) in iotx_mc_handle_recv_PUBACK()
1103 static int iotx_mc_handle_recv_SUBACK(iotx_mc_client_t *c) in iotx_mc_handle_recv_SUBACK()
1217 static void iotx_mc_deliver_message(iotx_mc_client_t *c, MQTTString *topicName, in iotx_mc_deliver_message()
1317 static int MQTTPuback(iotx_mc_client_t *c, unsigned int msgId, in MQTTPuback()
1379 static int iotx_mc_handle_recv_PUBLISH(iotx_mc_client_t *c) in iotx_mc_handle_recv_PUBLISH()
1485 static int iotx_mc_handle_recv_UNSUBACK(iotx_mc_client_t *c) in iotx_mc_handle_recv_UNSUBACK()
1508 static int iotx_mc_cycle(iotx_mc_client_t *c, iotx_time_t *timer) in iotx_mc_cycle()
1984 static int MQTTSubscribe(iotx_mc_client_t *c, const char *topicFilter, in MQTTSubscribe()
2272 static int iotx_mc_get_next_packetid(iotx_mc_client_t *c) in iotx_mc_get_next_packetid()
2379 static int MQTTUnsubscribe(iotx_mc_client_t *c, const char *topicFilter, in MQTTUnsubscribe()
2556 int MQTTPublish(iotx_mc_client_t *c, const char *topicName, in MQTTPublish()
2652 static int MQTTDisconnect(iotx_mc_client_t *c) in MQTTDisconnect()
2801 int wrapper_mqtt_release(void **c) in wrapper_mqtt_release()
2922 iotx_mc_client_t *c; in wrapper_mqtt_subscribe() local
2961 void *c, const char *topic_filter, iotx_mqtt_qos_t qos, in wrapper_mqtt_subscribe_sync()
3131 iotx_mc_client_t *c = (iotx_mc_client_t *)client; in wrapper_mqtt_unsubscribe() local
3169 iotx_mc_client_t *c = (iotx_mc_client_t *)client; in wrapper_mqtt_publish() local