Lines Matching defs:mqtt
35 #include "mqtt.h"
107 DEBUGASSERT(data->req.p.mqtt == NULL);
113 data->req.p.mqtt = mq;
121 struct MQTT *mq = data->req.p.mqtt;
351 struct MQTT *mq = data->req.p.mqtt;
360 struct MQTT *mq = data->req.p.mqtt;
383 struct MQTT *mq = data->req.p.mqtt;
393 struct MQTT *mq = data->req.p.mqtt;
451 conn->proto.mqtt.packetid++;
466 packet[1 + n] = (conn->proto.mqtt.packetid >> 8) & 0xff;
467 packet[2 + n] = conn->proto.mqtt.packetid & 0xff;
486 struct MQTT *mq = data->req.p.mqtt;
488 struct mqtt_conn *mqtt = &conn->proto.mqtt;
501 if(((unsigned char)ptr[0]) != ((mqtt->packetid >> 8) & 0xff) ||
502 ((unsigned char)ptr[1]) != (mqtt->packetid & 0xff) ||
608 struct mqtt_conn *mqtt = &conn->proto.mqtt;
612 statenames[mqtt->state],
615 mqtt->state = state;
617 mqtt->nextstate = nextstate;
628 struct mqtt_conn *mqtt = &conn->proto.mqtt;
629 struct MQTT *mq = data->req.p.mqtt;
632 switch(mqtt->state) {
732 struct MQTT *mq = data->req.p.mqtt;
744 struct mqtt_conn *mqtt = &conn->proto.mqtt;
745 struct MQTT *mq = data->req.p.mqtt;
761 infof(data, "mqtt_doing: state [%d]", (int) mqtt->state);
762 switch(mqtt->state) {
796 mqstate(data, mqtt->nextstate, MQTT_NOSTATE);
817 mqtt->nextstate = MQTT_FIRST;