Typedefs
MyQtt Handlers: Handlers used across MyQtt Library for async notifications.

Typedefs

typedef void(* MyQttAsyncQueueForeach )(MyQttAsyncQueue *queue, axlPointer item_stored, int position, axlPointer user_data)
 Handler definition used by myqtt_async_queue_foreach to implement a foreach operation over all items inside the provided queue, blocking its access during its process. More...
 
typedef void(* MyQttConnNew )(MyQttConn *connection, axlPointer user_data)
 Async notification for connection creation process. More...
 
typedef void(* MyQttConnOnClose )(MyQttConn *connection, axlPointer data)
 Allows to set a handler that will be called when a connection is about being closed. More...
 
typedef void(* MyQttIdleHandler )(MyQttCtx *ctx, MyQttConn *conn, axlPointer user_data, axlPointer user_data2)
 Handler called to notify idle state reached for a particular connection. More...
 
typedef axlPointer(* MyQttInitSessionSetupPtr )(MyQttCtx *ctx, MyQttConn *conn, axlPointer user_data, axlPointer user_data2, axlPointer user_data3)
 Handler definition for the user pointer used by the session setup handler. More...
 
typedef axl_bool(* MyQttIoAddToFdGroup )(int fds, MyQttConn *connection, axlPointer fd_group)
 IO handler definition to perform the "add to" the fd set operation. More...
 
typedef void(* MyQttIoClearFdGroup )(axlPointer fd_set)
 IO handler definition to allow defining the method to be invoked while clearing a fd set. More...
 
typedef axlPointer(* MyQttIoCreateFdGroup )(MyQttCtx *ctx, MyQttIoWaitingFor wait_to)
 IO handler definition to allow defining the method to be invoked while createing a new fd set. More...
 
typedef void(* MyQttIoDestroyFdGroup )(axlPointer fd_set)
 IO handler definition to allow defining the method to be invoked while destroying a fd set. More...
 
typedef void(* MyQttIoDispatch )(axlPointer fd_group, MyQttIoDispatchFunc dispatch_func, int changed, axlPointer user_data)
 Handler definition for the automatic dispatch implementation for the particular I/O mechanism selected. More...
 
typedef void(* MyQttIoDispatchFunc )(int fds, MyQttIoWaitingFor wait_to, MyQttConn *connection, axlPointer user_data)
 User space handler to implement automatic dispatch for I/O waiting mechanism implemented at myqtt io module. More...
 
typedef axl_bool(* MyQttIoHaveDispatch )(axlPointer fd_group)
 Handler definition to allow implementing the have dispatch function at the myqtt io module. More...
 
typedef axl_bool(* MyQttIoIsSetFdGroup )(int fds, axlPointer fd_group, axlPointer user_data)
 IO handler definition to perform the "is set" the fd set operation. More...
 
typedef int(* MyQttIoWaitOnFdGroup )(axlPointer fd_group, int max_fds, MyQttIoWaitingFor wait_to)
 IO handler definition to allow defining the method to be used while performing a IO blocking wait, by default implemented by the IO "select" call. More...
 
typedef void(* MyQttListenerReady )(const char *host, int port, MyQttStatus status, char *message, MyQttConn *conn, axlPointer user_data)
 Async notification for listener creation. More...
 
typedef void(* MyQttLogHandler )(MyQttCtx *ctx, const char *file, int line, MyQttDebugLevel log_level, const char *message, va_list args, axlPointer user_data)
 Handler definition that allows a client to print log messages itself. More...
 
typedef axl_bool(* MyQttOnAcceptedConnection )(MyQttConn *connection, axlPointer data)
 Async handler definition to get a notification when a new connection is received. More...
 
typedef MyQttConnAckTypes(* MyQttOnConnectHandler )(MyQttCtx *ctx, MyQttConn *conn, axlPointer user_data)
 Set of handlers used by the library to delegate to user level if the provided connection should be accepted. More...
 
typedef void(* MyQttOnFinishHandler )(MyQttCtx *ctx, axlPointer user_data)
 Handler used by myqtt_ctx_set_on_finish which is called when the myqtt reader process detects no more pending connections are available to be watched which is a signal that no more pending work is available. More...
 
typedef axl_bool(* MyQttOnHeaderReceived )(MyQttCtx *ctx, MyQttConn *conn, MyQttMsg *msg, axlPointer user_data)
 Async notification handler called when the message header is received (and before receiving the rest of the message). More...
 
typedef void(* MyQttOnMsgReceived )(MyQttCtx *ctx, MyQttConn *conn, MyQttMsg *msg, axlPointer user_data)
 Async notification handler called to notify a new message received (MyQttMsg) due to a PUBLISH packet. More...
 
typedef void(* MyQttOnMsgSent )(MyQttCtx *ctx, MyQttConn *conn, unsigned char *app_msg, int app_msg_size, MyQttMsgType msg_type, axlPointer user_data)
 Set of handler sdefined at myqtt_conn_set_on_msg_sent that are called when a message is sent completely. More...
 
typedef MyQttPublishCodes(* MyQttOnPublish )(MyQttCtx *ctx, MyQttConn *conn, MyQttMsg *msg, axlPointer user_data)
 Async notification handler that gets called once a PUBLISH message is received on a listener connection. More...
 
typedef void(* MyQttOnReconnect )(MyQttConn *connection, axlPointer data)
 Allows to set a handler that will be called when a reconnect operation took place. More...
 
typedef void(* MyQttOnReleaseMsg )(MyQttCtx *ctx, MyQttConn *conn, const char *client_identifier, int packaet_id, MyQttQos qos, unsigned char *app_msg, int app_msg_size, axlPointer user_data)
 Optional handler that is called by the engine to notify a message is being released. More...
 
typedef axl_bool(* MyQttOnStoreMsg )(MyQttCtx *ctx, MyQttConn *conn, const char *client_identifier, int packet_id, MyQttQos qos, unsigned char *app_msg, int app_msg_size, axlPointer user_data)
 Optional handler that is called by the engine to allow or deny storing the provided message. More...
 
typedef MyQttQos(* MyQttOnSubscribeHandler )(MyQttCtx *ctx, MyQttConn *conn, const char *topic_filter, MyQttQos qos, axlPointer user_data)
 Async notification handler that allows application level to control whether a subscription request should be accepted or not. More...
 
typedef axl_bool(* MyQttOnUnSubscribeHandler )(MyQttCtx *ctx, MyQttConn *conn, const char *topic_filter, axlPointer user_data)
 Async notification handler that is called to notify that a unsubscribe request has been received. More...
 
typedef int(* MyQttPortShareHandler )(MyQttCtx *ctx, MyQttConn *listener, MyQttConn *conn, MYQTT_SOCKET _session, const char *bytes, axlPointer user_data)
 Port sharing handler definition used by those functions that tries to detect alternative transports that must be activated before continue with normal MQTT course. More...
 
typedef void(* MyQttPreRead )(MyQttCtx *ctx, MyQttConn *listener, MyQttConn *conn, MyQttConnOpts *opts, axlPointer user_data)
 Optional Pre-read handler definition that represents the set of functions that are called before any read operation happens on the provided connection. More...
 
typedef int(* MyQttReceive )(MyQttConn *connection, unsigned char *buffer, int buffer_len)
 Defines the readers handlers used to actually received data from the underlying socket descriptor. More...
 
typedef int(* MyQttSend )(MyQttConn *connection, const unsigned char *buffer, int buffer_len)
 Defines the writers handlers used to actually send data through the underlaying socket descriptor. More...
 
typedef axl_bool(* MyQttSessionSetup )(MyQttCtx *ctx, MyQttConn *conn, MyQttConnOpts *opts, axlPointer user_data)
 A handler that is called to establish the session that is going to be used by the provided connetion. More...
 
typedef axl_bool(* MyQttThreadAsyncEvent )(MyQttCtx *ctx, axlPointer user_data, axlPointer user_data2)
 Handler used by async event handlers activated via myqtt_thread_pool_new_event, which causes the handler definition to be called at the provided milliseconds period. More...
 
typedef axl_bool(* MyQttThreadCreateFunc )(MyQttThread *thread_def, MyQttThreadFunc func, axlPointer user_data, va_list args)
 Handler used by MyQtt library to create a new thread. More...
 
typedef axl_bool(* MyQttThreadDestroyFunc )(MyQttThread *thread_def, axl_bool free_data)
 Handler used by MyQtt Library to release a thread's resources. More...
 

Detailed Description