ymo_proto_mqtt.h

ssize_t ymo_proto_mqtt_read(void *proto_data, ymo_conn_t *conn, void *conn_data, char *recv_buf, size_t len)

MQTT Parse main entry point. :param server: ymo_server issuing the parse request :param session: MQTT session we’re parsing :param proto_data: MQTT-specific data created by proto init :param recv_buf: server read buffer :param len: number of bytes in recv_buf

Returns number of bytes parsed on success, -1 on failure.

ymo_status_t ymo_proto_mqtt_write(void *proto_data, ymo_conn_t *conn, void *conn_data, int socket)

MQTT protocol write callback