Lines Matching refs:recvbuf
112 Curl_dyn_init(&mq->recvbuf, DYN_MQTT_RECV);
354 Curl_dyn_free(&mq->recvbuf);
361 size_t rlen = Curl_dyn_len(&mq->recvbuf);
374 if(Curl_dyn_addn(&mq->recvbuf, readbuf, (size_t)nread))
376 rlen = Curl_dyn_len(&mq->recvbuf);
384 size_t rlen = Curl_dyn_len(&mq->recvbuf);
386 Curl_dyn_reset(&mq->recvbuf);
388 Curl_dyn_tail(&mq->recvbuf, rlen - nbytes);
402 DEBUGASSERT(Curl_dyn_len(&mq->recvbuf) >= MQTT_CONNACK_LEN);
403 ptr = Curl_dyn_ptr(&mq->recvbuf);
409 Curl_dyn_reset(&mq->recvbuf);
497 DEBUGASSERT(Curl_dyn_len(&mq->recvbuf) >= MQTT_SUBACK_LEN);
498 ptr = Curl_dyn_ptr(&mq->recvbuf);
504 Curl_dyn_reset(&mq->recvbuf);
736 Curl_dyn_free(&mq->recvbuf);