Lines Matching defs:mq
105 struct MQTT *mq;
109 mq = calloc(1, sizeof(struct MQTT));
110 if(!mq)
112 Curl_dyn_init(&mq->recvbuf, DYN_MQTT_RECV);
113 data->req.p.mqtt = mq;
121 struct MQTT *mq = data->req.p.mqtt;
132 mq->sendleftovers = sendleftovers;
133 mq->nsend = nsend;
136 mq->sendleftovers = NULL;
137 mq->nsend = 0;
351 struct MQTT *mq = data->req.p.mqtt;
353 Curl_safefree(mq->sendleftovers);
354 Curl_dyn_free(&mq->recvbuf);
360 struct MQTT *mq = data->req.p.mqtt;
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);
383 struct MQTT *mq = data->req.p.mqtt;
384 size_t rlen = Curl_dyn_len(&mq->recvbuf);
386 Curl_dyn_reset(&mq->recvbuf);
388 Curl_dyn_tail(&mq->recvbuf, rlen - nbytes);
393 struct MQTT *mq = data->req.p.mqtt;
402 DEBUGASSERT(Curl_dyn_len(&mq->recvbuf) >= MQTT_CONNACK_LEN);
403 ptr = Curl_dyn_ptr(&mq->recvbuf);
409 Curl_dyn_reset(&mq->recvbuf);
486 struct MQTT *mq = data->req.p.mqtt;
497 DEBUGASSERT(Curl_dyn_len(&mq->recvbuf) >= MQTT_SUBACK_LEN);
498 ptr = Curl_dyn_ptr(&mq->recvbuf);
504 Curl_dyn_reset(&mq->recvbuf);
629 struct MQTT *mq = data->req.p.mqtt;
645 packet = mq->firstbyte & 0xf0;
663 remlen = mq->remaining_length;
674 mq->npacket = remlen; /* get this many bytes */
679 size_t rest = mq->npacket;
700 mq->npacket -= nread;
701 if(!mq->npacket)
732 struct MQTT *mq = data->req.p.mqtt;
735 Curl_safefree(mq->sendleftovers);
736 Curl_dyn_free(&mq->recvbuf);
745 struct MQTT *mq = data->req.p.mqtt;
752 if(mq->nsend) {
754 char *ptr = mq->sendleftovers;
755 result = mqtt_send(data, mq->sendleftovers, mq->nsend);
765 result = Curl_read(data, sockfd, (char *)&mq->firstbyte, 1, &nread);
774 Curl_debug(data, CURLINFO_HEADER_IN, (char *)&mq->firstbyte, 1);
776 mq->npacket = 0;
785 mq->pkt_hd[mq->npacket++] = byte;
786 } while((byte & 0x80) && (mq->npacket < 4));
793 mq->remaining_length = mqtt_decode_len(mq->pkt_hd, mq->npacket, NULL);
794 mq->npacket = 0;
795 if(mq->remaining_length) {
801 if(mq->firstbyte == MQTT_MSG_DISCONNECT) {