Lines Matching refs:nread
367 ssize_t nread; in mqtt_recv_atleast() local
370 result = Curl_xfer_recv(data, (char *)readbuf, nbytes - rlen, &nread); in mqtt_recv_atleast()
373 DEBUGASSERT(nread >= 0); in mqtt_recv_atleast()
374 if(Curl_dyn_addn(&mq->recvbuf, readbuf, (size_t)nread)) in mqtt_recv_atleast()
625 ssize_t nread; in mqtt_read_publish() local
681 result = Curl_xfer_recv(data, buffer, rest, &nread); in mqtt_read_publish()
688 if(!nread) { in mqtt_read_publish()
695 result = Curl_client_write(data, CLIENTWRITE_BODY, buffer, nread); in mqtt_read_publish()
699 mq->npacket -= nread; in mqtt_read_publish()
745 ssize_t nread; in mqtt_doing() local
763 result = Curl_xfer_recv(data, (char *)&mq->firstbyte, 1, &nread); in mqtt_doing()
766 else if(!nread) { in mqtt_doing()
779 result = Curl_xfer_recv(data, (char *)&recvbyte, 1, &nread); in mqtt_doing()
780 if(result || !nread) in mqtt_doing()
785 if(!result && nread && (recvbyte & 0x80)) in mqtt_doing()
