97   struct MQTT *mq;  in mqtt_setup_conn()  local
101   mq = calloc(1, sizeof(struct MQTT));  in mqtt_setup_conn()
102   if(!mq)  in mqtt_setup_conn()
104   data->req.protop = mq;  in mqtt_setup_conn()
114   struct MQTT *mq = data->req.protop;  in mqtt_send()  local
124     mq->sendleftovers = sendleftovers;  in mqtt_send()
125     mq->nsend = nsend;  in mqtt_send()
430   struct MQTT *mq = data->req.protop;  in mqtt_read_publish()  local
446     packet = mq->firstbyte & 0xf0;  in mqtt_read_publish()
464     remlen = mq->remaining_length;  in mqtt_read_publish()
469     mq->npacket = remlen; /* get this many bytes */  in mqtt_read_publish()
474     size_t rest = mq->npacket;  in mqtt_read_publish()
492     mq->npacket -= nread;  in mqtt_read_publish()
502     if(!mq->npacket)  in mqtt_read_publish()
537   struct MQTT *mq = data->req.protop;  in mqtt_doing()  local
545   if(mq->nsend) {  in mqtt_doing()
547     char *ptr = mq->sendleftovers;  in mqtt_doing()
548     result = mqtt_send(conn, mq->sendleftovers, mq->nsend);  in mqtt_doing()
558     result = Curl_read(conn, sockfd, (char *)&mq->firstbyte, 1, &nread);  in mqtt_doing()
562       Curl_debug(data, CURLINFO_HEADER_IN, (char *)&mq->firstbyte, 1);  in mqtt_doing()
564     mq->npacket = 0;  in mqtt_doing()
574       pkt[mq->npacket++] = byte;  in mqtt_doing()
575     } while((byte & 0x80) && (mq->npacket < 4));  in mqtt_doing()
578     mq->remaining_length = mqtt_decode_len(&pkt[0], mq->npacket, NULL);  in mqtt_doing()
579     mq->npacket = 0;  in mqtt_doing()
580     if(mq->remaining_length) {  in mqtt_doing()
586     if(mq->firstbyte == MQTT_MSG_DISCONNECT) {  in mqtt_doing()