1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
|
/* Copyright (c) 2007-2020, The Tor Project, Inc. */
/* See LICENSE for licensing information */
/**
* \file orconn_event.c
* \brief Publish state change messages for OR connections
*
* Implements a basic publish-subscribe framework for messages about
* the state of OR connections. The publisher calls the subscriber
* callback functions synchronously.
*
* Although the synchronous calls might not simplify the call graph,
* this approach improves data isolation because the publisher doesn't
* need knowledge about the internals of subscribing subsystems. It
* also avoids race conditions that might occur in asynchronous
* frameworks.
**/
#include "core/or/or.h"
#include "lib/pubsub/pubsub.h"
#include "lib/subsys/subsys.h"
#define ORCONN_EVENT_PRIVATE
#include "core/or/orconn_event.h"
#include "core/or/or_sys.h"
DECLARE_PUBLISH(orconn_state);
DECLARE_PUBLISH(orconn_status);
static void
orconn_event_free(msg_aux_data_t u)
{
tor_free_(u.ptr);
}
static char *
orconn_state_fmt(msg_aux_data_t u)
{
orconn_state_msg_t *msg = (orconn_state_msg_t *)u.ptr;
char *s = NULL;
tor_asprintf(&s, "<gid=%"PRIu64" chan=%"PRIu64" proxy_type=%d state=%d>",
msg->gid, msg->chan, msg->proxy_type, msg->state);
return s;
}
static char *
orconn_status_fmt(msg_aux_data_t u)
{
orconn_status_msg_t *msg = (orconn_status_msg_t *)u.ptr;
char *s = NULL;
tor_asprintf(&s, "<gid=%"PRIu64" status=%d reason=%d>",
msg->gid, msg->status, msg->reason);
return s;
}
static dispatch_typefns_t orconn_state_fns = {
.free_fn = orconn_event_free,
.fmt_fn = orconn_state_fmt,
};
static dispatch_typefns_t orconn_status_fns = {
.free_fn = orconn_event_free,
.fmt_fn = orconn_status_fmt,
};
int
orconn_add_pubsub(struct pubsub_connector_t *connector)
{
if (DISPATCH_REGISTER_TYPE(connector, orconn_state, &orconn_state_fns))
return -1;
if (DISPATCH_REGISTER_TYPE(connector, orconn_status, &orconn_status_fns))
return -1;
if (DISPATCH_ADD_PUB(connector, orconn, orconn_state) != 0)
return -1;
if (DISPATCH_ADD_PUB(connector, orconn, orconn_status) != 0)
return -1;
return 0;
}
void
orconn_state_publish(orconn_state_msg_t *msg)
{
PUBLISH(orconn_state, msg);
}
void
orconn_status_publish(orconn_status_msg_t *msg)
{
PUBLISH(orconn_status, msg);
}
|
