Lines Matching refs:mqtt
108 DEBUGASSERT(data->req.p.mqtt == NULL); in mqtt_setup_conn()
114 data->req.p.mqtt = mq; in mqtt_setup_conn()
122 struct MQTT *mq = data->req.p.mqtt; in mqtt_send()
352 struct MQTT *mq = data->req.p.mqtt; in mqtt_disconnect()
361 struct MQTT *mq = data->req.p.mqtt; in mqtt_recv_atleast()
383 struct MQTT *mq = data->req.p.mqtt; in mqtt_recv_consume()
393 struct MQTT *mq = data->req.p.mqtt; in mqtt_verify_connack()
451 conn->proto.mqtt.packetid++; in mqtt_subscribe()
466 packet[1 + n] = (conn->proto.mqtt.packetid >> 8) & 0xff; in mqtt_subscribe()
467 packet[2 + n] = conn->proto.mqtt.packetid & 0xff; in mqtt_subscribe()
486 struct MQTT *mq = data->req.p.mqtt; in mqtt_verify_suback()
488 struct mqtt_conn *mqtt = &conn->proto.mqtt; in mqtt_verify_suback() local
501 if(((unsigned char)ptr[0]) != ((mqtt->packetid >> 8) & 0xff) || in mqtt_verify_suback()
502 ((unsigned char)ptr[1]) != (mqtt->packetid & 0xff) || in mqtt_verify_suback()
608 struct mqtt_conn *mqtt = &conn->proto.mqtt; in mqstate() local
612 statenames[mqtt->state], in mqstate()
615 mqtt->state = state; in mqstate()
617 mqtt->nextstate = nextstate; in mqstate()
627 struct mqtt_conn *mqtt = &conn->proto.mqtt; in mqtt_read_publish() local
628 struct MQTT *mq = data->req.p.mqtt; in mqtt_read_publish()
631 switch(mqtt->state) { in mqtt_read_publish()
731 struct MQTT *mq = data->req.p.mqtt; in mqtt_done()
743 struct mqtt_conn *mqtt = &conn->proto.mqtt; in mqtt_doing() local
744 struct MQTT *mq = data->req.p.mqtt; in mqtt_doing()
759 infof(data, "mqtt_doing: state [%d]", (int) mqtt->state); in mqtt_doing()
760 switch(mqtt->state) { in mqtt_doing()
794 mqstate(data, mqtt->nextstate, MQTT_NOSTATE); in mqtt_doing()
815 mqtt->nextstate = MQTT_FIRST; in mqtt_doing()
