103   DEBUGASSERT(data->req.p.mqtt == NULL);  in mqtt_setup_conn()
108   data->req.p.mqtt = mq;  in mqtt_setup_conn()
118   struct MQTT *mq = data->req.p.mqtt;  in mqtt_send()
408   conn->proto.mqtt.packetid++;  in mqtt_subscribe()
423   packet[1 + n] = (conn->proto.mqtt.packetid >> 8) & 0xff;  in mqtt_subscribe()
424   packet[2 + n] = conn->proto.mqtt.packetid & 0xff;  in mqtt_subscribe()
448   struct mqtt_conn *mqtt = &conn->proto.mqtt;  in mqtt_verify_suback()  local
463   if(readbuf[0] != ((mqtt->packetid >> 8) & 0xff) ||  in mqtt_verify_suback()
464      readbuf[1] != (mqtt->packetid & 0xff) ||  in mqtt_verify_suback()
565   struct mqtt_conn *mqtt = &conn->proto.mqtt;  in mqstate()  local
569         statenames[mqtt->state],  in mqstate()
572   mqtt->state = state;  in mqstate()
574     mqtt->nextstate = nextstate;  in mqstate()
589   struct mqtt_conn *mqtt = &conn->proto.mqtt;  in mqtt_read_publish()  local
590   struct MQTT *mq = data->req.p.mqtt;  in mqtt_read_publish()
593   switch(mqtt->state) {  in mqtt_read_publish()
699   struct mqtt_conn *mqtt = &conn->proto.mqtt;  in mqtt_doing()  local
700   struct MQTT *mq = data->req.p.mqtt;  in mqtt_doing()
717   infof(data, "mqtt_doing: state [%d]", (int) mqtt->state);  in mqtt_doing()
718   switch(mqtt->state) {  in mqtt_doing()
746       mqstate(data, mqtt->nextstate, MQTT_NOSTATE);  in mqtt_doing()
767       mqtt->nextstate = MQTT_FIRST;  in mqtt_doing()