Lines Matching refs:recvbuf
113 Curl_dyn_init(&mq->recvbuf, DYN_MQTT_RECV); in mqtt_setup_conn()
355 Curl_dyn_free(&mq->recvbuf); in mqtt_disconnect()
362 size_t rlen = Curl_dyn_len(&mq->recvbuf); in mqtt_recv_atleast()
374 if(Curl_dyn_addn(&mq->recvbuf, readbuf, (size_t)nread)) in mqtt_recv_atleast()
376 rlen = Curl_dyn_len(&mq->recvbuf); in mqtt_recv_atleast()
384 size_t rlen = Curl_dyn_len(&mq->recvbuf); in mqtt_recv_consume()
386 Curl_dyn_reset(&mq->recvbuf); in mqtt_recv_consume()
388 Curl_dyn_tail(&mq->recvbuf, rlen - nbytes); in mqtt_recv_consume()
402 DEBUGASSERT(Curl_dyn_len(&mq->recvbuf) >= MQTT_CONNACK_LEN); in mqtt_verify_connack()
403 ptr = Curl_dyn_ptr(&mq->recvbuf); in mqtt_verify_connack()
409 Curl_dyn_reset(&mq->recvbuf); in mqtt_verify_connack()
497 DEBUGASSERT(Curl_dyn_len(&mq->recvbuf) >= MQTT_SUBACK_LEN); in mqtt_verify_suback()
498 ptr = Curl_dyn_ptr(&mq->recvbuf); in mqtt_verify_suback()
504 Curl_dyn_reset(&mq->recvbuf); in mqtt_verify_suback()
735 Curl_dyn_free(&mq->recvbuf); in mqtt_done()
