diff options
Diffstat (limited to 'src/set')
-rw-r--r-- | src/set/gnunet-service-set.c | 5 | ||||
-rw-r--r-- | src/set/gnunet-service-set.h | 4 | ||||
-rw-r--r-- | src/set/gnunet-service-set_intersection.c | 2 | ||||
-rw-r--r-- | src/set/gnunet-service-set_union.c | 5 | ||||
-rw-r--r-- | src/set/gnunet-set-profiler.c | 3 | ||||
-rw-r--r-- | src/set/set_api.c | 6 |
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 | */ |
256 | static int | 258 | static 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 | */ |
262 | void | 262 | void |
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 | */ |
292 | void | 292 | void |
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 | */ |
1292 | void | 1292 | void |
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 | */ |
1292 | void | 1293 | void |
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 | ||
39 | static unsigned int salt = 42; | 39 | static unsigned int salt = 42; |
40 | 40 | ||
41 | static char* op_str = "union"; | 41 | static char *op_str = "union"; |
42 | 42 | ||
43 | const static struct GNUNET_CONFIGURATION_Handle *config; | 43 | const 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 | */ |
406 | struct GNUNET_SET_OperationHandle * | 406 | struct GNUNET_SET_OperationHandle * |
407 | GNUNET_SET_accept (struct GNUNET_SET_Request *request, | 407 | GNUNET_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); |