diff options
Diffstat (limited to 'src/testbed/gnunet-service-testbed.h')
-rw-r--r-- | src/testbed/gnunet-service-testbed.h | 223 |
1 files changed, 100 insertions, 123 deletions
diff --git a/src/testbed/gnunet-service-testbed.h b/src/testbed/gnunet-service-testbed.h index 5e835392b..d68f8a3e4 100644 --- a/src/testbed/gnunet-service-testbed.h +++ b/src/testbed/gnunet-service-testbed.h | |||
@@ -1,22 +1,22 @@ | |||
1 | /* | 1 | /* |
2 | This file is part of GNUnet. | 2 | This file is part of GNUnet. |
3 | Copyright (C) 2008--2013 GNUnet e.V. | 3 | Copyright (C) 2008--2013 GNUnet e.V. |
4 | 4 | ||
5 | GNUnet is free software: you can redistribute it and/or modify it | 5 | GNUnet is free software: you can redistribute it and/or modify it |
6 | under the terms of the GNU Affero General Public License as published | 6 | under the terms of the GNU Affero General Public License as published |
7 | by the Free Software Foundation, either version 3 of the License, | 7 | by the Free Software Foundation, either version 3 of the License, |
8 | or (at your option) any later version. | 8 | or (at your option) any later version. |
9 | 9 | ||
10 | GNUnet is distributed in the hope that it will be useful, but | 10 | GNUnet is distributed in the hope that it will be useful, but |
11 | WITHOUT ANY WARRANTY; without even the implied warranty of | 11 | WITHOUT ANY WARRANTY; without even the implied warranty of |
12 | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU | 12 | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU |
13 | Affero General Public License for more details. | 13 | Affero General Public License for more details. |
14 | 14 | ||
15 | You should have received a copy of the GNU Affero General Public License | 15 | You should have received a copy of the GNU Affero General Public License |
16 | along with this program. If not, see <http://www.gnu.org/licenses/>. | 16 | along with this program. If not, see <http://www.gnu.org/licenses/>. |
17 | 17 | ||
18 | SPDX-License-Identifier: AGPL3.0-or-later | 18 | SPDX-License-Identifier: AGPL3.0-or-later |
19 | */ | 19 | */ |
20 | 20 | ||
21 | /** | 21 | /** |
22 | * @file testbed/gnunet-service-testbed.h | 22 | * @file testbed/gnunet-service-testbed.h |
@@ -41,14 +41,14 @@ | |||
41 | /** | 41 | /** |
42 | * Generic logging | 42 | * Generic logging |
43 | */ | 43 | */ |
44 | #define LOG(kind,...) \ | 44 | #define LOG(kind, ...) \ |
45 | GNUNET_log (kind, __VA_ARGS__) | 45 | GNUNET_log(kind, __VA_ARGS__) |
46 | 46 | ||
47 | /** | 47 | /** |
48 | * Debug logging | 48 | * Debug logging |
49 | */ | 49 | */ |
50 | #define LOG_DEBUG(...) \ | 50 | #define LOG_DEBUG(...) \ |
51 | LOG (GNUNET_ERROR_TYPE_DEBUG, __VA_ARGS__) | 51 | LOG(GNUNET_ERROR_TYPE_DEBUG, __VA_ARGS__) |
52 | 52 | ||
53 | /** | 53 | /** |
54 | * By how much should the arrays lists grow | 54 | * By how much should the arrays lists grow |
@@ -59,8 +59,7 @@ | |||
59 | /** | 59 | /** |
60 | * A routing entry | 60 | * A routing entry |
61 | */ | 61 | */ |
62 | struct Route | 62 | struct Route { |
63 | { | ||
64 | /** | 63 | /** |
65 | * destination host | 64 | * destination host |
66 | */ | 65 | */ |
@@ -76,8 +75,7 @@ struct Route | |||
76 | /** | 75 | /** |
77 | * Context information for operations forwarded to subcontrollers | 76 | * Context information for operations forwarded to subcontrollers |
78 | */ | 77 | */ |
79 | struct ForwardedOperationContext | 78 | struct ForwardedOperationContext { |
80 | { | ||
81 | /** | 79 | /** |
82 | * The next pointer for DLL | 80 | * The next pointer for DLL |
83 | */ | 81 | */ |
@@ -117,15 +115,13 @@ struct ForwardedOperationContext | |||
117 | * The type of the operation which is forwarded | 115 | * The type of the operation which is forwarded |
118 | */ | 116 | */ |
119 | enum OperationType type; | 117 | enum OperationType type; |
120 | |||
121 | }; | 118 | }; |
122 | 119 | ||
123 | 120 | ||
124 | /** | 121 | /** |
125 | * A DLL of host registrations to be made | 122 | * A DLL of host registrations to be made |
126 | */ | 123 | */ |
127 | struct HostRegistration | 124 | struct HostRegistration { |
128 | { | ||
129 | /** | 125 | /** |
130 | * next registration in the DLL | 126 | * next registration in the DLL |
131 | */ | 127 | */ |
@@ -156,8 +152,7 @@ struct HostRegistration | |||
156 | /** | 152 | /** |
157 | * Context information used while linking controllers | 153 | * Context information used while linking controllers |
158 | */ | 154 | */ |
159 | struct LinkControllersContext | 155 | struct LinkControllersContext { |
160 | { | ||
161 | /** | 156 | /** |
162 | * The client which initiated the link controller operation | 157 | * The client which initiated the link controller operation |
163 | */ | 158 | */ |
@@ -167,20 +162,15 @@ struct LinkControllersContext | |||
167 | * The ID of the operation | 162 | * The ID of the operation |
168 | */ | 163 | */ |
169 | uint64_t operation_id; | 164 | uint64_t operation_id; |
170 | |||
171 | }; | 165 | }; |
172 | 166 | ||
173 | 167 | ||
174 | /** | 168 | /** |
175 | * A peer | 169 | * A peer |
176 | */ | 170 | */ |
177 | struct Peer | 171 | struct Peer { |
178 | { | 172 | union { |
179 | 173 | struct { | |
180 | union | ||
181 | { | ||
182 | struct | ||
183 | { | ||
184 | /** | 174 | /** |
185 | * The peer handle from testing API | 175 | * The peer handle from testing API |
186 | */ | 176 | */ |
@@ -196,11 +186,9 @@ struct Peer | |||
196 | * Is the peer running | 186 | * Is the peer running |
197 | */ | 187 | */ |
198 | int is_running; | 188 | int is_running; |
199 | |||
200 | } local; | 189 | } local; |
201 | 190 | ||
202 | struct | 191 | struct { |
203 | { | ||
204 | /** | 192 | /** |
205 | * The slave this peer is started through | 193 | * The slave this peer is started through |
206 | */ | 194 | */ |
@@ -210,9 +198,7 @@ struct Peer | |||
210 | * The id of the remote host this peer is running on | 198 | * The id of the remote host this peer is running on |
211 | */ | 199 | */ |
212 | uint32_t remote_host_id; | 200 | uint32_t remote_host_id; |
213 | |||
214 | } remote; | 201 | } remote; |
215 | |||
216 | } details; | 202 | } details; |
217 | 203 | ||
218 | /** | 204 | /** |
@@ -242,15 +228,13 @@ struct Peer | |||
242 | * the peer | 228 | * the peer |
243 | */ | 229 | */ |
244 | uint32_t destroy_flag; | 230 | uint32_t destroy_flag; |
245 | |||
246 | }; | 231 | }; |
247 | 232 | ||
248 | 233 | ||
249 | /** | 234 | /** |
250 | * The main context information associated with the client which started us | 235 | * The main context information associated with the client which started us |
251 | */ | 236 | */ |
252 | struct Context | 237 | struct Context { |
253 | { | ||
254 | /** | 238 | /** |
255 | * The client handle associated with this context | 239 | * The client handle associated with this context |
256 | */ | 240 | */ |
@@ -276,8 +260,7 @@ struct Context | |||
276 | /** | 260 | /** |
277 | * The structure for identifying a shared service | 261 | * The structure for identifying a shared service |
278 | */ | 262 | */ |
279 | struct SharedService | 263 | struct SharedService { |
280 | { | ||
281 | /** | 264 | /** |
282 | * The name of the shared service | 265 | * The name of the shared service |
283 | */ | 266 | */ |
@@ -302,8 +285,7 @@ struct RegisteredHostContext; | |||
302 | * Context information to used during operations which forward the overlay | 285 | * Context information to used during operations which forward the overlay |
303 | * connect message | 286 | * connect message |
304 | */ | 287 | */ |
305 | struct ForwardedOverlayConnectContext | 288 | struct ForwardedOverlayConnectContext { |
306 | { | ||
307 | /** | 289 | /** |
308 | * next ForwardedOverlayConnectContext in the DLL | 290 | * next ForwardedOverlayConnectContext in the DLL |
309 | */ | 291 | */ |
@@ -355,8 +337,7 @@ struct ForwardedOverlayConnectContext | |||
355 | * This context information will be created for each host that is registered at | 337 | * This context information will be created for each host that is registered at |
356 | * slave controllers during overlay connects. | 338 | * slave controllers during overlay connects. |
357 | */ | 339 | */ |
358 | struct RegisteredHostContext | 340 | struct RegisteredHostContext { |
359 | { | ||
360 | /** | 341 | /** |
361 | * The host which is being registered | 342 | * The host which is being registered |
362 | */ | 343 | */ |
@@ -380,9 +361,7 @@ struct RegisteredHostContext | |||
380 | /** | 361 | /** |
381 | * Enumeration of states for this context | 362 | * Enumeration of states for this context |
382 | */ | 363 | */ |
383 | enum RHCState | 364 | enum RHCState { |
384 | { | ||
385 | |||
386 | /** | 365 | /** |
387 | * The initial state | 366 | * The initial state |
388 | */ | 367 | */ |
@@ -393,15 +372,13 @@ struct RegisteredHostContext | |||
393 | */ | 372 | */ |
394 | RHC_DONE | 373 | RHC_DONE |
395 | } state; | 374 | } state; |
396 | |||
397 | }; | 375 | }; |
398 | 376 | ||
399 | 377 | ||
400 | /** | 378 | /** |
401 | * Context data for #GNUNET_MESSAGE_TYPE_TESTBED_SHUTDOWN_PEERS handler | 379 | * Context data for #GNUNET_MESSAGE_TYPE_TESTBED_SHUTDOWN_PEERS handler |
402 | */ | 380 | */ |
403 | struct HandlerContext_ShutdownPeers | 381 | struct HandlerContext_ShutdownPeers { |
404 | { | ||
405 | /** | 382 | /** |
406 | * The number of slave we expect to hear from since we forwarded the | 383 | * The number of slave we expect to hear from since we forwarded the |
407 | * #GNUNET_MESSAGE_TYPE_TESTBED_SHUTDOWN_PEERS message to them | 384 | * #GNUNET_MESSAGE_TYPE_TESTBED_SHUTDOWN_PEERS message to them |
@@ -480,13 +457,13 @@ extern char *GST_stats_dir; | |||
480 | * Condition to check if host id is valid | 457 | * Condition to check if host id is valid |
481 | */ | 458 | */ |
482 | #define VALID_HOST_ID(id) \ | 459 | #define VALID_HOST_ID(id) \ |
483 | ( ((id) < GST_host_list_size) && (NULL != GST_host_list[id]) ) | 460 | (((id) < GST_host_list_size) && (NULL != GST_host_list[id])) |
484 | 461 | ||
485 | /** | 462 | /** |
486 | * Condition to check if peer id is valid | 463 | * Condition to check if peer id is valid |
487 | */ | 464 | */ |
488 | #define VALID_PEER_ID(id) \ | 465 | #define VALID_PEER_ID(id) \ |
489 | ( ((id) < GST_peer_list_size) && (NULL != GST_peer_list[id]) ) | 466 | (((id) < GST_peer_list_size) && (NULL != GST_peer_list[id])) |
490 | 467 | ||
491 | 468 | ||
492 | /** | 469 | /** |
@@ -502,15 +479,15 @@ extern char *GST_stats_dir; | |||
502 | */ | 479 | */ |
503 | #define GST_array_grow_large_enough(ptr, size, accommodate_size) \ | 480 | #define GST_array_grow_large_enough(ptr, size, accommodate_size) \ |
504 | do \ | 481 | do \ |
505 | { \ | 482 | { \ |
506 | unsigned int growth_size; \ | 483 | unsigned int growth_size; \ |
507 | GNUNET_assert (size <= accommodate_size); \ | 484 | GNUNET_assert(size <= accommodate_size); \ |
508 | growth_size = size; \ | 485 | growth_size = size; \ |
509 | while (growth_size <= accommodate_size) \ | 486 | while (growth_size <= accommodate_size) \ |
510 | growth_size += LIST_GROW_STEP; \ | 487 | growth_size += LIST_GROW_STEP; \ |
511 | GNUNET_array_grow (ptr, size, growth_size); \ | 488 | GNUNET_array_grow (ptr, size, growth_size); \ |
512 | GNUNET_assert (size > accommodate_size); \ | 489 | GNUNET_assert(size > accommodate_size); \ |
513 | } while (0) | 490 | } while (0) |
514 | 491 | ||
515 | 492 | ||
516 | /** | 493 | /** |
@@ -519,14 +496,14 @@ extern char *GST_stats_dir; | |||
519 | * @param peer the peer structure to destroy | 496 | * @param peer the peer structure to destroy |
520 | */ | 497 | */ |
521 | void | 498 | void |
522 | GST_destroy_peer (struct Peer *peer); | 499 | GST_destroy_peer(struct Peer *peer); |
523 | 500 | ||
524 | 501 | ||
525 | /** | 502 | /** |
526 | * Stops and destroys all peers | 503 | * Stops and destroys all peers |
527 | */ | 504 | */ |
528 | void | 505 | void |
529 | GST_destroy_peers (void); | 506 | GST_destroy_peers(void); |
530 | 507 | ||
531 | 508 | ||
532 | /** | 509 | /** |
@@ -538,7 +515,7 @@ GST_destroy_peers (void); | |||
538 | * is found | 515 | * is found |
539 | */ | 516 | */ |
540 | struct Route * | 517 | struct Route * |
541 | GST_find_dest_route (uint32_t host_id); | 518 | GST_find_dest_route(uint32_t host_id); |
542 | 519 | ||
543 | 520 | ||
544 | /** | 521 | /** |
@@ -548,8 +525,8 @@ GST_find_dest_route (uint32_t host_id); | |||
548 | * @param msg the actual message | 525 | * @param msg the actual message |
549 | */ | 526 | */ |
550 | void | 527 | void |
551 | handle_overlay_connect (void *cls, | 528 | handle_overlay_connect(void *cls, |
552 | const struct GNUNET_TESTBED_OverlayConnectMessage *msg); | 529 | const struct GNUNET_TESTBED_OverlayConnectMessage *msg); |
553 | 530 | ||
554 | 531 | ||
555 | /** | 532 | /** |
@@ -562,9 +539,9 @@ handle_overlay_connect (void *cls, | |||
562 | * @param host the host which has to be registered | 539 | * @param host the host which has to be registered |
563 | */ | 540 | */ |
564 | void | 541 | void |
565 | GST_queue_host_registration (struct Slave *slave, | 542 | GST_queue_host_registration(struct Slave *slave, |
566 | GNUNET_TESTBED_HostRegistrationCompletion cb, | 543 | GNUNET_TESTBED_HostRegistrationCompletion cb, |
567 | void *cb_cls, struct GNUNET_TESTBED_Host *host); | 544 | void *cb_cls, struct GNUNET_TESTBED_Host *host); |
568 | 545 | ||
569 | 546 | ||
570 | /** | 547 | /** |
@@ -574,8 +551,8 @@ GST_queue_host_registration (struct Slave *slave, | |||
574 | * @param msg the message to relay | 551 | * @param msg the message to relay |
575 | */ | 552 | */ |
576 | void | 553 | void |
577 | GST_forwarded_operation_reply_relay (void *cls, | 554 | GST_forwarded_operation_reply_relay(void *cls, |
578 | const struct GNUNET_MessageHeader *msg); | 555 | const struct GNUNET_MessageHeader *msg); |
579 | 556 | ||
580 | 557 | ||
581 | /** | 558 | /** |
@@ -585,14 +562,14 @@ GST_forwarded_operation_reply_relay (void *cls, | |||
585 | * @param tc the task context from scheduler | 562 | * @param tc the task context from scheduler |
586 | */ | 563 | */ |
587 | void | 564 | void |
588 | GST_forwarded_operation_timeout (void *cls); | 565 | GST_forwarded_operation_timeout(void *cls); |
589 | 566 | ||
590 | 567 | ||
591 | /** | 568 | /** |
592 | * Clears the forwarded operations queue | 569 | * Clears the forwarded operations queue |
593 | */ | 570 | */ |
594 | void | 571 | void |
595 | GST_clear_fopcq (void); | 572 | GST_clear_fopcq(void); |
596 | 573 | ||
597 | 574 | ||
598 | /** | 575 | /** |
@@ -603,9 +580,9 @@ GST_clear_fopcq (void); | |||
603 | * @param emsg the error message; can be NULL | 580 | * @param emsg the error message; can be NULL |
604 | */ | 581 | */ |
605 | void | 582 | void |
606 | GST_send_operation_fail_msg (struct GNUNET_SERVICE_Client *client, | 583 | GST_send_operation_fail_msg(struct GNUNET_SERVICE_Client *client, |
607 | uint64_t operation_id, | 584 | uint64_t operation_id, |
608 | const char *emsg); | 585 | const char *emsg); |
609 | 586 | ||
610 | 587 | ||
611 | /** | 588 | /** |
@@ -614,7 +591,7 @@ GST_send_operation_fail_msg (struct GNUNET_SERVICE_Client *client, | |||
614 | * @param client the client that disconnected | 591 | * @param client the client that disconnected |
615 | */ | 592 | */ |
616 | void | 593 | void |
617 | GST_notify_client_disconnect_oc (struct GNUNET_SERVICE_Client *client); | 594 | GST_notify_client_disconnect_oc(struct GNUNET_SERVICE_Client *client); |
618 | 595 | ||
619 | 596 | ||
620 | /** | 597 | /** |
@@ -623,7 +600,7 @@ GST_notify_client_disconnect_oc (struct GNUNET_SERVICE_Client *client); | |||
623 | * @param client the client that disconnected | 600 | * @param client the client that disconnected |
624 | */ | 601 | */ |
625 | void | 602 | void |
626 | GST_notify_client_disconnect_peers (struct GNUNET_SERVICE_Client *client); | 603 | GST_notify_client_disconnect_peers(struct GNUNET_SERVICE_Client *client); |
627 | 604 | ||
628 | 605 | ||
629 | /** | 606 | /** |
@@ -633,8 +610,8 @@ GST_notify_client_disconnect_peers (struct GNUNET_SERVICE_Client *client); | |||
633 | * @param operation_id the id of the operation which was successful | 610 | * @param operation_id the id of the operation which was successful |
634 | */ | 611 | */ |
635 | void | 612 | void |
636 | GST_send_operation_success_msg (struct GNUNET_SERVICE_Client *client, | 613 | GST_send_operation_success_msg(struct GNUNET_SERVICE_Client *client, |
637 | uint64_t operation_id); | 614 | uint64_t operation_id); |
638 | 615 | ||
639 | 616 | ||
640 | /** | 617 | /** |
@@ -645,8 +622,8 @@ GST_send_operation_success_msg (struct GNUNET_SERVICE_Client *client, | |||
645 | * @return #GNUNET_OK if @a msg is well-formed | 622 | * @return #GNUNET_OK if @a msg is well-formed |
646 | */ | 623 | */ |
647 | int | 624 | int |
648 | check_remote_overlay_connect (void *cls, | 625 | check_remote_overlay_connect(void *cls, |
649 | const struct GNUNET_TESTBED_RemoteOverlayConnectMessage *msg); | 626 | const struct GNUNET_TESTBED_RemoteOverlayConnectMessage *msg); |
650 | 627 | ||
651 | 628 | ||
652 | /** | 629 | /** |
@@ -656,8 +633,8 @@ check_remote_overlay_connect (void *cls, | |||
656 | * @param msg the actual message | 633 | * @param msg the actual message |
657 | */ | 634 | */ |
658 | void | 635 | void |
659 | handle_remote_overlay_connect (void *cls, | 636 | handle_remote_overlay_connect(void *cls, |
660 | const struct GNUNET_TESTBED_RemoteOverlayConnectMessage *msg); | 637 | const struct GNUNET_TESTBED_RemoteOverlayConnectMessage *msg); |
661 | 638 | ||
662 | 639 | ||
663 | /** | 640 | /** |
@@ -668,8 +645,8 @@ handle_remote_overlay_connect (void *cls, | |||
668 | * @return #GNUNET_OK if @a msg is well-formed | 645 | * @return #GNUNET_OK if @a msg is well-formed |
669 | */ | 646 | */ |
670 | int | 647 | int |
671 | check_peer_create (void *cls, | 648 | check_peer_create(void *cls, |
672 | const struct GNUNET_TESTBED_PeerCreateMessage *msg); | 649 | const struct GNUNET_TESTBED_PeerCreateMessage *msg); |
673 | 650 | ||
674 | 651 | ||
675 | /** | 652 | /** |
@@ -679,8 +656,8 @@ check_peer_create (void *cls, | |||
679 | * @param message the actual message | 656 | * @param message the actual message |
680 | */ | 657 | */ |
681 | void | 658 | void |
682 | handle_peer_create (void *cls, | 659 | handle_peer_create(void *cls, |
683 | const struct GNUNET_TESTBED_PeerCreateMessage *msg); | 660 | const struct GNUNET_TESTBED_PeerCreateMessage *msg); |
684 | 661 | ||
685 | 662 | ||
686 | /** | 663 | /** |
@@ -690,8 +667,8 @@ handle_peer_create (void *cls, | |||
690 | * @param msg the actual message | 667 | * @param msg the actual message |
691 | */ | 668 | */ |
692 | void | 669 | void |
693 | handle_peer_destroy (void *cls, | 670 | handle_peer_destroy(void *cls, |
694 | const struct GNUNET_TESTBED_PeerDestroyMessage *msg); | 671 | const struct GNUNET_TESTBED_PeerDestroyMessage *msg); |
695 | 672 | ||
696 | 673 | ||
697 | /** | 674 | /** |
@@ -701,8 +678,8 @@ handle_peer_destroy (void *cls, | |||
701 | * @param msg the actual message | 678 | * @param msg the actual message |
702 | */ | 679 | */ |
703 | void | 680 | void |
704 | handle_peer_start (void *cls, | 681 | handle_peer_start(void *cls, |
705 | const struct GNUNET_TESTBED_PeerStartMessage *msg); | 682 | const struct GNUNET_TESTBED_PeerStartMessage *msg); |
706 | 683 | ||
707 | 684 | ||
708 | /** | 685 | /** |
@@ -712,8 +689,8 @@ handle_peer_start (void *cls, | |||
712 | * @param message the actual message | 689 | * @param message the actual message |
713 | */ | 690 | */ |
714 | void | 691 | void |
715 | handle_peer_stop (void *cls, | 692 | handle_peer_stop(void *cls, |
716 | const struct GNUNET_TESTBED_PeerStopMessage *msg); | 693 | const struct GNUNET_TESTBED_PeerStopMessage *msg); |
717 | 694 | ||
718 | 695 | ||
719 | /** | 696 | /** |
@@ -723,8 +700,8 @@ handle_peer_stop (void *cls, | |||
723 | * @param msg the actual message | 700 | * @param msg the actual message |
724 | */ | 701 | */ |
725 | void | 702 | void |
726 | handle_peer_get_config (void *cls, | 703 | handle_peer_get_config(void *cls, |
727 | const struct GNUNET_TESTBED_PeerGetConfigurationMessage *msg); | 704 | const struct GNUNET_TESTBED_PeerGetConfigurationMessage *msg); |
728 | 705 | ||
729 | 706 | ||
730 | /** | 707 | /** |
@@ -734,8 +711,8 @@ handle_peer_get_config (void *cls, | |||
734 | * @param msg the actual message | 711 | * @param msg the actual message |
735 | */ | 712 | */ |
736 | void | 713 | void |
737 | handle_shutdown_peers (void *cls, | 714 | handle_shutdown_peers(void *cls, |
738 | const struct GNUNET_TESTBED_ShutdownPeersMessage *msg); | 715 | const struct GNUNET_TESTBED_ShutdownPeersMessage *msg); |
739 | 716 | ||
740 | 717 | ||
741 | /** | 718 | /** |
@@ -746,8 +723,8 @@ handle_shutdown_peers (void *cls, | |||
746 | * @return #GNUNET_OK if @a msg is well-formed | 723 | * @return #GNUNET_OK if @a msg is well-formed |
747 | */ | 724 | */ |
748 | int | 725 | int |
749 | check_manage_peer_service (void *cls, | 726 | check_manage_peer_service(void *cls, |
750 | const struct GNUNET_TESTBED_ManagePeerServiceMessage *msg); | 727 | const struct GNUNET_TESTBED_ManagePeerServiceMessage *msg); |
751 | 728 | ||
752 | 729 | ||
753 | /** | 730 | /** |
@@ -757,8 +734,8 @@ check_manage_peer_service (void *cls, | |||
757 | * @param msg the actual message | 734 | * @param msg the actual message |
758 | */ | 735 | */ |
759 | void | 736 | void |
760 | handle_manage_peer_service (void *cls, | 737 | handle_manage_peer_service(void *cls, |
761 | const struct GNUNET_TESTBED_ManagePeerServiceMessage *msg); | 738 | const struct GNUNET_TESTBED_ManagePeerServiceMessage *msg); |
762 | 739 | ||
763 | 740 | ||
764 | 741 | ||
@@ -771,8 +748,8 @@ handle_manage_peer_service (void *cls, | |||
771 | * @return #GNUNET_OK if @a msg is well-formed | 748 | * @return #GNUNET_OK if @a msg is well-formed |
772 | */ | 749 | */ |
773 | int | 750 | int |
774 | check_peer_reconfigure (void *cls, | 751 | check_peer_reconfigure(void *cls, |
775 | const struct GNUNET_TESTBED_PeerReconfigureMessage *msg); | 752 | const struct GNUNET_TESTBED_PeerReconfigureMessage *msg); |
776 | 753 | ||
777 | 754 | ||
778 | /** | 755 | /** |
@@ -784,29 +761,29 @@ check_peer_reconfigure (void *cls, | |||
784 | * @param msg the actual message | 761 | * @param msg the actual message |
785 | */ | 762 | */ |
786 | void | 763 | void |
787 | handle_peer_reconfigure (void *cls, | 764 | handle_peer_reconfigure(void *cls, |
788 | const struct GNUNET_TESTBED_PeerReconfigureMessage *msg); | 765 | const struct GNUNET_TESTBED_PeerReconfigureMessage *msg); |
789 | 766 | ||
790 | 767 | ||
791 | /** | 768 | /** |
792 | * Frees the ManageServiceContext queue | 769 | * Frees the ManageServiceContext queue |
793 | */ | 770 | */ |
794 | void | 771 | void |
795 | GST_free_mctxq (void); | 772 | GST_free_mctxq(void); |
796 | 773 | ||
797 | 774 | ||
798 | /** | 775 | /** |
799 | * Cleans up the queue used for forwarding link controllers requests | 776 | * Cleans up the queue used for forwarding link controllers requests |
800 | */ | 777 | */ |
801 | void | 778 | void |
802 | GST_free_lcf (void); | 779 | GST_free_lcf(void); |
803 | 780 | ||
804 | 781 | ||
805 | /** | 782 | /** |
806 | * Cleans up the route list | 783 | * Cleans up the route list |
807 | */ | 784 | */ |
808 | void | 785 | void |
809 | GST_route_list_clear (void); | 786 | GST_route_list_clear(void); |
810 | 787 | ||
811 | 788 | ||
812 | /** | 789 | /** |
@@ -815,7 +792,7 @@ GST_route_list_clear (void); | |||
815 | * @param rhc the RegisteredHostContext | 792 | * @param rhc the RegisteredHostContext |
816 | */ | 793 | */ |
817 | void | 794 | void |
818 | GST_process_next_focc (struct RegisteredHostContext *rhc); | 795 | GST_process_next_focc(struct RegisteredHostContext *rhc); |
819 | 796 | ||
820 | 797 | ||
821 | /** | 798 | /** |
@@ -824,28 +801,28 @@ GST_process_next_focc (struct RegisteredHostContext *rhc); | |||
824 | * @param focc the ForwardedOverlayConnectContext to cleanup | 801 | * @param focc the ForwardedOverlayConnectContext to cleanup |
825 | */ | 802 | */ |
826 | void | 803 | void |
827 | GST_cleanup_focc (struct ForwardedOverlayConnectContext *focc); | 804 | GST_cleanup_focc(struct ForwardedOverlayConnectContext *focc); |
828 | 805 | ||
829 | 806 | ||
830 | /** | 807 | /** |
831 | * Clears all pending overlay connect contexts in queue | 808 | * Clears all pending overlay connect contexts in queue |
832 | */ | 809 | */ |
833 | void | 810 | void |
834 | GST_free_occq (void); | 811 | GST_free_occq(void); |
835 | 812 | ||
836 | 813 | ||
837 | /** | 814 | /** |
838 | * Clears all pending remote overlay connect contexts in queue | 815 | * Clears all pending remote overlay connect contexts in queue |
839 | */ | 816 | */ |
840 | void | 817 | void |
841 | GST_free_roccq (void); | 818 | GST_free_roccq(void); |
842 | 819 | ||
843 | 820 | ||
844 | /** | 821 | /** |
845 | * Cleans up the Peer reconfigure context list | 822 | * Cleans up the Peer reconfigure context list |
846 | */ | 823 | */ |
847 | void | 824 | void |
848 | GST_free_prcq (void); | 825 | GST_free_prcq(void); |
849 | 826 | ||
850 | 827 | ||
851 | /** | 828 | /** |
@@ -854,14 +831,14 @@ GST_free_prcq (void); | |||
854 | * @param size the size of the cache | 831 | * @param size the size of the cache |
855 | */ | 832 | */ |
856 | void | 833 | void |
857 | GST_cache_init (unsigned int size); | 834 | GST_cache_init(unsigned int size); |
858 | 835 | ||
859 | 836 | ||
860 | /** | 837 | /** |
861 | * Clear cache | 838 | * Clear cache |
862 | */ | 839 | */ |
863 | void | 840 | void |
864 | GST_cache_clear (void); | 841 | GST_cache_clear(void); |
865 | 842 | ||
866 | 843 | ||
867 | /** | 844 | /** |
@@ -871,7 +848,7 @@ GST_cache_clear (void); | |||
871 | * @return the HELLO message; NULL if not found | 848 | * @return the HELLO message; NULL if not found |
872 | */ | 849 | */ |
873 | const struct GNUNET_MessageHeader * | 850 | const struct GNUNET_MessageHeader * |
874 | GST_cache_lookup_hello (const unsigned int peer_id); | 851 | GST_cache_lookup_hello(const unsigned int peer_id); |
875 | 852 | ||
876 | 853 | ||
877 | /** | 854 | /** |
@@ -882,8 +859,8 @@ GST_cache_lookup_hello (const unsigned int peer_id); | |||
882 | * @param hello the HELLO message | 859 | * @param hello the HELLO message |
883 | */ | 860 | */ |
884 | void | 861 | void |
885 | GST_cache_add_hello (const unsigned int peer_id, | 862 | GST_cache_add_hello(const unsigned int peer_id, |
886 | const struct GNUNET_MessageHeader *hello); | 863 | const struct GNUNET_MessageHeader *hello); |
887 | 864 | ||
888 | 865 | ||
889 | /** | 866 | /** |
@@ -892,13 +869,13 @@ GST_cache_add_hello (const unsigned int peer_id, | |||
892 | * generated from the hostname and the process's PID. | 869 | * generated from the hostname and the process's PID. |
893 | */ | 870 | */ |
894 | void | 871 | void |
895 | GST_stats_init (const struct GNUNET_CONFIGURATION_Handle *cfg); | 872 | GST_stats_init(const struct GNUNET_CONFIGURATION_Handle *cfg); |
896 | 873 | ||
897 | 874 | ||
898 | /** | 875 | /** |
899 | * Shutdown the status calls module. | 876 | * Shutdown the status calls module. |
900 | */ | 877 | */ |
901 | void | 878 | void |
902 | GST_stats_destroy (void); | 879 | GST_stats_destroy(void); |
903 | 880 | ||
904 | /* End of gnunet-service-testbed.h */ | 881 | /* End of gnunet-service-testbed.h */ |