Lines Matching refs:tpcb
234 mqtt_output_send(struct mqtt_ringbuf_t *rb, struct altcp_pcb *tpcb) in mqtt_output_send() argument
239 u16_t send_len = altcp_sndbuf(tpcb); in mqtt_output_send()
240 LWIP_ASSERT("mqtt_output_send: tpcb != NULL", tpcb != NULL); in mqtt_output_send()
255 …err = altcp_write(tpcb, mqtt_ringbuf_get_ptr(rb), send_len, TCP_WRITE_FLAG_COPY | (wrap ? TCP_WRIT… in mqtt_output_send()
259 send_len = LWIP_MIN(altcp_sndbuf(tpcb), mqtt_ringbuf_linear_read_length(rb)); in mqtt_output_send()
260 err = altcp_write(tpcb, mqtt_ringbuf_get_ptr(rb), send_len, TCP_WRITE_FLAG_COPY); in mqtt_output_send()
266 altcp_output(tpcb); in mqtt_output_send()
976 mqtt_tcp_sent_cb(void *arg, struct altcp_pcb *tpcb, u16_t len) in mqtt_tcp_sent_cb() argument
980 LWIP_UNUSED_ARG(tpcb); in mqtt_tcp_sent_cb()
1027 mqtt_tcp_poll_cb(void *arg, struct altcp_pcb *tpcb) in mqtt_tcp_poll_cb() argument
1032 mqtt_output_send(&client->output, tpcb); in mqtt_tcp_poll_cb()
1044 mqtt_tcp_connect_cb(void *arg, struct altcp_pcb *tpcb, err_t err) in mqtt_tcp_connect_cb() argument
1057 altcp_recv(tpcb, mqtt_tcp_recv_cb); in mqtt_tcp_connect_cb()
1058 altcp_sent(tpcb, mqtt_tcp_sent_cb); in mqtt_tcp_connect_cb()
1059 altcp_poll(tpcb, mqtt_tcp_poll_cb, 2); in mqtt_tcp_connect_cb()