Lines Matching defs:arg
125 static void mqtt_cyclic_timer(void *arg);
283 * @param arg Parameter following callback
287 mqtt_create_request(struct mqtt_request_t *r_objs, size_t r_objs_len, u16_t pkt_id, mqtt_request_cb_t cb, void *arg)
298 r->arg = arg;
403 r->cb(r->arg, ERR_TIMEOUT);
573 * @param arg MQTT client
576 mqtt_cyclic_timer(void *arg)
579 mqtt_client_t *client = (mqtt_client_t *)arg;
621 sys_timeout(MQTT_CYCLIC_TIMER_INTERVAL * 1000, mqtt_cyclic_timer, arg);
659 r->cb(r->arg, result < 3 ? ERR_OK : ERR_ABRT);
816 r->cb(r->arg, ERR_OK);
925 * @param arg MQTT client
931 mqtt_tcp_recv_cb(void *arg, struct altcp_pcb *pcb, struct pbuf *p, err_t err)
933 mqtt_client_t *client = (mqtt_client_t *)arg;
969 * @param arg MQTT client
975 mqtt_tcp_sent_cb(void *arg, struct altcp_pcb *tpcb, u16_t len)
977 mqtt_client_t *client = (mqtt_client_t *)arg;
992 r->cb(r->arg, ERR_OK);
1004 * @param arg MQTT client
1008 mqtt_tcp_err_cb(void *arg, err_t err)
1010 mqtt_client_t *client = (mqtt_client_t *)arg;
1012 LWIP_DEBUGF(MQTT_DEBUG_TRACE, ("mqtt_tcp_err_cb: TCP error callback: error %d, arg: %p\n", err, arg));
1021 * @param arg MQTT client
1026 mqtt_tcp_poll_cb(void *arg, struct altcp_pcb *tpcb)
1028 mqtt_client_t *client = (mqtt_client_t *)arg;
1038 * @param arg MQTT client
1043 mqtt_tcp_connect_cb(void *arg, struct altcp_pcb *tpcb, err_t err)
1045 mqtt_client_t *client = (mqtt_client_t *)arg;
1090 * @param arg User supplied argument to publish callback
1097 mqtt_request_cb_t cb, void *arg)
1129 r = mqtt_create_request(client->req_list, LWIP_ARRAYSIZE(client->req_list), pkt_id, cb, arg);
1167 * @param arg User supplied argument to publish callback
1172 mqtt_sub_unsub(mqtt_client_t *client, const char *topic, u8_t qos, mqtt_request_cb_t cb, void *arg, u8_t sub)
1200 r = mqtt_create_request(client->req_list, LWIP_ARRAYSIZE(client->req_list), pkt_id, cb, arg);
1234 * @param arg User supplied argument to both callbacks
1238 mqtt_incoming_data_cb_t data_cb, void *arg)
1244 client->inpub_arg = arg;
1277 * @param arg User supplied argument to connection callback
1282 mqtt_client_connect(mqtt_client_t *client, const ip_addr_t *ip_addr, u16_t port, mqtt_connection_cb_t cb, void *arg,
1306 client->connect_arg = arg;
1376 /* Set arg pointer for callbacks */