aboutsummaryrefslogtreecommitdiff
path: root/src/set
diff options
context:
space:
mode:
Diffstat (limited to 'src/set')
-rw-r--r--src/set/gnunet-service-set.c5
-rw-r--r--src/set/gnunet-service-set.h4
-rw-r--r--src/set/gnunet-service-set_intersection.c2
-rw-r--r--src/set/gnunet-service-set_union.c5
-rw-r--r--src/set/gnunet-set-profiler.c3
-rw-r--r--src/set/set_api.c6
6 files changed, 15 insertions, 10 deletions
diff --git a/src/set/gnunet-service-set.c b/src/set/gnunet-service-set.c
index 644626dd0..bab29b097 100644
--- a/src/set/gnunet-service-set.c
+++ b/src/set/gnunet-service-set.c
@@ -251,6 +251,8 @@ tunnel_context_destroy (struct TunnelContext *tc)
251 * another peer. 251 * another peer.
252 * 252 *
253 * @param cls the incoming socket 253 * @param cls the incoming socket
254 * @param tunnel the tunnel that sent the message
255 * @param tunnel_ctx the tunnel context
254 * @param mh the message 256 * @param mh the message
255 */ 257 */
256static int 258static int
@@ -524,7 +526,6 @@ handle_client_evaluate (void *cls,
524 return; 526 return;
525 } 527 }
526 528
527
528 switch (set->operation) 529 switch (set->operation)
529 { 530 {
530 case GNUNET_SET_OPERATION_INTERSECTION: 531 case GNUNET_SET_OPERATION_INTERSECTION:
@@ -694,6 +695,8 @@ tunnel_new_cb (void *cls,
694 struct Incoming *incoming; 695 struct Incoming *incoming;
695 struct TunnelContext *tc; 696 struct TunnelContext *tc;
696 697
698 GNUNET_log (GNUNET_ERROR_TYPE_INFO, "new incoming tunnel\n");
699
697 GNUNET_assert (port == GNUNET_APPLICATION_TYPE_SET); 700 GNUNET_assert (port == GNUNET_APPLICATION_TYPE_SET);
698 tc = GNUNET_new (struct TunnelContext); 701 tc = GNUNET_new (struct TunnelContext);
699 incoming = GNUNET_new (struct Incoming); 702 incoming = GNUNET_new (struct Incoming);
diff --git a/src/set/gnunet-service-set.h b/src/set/gnunet-service-set.h
index 937bc9adc..d60b5f477 100644
--- a/src/set/gnunet-service-set.h
+++ b/src/set/gnunet-service-set.h
@@ -257,7 +257,7 @@ _GSS_union_set_create (void);
257 * a remote peer. 257 * a remote peer.
258 * 258 *
259 * @param m the evaluate request message from the client 259 * @param m the evaluate request message from the client
260 * @parem set the set to evaluate the operation with 260 * @param set the set to evaluate the operation with
261 */ 261 */
262void 262void
263_GSS_union_evaluate (struct GNUNET_SET_EvaluateMessage *m, struct Set *set); 263_GSS_union_evaluate (struct GNUNET_SET_EvaluateMessage *m, struct Set *set);
@@ -287,7 +287,7 @@ _GSS_union_remove (struct GNUNET_SET_ElementMessage *m, struct Set *set);
287/** 287/**
288 * Destroy a set that supports the union operation 288 * Destroy a set that supports the union operation
289 * 289 *
290 * @param the set to destroy, must be of type GNUNET_SET_OPERATION_UNION 290 * @param set the set to destroy, must be of type GNUNET_SET_OPERATION_UNION
291 */ 291 */
292void 292void
293_GSS_union_set_destroy (struct Set *set); 293_GSS_union_set_destroy (struct Set *set);
diff --git a/src/set/gnunet-service-set_intersection.c b/src/set/gnunet-service-set_intersection.c
index 411959329..fe3ba56ea 100644
--- a/src/set/gnunet-service-set_intersection.c
+++ b/src/set/gnunet-service-set_intersection.c
@@ -1287,7 +1287,7 @@ _GSS_intersection_add (struct GNUNET_SET_ElementMessage *m, struct Set *set)
1287/** 1287/**
1288 * Destroy a set that supports the union operation 1288 * Destroy a set that supports the union operation
1289 * 1289 *
1290 * @param the set to destroy, must be of type GNUNET_SET_OPERATION_UNION 1290 * @param set the set to destroy, must be of type GNUNET_SET_OPERATION_UNION
1291 */ 1291 */
1292void 1292void
1293_GSS_union_set_destroy (struct Set *set) 1293_GSS_union_set_destroy (struct Set *set)
diff --git a/src/set/gnunet-service-set_union.c b/src/set/gnunet-service-set_union.c
index 294fa3304..670626cd4 100644
--- a/src/set/gnunet-service-set_union.c
+++ b/src/set/gnunet-service-set_union.c
@@ -493,7 +493,8 @@ send_operation_request (struct UnionEvaluateOperation *eo)
493 struct GNUNET_MQ_Envelope *mqm; 493 struct GNUNET_MQ_Envelope *mqm;
494 struct OperationRequestMessage *msg; 494 struct OperationRequestMessage *msg;
495 495
496 mqm = GNUNET_MQ_msg_nested_mh (msg, GNUNET_MESSAGE_TYPE_SET_P2P_OPERATION_REQUEST, eo->context_msg); 496 mqm = GNUNET_MQ_msg_nested_mh (msg, GNUNET_MESSAGE_TYPE_SET_P2P_OPERATION_REQUEST,
497 eo->context_msg);
497 498
498 if (NULL == mqm) 499 if (NULL == mqm)
499 { 500 {
@@ -1287,7 +1288,7 @@ _GSS_union_add (struct GNUNET_SET_ElementMessage *m, struct Set *set)
1287/** 1288/**
1288 * Destroy a set that supports the union operation 1289 * Destroy a set that supports the union operation
1289 * 1290 *
1290 * @param the set to destroy, must be of type GNUNET_SET_OPERATION_UNION 1291 * @param set the set to destroy, must be of type GNUNET_SET_OPERATION_UNION
1291 */ 1292 */
1292void 1293void
1293_GSS_union_set_destroy (struct Set *set) 1294_GSS_union_set_destroy (struct Set *set)
diff --git a/src/set/gnunet-set-profiler.c b/src/set/gnunet-set-profiler.c
index 0a2c2779b..814c9e436 100644
--- a/src/set/gnunet-set-profiler.c
+++ b/src/set/gnunet-set-profiler.c
@@ -38,7 +38,7 @@ static unsigned int num_c = 20;
38 38
39static unsigned int salt = 42; 39static unsigned int salt = 42;
40 40
41static char* op_str = "union"; 41static char *op_str = "union";
42 42
43const static struct GNUNET_CONFIGURATION_Handle *config; 43const static struct GNUNET_CONFIGURATION_Handle *config;
44 44
@@ -157,6 +157,7 @@ set_listen_cb (void *cls,
157 struct GNUNET_SET_Request *request) 157 struct GNUNET_SET_Request *request)
158{ 158{
159 GNUNET_assert (NULL == set_oh2); 159 GNUNET_assert (NULL == set_oh2);
160 GNUNET_log (GNUNET_ERROR_TYPE_INFO, "set listen cb called\n");
160 set_oh2 = GNUNET_SET_accept (request, GNUNET_SET_RESULT_ADDED, 161 set_oh2 = GNUNET_SET_accept (request, GNUNET_SET_RESULT_ADDED,
161 set_result_cb_2, NULL); 162 set_result_cb_2, NULL);
162 GNUNET_SET_commit (set_oh2, set_b); 163 GNUNET_SET_commit (set_oh2, set_b);
diff --git a/src/set/set_api.c b/src/set/set_api.c
index e1b6132cb..370846bae 100644
--- a/src/set/set_api.c
+++ b/src/set/set_api.c
@@ -400,14 +400,14 @@ GNUNET_SET_listen_cancel (struct GNUNET_SET_ListenHandle *lh)
400 * @param result_mode specified how results will be returned, 400 * @param result_mode specified how results will be returned,
401 * see 'GNUNET_SET_ResultMode'. 401 * see 'GNUNET_SET_ResultMode'.
402 * @param result_cb callback for the results 402 * @param result_cb callback for the results
403 * @param cls closure for result_cb 403 * @param result_cls closure for result_cb
404 * @return a handle to cancel the operation 404 * @return a handle to cancel the operation
405 */ 405 */
406struct GNUNET_SET_OperationHandle * 406struct GNUNET_SET_OperationHandle *
407GNUNET_SET_accept (struct GNUNET_SET_Request *request, 407GNUNET_SET_accept (struct GNUNET_SET_Request *request,
408 enum GNUNET_SET_ResultMode result_mode, 408 enum GNUNET_SET_ResultMode result_mode,
409 GNUNET_SET_ResultIterator result_cb, 409 GNUNET_SET_ResultIterator result_cb,
410 void *cls) 410 void *result_cls)
411{ 411{
412 struct GNUNET_MQ_Envelope *mqm; 412 struct GNUNET_MQ_Envelope *mqm;
413 struct GNUNET_SET_OperationHandle *oh; 413 struct GNUNET_SET_OperationHandle *oh;
@@ -418,7 +418,7 @@ GNUNET_SET_accept (struct GNUNET_SET_Request *request,
418 418
419 oh = GNUNET_new (struct GNUNET_SET_OperationHandle); 419 oh = GNUNET_new (struct GNUNET_SET_OperationHandle);
420 oh->result_cb = result_cb; 420 oh->result_cb = result_cb;
421 oh->result_cls = cls; 421 oh->result_cls = result_cls;
422 422
423 mqm = GNUNET_MQ_msg (msg, GNUNET_MESSAGE_TYPE_SET_ACCEPT); 423 mqm = GNUNET_MQ_msg (msg, GNUNET_MESSAGE_TYPE_SET_ACCEPT);
424 msg->accept_reject_id = htonl (request->accept_id); 424 msg->accept_reject_id = htonl (request->accept_id);