Refactor CEL to avoid using the event system core

This removes usage of the event system for CEL backend data
distribution and strips unused pieces out of the event system.

Review: https://reviewboard.asterisk.org/r/2732/


git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@396888 65c4cc65-6c06-0410-ace0-fbb531ad65f3

1 files changed, 0 insertions, 658 deletions

diff --git a/main/event.c b/main/event.c
index 787f3bc51..0f0406f55 100644
--- a/main/event.c
+++ b/main/event.c
@@ -44,12 +44,9 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
 #include "asterisk/astobj2.h"
 #include "asterisk/cli.h"
 
-static struct ast_taskprocessor *event_dispatcher;
 static int event_append_ie_raw(struct ast_event **event, enum ast_event_ie_type ie_type,
 	const void *data, size_t data_len);
 static const void *event_get_ie_raw(const struct ast_event *event, enum ast_event_ie_type ie_type);
-static uint16_t event_get_ie_raw_payload_len(const struct ast_event *event, enum ast_event_ie_type ie_type);
-static uint32_t event_get_ie_str_hash(const struct ast_event *event, enum ast_event_ie_type ie_type);
 
 /*!
  * \brief An event information element
@@ -112,23 +109,6 @@ struct ast_event_ie_val {
 	size_t raw_datalen;
 };
 
-/*! \brief Event subscription */
-struct ast_event_sub {
-	enum ast_event_type type;
-	ast_event_cb_t cb;
-	char description[64];
-	void *userdata;
-	uint32_t uniqueid;
-	AST_LIST_HEAD_NOLOCK(, ast_event_ie_val) ie_vals;
-	AST_RWDLLIST_ENTRY(ast_event_sub) entry;
-};
-
-static uint32_t sub_uniqueid;
-
-/*! \brief Event subscriptions
- * The event subscribers are indexed by which event they are subscribed to */
-static AST_RWDLLIST_HEAD(ast_event_sub_list, ast_event_sub) ast_event_subs[AST_EVENT_TOTAL];
-
 struct ie_map {
 	enum ast_event_ie_pltype ie_pltype;
 	const char *name;
@@ -217,513 +197,11 @@ size_t ast_event_get_size(const struct ast_event *event)
 	return res;
 }
 
-static void ast_event_ie_val_destroy(struct ast_event_ie_val *ie_val)
-{
-	switch (ie_val->ie_pltype) {
-	case AST_EVENT_IE_PLTYPE_STR:
-		ast_free((char *) ie_val->payload.str);
-		break;
-	case AST_EVENT_IE_PLTYPE_RAW:
-		ast_free(ie_val->payload.raw);
-		break;
-	case AST_EVENT_IE_PLTYPE_UINT:
-	case AST_EVENT_IE_PLTYPE_UNKNOWN:
-		break;
-	}
-
-	ast_free(ie_val);
-}
-
 /*! \brief Subscription event check list. */
 struct ast_ev_check_list {
 	AST_LIST_HEAD_NOLOCK(, ast_event_ie_val) ie_vals;
 };
 
-/*!
- * \internal
- * \brief Check if a subscription ie_val matches an event.
- *
- * \param sub_ie_val Subscripton IE value to check
- * \param check_ie_vals event list to check against
- *
- * \retval 0 not matched
- * \retval non-zero matched
- */
-static int match_sub_ie_val_to_event(const struct ast_event_ie_val *sub_ie_val, const struct ast_ev_check_list *check_ie_vals)
-{
-	const struct ast_event_ie_val *event_ie_val;
-	int res = 0;
-
-	AST_LIST_TRAVERSE(&check_ie_vals->ie_vals, event_ie_val, entry) {
-		if (sub_ie_val->ie_type == event_ie_val->ie_type) {
-			break;
-		}
-	}
-	if (!event_ie_val) {
-		/* We did not find the event ie the subscriber cares about. */
-		return 0;
-	}
-
-	if (sub_ie_val->ie_pltype != event_ie_val->ie_pltype) {
-		/* Payload types do not match. */
-		return 0;
-	}
-
-	switch (sub_ie_val->ie_pltype) {
-	case AST_EVENT_IE_PLTYPE_UINT:
-		res = (sub_ie_val->payload.uint == event_ie_val->payload.uint);
-		break;
-	case AST_EVENT_IE_PLTYPE_STR:
-	{
-		const char *substr = sub_ie_val->payload.str;
-		const char *estr = event_ie_val->payload.str;
-		res = !strcmp(substr, estr);
-		break;
-	}
-	case AST_EVENT_IE_PLTYPE_RAW:
-		res = (sub_ie_val->raw_datalen == event_ie_val->raw_datalen
-			&& !memcmp(sub_ie_val->payload.raw, event_ie_val->payload.raw,
-				sub_ie_val->raw_datalen));
-		break;
-	case AST_EVENT_IE_PLTYPE_UNKNOWN:
-		/*
-		 * Should never be in a subscription event ie val list and
-		 * check_ie_vals cannot have this type either.
-		 */
-		break;
-	}
-
-	return res;
-}
-
-enum ast_event_subscriber_res ast_event_check_subscriber(enum ast_event_type type, ...)
-{
-	va_list ap;
-	enum ast_event_ie_type ie_type;
-	enum ast_event_subscriber_res res = AST_EVENT_SUB_NONE;
-	struct ast_event_ie_val *ie_val;
-	struct ast_event_sub *sub;
-	struct ast_ev_check_list check_ie_vals = {
-		.ie_vals = AST_LIST_HEAD_NOLOCK_INIT_VALUE
-	};
-	const enum ast_event_type event_types[] = { type, AST_EVENT_ALL };
-	int i;
-	int want_specific_event;/* TRUE if looking for subscribers wanting specific parameters. */
-
-	if (type >= AST_EVENT_TOTAL) {
-		ast_log(LOG_ERROR, "%u is an invalid type!\n", type);
-		return res;
-	}
-
-	want_specific_event = 0;
-	va_start(ap, type);
-	for (ie_type = va_arg(ap, enum ast_event_ie_type);
-		ie_type != AST_EVENT_IE_END;
-		ie_type = va_arg(ap, enum ast_event_ie_type))
-	{
-		struct ast_event_ie_val *ie_value = ast_alloca(sizeof(*ie_value));
-		int insert = 0;
-
-		memset(ie_value, 0, sizeof(*ie_value));
-		ie_value->ie_type = ie_type;
-		ie_value->ie_pltype = va_arg(ap, enum ast_event_ie_pltype);
-		switch (ie_value->ie_pltype) {
-		case AST_EVENT_IE_PLTYPE_UINT:
-			ie_value->payload.uint = va_arg(ap, uint32_t);
-			insert = 1;
-			break;
-		case AST_EVENT_IE_PLTYPE_STR:
-			ie_value->payload.str = va_arg(ap, const char *);
-			insert = 1;
-			break;
-		case AST_EVENT_IE_PLTYPE_RAW:
-		{
-			void *data = va_arg(ap, void *);
-			size_t datalen = va_arg(ap, size_t);
-
-			ie_value->payload.raw = ast_alloca(datalen);
-			memcpy(ie_value->payload.raw, data, datalen);
-			ie_value->raw_datalen = datalen;
-			insert = 1;
-			break;
-		}
-		case AST_EVENT_IE_PLTYPE_UNKNOWN:
-			/* Unsupported payload type. */
-			break;
-		}
-
-		if (insert) {
-			want_specific_event = 1;
-			AST_LIST_INSERT_TAIL(&check_ie_vals.ie_vals, ie_value, entry);
-		} else {
-			ast_log(LOG_WARNING, "Unsupported PLTYPE(%d)\n", ie_value->ie_pltype);
-		}
-	}
-	va_end(ap);
-
-	for (i = 0; i < ARRAY_LEN(event_types); i++) {
-		AST_RWDLLIST_RDLOCK(&ast_event_subs[event_types[i]]);
-		if (want_specific_event) {
-			AST_RWDLLIST_TRAVERSE(&ast_event_subs[event_types[i]], sub, entry) {
-				AST_LIST_TRAVERSE(&sub->ie_vals, ie_val, entry) {
-					if (!match_sub_ie_val_to_event(ie_val, &check_ie_vals)) {
-						/* The current subscription ie did not match an event ie. */
-						break;
-					}
-				}
-				if (!ie_val) {
-					/* Everything matched.  A subscriber is looking for this event. */
-					break;
-				}
-			}
-		} else {
-			/* Just looking to see if there are ANY subscribers to the event type. */
-			sub = AST_RWLIST_FIRST(&ast_event_subs[event_types[i]]);
-		}
-		AST_RWDLLIST_UNLOCK(&ast_event_subs[event_types[i]]);
-		if (sub) {
-			break;
-		}
-	}
-
-	return sub ? AST_EVENT_SUB_EXISTS : AST_EVENT_SUB_NONE;
-}
-
-/*!
- * \internal
- * \brief Check if an ie_val matches an event
- *
- * \param event event to check against
- * \param ie_val IE value to check
- * \param event2 optional event, if specified, the value to compare against will be pulled
- *        from this event instead of from the ie_val structure.  In this case, only the IE
- *        type and payload type will be pulled from ie_val.
- *
- * \retval 0 not matched
- * \retval non-zero matched
- */
-static int match_ie_val(const struct ast_event *event,
-		const struct ast_event_ie_val *ie_val, const struct ast_event *event2)
-{
-	switch (ie_val->ie_pltype) {
-	case AST_EVENT_IE_PLTYPE_UINT:
-	{
-		uint32_t val = event2 ? ast_event_get_ie_uint(event2, ie_val->ie_type) : ie_val->payload.uint;
-
-		return (val == ast_event_get_ie_uint(event, ie_val->ie_type)) ? 1 : 0;
-	}
-
-	case AST_EVENT_IE_PLTYPE_STR:
-	{
-		const char *str;
-		uint32_t hash;
-
-		hash = event2 ? event_get_ie_str_hash(event2, ie_val->ie_type) : ie_val->payload.hash;
-		if (hash != event_get_ie_str_hash(event, ie_val->ie_type)) {
-			return 0;
-		}
-
-		str = event2 ? ast_event_get_ie_str(event2, ie_val->ie_type) : ie_val->payload.str;
-		if (str) {
-			const char *e1str, *e2str;
-			e1str = ast_event_get_ie_str(event, ie_val->ie_type);
-			e2str = str;
-
-			if (!strcmp(e1str, e2str)) {
-				return 1;
-			}
-		}
-
-		return 0;
-	}
-
-	case AST_EVENT_IE_PLTYPE_RAW:
-	{
-		const void *buf = event2 ? event_get_ie_raw(event2, ie_val->ie_type) : ie_val->payload.raw;
-		uint16_t ie_payload_len = event2 ? event_get_ie_raw_payload_len(event2, ie_val->ie_type) : ie_val->raw_datalen;
-
-		return (buf
-			&& ie_payload_len == event_get_ie_raw_payload_len(event, ie_val->ie_type)
-			&& !memcmp(buf, event_get_ie_raw(event, ie_val->ie_type), ie_payload_len)) ? 1 : 0;
-	}
-
-	case AST_EVENT_IE_PLTYPE_UNKNOWN:
-		return 0;
-	}
-
-	return 0;
-}
-
-static struct ast_event *gen_sub_event(struct ast_event_sub *sub)
-{
-	struct ast_event_ie_val *ie_val;
-	struct ast_event *event;
-
-	event = ast_event_new(AST_EVENT_SUB,
-		AST_EVENT_IE_UNIQUEID,    AST_EVENT_IE_PLTYPE_UINT, sub->uniqueid,
-		AST_EVENT_IE_EVENTTYPE,   AST_EVENT_IE_PLTYPE_UINT, sub->type,
-		AST_EVENT_IE_DESCRIPTION, AST_EVENT_IE_PLTYPE_STR, sub->description,
-		AST_EVENT_IE_END);
-	if (!event)
-		return NULL;
-
-	AST_LIST_TRAVERSE(&sub->ie_vals, ie_val, entry) {
-		switch (ie_val->ie_pltype) {
-		case AST_EVENT_IE_PLTYPE_UNKNOWN:
-			break;
-		case AST_EVENT_IE_PLTYPE_UINT:
-			ast_event_append_ie_uint(&event, ie_val->ie_type, ie_val->payload.uint);
-			break;
-		case AST_EVENT_IE_PLTYPE_STR:
-			ast_event_append_ie_str(&event, ie_val->ie_type, ie_val->payload.str);
-			break;
-		case AST_EVENT_IE_PLTYPE_RAW:
-			event_append_ie_raw(&event, ie_val->ie_type, ie_val->payload.raw, ie_val->raw_datalen);
-			break;
-		}
-		if (!event)
-			break;
-	}
-
-	return event;
-}
-
-/*! \brief Send AST_EVENT_SUB events to this subscriber of ... subscriber events */
-void ast_event_report_subs(const struct ast_event_sub *event_sub)
-{
-	struct ast_event *event;
-	struct ast_event_sub *sub;
-	enum ast_event_type event_type = -1;
-	struct ast_event_ie_val *ie_val;
-
-	if (event_sub->type != AST_EVENT_SUB)
-		return;
-
-	AST_LIST_TRAVERSE(&event_sub->ie_vals, ie_val, entry) {
-		if (ie_val->ie_type == AST_EVENT_IE_EVENTTYPE) {
-			event_type = ie_val->payload.uint;
-			break;
-		}
-	}
-
-	if (event_type == -1)
-		return;
-
-	AST_RWDLLIST_RDLOCK(&ast_event_subs[event_type]);
-	AST_RWDLLIST_TRAVERSE(&ast_event_subs[event_type], sub, entry) {
-		if (event_sub == sub) {
-			continue;
-		}
-
-		event = gen_sub_event(sub);
-		if (!event) {
-			continue;
-		}
-
-		event_sub->cb(event, event_sub->userdata);
-
-		ast_event_destroy(event);
-	}
-	AST_RWDLLIST_UNLOCK(&ast_event_subs[event_type]);
-}
-
-struct ast_event_sub *ast_event_subscribe_new(enum ast_event_type type,
-	ast_event_cb_t cb, void *userdata)
-{
-	struct ast_event_sub *sub;
-
-	if (type < 0 || type >= AST_EVENT_TOTAL) {
-		ast_log(LOG_ERROR, "%u is an invalid type!\n", type);
-		return NULL;
-	}
-
-	if (!(sub = ast_calloc(1, sizeof(*sub)))) {
-		return NULL;
-	}
-
-	sub->type = type;
-	sub->cb = cb;
-	sub->userdata = userdata;
-	sub->uniqueid = ast_atomic_fetchadd_int((int *) &sub_uniqueid, 1);
-
-	return sub;
-}
-
-int ast_event_sub_append_ie_uint(struct ast_event_sub *sub,
-	enum ast_event_ie_type ie_type, uint32_t unsigned_int)
-{
-	struct ast_event_ie_val *ie_val;
-
-	if (ie_type <= 0 || ie_type >= AST_EVENT_IE_TOTAL) {
-		return -1;
-	}
-
-	if (!(ie_val = ast_calloc(1, sizeof(*ie_val)))) {
-		return -1;
-	}
-
-	ie_val->ie_type = ie_type;
-	ie_val->payload.uint = unsigned_int;
-	ie_val->ie_pltype = AST_EVENT_IE_PLTYPE_UINT;
-
-	AST_LIST_INSERT_TAIL(&sub->ie_vals, ie_val, entry);
-
-	return 0;
-}
-
-int ast_event_sub_append_ie_str(struct ast_event_sub *sub,
-	enum ast_event_ie_type ie_type, const char *str)
-{
-	struct ast_event_ie_val *ie_val;
-
-	if (ie_type <= 0 || ie_type >= AST_EVENT_IE_TOTAL) {
-		return -1;
-	}
-
-	if (!(ie_val = ast_calloc(1, sizeof(*ie_val)))) {
-		return -1;
-	}
-
-	ie_val->ie_type = ie_type;
-	ie_val->ie_pltype = AST_EVENT_IE_PLTYPE_STR;
-
-	if (!(ie_val->payload.str = ast_strdup(str))) {
-		ast_free(ie_val);
-		return -1;
-	}
-
-	ie_val->payload.hash = ast_str_hash(str);
-
-	AST_LIST_INSERT_TAIL(&sub->ie_vals, ie_val, entry);
-
-	return 0;
-}
-
-int ast_event_sub_append_ie_raw(struct ast_event_sub *sub,
-	enum ast_event_ie_type ie_type, void *data, size_t raw_datalen)
-{
-	struct ast_event_ie_val *ie_val;
-
-	if (ie_type <= 0 || ie_type >= AST_EVENT_IE_TOTAL) {
-		return -1;
-	}
-
-	if (!(ie_val = ast_calloc(1, sizeof(*ie_val)))) {
-		return -1;
-	}
-
-	ie_val->ie_type = ie_type;
-	ie_val->ie_pltype = AST_EVENT_IE_PLTYPE_RAW;
-	ie_val->raw_datalen = raw_datalen;
-
-	if (!(ie_val->payload.raw = ast_malloc(raw_datalen))) {
-		ast_free(ie_val);
-		return -1;
-	}
-
-	memcpy(ie_val->payload.raw, data, raw_datalen);
-
-	AST_LIST_INSERT_TAIL(&sub->ie_vals, ie_val, entry);
-
-	return 0;
-}
-
-int ast_event_sub_activate(struct ast_event_sub *sub)
-{
-	if (ast_event_check_subscriber(AST_EVENT_SUB,
-		AST_EVENT_IE_EVENTTYPE, AST_EVENT_IE_PLTYPE_UINT, sub->type,
-		AST_EVENT_IE_END) != AST_EVENT_SUB_NONE) {
-		struct ast_event *event;
-
-		event = gen_sub_event(sub);
-		if (event && ast_event_queue(event)) {
-			ast_event_destroy(event);
-		}
-	}
-
-	AST_RWDLLIST_WRLOCK(&ast_event_subs[sub->type]);
-	AST_RWDLLIST_INSERT_TAIL(&ast_event_subs[sub->type], sub, entry);
-	AST_RWDLLIST_UNLOCK(&ast_event_subs[sub->type]);
-
-	return 0;
-}
-
-struct ast_event_sub *ast_event_subscribe(enum ast_event_type type, ast_event_cb_t cb,
-	const char *description, void *userdata, ...)
-{
-	va_list ap;
-	enum ast_event_ie_type ie_type;
-	struct ast_event_sub *sub;
-
-	if (!(sub = ast_event_subscribe_new(type, cb, userdata))) {
-		return NULL;
-	}
-
-	ast_copy_string(sub->description, description, sizeof(sub->description));
-
-	va_start(ap, userdata);
-	for (ie_type = va_arg(ap, enum ast_event_ie_type);
-		ie_type != AST_EVENT_IE_END;
-		ie_type = va_arg(ap, enum ast_event_ie_type))
-	{
-		enum ast_event_ie_pltype ie_pltype;
-
-		ie_pltype = va_arg(ap, enum ast_event_ie_pltype);
-
-		switch (ie_pltype) {
-		case AST_EVENT_IE_PLTYPE_UNKNOWN:
-			break;
-		case AST_EVENT_IE_PLTYPE_UINT:
-		{
-			uint32_t unsigned_int = va_arg(ap, uint32_t);
-			ast_event_sub_append_ie_uint(sub, ie_type, unsigned_int);
-			break;
-		}
-		case AST_EVENT_IE_PLTYPE_STR:
-		{
-			const char *str = va_arg(ap, const char *);
-			ast_event_sub_append_ie_str(sub, ie_type, str);
-			break;
-		}
-		case AST_EVENT_IE_PLTYPE_RAW:
-		{
-			void *data = va_arg(ap, void *);
-			size_t data_len = va_arg(ap, size_t);
-			ast_event_sub_append_ie_raw(sub, ie_type, data, data_len);
-			break;
-		}
-		}
-	}
-	va_end(ap);
-
-	ast_event_sub_activate(sub);
-
-	return sub;
-}
-
-void ast_event_sub_destroy(struct ast_event_sub *sub)
-{
-	struct ast_event_ie_val *ie_val;
-
-	while ((ie_val = AST_LIST_REMOVE_HEAD(&sub->ie_vals, entry))) {
-		ast_event_ie_val_destroy(ie_val);
-	}
-
-	ast_free(sub);
-}
-
-struct ast_event_sub *ast_event_unsubscribe(struct ast_event_sub *sub)
-{
-
-	AST_RWDLLIST_WRLOCK(&ast_event_subs[sub->type]);
-	AST_DLLIST_REMOVE(&ast_event_subs[sub->type], sub, entry);
-	AST_RWDLLIST_UNLOCK(&ast_event_subs[sub->type]);
-
-	ast_event_sub_destroy(sub);
-
-	return NULL;
-}
-
 int ast_event_iterator_init(struct ast_event_iterator *iterator, const struct ast_event *event)
 {
 	int res = 0;
@@ -770,11 +248,6 @@ static void *event_iterator_get_ie_raw(struct ast_event_iterator *iterator)
 	return iterator->ie->ie_payload;
 }
 
-static uint16_t event_iterator_get_ie_raw_payload_len(struct ast_event_iterator *iterator)
-{
-	return ntohs(iterator->ie->ie_payload_len);
-}
-
 enum ast_event_type ast_event_get_type(const struct ast_event *event)
 {
 	return ntohs(event->type);
@@ -789,15 +262,6 @@ uint32_t ast_event_get_ie_uint(const struct ast_event *event, enum ast_event_ie_
 	return ie_val ? ntohl(get_unaligned_uint32(ie_val)) : 0;
 }
 
-static uint32_t event_get_ie_str_hash(const struct ast_event *event, enum ast_event_ie_type ie_type)
-{
-	const struct ast_event_ie_str_payload *str_payload;
-
-	str_payload = event_get_ie_raw(event, ie_type);
-
-	return str_payload ? str_payload->hash : 0;
-}
-
 const char *ast_event_get_ie_str(const struct ast_event *event, enum ast_event_ie_type ie_type)
 {
 	const struct ast_event_ie_str_payload *str_payload;
@@ -821,20 +285,6 @@ static const void *event_get_ie_raw(const struct ast_event *event, enum ast_even
 	return NULL;
 }
 
-static uint16_t event_get_ie_raw_payload_len(const struct ast_event *event, enum ast_event_ie_type ie_type)
-{
-	struct ast_event_iterator iterator;
-	int res;
-
-	for (res = ast_event_iterator_init(&iterator, event); !res; res = ast_event_iterator_next(&iterator)) {
-		if (ast_event_iterator_get_ie_type(&iterator) == ie_type) {
-			return event_iterator_get_ie_raw_payload_len(&iterator);
-		}
-	}
-
-	return 0;
-}
-
 int ast_event_append_ie_str(struct ast_event **event, enum ast_event_ie_type ie_type,
 	const char *str)
 {
@@ -974,111 +424,3 @@ void ast_event_destroy(struct ast_event *event)
 {
 	ast_free(event);
 }
-
-static int handle_event(void *data)
-{
-	struct ast_event *event = data;
-	struct ast_event_sub *sub;
-	const enum ast_event_type event_types[] = {
-		ntohs(event->type),
-		AST_EVENT_ALL
-	};
-	int i;
-
-	for (i = 0; i < ARRAY_LEN(event_types); i++) {
-		AST_RWDLLIST_RDLOCK(&ast_event_subs[event_types[i]]);
-		AST_RWDLLIST_TRAVERSE(&ast_event_subs[event_types[i]], sub, entry) {
-			struct ast_event_ie_val *ie_val;
-
-			AST_LIST_TRAVERSE(&sub->ie_vals, ie_val, entry) {
-				if (!match_ie_val(event, ie_val, NULL)) {
-					/* The current subscription ie did not match an event ie. */
-					break;
-				}
-			}
-			if (ie_val) {
-				/* The event did not match this subscription. */
-				continue;
-			}
-			sub->cb(event, sub->userdata);
-		}
-		AST_RWDLLIST_UNLOCK(&ast_event_subs[event_types[i]]);
-	}
-
-	ast_event_destroy(event);
-
-	return 0;
-}
-
-int ast_event_queue(struct ast_event *event)
-{
-	uint16_t host_event_type;
-	int res;
-
-	host_event_type = ntohs(event->type);
-
-	/* Invalid type */
-	if (host_event_type >= AST_EVENT_TOTAL) {
-		ast_log(LOG_WARNING, "Someone tried to queue an event of invalid "
-			"type '%d'!\n", host_event_type);
-		return -1;
-	}
-
-	/* If nobody has subscribed to this event type, throw it away now */
-	if (ast_event_check_subscriber(host_event_type, AST_EVENT_IE_END)
-			== AST_EVENT_SUB_NONE) {
-		ast_event_destroy(event);
-		return 0;
-	}
-
-	res = ast_taskprocessor_push(event_dispatcher, handle_event, event);
-	if (res) {
-		ast_event_destroy(event);
-	}
-	return res;
-}
-
-/*! \internal \brief Clean up resources on Asterisk shutdown */
-static void event_shutdown(void)
-{
-	struct ast_event_sub *sub;
-	int i;
-
-	if (event_dispatcher) {
-		event_dispatcher = ast_taskprocessor_unreference(event_dispatcher);
-	}
-
-	/* Remove any remaining subscriptions.  Note that we can't just call
-	 * unsubscribe, as it will attempt to lock the subscription list
-	 * as well */
-	for (i = 0; i < AST_EVENT_TOTAL; i++) {
-		AST_RWDLLIST_WRLOCK(&ast_event_subs[i]);
-		while ((sub = AST_RWDLLIST_REMOVE_HEAD(&ast_event_subs[i], entry))) {
-			ast_event_sub_destroy(sub);
-		}
-		AST_RWDLLIST_UNLOCK(&ast_event_subs[i]);
-		AST_RWDLLIST_HEAD_DESTROY(&ast_event_subs[i]);
-	}
-}
-
-int ast_event_init(void)
-{
-	int i;
-
-	for (i = 0; i < AST_EVENT_TOTAL; i++) {
-		AST_RWDLLIST_HEAD_INIT(&ast_event_subs[i]);
-	}
-
-	if (!(event_dispatcher = ast_taskprocessor_get("core_event_dispatcher", 0))) {
-		goto event_init_cleanup;
-	}
-
-	ast_register_atexit(event_shutdown);
-
-	return 0;
-
-event_init_cleanup:
-	event_shutdown();
-	return -1;
-}
-