From 2925310d67483aca6e055e1ce0593c6463cd6c72 Mon Sep 17 00:00:00 2001 From: TheJackiMonster Date: Sun, 1 Nov 2020 22:57:28 +0100 Subject: -added core functionality of the messenger service Signed-off-by: TheJackiMonster formatting messenger code Signed-off-by: TheJackiMonster -completed core functionality of messenger service Signed-off-by: TheJackiMonster -code cleanup and reuse Signed-off-by: TheJackiMonster +added structure to memberships of rooms Signed-off-by: TheJackiMonster -implemented member permission checks and deletion of messages Signed-off-by: TheJackiMonster -moved solving requests out of updating last messages (also forward before update) Signed-off-by: TheJackiMonster -reduced complexity of permisson check and changed load/save of rooms Signed-off-by: TheJackiMonster -added save/load for accessed keys and basement peers of a room Signed-off-by: TheJackiMonster -implemented save/load for members with their history and session Signed-off-by: TheJackiMonster -abstracted management of egos and contacts Signed-off-by: TheJackiMonster -fix warning Signed-off-by: TheJackiMonster -abstracted management of members Signed-off-by: TheJackiMonster -fixed and adjusted test case Signed-off-by: TheJackiMonster -separated handling of direct and anonymous contacts Signed-off-by: TheJackiMonster -messenger added member-sessions which fix multiple edge cases, also additional cleanup Signed-off-by: TheJackiMonster -updated docs and fixed memory leak Signed-off-by: TheJackiMonster -changed info messages and added protocol version exchange Signed-off-by: TheJackiMonster -adjusted client api to use contacts from sessions Signed-off-by: TheJackiMonster -added more logging and fixed wrong session usage Signed-off-by: TheJackiMonster -adjusted comm0 test case and removed adding members from checking messages Signed-off-by: TheJackiMonster -fixed test-case for peer exchange Signed-off-by: TheJackiMonster -getting multiple peers connected in test-case with cadet Signed-off-by: TheJackiMonster -fixed wrong assert and added tunnel version check -simplified handling and forwarding Signed-off-by: TheJackiMonster -fixed merging last messages and cycling info messages Signed-off-by: TheJackiMonster -automated adding sessions and members Signed-off-by: TheJackiMonster -corrected use of identity keys and signatures Signed-off-by: TheJackiMonster -adding local joining on entering external room Signed-off-by: TheJackiMonster -fixed test-case comm0 Signed-off-by: TheJackiMonster -added more test-cases with generic setup Signed-off-by: TheJackiMonster -fixed multiple simultaneous channels blocking each other Signed-off-by: TheJackiMonster -making test-cases more precise Signed-off-by: TheJackiMonster -added check of members in test-cases, reduced merge messages Signed-off-by: TheJackiMonster -unified delayed operations: requests, deletions and merges Signed-off-by: TheJackiMonster -finished handling of operations Signed-off-by: TheJackiMonster -fixed member session historystorage, added request permission check and padding for transmission Signed-off-by: TheJackiMonster -improved padding and removed automatic recursive requests Signed-off-by: TheJackiMonster -implemented filter for sending messages and added private messages to API level Signed-off-by: TheJackiMonster -wrong setups fixed with proper ego lookups Signed-off-by: TheJackiMonster -fixed problem with anonymous ego and changed to discrete-level padding Signed-off-by: TheJackiMonster -added links to replace deleted messages, added local deletion and fixed anonymous id changing Signed-off-by: TheJackiMonster -added session completion and removal through completion process Signed-off-by: TheJackiMonster --- src/messenger/testing_messenger_barrier.c | 170 ++++++++++++++++++++++++++++++ 1 file changed, 170 insertions(+) create mode 100644 src/messenger/testing_messenger_barrier.c (limited to 'src/messenger/testing_messenger_barrier.c') 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 . + + 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); +} -- cgit v1.2.3