GNUnet 0.22.0
gnunet-service-messenger_subscription.c
Go to the documentation of this file.
1/*
2 This file is part of GNUnet.
3 Copyright (C) 2024 GNUnet e.V.
4
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
7 by the Free Software Foundation, either version 3 of the License,
8 or (at your option) any later version.
9
10 GNUnet is distributed in the hope that it will be useful, but
11 WITHOUT ANY WARRANTY; without even the implied warranty of
12 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 Affero General Public License for more details.
14
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/>.
17
18 SPDX-License-Identifier: AGPL3.0-or-later
19 */
26#include "platform.h"
28
31
35 const struct GNUNET_ShortHashCode *discourse,
38{
39 struct GNUNET_MESSENGER_Subscription *subscribtion;
40
41 GNUNET_assert ((room) && (member) && (discourse));
42
43 subscribtion = GNUNET_new (struct GNUNET_MESSENGER_Subscription);
44
45 if (! subscribtion)
46 return NULL;
47
48 subscribtion->room = room;
49 subscribtion->member = member;
50 subscribtion->task = NULL;
51
52 memcpy (&(subscribtion->discourse), discourse, sizeof (struct GNUNET_ShortHashCode));
53
54 subscribtion->start = timestamp;
56
57 return subscribtion;
58}
59
60void
62{
63 GNUNET_assert (subscribtion);
64
65 if (subscribtion->task)
66 GNUNET_SCHEDULER_cancel (subscribtion->task);
67
68 GNUNET_free (subscribtion);
69}
70
71const struct GNUNET_ShortHashCode*
73{
74 GNUNET_assert (subscribtion);
75
76 return &(subscribtion->discourse);
77}
78
82{
83 GNUNET_assert (subscribtion);
84
85 if ((GNUNET_TIME_absolute_cmp (timestamp, <, subscribtion->start)) ||
86 (GNUNET_TIME_absolute_cmp (timestamp, >, subscribtion->end)))
87 return GNUNET_NO;
88 else
89 return GNUNET_YES;
90}
91
92void
96{
98
99 GNUNET_assert (subscribtion);
100
102
103 if (GNUNET_TIME_absolute_cmp (end, <, subscribtion->start))
104 return;
105
106 if (GNUNET_TIME_absolute_cmp (timestamp, <, subscribtion->start))
107 subscribtion->start = timestamp;
108
109 subscribtion->end = end;
110}
111
112static void
114{
115 struct GNUNET_MESSENGER_Subscription *subscribtion;
116 struct GNUNET_MESSENGER_Member *member;
117 struct GNUNET_MESSENGER_SrvRoom *room;
118 struct GNUNET_ShortHashCode discourse;
119
120 GNUNET_assert (cls);
121
122 subscribtion = cls;
123 member = subscribtion->member;
124
125 subscribtion->task = NULL;
126
127 if (! member)
128 return;
129
130 room = subscribtion->room;
131
132 memcpy (&discourse, &(subscribtion->discourse),
133 sizeof (struct GNUNET_ShortHashCode));
134
135 remove_member_subscription (member, subscribtion);
136 destroy_subscription (subscribtion);
137
138 cleanup_srv_room_discourse_messages (room, &discourse);
139}
140
141void
143{
144 struct GNUNET_TIME_Absolute current;
145 struct GNUNET_TIME_Relative time;
146
147 GNUNET_assert (subscribtion);
148
149 current = GNUNET_TIME_absolute_get ();
150 time = GNUNET_TIME_absolute_get_difference (current, subscribtion->end);
151
152 if (subscribtion->task)
153 GNUNET_SCHEDULER_cancel (subscribtion->task);
154
155 subscribtion->task =
157}
static int end
Set if we are to shutdown all services (including ARM).
Definition: gnunet-arm.c:33
static uint64_t timestamp(void)
Get current timestamp.
void remove_member_subscription(struct GNUNET_MESSENGER_Member *member, struct GNUNET_MESSENGER_Subscription *subscription)
Removes a given subscription from a member.
void cleanup_srv_room_discourse_messages(struct GNUNET_MESSENGER_SrvRoom *room, const struct GNUNET_ShortHashCode *discourse)
Cleanup discourse messages outside of current subscriptions from a specific discourse of all the memb...
void update_subscription(struct GNUNET_MESSENGER_Subscription *subscribtion, struct GNUNET_TIME_Absolute timestamp, struct GNUNET_TIME_Relative duration)
static void task_subscription_exit(void *cls)
enum GNUNET_GenericReturnValue has_subscription_of_timestamp(const struct GNUNET_MESSENGER_Subscription *subscribtion, struct GNUNET_TIME_Absolute timestamp)
void update_subscription_timing(struct GNUNET_MESSENGER_Subscription *subscribtion)
const struct GNUNET_ShortHashCode * get_subscription_discourse(const struct GNUNET_MESSENGER_Subscription *subscribtion)
void destroy_subscription(struct GNUNET_MESSENGER_Subscription *subscribtion)
struct GNUNET_MESSENGER_Subscription * create_subscription(struct GNUNET_MESSENGER_SrvRoom *room, struct GNUNET_MESSENGER_Member *member, const struct GNUNET_ShortHashCode *discourse, struct GNUNET_TIME_Absolute timestamp, struct GNUNET_TIME_Relative duration)
static struct GNUNET_TIME_Relative duration
Option '-d': duration of the mapping.
Definition: gnunet-vpn.c:90
GNUNET_GenericReturnValue
Named constants for return values.
@ GNUNET_YES
@ GNUNET_NO
#define GNUNET_assert(cond)
Use this for fatal errors that cannot be handled.
#define GNUNET_new(type)
Allocate a struct or union of the given type.
#define GNUNET_free(ptr)
Wrapper around free.
void * GNUNET_SCHEDULER_cancel(struct GNUNET_SCHEDULER_Task *task)
Cancel the task with the specified identifier.
Definition: scheduler.c:979
struct GNUNET_SCHEDULER_Task * GNUNET_SCHEDULER_add_delayed(struct GNUNET_TIME_Relative delay, GNUNET_SCHEDULER_TaskCallback task, void *task_cls)
Schedule a new task to be run with a specified delay.
Definition: scheduler.c:1276
struct GNUNET_TIME_Absolute GNUNET_TIME_absolute_get(void)
Get the current time.
Definition: time.c:111
#define GNUNET_TIME_absolute_cmp(t1, op, t2)
Compare two absolute times.
struct GNUNET_TIME_Absolute GNUNET_TIME_absolute_add(struct GNUNET_TIME_Absolute start, struct GNUNET_TIME_Relative duration)
Add a given relative duration to the given start time.
Definition: time.c:452
struct GNUNET_TIME_Relative GNUNET_TIME_absolute_get_difference(struct GNUNET_TIME_Absolute start, struct GNUNET_TIME_Absolute end)
Compute the time difference between the given start and end times.
Definition: time.c:423
A 256-bit hashcode.
Time for absolute times used by GNUnet, in microseconds.
Time for relative time used by GNUnet, in microseconds.