Lines Matching refs:nread
357 ssize_t nread; in mqtt_verify_connack() local
359 result = Curl_read(data, sockfd, (char *)readbuf, MQTT_CONNACK_LEN, &nread); in mqtt_verify_connack()
363 Curl_debug(data, CURLINFO_HEADER_IN, (char *)readbuf, (size_t)nread); in mqtt_verify_connack()
366 if(nread < MQTT_CONNACK_LEN) { in mqtt_verify_connack()
447 ssize_t nread; in mqtt_verify_suback() local
450 result = Curl_read(data, sockfd, (char *)readbuf, MQTT_SUBACK_LEN, &nread); in mqtt_verify_suback()
454 Curl_debug(data, CURLINFO_HEADER_IN, (char *)readbuf, (size_t)nread); in mqtt_verify_suback()
457 if(nread < MQTT_SUBACK_LEN) { in mqtt_verify_suback()
586 ssize_t nread; in mqtt_read_publish() local
643 result = Curl_read(data, sockfd, (char *)pkt, rest, &nread); in mqtt_read_publish()
650 if(!nread) { in mqtt_read_publish()
655 Curl_debug(data, CURLINFO_DATA_IN, (char *)pkt, (size_t)nread); in mqtt_read_publish()
657 mq->npacket -= nread; in mqtt_read_publish()
658 k->bytecount += nread; in mqtt_read_publish()
663 result = Curl_client_write(data, CLIENTWRITE_BODY, (char *)pkt, nread); in mqtt_read_publish()
701 ssize_t nread; in mqtt_doing() local
721 result = Curl_read(data, sockfd, (char *)&mq->firstbyte, 1, &nread); in mqtt_doing()
722 if(!nread) in mqtt_doing()
731 result = Curl_read(data, sockfd, (char *)&byte, 1, &nread); in mqtt_doing()
732 if(!nread) in mqtt_doing()
737 if(nread && (byte & 0x80)) in mqtt_doing()