GNUnet 0.22.2
gnunet-service-messenger_subscription.h File Reference
#include "gnunet_util_lib.h"
Include dependency graph for gnunet-service-messenger_subscription.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures

struct  GNUNET_MESSENGER_Subscription
 

Functions

struct GNUNET_MESSENGER_Subscriptioncreate_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)
 
void destroy_subscription (struct GNUNET_MESSENGER_Subscription *subscribtion)
 
const struct GNUNET_ShortHashCodeget_subscription_discourse (const struct GNUNET_MESSENGER_Subscription *subscribtion)
 
enum GNUNET_GenericReturnValue has_subscription_of_timestamp (const struct GNUNET_MESSENGER_Subscription *subscribtion, struct GNUNET_TIME_Absolute timestamp)
 
void update_subscription (struct GNUNET_MESSENGER_Subscription *subscribtion, struct GNUNET_TIME_Absolute timestamp, struct GNUNET_TIME_Relative duration)
 
void update_subscription_timing (struct GNUNET_MESSENGER_Subscription *subscribtion)
 

Function Documentation

◆ create_subscription()

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 
)

Definition at line 33 of file gnunet-service-messenger_subscription.c.

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}
static uint64_t timestamp(void)
Get current timestamp.
static struct GNUNET_TIME_Relative duration
Option '-d': duration of the mapping.
Definition: gnunet-vpn.c:90
#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.
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
A 256-bit hashcode.

References GNUNET_MESSENGER_Subscription::discourse, duration, GNUNET_MESSENGER_Subscription::end, GNUNET_assert, GNUNET_new, GNUNET_TIME_absolute_add(), GNUNET_MESSENGER_Subscription::member, GNUNET_MESSENGER_Subscription::room, GNUNET_MESSENGER_Subscription::start, GNUNET_MESSENGER_Subscription::task, and timestamp().

Referenced by handle_message_subscribe().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ destroy_subscription()

void destroy_subscription ( struct GNUNET_MESSENGER_Subscription subscribtion)

Definition at line 61 of file gnunet-service-messenger_subscription.c.

62{
63 GNUNET_assert (subscribtion);
64
65 if (subscribtion->task)
66 GNUNET_SCHEDULER_cancel (subscribtion->task);
67
68 GNUNET_free (subscribtion);
69}
#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

References GNUNET_assert, GNUNET_free, GNUNET_SCHEDULER_cancel(), and GNUNET_MESSENGER_Subscription::task.

Referenced by iterate_destroy_subscription(), and task_subscription_exit().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ get_subscription_discourse()

const struct GNUNET_ShortHashCode * get_subscription_discourse ( const struct GNUNET_MESSENGER_Subscription subscribtion)

Definition at line 72 of file gnunet-service-messenger_subscription.c.

73{
74 GNUNET_assert (subscribtion);
75
76 return &(subscribtion->discourse);
77}

References GNUNET_MESSENGER_Subscription::discourse, and GNUNET_assert.

Referenced by add_member_subscription(), and remove_member_subscription().

Here is the caller graph for this function:

◆ has_subscription_of_timestamp()

enum GNUNET_GenericReturnValue has_subscription_of_timestamp ( const struct GNUNET_MESSENGER_Subscription subscribtion,
struct GNUNET_TIME_Absolute  timestamp 
)

Definition at line 80 of file gnunet-service-messenger_subscription.c.

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}
@ GNUNET_YES
@ GNUNET_NO
#define GNUNET_TIME_absolute_cmp(t1, op, t2)
Compare two absolute times.

References GNUNET_MESSENGER_Subscription::end, GNUNET_assert, GNUNET_NO, GNUNET_TIME_absolute_cmp, GNUNET_YES, GNUNET_MESSENGER_Subscription::start, and timestamp().

Referenced by notify_srv_handle_message().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ update_subscription()

void update_subscription ( struct GNUNET_MESSENGER_Subscription subscribtion,
struct GNUNET_TIME_Absolute  timestamp,
struct GNUNET_TIME_Relative  duration 
)

Definition at line 93 of file gnunet-service-messenger_subscription.c.

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}
static int end
Set if we are to shutdown all services (including ARM).
Definition: gnunet-arm.c:33
Time for absolute times used by GNUnet, in microseconds.

References duration, end, GNUNET_MESSENGER_Subscription::end, GNUNET_assert, GNUNET_TIME_absolute_add(), GNUNET_TIME_absolute_cmp, GNUNET_MESSENGER_Subscription::start, and timestamp().

Referenced by handle_message_subscribe().

Here is the call graph for this function:
Here is the caller graph for this function:

◆ update_subscription_timing()

void update_subscription_timing ( struct GNUNET_MESSENGER_Subscription subscribtion)

Definition at line 142 of file gnunet-service-messenger_subscription.c.

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 void task_subscription_exit(void *cls)
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
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
Time for relative time used by GNUnet, in microseconds.

References GNUNET_MESSENGER_Subscription::end, GNUNET_assert, GNUNET_SCHEDULER_add_delayed(), GNUNET_SCHEDULER_cancel(), GNUNET_TIME_absolute_get(), GNUNET_TIME_absolute_get_difference(), GNUNET_MESSENGER_Subscription::task, and task_subscription_exit().

Referenced by handle_message_subscribe().

Here is the call graph for this function:
Here is the caller graph for this function: