From: Bart Polot Date: Wed, 25 Jan 2017 12:17:22 +0000 (+0100) Subject: New CADET MQ API draft X-Git-Tag: taler-0.2.1~309^2 X-Git-Url: https://git.librecmc.org/?a=commitdiff_plain;h=f27982470b7d56cd83f5abfc1befa69bc20d952b;p=oweals%2Fgnunet.git New CADET MQ API draft --- diff --git a/src/include/gnunet_cadet_service.h b/src/include/gnunet_cadet_service.h index 68d557d1c..8d10c3d8d 100644 --- a/src/include/gnunet_cadet_service.h +++ b/src/include/gnunet_cadet_service.h @@ -692,6 +692,164 @@ const struct GNUNET_HashCode * GC_u2h (uint32_t port); +/******************************************************************************/ +/******************************* MQ-BASED API *********************************/ +/******************************************************************************/ + +/** + * Function called after #GNUNET_CADET_connecT has succeeded (or failed + * for good). Implementations of this function must not call + * #GNUNET_CADET_disconnecT (other than by scheduling a new task to + * do this later). + * + * @param cls closure + * @param connected #GNUNET_YES if successfully connected, #GNUNET_NO otherwise. + */ +typedef void +(*GNUNET_CADET_StartupCallback) (void *cls, int connected); + + +/** + * Method called whenever a given peer connects in mq-based CADET. + * + * @param cls Closure given to @a GNUNET_CADET_connecT. + * @param channel New handle to the channel. + * @param channel_cls Closure given to @a GNUNET_CADET_open_porT. + * NOTE: do we need two cls? I'd get rid of this one. + * @param peer Peer that started this channel. + * + * NOTE: to keep symmetry between incoming and outgoing channels, this call + * does not provide the *mq, since we cannot cleanly return an mq + * from @a GNUNET_CADET_channel_create. + * The client must always call @a GNUNET_CADET_get_mq to the *mq + * Alternatively, we can provide the mq here and add and out **mq + * to @a GNUNET_CADET_channel_create + * + * @return initial channel context for the channel + * (can be NULL -- that's not an error) + */ +typedef void * +(*GNUNET_CADET_ConnectEventHandler) (void *cls, + struct GNUNET_CADET_Channel *channel, + const struct GNUNET_PeerIdentity *peer); + +/** + * Function called whenever an mq-channel is destroyed. Should clean up + * any associated state, including cancelling any pending transmission on this + * channel. + * + * It must NOT call @a GNUNET_CADET_channel_destroy on the channel. + * + * @param cls Closure (set from @a GNUNET_CADET_connecT). + * @param channel Connection to the other end (henceforth invalid). + * @param channel_ctx Context (set from @a GNUNET_CADET_ConnectEventHandler). + */ +typedef void +(GNUNET_CADET_DisconnectEventHandler) (void *cls, + const struct GNUNET_CADET_Channel *channel, + void *channel_ctx); + +/** + * Connect to the mq-based cadet service. + * + * NOTE: it would be more elegant to provide a separate @a handlers and + * @a disconnects for each port, giving them to @a GNUNET_CADET_open_porT, + * but how do we handle *incoming* channels? + * + * @param cfg Configuration to use. + * @param cls Closure for the various callbacks that follow (including + * handlers in the handlers array). + * @param init callback to call once we have successfully connected + * to the cadet service + * @param disconnects Function called when a channel is destroyed. + * It is called immediately if the channel is destroyed by + * calling @a GNUNET_CADET_channel_destroy. + * @param handlers Callbacks for messages we care about, NULL-terminated. + * Messages of a type that is not in the handlers array + * are ignored if received. + * + * @return handle to the cadet service NULL on error + * (in this case, init is never called) + */ +struct GNUNET_CADET_Handle * +GNUNET_CADET_connecT (const struct GNUNET_CONFIGURATION_Handle *cfg, + void *cls, + GNUNET_CADET_StartupCallback init, + GNUNET_CADET_DisconnectEventHandler disconnects, + const struct GNUNET_MQ_MessageHandler *handlers); + +/** + * Disconnect from the mq-based cadet service. All channels will be destroyed. + * All channel disconnect callbacks will be called on any still connected peers, + * notifying about their disconnection. The registered inbound channel cleaner + * will be called should any inbound channels still exist. + * + * @param handle connection to cadet to disconnect + */ +void +GNUNET_CADET_disconnecT (struct GNUNET_CADET_Handle *handle); + +/** + * Open a port to receive incomming mq-based channels. + * + * @param h CADET handle. + * @param port Hash representing the port number. + * @param new_channel Function called when an channel is received. + * @param new_channel_cls Closure for @a new_channel. + * NOTE: get rid of this cls? + * + * @return Port handle. + */ +struct GNUNET_CADET_Port * +GNUNET_CADET_open_porT (struct GNUNET_CADET_Handle *h, + const struct GNUNET_HashCode *port, + GNUNET_CADET_ConnectEventHandler new_channel, + void *new_channel_cls); + +/** + * Close a port opened with @a GNUNET_CADET_open_porT. + * The @a new_channel callback will no longer be called. + * + * @param p Port handle. + */ +void +GNUNET_CADET_close_porT (struct GNUNET_CADET_Port *p); + +/** + * Obtain the message queue for a connected peer. + * + * @param h the cadet handle + * @param channel the identity of the peer + * + * @return NULL if @a channel is not yet connected. + * NOTE: provide an mq before a channel is connected? + * provide a callback to notify a client a channel connected? + */ +struct GNUNET_MQ_Handle * +GNUNET_CADET_get_mq (const struct GNUNET_CADET_Handle *h, + const struct GNUNET_CADET_Channel *channel); + +/* NOTE: + * GNUNET_CADET_channel_create and _destroy can stay the same. + * Monitor API can stay the same (low-priority). + +struct GNUNET_CADET_Channel * +GNUNET_CADET_channel_create (struct GNUNET_CADET_Handle *h, + void *channel_ctx, + const struct GNUNET_PeerIdentity *peer, + const struct GNUNET_HashCode *port, + enum GNUNET_CADET_ChannelOption options); +void +GNUNET_CADET_channel_destroy (struct GNUNET_CADET_Channel *channel); + +*/ + +/******************************************************************************/ +/******************************* MQ-BASED API *********************************/ +/******************************************************************************/ + + + #if 0 /* keep Emacsens' auto-indent happy */ { #endif