diff options
author | TheJackiMonster <thejackimonster@gmail.com> | 2020-11-01 22:57:28 +0100 |
---|---|---|
committer | TheJackiMonster <thejackimonster@gmail.com> | 2021-03-06 01:30:37 +0100 |
commit | 2925310d67483aca6e055e1ce0593c6463cd6c72 (patch) | |
tree | 2cc8aacafc25563cdccde2eee9a90f9ca257d405 /src/messenger/testing_messenger_barrier.c | |
parent | 82b864a64679b0a735201724907cdf2b7e4e16c3 (diff) |
-added core functionality of the messenger service
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
formatting messenger code
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-completed core functionality of messenger service
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-code cleanup and reuse
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
+added structure to memberships of rooms
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-implemented member permission checks and deletion of messages
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-moved solving requests out of updating last messages (also forward before update)
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-reduced complexity of permisson check and changed load/save of rooms
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-added save/load for accessed keys and basement peers of a room
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-implemented save/load for members with their history and session
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-abstracted management of egos and contacts
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-fix warning
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-abstracted management of members
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-fixed and adjusted test case
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-separated handling of direct and anonymous contacts
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-messenger added member-sessions which fix multiple edge cases, also additional cleanup
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-updated docs and fixed memory leak
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-changed info messages and added protocol version exchange
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-adjusted client api to use contacts from sessions
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-added more logging and fixed wrong session usage
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-adjusted comm0 test case and removed adding members from checking messages
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-fixed test-case for peer exchange
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-getting multiple peers connected in test-case with cadet
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-fixed wrong assert and added tunnel version check
-simplified handling and forwarding
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-fixed merging last messages and cycling info messages
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-automated adding sessions and members
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-corrected use of identity keys and signatures
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-adding local joining on entering external room
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-fixed test-case comm0
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-added more test-cases with generic setup
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-fixed multiple simultaneous channels blocking each other
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-making test-cases more precise
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-added check of members in test-cases, reduced merge messages
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-unified delayed operations: requests, deletions and merges
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-finished handling of operations
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-fixed member session historystorage, added request permission check and padding for transmission
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-improved padding and removed automatic recursive requests
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-implemented filter for sending messages and added private messages to API level
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-wrong setups fixed with proper ego lookups
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-fixed problem with anonymous ego and changed to discrete-level padding
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-added links to replace deleted messages, added local deletion and fixed anonymous id changing
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
-added session completion and removal through completion process
Signed-off-by: TheJackiMonster <thejackimonster@gmail.com>
Diffstat (limited to 'src/messenger/testing_messenger_barrier.c')
-rw-r--r-- | src/messenger/testing_messenger_barrier.c | 170 |
1 files changed, 170 insertions, 0 deletions
diff --git a/src/messenger/testing_messenger_barrier.c b/src/messenger/testing_messenger_barrier.c new file mode 100644 index 000000000..618d255b7 --- /dev/null +++ b/src/messenger/testing_messenger_barrier.c @@ -0,0 +1,170 @@ +/* + This file is part of GNUnet. + Copyright (C) 2021 GNUnet e.V. + + GNUnet is free software: you can redistribute it and/or modify it + under the terms of the GNU Affero General Public License as published + by the Free Software Foundation, either version 3 of the License, + or (at your option) any later version. + + GNUnet is distributed in the hope that it will be useful, but + WITHOUT ANY WARRANTY; without even the implied warranty of + MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU + Affero General Public License for more details. + + You should have received a copy of the GNU Affero General Public License + along with this program. If not, see <http://www.gnu.org/licenses/>. + + SPDX-License-Identifier: AGPL3.0-or-later + */ +/** + * @file messenger/testing_messenger_barrier.c + * @author Tobias Frisch + * @brief Pseudo-barriers for simple event handling + */ + +#include "testing_messenger_barrier.h" + +struct GNUNET_BarrierHandle +{ + unsigned int requirement; + GNUNET_BarrierStatusCallback cb; + void *cls; + + struct GNUNET_BarrierWaitHandle *head; + struct GNUNET_BarrierWaitHandle *tail; + + struct GNUNET_SCHEDULER_Task* task; +}; + +struct GNUNET_BarrierHandle* +GNUNET_init_barrier (unsigned int requirement, + GNUNET_BarrierStatusCallback cb, + void *cb_cls) +{ + if (0 == requirement) + return NULL; + + struct GNUNET_BarrierHandle *barrier = GNUNET_new(struct GNUNET_BarrierHandle); + + if (!barrier) + return NULL; + + barrier->requirement = requirement; + barrier->cb = cb; + barrier->cls = cb_cls; + barrier->head = NULL; + barrier->tail = NULL; + barrier->task = NULL; + + return barrier; +} + +static void +exit_status (struct GNUNET_BarrierHandle *barrier, int status); + +static void +cancel_barrier (void *cls) +{ + exit_status ((struct GNUNET_BarrierHandle*) cls, GNUNET_SYSERR); +} + +static void +complete_barrier (void *cls) +{ + exit_status ((struct GNUNET_BarrierHandle*) cls, GNUNET_OK); +} + +void +GNUNET_cancel_barrier (struct GNUNET_BarrierHandle *barrier) +{ + if ((!barrier) || (barrier->task)) + return; + + barrier->task = GNUNET_SCHEDULER_add_now(cancel_barrier, barrier); +} + +struct GNUNET_BarrierWaitHandle +{ + GNUNET_BarrierWaitStatusCallback cb; + void *cls; + + struct GNUNET_BarrierWaitHandle *prev; + struct GNUNET_BarrierWaitHandle *next; + + struct GNUNET_BarrierHandle *barrier; +}; + +static void +exit_status (struct GNUNET_BarrierHandle *barrier, int status) +{ + struct GNUNET_BarrierWaitHandle *waiting = barrier->head; + while (waiting) + { + struct GNUNET_BarrierWaitHandle *current = waiting; + + if (current->cb) + current->cb(current->cls, current, status); + + waiting = waiting->next; + + GNUNET_CONTAINER_DLL_remove(barrier->head, barrier->tail, current); + GNUNET_free(current); + } + + if (barrier->cb) + barrier->cb(barrier->cls, barrier, status); + + GNUNET_free(barrier); +} + +struct GNUNET_BarrierWaitHandle* +GNUNET_wait_barrier (struct GNUNET_BarrierHandle *barrier, + GNUNET_BarrierWaitStatusCallback cb, + void *cb_cls) +{ + if ((!barrier) || (0 == barrier->requirement)) + return NULL; + + struct GNUNET_BarrierWaitHandle *waiting = GNUNET_new(struct GNUNET_BarrierWaitHandle); + + if (!waiting) + return NULL; + + waiting->cb = cb; + waiting->cls = cb_cls; + waiting->prev = NULL; + waiting->next = NULL; + waiting->barrier = barrier; + + GNUNET_CONTAINER_DLL_insert_tail(barrier->head, barrier->tail, waiting); + barrier->requirement--; + + if ((barrier->requirement == 0) && (!barrier->task)) + barrier->task = GNUNET_SCHEDULER_add_now(complete_barrier, barrier); + + return waiting; +} + +void +GNUNET_cancel_wait_barrier (struct GNUNET_BarrierWaitHandle *waiting) +{ + if (!waiting) + return; + + struct GNUNET_BarrierHandle *barrier = waiting->barrier; + + if (!barrier) + return; + + if ((barrier->requirement == 0) && (barrier->task)) + { + GNUNET_SCHEDULER_cancel(barrier->task); + barrier->task = NULL; + } + + barrier->requirement++; + GNUNET_CONTAINER_DLL_remove(barrier->head, barrier->tail, waiting); + + GNUNET_free(waiting); +} |