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
projects / oweals / gnunet.git / commitdiff