{
GNUNET_SCALARPRODUCT_Status_Success = 0,
GNUNET_SCALARPRODUCT_Status_Failure,
- GNUNET_SCALARPRODUCT_Status_Timeout,
GNUNET_SCALARPRODUCT_Status_InvalidResponse,
GNUNET_SCALARPRODUCT_Status_ServiceDisconnected
};
-struct GNUNET_SCALARPRODUCT_Handle
-{
- /**
- * Our configuration.
- */
- const struct GNUNET_CONFIGURATION_Handle *cfg;
-
- /**
- * Current connection to the scalarproduct service.
- */
- struct GNUNET_CLIENT_Connection *client;
-
- /**
- * Handle for statistics.
- */
- struct GNUNET_STATISTICS_Handle *stats;
-
- /**
- * Current transmit handle.
- */
- struct GNUNET_CLIENT_TransmitHandle *th;
-
- /**
- * Handle to the master context.
- */
- struct GNUNET_SCALARPRODUCT_Handle *h;
-
- /**
- * The shared session key identifying this computation
- */
- struct GNUNET_HashCode * key;
-
- /**
- * The message to be transmitted
- */
- void * msg;
-
- union
- {
- /**
- * Function to call after transmission of the request.
- */
- GNUNET_SCALARPRODUCT_ContinuationWithStatus cont_status;
-
- /**
- * Function to call after transmission of the request.
- */
- GNUNET_SCALARPRODUCT_DatumProcessor cont_datum;
- };
-
- /**
- * Closure for 'cont'.
- */
- void *cont_cls;
-
- /**
- * Response Processor for response from the service. This function calls the
- * continuation function provided by the client.
- */
- GNUNET_SCALARPRODUCT_ResponseMessageHandler response_proc;
-};
+struct GNUNET_SCALARPRODUCT_Handle;
typedef void (*GNUNET_SCALARPRODUCT_ResponseMessageHandler) (void *cls,
const struct GNUNET_MessageHeader *msg,
enum GNUNET_SCALARPRODUCT_ResponseStatus status);
/**
* Process a datum that was stored in the scalarproduct.
- *
+ *
* @param cls closure
* @param status Status of the request
* @param type result of the computation
/**
* Request by Alice's client for computing a scalar product
- *
+ *
* @param h handle to the master context
* @param key Session key - unique to the requesting client
* @param peer PeerID of the other peer
* @param cont Callback function
* @param cont_cls Closure for the callback function
*/
-struct GNUNET_SCALARPRODUCT_Handle *
-GNUNET_SCALARPRODUCT_request (const struct GNUNET_CONFIGURATION_Handle *h,
+struct GNUNET_SCALARPRODUCT_ComputationHandle *
+GNUNET_SCALARPRODUCT_request (const struct GNUNET_CONFIGURATION_Handle *cfg,
const struct GNUNET_HashCode * key,
const struct GNUNET_PeerIdentity *peer,
const int32_t * elements,
void *cont_cls);
/**
- * Used by Bob's client to cooperate with Alice,
- *
- * @param h handle to the master context
+ * Used by Bob's client to cooperate with Alice,
+ *
+ * @param h handle to our configuration
* @param key Session key - unique to the requesting client
* @param elements Array of elements of the vector
* @param element_count Number of elements in the vector
* @param cont Callback function
* @param cont_cls Closure for the callback function
*/
-struct GNUNET_SCALARPRODUCT_Handle *
-GNUNET_SCALARPRODUCT_response (const struct GNUNET_CONFIGURATION_Handle *h,
+struct GNUNET_SCALARPRODUCT_ComputationHandle *
+GNUNET_SCALARPRODUCT_response (const struct GNUNET_CONFIGURATION_Handle *cfg,
const struct GNUNET_HashCode * key,
const int32_t * elements,
uint32_t element_count,
/**
* Cancel an ongoing computation or revoke our collaboration offer.
* Closes the connection to the service
- *
+ *
* @param h handel to terminate
*/
-void
-GNUNET_SCALARPRODUCT_cancel (const struct GNUNET_SCALARPRODUCT_Handle *h);
+void
+GNUNET_SCALARPRODUCT_cancel (struct GNUNET_SCALARPRODUCT_ComputationHandle * h);
+
+/**
+ * Cancel ALL ongoing computation or revoke our collaboration offer.
+ * Closes ALL connections to the service
+ *
+ */
+void
+GNUNET_SCALARPRODUCT_disconnect ();
#if 0 /* keep Emacsens' auto-indent happy */
{