123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899 |
- /* Copyright (c) 2007-2019, 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/orconn_event_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,
- };
- static 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);
- }
- const subsys_fns_t sys_orconn_event = {
- .name = "orconn_event",
- .supported = true,
- .level = -33,
- .add_pubsub = orconn_add_pubsub,
- };
|