ymo_proto_mqtt.h
==================




.. c:function:: 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.



.. c:function:: ymo_status_t ymo_proto_mqtt_write( void* proto_data, ymo_conn_t* conn, void* conn_data, int socket)

   MQTT protocol write callback