Sapian
/
asterisk
mirror of http://gerrit.asterisk.org/asterisk
3
0
Fork 0
Code Issues Releases Wiki Activity

Strip down the old event system

Browse Source 
This removes unused code, event types, IE pltypes, and event IE types
where possible and makes several functions private that were once
public. This includes a renumbering of the remaining event and IE types
which breaks binary compatibility with previous versions. The last
remaining consumers of the old event system (or parts thereof) are
main/security_events.c, res/res_security_log.c, tests/test_cel.c,
tests/test_event.c, main/cel.c, and the CEL backends.

Review: https://reviewboard.asterisk.org/r/2703/
(closes issue ASTERISK-22139)


git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@396887 65c4cc65-6c06-0410-ace0-fbb531ad65f3
changes/78/78/1
Kinsey Moore 12 years ago
parent 35b9c6a660
commit 59753b1ea1
31 changed files with 152 additions and 1548 deletions
Show Stats Download Patch File Download Diff File

1
apps/app_queue.c
Unescape View File

@ -96,7 +96,6 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
#include "asterisk/astdb.h"
#include "asterisk/devicestate.h"
#include "asterisk/stringfields.h"
#include "asterisk/event.h"
#include "asterisk/astobj2.h"
#include "asterisk/strings.h"
#include "asterisk/global_datastores.h"

1
apps/app_voicemail.c
Unescape View File

@ -131,7 +131,6 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
#include "asterisk/strings.h"
#include "asterisk/smdi.h"
#include "asterisk/astobj2.h"
#include "asterisk/event.h"
#include "asterisk/taskprocessor.h"
#include "asterisk/test.h"

1
channels/chan_dahdi.c
Unescape View File

@ -119,7 +119,6 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
#include "asterisk/abstract_jb.h"
#include "asterisk/smdi.h"
#include "asterisk/astobj.h"
#include "asterisk/event.h"
#include "asterisk/devicestate.h"
#include "asterisk/paths.h"
#include "asterisk/ccss.h"

1
channels/chan_iax2.c
Unescape View File

@ -105,7 +105,6 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
#include "asterisk/netsock.h"
#include "asterisk/stringfields.h"
#include "asterisk/linkedlists.h"
#include "asterisk/event.h"
#include "asterisk/astobj2.h"
#include "asterisk/timing.h"
#include "asterisk/taskprocessor.h"

1
channels/chan_mgcp.c
Unescape View File

@ -79,7 +79,6 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
#include "asterisk/devicestate.h"
#include "asterisk/stringfields.h"
#include "asterisk/abstract_jb.h"
#include "asterisk/event.h"
#include "asterisk/chanvars.h"
#include "asterisk/pktccops.h"
#include "asterisk/stasis.h"

1
channels/chan_sip.c
Unescape View File

@ -276,7 +276,6 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
#include "asterisk/threadstorage.h"
#include "asterisk/translate.h"
#include "asterisk/ast_version.h"
#include "asterisk/event.h"
#include "asterisk/data.h"
#include "asterisk/aoc.h"
#include "asterisk/message.h"

1
channels/chan_skinny.c
Unescape View File

@ -77,7 +77,6 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
#include "asterisk/abstract_jb.h"
#include "asterisk/threadstorage.h"
#include "asterisk/devicestate.h"
#include "asterisk/event.h"
#include "asterisk/indications.h"
#include "asterisk/linkedlists.h"
#include "asterisk/stasis_endpoints.h"

1
channels/chan_unistim.c
Unescape View File

@ -63,7 +63,6 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
#include "asterisk/config.h"
#include "asterisk/module.h"
#include "asterisk/pbx.h"
#include "asterisk/event.h"
#include "asterisk/rtp_engine.h"
#include "asterisk/netsock2.h"
#include "asterisk/acl.h"

6
channels/sig_pri.c
Unescape View File

@ -8884,8 +8884,10 @@ static void sig_pri_send_mwi_indication(struct sig_pri_span *pri, const char *vm
* \brief MWI subscription event callback.
* \since 1.8
*
* \param event the event being passed to the subscriber
* \param userdata the data provider in the call to ast_event_subscribe()
* \param userdata the data provider in the call to stasis_subscribe()
* \param sub the subscription to which the message was delivered for this callback
* \param topic the topic on which the message was published
* \param msg the message being passed to the subscriber
*
* \return Nothing
*/

1
channels/sig_pri.h
Unescape View File

@ -27,7 +27,6 @@
#include "asterisk/channel.h"
#include "asterisk/frame.h"
#include "asterisk/event.h"
#include "asterisk/ccss.h"
#include <libpri.h>
#include <dahdi/user.h>

1
funcs/func_presencestate.c
Unescape View File

@ -41,7 +41,6 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
#include "asterisk/app.h"
#ifdef TEST_FRAMEWORK
#include "asterisk/test.h"
#include "asterisk/event.h"
#include <semaphore.h>
#endif

2
include/asterisk/devicestate.h
Unescape View File

@ -19,7 +19,7 @@
/*! \file
* \brief Device state management
*
* To subscribe to device state changes, use the generic ast_event_subscribe
* To subscribe to device state changes, use the stasis_subscribe
* method. For an example, see apps/app_queue.c.
*
* \todo Currently, when the state of a device changes, the device state provider

262
include/asterisk/event.h
Unescape View File

@ -90,9 +90,7 @@ typedef void (*ast_event_cb_t)(const struct ast_event *event, void *userdata);
* and must end with AST_EVENT_IE_END.
*
* If the ie_type specified is *not* AST_EVENT_IE_END, then it must be followed
* by a valid IE payload type. If the payload type specified is
* AST_EVENT_IE_PLTYPE_EXISTS, then the 3rd argument should not be provided.
* Otherwise, a payload must also be specified.
* by a valid IE payload type. A payload must also be specified.
*
* \return This returns a reference to the subscription for use with
* un-subscribing later. If there is a failure in creating the
@ -159,20 +157,6 @@ void ast_event_sub_destroy(struct ast_event_sub *sub);
int ast_event_sub_append_ie_uint(struct ast_event_sub *sub,
enum ast_event_ie_type ie_type, uint32_t uint);
/*!
* \brief Append a bitflags parameter to a subscription
*
* \param sub the dynamic subscription allocated with ast_event_subscribe_new()
* \param ie_type the information element type for the parameter
* \param flags the flags that must be present in the event to match this subscription
*
* \retval 0 success
* \retval non-zero failure
* \since 1.8
*/
int ast_event_sub_append_ie_bitflags(struct ast_event_sub *sub,
enum ast_event_ie_type ie_type, uint32_t flags);
/*!
* \brief Append a string parameter to a subscription
*
@ -202,20 +186,6 @@ int ast_event_sub_append_ie_str(struct ast_event_sub *sub,
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);
/*!
* \brief Append an 'exists' parameter to a subscription
*
* \param sub the dynamic subscription allocated with ast_event_subscribe_new()
* \param ie_type the information element type that must be present in the event
* for it to match this subscription.
*
* \retval 0 success
* \retval non-zero failure
* \since 1.6.1
*/
int ast_event_sub_append_ie_exists(struct ast_event_sub *sub,
enum ast_event_ie_type ie_type);
/*!
* \brief Activate a dynamically built subscription
*
@ -245,15 +215,6 @@ int ast_event_sub_activate(struct ast_event_sub *sub);
*/
struct ast_event_sub *ast_event_unsubscribe(struct ast_event_sub *event_sub);
/*!
* \brief Get description for a subscription
*
* \param sub subscription
*
* \return string description of the subscription
*/
const char *ast_event_subscriber_get_description(struct ast_event_sub *sub);
/*!
* \brief Check if subscribers exist
*
@ -269,9 +230,7 @@ const char *ast_event_subscriber_get_description(struct ast_event_sub *sub);
* and must end with AST_EVENT_IE_END.
*
* If the ie_type specified is *not* AST_EVENT_IE_END, then it must be followed
* by a valid IE payload type. If the payload type specified is
* AST_EVENT_IE_PLTYPE_EXISTS, then the 3rd argument should not be provided.
* Otherwise, a payload must also be specified.
* by a valid IE payload type. A payload must also be specified.
*
* \return This returns one of the values defined in the ast_event_subscriber_res
* enum which will indicate if subscribers exist that match the given
@ -309,12 +268,6 @@ enum ast_event_subscriber_res ast_event_check_subscriber(enum ast_event_type eve
*/
void ast_event_report_subs(const struct ast_event_sub *sub);
/*!
* \brief Dump the event cache for the subscriber
* \since 1.6.1
*/
void ast_event_dump_cache(const struct ast_event_sub *event_sub);
/*!
* \brief Create a new event
*
@ -328,8 +281,7 @@ void ast_event_dump_cache(const struct ast_event_sub *event_sub);
* and must end with AST_EVENT_IE_END.
*
* If the ie_type specified is *not* AST_EVENT_IE_END, then it must be followed
* by a valid IE payload type. The payload type, EXISTS, should not be used here
* because it makes no sense to do so. So, a payload must also be specified
* by a valid IE payload type. A payload must also be specified
* after the IE payload type.
*
* \note The EID IE will be appended automatically when this function is used
@ -384,63 +336,6 @@ void ast_event_destroy(struct ast_event *event);
*/
int ast_event_queue(struct ast_event *event);
/*!
* \brief Queue and cache an event
*
* \param event the event to be queued and cached
*
* \details
* The purpose of caching events is so that the core can retain the last known
* information for events that represent some sort of state. That way, when
* code needs to find out the current state, it can query the cache.
*
* The event API already knows which events can be cached and how to cache them.
*
* \retval 0 success
* \retval non-zero failure.
*/
int ast_event_queue_and_cache(struct ast_event *event);
/*!
* \brief Retrieve an event from the cache
*
* \param ast_event_type The type of event to retrieve from the cache
*
* The rest of the arguments to this function specify information elements to
* match for retrieving events from the cache. They are specified in the form:
* \code
* <enum ast_event_ie_type>, [enum ast_event_ie_pltype, [payload] ]
* \endcode
* and must end with AST_EVENT_IE_END.
*
* If the ie_type specified is *not* AST_EVENT_IE_END, then it must be followed
* by a valid IE payload type. If the payload type specified is
* AST_EVENT_IE_PLTYPE_EXISTS, then the 3rd argument should not be provided.
* Otherwise, a payload must also be specified.
*
* \return A reference to an event retrieved from the cache. If no event was
* found that matches the specified criteria, then NULL will be returned.
*
* \note If more than one event in the cache matches the specified criteria, only
* one will be returned, and it is undefined which one it will be.
*
* \note The caller of this function *must* call ast_event_destroy() on the
* returned event after it is done using it.
*
* Example Usage:
*
* \code
* event = ast_event_get_cached(AST_EVENT_MWI,
* AST_EVENT_IE_MAILBOX, AST_EVENT_IE_PLTYPE_STR, mailbox,
* AST_EVENT_IE_END);
* \endcode
*
* This example will check for an MWI event in the cache that matches the
* specified mailbox. This would be the way to find out the last known state
* of a mailbox without having to poll the mailbox directly.
*/
struct ast_event *ast_event_get_cached(enum ast_event_type, ...);
/*!
* \brief Append an information element that has a string payload
*
@ -475,55 +370,6 @@ int ast_event_append_ie_str(struct ast_event **event, enum ast_event_ie_type ie_
int ast_event_append_ie_uint(struct ast_event **event, enum ast_event_ie_type ie_type,
uint32_t data);
/*!
* \brief Append an information element that has a bitflags payload
*
* \param event the event that the IE will be appended to
* \param ie_type the type of IE to append
* \param bitflags the flags that are the payload of the IE
*
* \retval 0 success
* \retval -1 failure
* \since 1.8
*
* The pointer to the event will get updated with the new location for the event
* that now contains the appended information element. If the re-allocation of
* the memory for this event fails, it will be set to NULL.
*/
int ast_event_append_ie_bitflags(struct ast_event **event, enum ast_event_ie_type ie_type,
uint32_t bitflags);
/*!
* \brief Append an information element that has a raw payload
*
* \param event the event that the IE will be appended to
* \param ie_type the type of IE to append
* \param data A pointer to the raw data for the payload of the IE
* \param data_len The amount of data to copy into the payload
*
* \retval 0 success
* \retval -1 failure
*
* The pointer to the event will get updated with the new location for the event
* that now contains the appended information element. If the re-allocation of
* the memory for this event fails, it will be set to NULL.
*/
int ast_event_append_ie_raw(struct ast_event **event, enum ast_event_ie_type ie_type,
const void *data, size_t data_len);
/*!
* \brief Append the global EID IE
*
* \param event the event to append IE to
*
* \note For ast_event_new() that includes IEs, this is done automatically
* for you.
*
* \retval 0 success
* \retval -1 failure
*/
int ast_event_append_eid(struct ast_event **event);
/*!
* \brief Get the value of an information element that has an integer payload
*
@ -536,18 +382,6 @@ int ast_event_append_eid(struct ast_event **event);
*/
uint32_t ast_event_get_ie_uint(const struct ast_event *event, enum ast_event_ie_type ie_type);
/*!
* \brief Get the value of an information element that has a bitflags payload
*
* \param event The event to get the IE from
* \param ie_type the type of information element to retrieve
*
* \return This returns the payload of the information element with the given type.
* However, an IE with a payload of 0, and the case where no IE is found
* yield the same return value.
*/
uint32_t ast_event_get_ie_bitflags(const struct ast_event *event, enum ast_event_ie_type ie_type);
/*!
* \brief Get the value of an information element that has a string payload
*
@ -559,40 +393,6 @@ uint32_t ast_event_get_ie_bitflags(const struct ast_event *event, enum ast_event
*/
const char *ast_event_get_ie_str(const struct ast_event *event, enum ast_event_ie_type ie_type);
/*!
* \brief Get the hash for the string payload of an IE
*
* \param event The event to get the IE from
* \param ie_type the type of information element to retrieve the hash for
*
* \return This function returns the hash value as calculated by ast_str_hash()
* for the string payload. This is stored in the event to avoid
* unnecessary string comparisons.
*/
uint32_t ast_event_get_ie_str_hash(const struct ast_event *event, enum ast_event_ie_type ie_type);
/*!
* \brief Get the value of an information element that has a raw payload
*
* \param event The event to get the IE from
* \param ie_type the type of information element to retrieve
*
* \return This returns the payload of the information element with the given type.
* If the information element isn't found, NULL will be returned.
*/
const void *ast_event_get_ie_raw(const struct ast_event *event, enum ast_event_ie_type ie_type);
/*!
* \brief Get the length of the raw payload for a particular IE
*
* \param event The event to get the IE payload length from
* \param ie_type the type of information element to get the length of
*
* \return If an IE of type ie_type is found, its payload length is returned.
* Otherwise, 0 is returned.
*/
uint16_t ast_event_get_ie_raw_payload_len(const struct ast_event *event, enum ast_event_ie_type ie_type);
/*!
* \brief Get the string representation of an information element type
*
@ -623,28 +423,6 @@ enum ast_event_ie_pltype ast_event_get_ie_pltype(enum ast_event_ie_type ie_type)
*/
enum ast_event_type ast_event_get_type(const struct ast_event *event);
/*!
* \brief Get the string representation of the type of the given event
*
* \arg event the event to get the type of
*
* \return the string representation of the event type of the provided event
* \since 1.6.1
*/
const char *ast_event_get_type_name(const struct ast_event *event);
/*!
* \brief Convert a string into an event type
*
* \param str the string to convert
* \param event_type an output parameter for the event type
*
* \retval 0 success
* \retval non-zero failure
* \since 1.6.1
*/
int ast_event_str_to_event_type(const char *str, enum ast_event_type *event_type);
/*!
* \brief Convert a string to an IE type
*
@ -707,15 +485,6 @@ enum ast_event_ie_type ast_event_iterator_get_ie_type(struct ast_event_iterator
*/
uint32_t ast_event_iterator_get_ie_uint(struct ast_event_iterator *iterator);
/*!
* \brief Get the value of the current IE in the iterator as a bitflags payload
*
* \param iterator The iterator instance
*
* \return This returns the payload of the information element as bitflags.
*/
uint32_t ast_event_iterator_get_ie_bitflags(struct ast_event_iterator *iterator);
/*!
* \brief Get the value of the current IE in the iterator as a string payload
*
@ -725,31 +494,6 @@ uint32_t ast_event_iterator_get_ie_bitflags(struct ast_event_iterator *iterator)
*/
const char *ast_event_iterator_get_ie_str(struct ast_event_iterator *iterator);
/*!
* \brief Get the value of the current IE in the iterator instance that has a raw payload
*
* \param iterator The iterator instance
*
* \return This returns the payload of the information element as type raw.
*/
void *ast_event_iterator_get_ie_raw(struct ast_event_iterator *iterator);
/*!
* \brief Get the length of the raw payload for the current IE for an iterator
*
* \param iterator The IE iterator
*
* \return The payload length of the current IE
*/
uint16_t ast_event_iterator_get_ie_raw_payload_len(struct ast_event_iterator *iterator);
/*!
* \brief Get the minimum length of an ast_event.
*
* \return minimum amount of memory that will be consumed by any ast_event.
*/
size_t ast_event_minimum_length(void);
#if defined(__cplusplus) || defined(c_plusplus)
}
#endif

176
include/asterisk/event_defs.h
Unescape View File

@ -26,7 +26,7 @@
#define AST_EVENT_DEFS_H
/*! \brief Event types
* \note These values can *never* change. */
* \note These values no longer go over the wire and can change when items are removed. */
enum ast_event_type {
/*! Reserved to provide the ability to subscribe to all events. A specific
* event should never have a payload of 0. */
@ -36,32 +36,12 @@ enum ast_event_type {
* \note There are no "custom" IE types, because IEs only have to be
* unique to the event itself, not necessarily across all events. */
AST_EVENT_CUSTOM = 0x01,
/*! Voicemail message waiting indication */
AST_EVENT_MWI = 0x02,
/*! Someone has subscribed to events */
AST_EVENT_SUB = 0x03,
/*! Someone has unsubscribed from events */
AST_EVENT_UNSUB = 0x04,
/*! The aggregate state of a device across all servers configured to be
* a part of a device state cluster has changed. */
AST_EVENT_DEVICE_STATE = 0x05,
/*! The state of a device has changed on _one_ server. This should not be used
* directly, in general. Use AST_EVENT_DEVICE_STATE instead. */
AST_EVENT_DEVICE_STATE_CHANGE = 0x06,
AST_EVENT_SUB = 0x02,
/*! Channel Event Logging events */
AST_EVENT_CEL = 0x07,
/*! A report of a security related event (see security_events.h) */
AST_EVENT_SECURITY = 0x08,
/*! Used by res_stun_monitor to alert listeners to an exernal network address change. */
AST_EVENT_NETWORK_CHANGE = 0x09,
/*! The presence state for a presence provider */
AST_EVENT_PRESENCE_STATE = 0x0a,
/*! Used to alert listeners when a named ACL has been changed. */
AST_EVENT_ACL_CHANGE = 0x0b,
/*! Send out a ping for debugging distributed events */
AST_EVENT_PING = 0x0c,
AST_EVENT_CEL = 0x03,
/*! Number of event types. This should be the last event type + 1 */
AST_EVENT_TOTAL = 0x0d,
AST_EVENT_TOTAL = 0x04,
};
/*! \brief Event Information Element types */
@ -69,243 +49,199 @@ enum ast_event_ie_type {
/*! Used to terminate the arguments to event functions */
AST_EVENT_IE_END = -1,
/*!
* \brief Number of new messages
* Used by: AST_EVENT_MWI
* Payload type: UINT
*/
AST_EVENT_IE_NEWMSGS = 0x0001,
/*!
* \brief Number of
* Used by: AST_EVENT_MWI
* Payload type: UINT
*/
AST_EVENT_IE_OLDMSGS = 0x0002,
/*!
* \brief Mailbox name \verbatim (mailbox[@context]) \endverbatim
* Used by: AST_EVENT_MWI
* Payload type: STR
*/
AST_EVENT_IE_MAILBOX = 0x0003,
/*!
* \brief Unique ID
* Used by: AST_EVENT_SUB, AST_EVENT_UNSUB
* Payload type: UINT
*/
AST_EVENT_IE_UNIQUEID = 0x0004,
AST_EVENT_IE_UNIQUEID = 0x0001,
/*!
* \brief Event type
* Used by: AST_EVENT_SUB, AST_EVENT_UNSUB
* Payload type: UINT
*/
AST_EVENT_IE_EVENTTYPE = 0x0005,
AST_EVENT_IE_EVENTTYPE = 0x0002,
/*!
* \brief Hint that someone cares that an IE exists
* Used by: AST_EVENT_SUB
* Payload type: UINT (ast_event_ie_type)
*/
AST_EVENT_IE_EXISTS = 0x0006,
/*!
* \brief Device Name
* Used by AST_EVENT_DEVICE_STATE_CHANGE
* Payload type: STR
*/
AST_EVENT_IE_DEVICE = 0x0007,
/*!
* \brief Generic State IE
* Used by AST_EVENT_DEVICE_STATE_CHANGE
* Payload type: UINT
* The actual state values depend on the event which
* this IE is a part of.
*/
AST_EVENT_IE_STATE = 0x0008,
AST_EVENT_IE_EXISTS = 0x0003,
/*!
* \brief Context IE
* Used by AST_EVENT_MWI
* Payload type: str
*/
AST_EVENT_IE_CONTEXT = 0x0009,
AST_EVENT_IE_CONTEXT = 0x0004,
/*!
* \brief Channel Event Type
* Used by: AST_EVENT_CEL
* Payload type: UINT
*/
AST_EVENT_IE_CEL_EVENT_TYPE = 0x000a,
AST_EVENT_IE_CEL_EVENT_TYPE = 0x0005,
/*!
* \brief Channel Event Time (seconds)
* Used by: AST_EVENT_CEL
* Payload type: UINT
*/
AST_EVENT_IE_CEL_EVENT_TIME = 0x000b,
AST_EVENT_IE_CEL_EVENT_TIME = 0x0006,
/*!
* \brief Channel Event Time (micro-seconds)
* Used by: AST_EVENT_CEL
* Payload type: UINT
*/
AST_EVENT_IE_CEL_EVENT_TIME_USEC = 0x000c,
AST_EVENT_IE_CEL_EVENT_TIME_USEC = 0x0007,
/*!
* \brief Channel Event User Event Name
* Used by: AST_EVENT_CEL
* Payload type: STR
*/
AST_EVENT_IE_CEL_USEREVENT_NAME = 0x000d,
AST_EVENT_IE_CEL_USEREVENT_NAME = 0x0008,
/*!
* \brief Channel Event CID name
* Used by: AST_EVENT_CEL
* Payload type: STR
*/
AST_EVENT_IE_CEL_CIDNAME = 0x000e,
AST_EVENT_IE_CEL_CIDNAME = 0x0009,
/*!
* \brief Channel Event CID num
* Used by: AST_EVENT_CEL
* Payload type: STR
*/
AST_EVENT_IE_CEL_CIDNUM = 0x000f,
AST_EVENT_IE_CEL_CIDNUM = 0x000a,
/*!
* \brief Channel Event extension name
* Used by: AST_EVENT_CEL
* Payload type: STR
*/
AST_EVENT_IE_CEL_EXTEN = 0x0010,
AST_EVENT_IE_CEL_EXTEN = 0x000b,
/*!
* \brief Channel Event context name
* Used by: AST_EVENT_CEL
* Payload type: STR
*/
AST_EVENT_IE_CEL_CONTEXT = 0x0011,
AST_EVENT_IE_CEL_CONTEXT = 0x000c,
/*!
* \brief Channel Event channel name
* Used by: AST_EVENT_CEL
* Payload type: STR
*/
AST_EVENT_IE_CEL_CHANNAME = 0x0012,
AST_EVENT_IE_CEL_CHANNAME = 0x000d,
/*!
* \brief Channel Event app name
* Used by: AST_EVENT_CEL
* Payload type: STR
*/
AST_EVENT_IE_CEL_APPNAME = 0x0013,
AST_EVENT_IE_CEL_APPNAME = 0x000e,
/*!
* \brief Channel Event app args/data
* Used by: AST_EVENT_CEL
* Payload type: STR
*/
AST_EVENT_IE_CEL_APPDATA = 0x0014,
AST_EVENT_IE_CEL_APPDATA = 0x000f,
/*!
* \brief Channel Event AMA flags
* Used by: AST_EVENT_CEL
* Payload type: UINT
*/
AST_EVENT_IE_CEL_AMAFLAGS = 0x0015,
AST_EVENT_IE_CEL_AMAFLAGS = 0x0010,
/*!
* \brief Channel Event AccountCode
* Used by: AST_EVENT_CEL
* Payload type: STR
*/
AST_EVENT_IE_CEL_ACCTCODE = 0x0016,
AST_EVENT_IE_CEL_ACCTCODE = 0x0011,
/*!
* \brief Channel Event UniqueID
* Used by: AST_EVENT_CEL
* Payload type: STR
*/
AST_EVENT_IE_CEL_UNIQUEID = 0x0017,
AST_EVENT_IE_CEL_UNIQUEID = 0x0012,
/*!
* \brief Channel Event Userfield
* Used by: AST_EVENT_CEL
* Payload type: STR
*/
AST_EVENT_IE_CEL_USERFIELD = 0x0018,
AST_EVENT_IE_CEL_USERFIELD = 0x0013,
/*!
* \brief Channel Event CID ANI field
* Used by: AST_EVENT_CEL
* Payload type: STR
*/
AST_EVENT_IE_CEL_CIDANI = 0x0019,
AST_EVENT_IE_CEL_CIDANI = 0x0014,
/*!
* \brief Channel Event CID RDNIS field
* Used by: AST_EVENT_CEL
* Payload type: STR
*/
AST_EVENT_IE_CEL_CIDRDNIS = 0x001a,
AST_EVENT_IE_CEL_CIDRDNIS = 0x0015,
/*!
* \brief Channel Event CID dnid
* Used by: AST_EVENT_CEL
* Payload type: STR
*/
AST_EVENT_IE_CEL_CIDDNID = 0x001b,
AST_EVENT_IE_CEL_CIDDNID = 0x0016,
/*!
* \brief Channel Event Peer -- for Things involving multiple channels, like BRIDGE
* Used by: AST_EVENT_CEL
* Payload type: STR
*/
AST_EVENT_IE_CEL_PEER = 0x001c,
AST_EVENT_IE_CEL_PEER = 0x0017,
/*!
* \brief Channel Event LinkedID
* Used by: AST_EVENT_CEL
* Payload type: STR
*/
AST_EVENT_IE_CEL_LINKEDID = 0x001d,
AST_EVENT_IE_CEL_LINKEDID = 0x0018,
/*!
* \brief Channel Event peeraccount
* Used by: AST_EVENT_CEL
* Payload type: STR
*/
AST_EVENT_IE_CEL_PEERACCT = 0x001e,
AST_EVENT_IE_CEL_PEERACCT = 0x0019,
/*!
* \brief Channel Event extra data
* Used by: AST_EVENT_CEL
* Payload type: STR
*/
AST_EVENT_IE_CEL_EXTRA = 0x001f,
AST_EVENT_IE_CEL_EXTRA = 0x001a,
/*!
* \brief Description
* Used by: AST_EVENT_SUB, AST_EVENT_UNSUB
* Payload type: STR
*/
AST_EVENT_IE_DESCRIPTION = 0x0020,
AST_EVENT_IE_DESCRIPTION = 0x001b,
/*!
* \brief Entity ID
* Used by All events
* Payload type: RAW
* This IE indicates which server the event originated from
*/
AST_EVENT_IE_EID = 0x0021,
AST_EVENT_IE_SECURITY_EVENT = 0x0022,
AST_EVENT_IE_EVENT_VERSION = 0x0023,
AST_EVENT_IE_SERVICE = 0x0024,
AST_EVENT_IE_MODULE = 0x0025,
AST_EVENT_IE_ACCOUNT_ID = 0x0026,
AST_EVENT_IE_SESSION_ID = 0x0027,
AST_EVENT_IE_SESSION_TV = 0x0028,
AST_EVENT_IE_ACL_NAME = 0x0029,
AST_EVENT_IE_LOCAL_ADDR = 0x002a,
AST_EVENT_IE_REMOTE_ADDR = 0x002b,
AST_EVENT_IE_EVENT_TV = 0x002c,
AST_EVENT_IE_REQUEST_TYPE = 0x002d,
AST_EVENT_IE_REQUEST_PARAMS = 0x002e,
AST_EVENT_IE_AUTH_METHOD = 0x002f,
AST_EVENT_IE_SEVERITY = 0x0030,
AST_EVENT_IE_EXPECTED_ADDR = 0x0031,
AST_EVENT_IE_CHALLENGE = 0x0032,
AST_EVENT_IE_RESPONSE = 0x0033,
AST_EVENT_IE_EXPECTED_RESPONSE = 0x0034,
AST_EVENT_IE_RECEIVED_CHALLENGE = 0x0035,
AST_EVENT_IE_RECEIVED_HASH = 0x0036,
AST_EVENT_IE_USING_PASSWORD = 0x0037,
AST_EVENT_IE_ATTEMPTED_TRANSPORT = 0x0038,
AST_EVENT_IE_PRESENCE_PROVIDER = 0x0039,
AST_EVENT_IE_PRESENCE_STATE = 0x003a,
AST_EVENT_IE_PRESENCE_SUBTYPE = 0x003b,
AST_EVENT_IE_PRESENCE_MESSAGE = 0x003c,
AST_EVENT_IE_EVENT_VERSION = 0x001c,
AST_EVENT_IE_SERVICE = 0x001d,
AST_EVENT_IE_MODULE = 0x001e,
AST_EVENT_IE_ACCOUNT_ID = 0x001f,
AST_EVENT_IE_SESSION_ID = 0x0020,
AST_EVENT_IE_SESSION_TV = 0x0021,
AST_EVENT_IE_ACL_NAME = 0x0022,
AST_EVENT_IE_LOCAL_ADDR = 0x0023,
AST_EVENT_IE_REMOTE_ADDR = 0x0024,
AST_EVENT_IE_EVENT_TV = 0x0025,
AST_EVENT_IE_REQUEST_TYPE = 0x0026,
AST_EVENT_IE_REQUEST_PARAMS = 0x0027,
AST_EVENT_IE_AUTH_METHOD = 0x0028,
AST_EVENT_IE_SEVERITY = 0x0029,
AST_EVENT_IE_EXPECTED_ADDR = 0x002a,
AST_EVENT_IE_CHALLENGE = 0x002b,
AST_EVENT_IE_RESPONSE = 0x002c,
AST_EVENT_IE_EXPECTED_RESPONSE = 0x002e,
AST_EVENT_IE_RECEIVED_CHALLENGE = 0x002f,
AST_EVENT_IE_RECEIVED_HASH = 0x0030,
AST_EVENT_IE_USING_PASSWORD = 0x0031,
AST_EVENT_IE_ATTEMPTED_TRANSPORT = 0x0032,
/*!
* \brief Event non-cachability flag
* Used by: All events
* Payload type: UINT
*/
AST_EVENT_IE_CACHABLE = 0x003d,
/*! \brief Must be the last IE value +1 */
AST_EVENT_IE_TOTAL = 0x003e,
AST_EVENT_IE_TOTAL = 0x0033,
};
/*!
@ -313,16 +249,12 @@ enum ast_event_ie_type {
*/
enum ast_event_ie_pltype {
AST_EVENT_IE_PLTYPE_UNKNOWN = -1,
/*! Just check if it exists, not the value */
AST_EVENT_IE_PLTYPE_EXISTS,
/*! Unsigned Integer (Can be used for signed, too ...) */
AST_EVENT_IE_PLTYPE_UINT,
/*! String */
AST_EVENT_IE_PLTYPE_STR,
/*! Raw data, compared with memcmp */
AST_EVENT_IE_PLTYPE_RAW,
/*! Bit flags (unsigned integer, compared using boolean logic) */
AST_EVENT_IE_PLTYPE_BITFLAGS,
};
/*!

5
include/asterisk/security_events_defs.h
Unescape View File

@ -36,11 +36,6 @@ extern "C" {
/*!
* \brief Security event types
*
* AST_EVENT_SECURITY is the event type of an ast_event generated as a security
* event. The event will have an information element of type
* AST_EVENT_IE_SECURITY_EVENT which identifies the security event sub-type.
* This enum defines the possible values for this sub-type.
*/
enum ast_security_event_type {
/*!

1
main/ccss.c
Unescape View File

@ -45,7 +45,6 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
#include "asterisk/pbx.h"
#include "asterisk/utils.h"
#include "asterisk/taskprocessor.h"
#include "asterisk/event.h"
#include "asterisk/devicestate.h"
#include "asterisk/module.h"
#include "asterisk/app.h"

1
main/devicestate.c
Unescape View File

@ -131,7 +131,6 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
#include "asterisk/app.h"
#include "asterisk/astobj2.h"
#include "asterisk/stasis.h"
#include "asterisk/event.h"
#include "asterisk/devicestate.h"
#define DEVSTATE_TOPIC_BUCKETS 57

863
main/event.c
View File

File diff suppressed because it is too large Load Diff

1
main/manager.c
Unescape View File

@ -87,7 +87,6 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
#include "asterisk/astobj2.h"
#include "asterisk/features.h"
#include "asterisk/security_events.h"
#include "asterisk/event.h"
#include "asterisk/aoc.h"
#include "asterisk/strings.h"
#include "asterisk/stringfields.h"

3
main/pbx.c
Unescape View File

@ -64,7 +64,6 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
#include "asterisk/app.h"
#include "asterisk/devicestate.h"
#include "asterisk/presencestate.h"
#include "asterisk/event.h"
#include "asterisk/hashtab.h"
#include "asterisk/module.h"
#include "asterisk/indications.h"
@ -5181,7 +5180,7 @@ static void device_state_cb(void *unused, struct stasis_subscription *sub, struc
ao2_iterator_destroy(&cb_iter);
/* For extension callbacks */
/* extended callbacks are called when the state changed or when AST_EVENT_RINGING is
/* extended callbacks are called when the state changed or when AST_STATE_RINGING is
* included. Normal callbacks are only called when the state changed.
*/
cb_iter = ao2_iterator_init(hint->callbacks, 0);

1
main/presencestate.c
Unescape View File

@ -36,7 +36,6 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
#include "asterisk/presencestate.h"
#include "asterisk/pbx.h"
#include "asterisk/app.h"
#include "asterisk/event.h"
/*! \brief Device state strings for printing */
static const struct {

4
main/security_events.c
Unescape View File

@ -657,13 +657,11 @@ static struct ast_json *alloc_security_event_json_object(const struct ast_securi
* This is true even if ast_json_object_set fails.
*/
/* AST_EVENT_IE_SECURITY_EVENT */
json_temp = ast_json_integer_create(sec->event_type);
if (!json_temp || ast_json_object_set(json_object, ast_event_get_ie_type_name(AST_EVENT_IE_SECURITY_EVENT), json_temp)) {
if (!json_temp || ast_json_object_set(json_object, "SecurityEvent", json_temp)) {
return NULL;
}
/* AST_EVENT_IE_EVENT_VERSION */
json_temp = ast_json_stringf("%d", sec->version);
if (!json_temp || ast_json_object_set(json_object, ast_event_get_ie_type_name(AST_EVENT_IE_EVENT_VERSION), json_temp)) {
return NULL;

1
res/parking/parking_applications.c
Unescape View File

@ -30,7 +30,6 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
#include "res_parking.h"
#include "asterisk/config.h"
#include "asterisk/config_options.h"
#include "asterisk/event.h"
#include "asterisk/utils.h"
#include "asterisk/astobj2.h"
#include "asterisk/features.h"

1
res/parking/parking_manager.c
Unescape View File

@ -30,7 +30,6 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
#include "res_parking.h"
#include "asterisk/config.h"
#include "asterisk/config_options.h"
#include "asterisk/event.h"
#include "asterisk/utils.h"
#include "asterisk/module.h"
#include "asterisk/cli.h"

1
res/parking/parking_ui.c
Unescape View File

@ -30,7 +30,6 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
#include "res_parking.h"
#include "asterisk/config.h"
#include "asterisk/config_options.h"
#include "asterisk/event.h"
#include "asterisk/utils.h"
#include "asterisk/module.h"
#include "asterisk/cli.h"

8
res/res_jabber.c
Unescape View File

@ -70,7 +70,6 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
#include "asterisk/astobj.h"
#include "asterisk/astdb.h"
#include "asterisk/manager.h"
#include "asterisk/event.h"
#include "asterisk/devicestate.h"
#include "asterisk/message.h"
@ -3335,7 +3334,6 @@ static int aji_handle_pubsub_event(void *data, ikspak *pak)
int oldmsgs, newmsgs;
iks *item, *item_content;
struct ast_eid pubsub_eid;
struct ast_event *event;
unsigned int cachable = AST_DEVSTATE_CACHABLE;
item = iks_find(iks_find(iks_find(pak->x, "event"), "items"), "item");
@ -3374,12 +3372,6 @@ static int aji_handle_pubsub_event(void *data, ikspak *pak)
return IKS_FILTER_EAT;
}
if (cachable == AST_DEVSTATE_CACHABLE) {
ast_event_queue_and_cache(event);
} else {
ast_event_queue(event);
}
return IKS_FILTER_EAT;
}

1
res/res_parking.c
Unescape View File

@ -184,7 +184,6 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
#include "parking/res_parking.h"
#include "asterisk/config.h"
#include "asterisk/config_options.h"
#include "asterisk/event.h"
#include "asterisk/utils.h"
#include "asterisk/module.h"
#include "asterisk/cli.h"

3
res/res_security_log.c
Unescape View File

@ -105,8 +105,7 @@ static void security_event_stasis_cb(struct ast_json *json)
return;
}
ast_str_set(&str, 0, "%s=\"%s\"",
ast_event_get_ie_type_name(AST_EVENT_IE_SECURITY_EVENT),
ast_str_set(&str, 0, "SecurityEvent=\"%s\"",
ast_security_event_get_name(event_type));
append_json(&str, json,

8
res/res_xmpp.c
Unescape View File

@ -59,7 +59,6 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
#include "asterisk/app.h"
#include "asterisk/message.h"
#include "asterisk/manager.h"
#include "asterisk/event.h"
#include "asterisk/cli.h"
#include "asterisk/config_options.h"
@ -1455,7 +1454,6 @@ static int xmpp_pubsub_handle_event(void *data, ikspak *pak)
int oldmsgs, newmsgs;
iks *item, *item_content;
struct ast_eid pubsub_eid;
struct ast_event *event;
unsigned int cachable = AST_DEVSTATE_CACHABLE;
item = iks_find(iks_find(iks_find(pak->x, "event"), "items"), "item");
if (!item) {
@ -1493,12 +1491,6 @@ static int xmpp_pubsub_handle_event(void *data, ikspak *pak)
return IKS_FILTER_EAT;
}
if (cachable == AST_DEVSTATE_CACHABLE) {
ast_event_queue_and_cache(event);
} else {
ast_event_queue(event);
}
return IKS_FILTER_EAT;
}

21
tests/test_cel.c
Unescape View File

@ -1730,12 +1730,6 @@ static int match_ie_val(
case AST_EVENT_IE_PLTYPE_STR:
{
const char *str;
uint32_t hash;
hash = ast_event_get_ie_str_hash(event2, type);
if (hash != ast_event_get_ie_str_hash(event1, type)) {
return 0;
}
str = ast_event_get_ie_str(event2, type);
if (str) {
@ -1743,11 +1737,6 @@ static int match_ie_val(
e1str = ast_event_get_ie_str(event1, type);
e2str = str;
if (type == AST_EVENT_IE_DEVICE) {
e1str = ast_tech_to_upper(ast_strdupa(e1str));
e2str = ast_tech_to_upper(ast_strdupa(e2str));
}
if (!strcmp(e1str, e2str)) {
return 1;
}
@ -1773,10 +1762,8 @@ static int events_are_equal(struct ast_test *test, struct ast_event *received, s
for (res = ast_event_iterator_init(&iterator, received); !res; res = ast_event_iterator_next(&iterator)) {
/* XXX ignore sec/usec for now */
/* ignore EID */
int ie_type = ast_event_iterator_get_ie_type(&iterator);
if (ie_type != AST_EVENT_IE_CEL_EVENT_TIME_USEC
&& ie_type != AST_EVENT_IE_EID
&& ie_type != AST_EVENT_IE_CEL_EVENT_TIME
&& !match_ie_val(received, expected, ie_type)) {
ast_test_status_update(test, "Failed matching on field %s\n", ast_event_get_ie_type_name(ie_type));
@ -1796,7 +1783,7 @@ static int dump_event(struct ast_test *test, struct ast_event *event)
return 0;
}
ast_test_status_update(test, "Event: %s %s\n", ast_event_get_type_name(event),
ast_test_status_update(test, "Event: %s\n",
ast_cel_get_type_name(ast_event_get_ie_uint(event, AST_EVENT_IE_CEL_EVENT_TYPE)));
do {
@ -1810,9 +1797,6 @@ static int dump_event(struct ast_test *test, struct ast_event *event)
switch (ie_pltype) {
case AST_EVENT_IE_PLTYPE_UNKNOWN:
case AST_EVENT_IE_PLTYPE_EXISTS:
ast_test_status_update(test, "%s\n", ie_type_name);
break;
case AST_EVENT_IE_PLTYPE_STR:
ast_test_status_update(test, "%.30s: %s\n", ie_type_name,
ast_event_iterator_get_ie_str(&i));
@ -1821,9 +1805,6 @@ static int dump_event(struct ast_test *test, struct ast_event *event)
ast_test_status_update(test, "%.30s: %u\n", ie_type_name,
ast_event_iterator_get_ie_uint(&i));
break;
case AST_EVENT_IE_PLTYPE_BITFLAGS:
ast_test_status_update(test, "%.30s: %u\n", ie_type_name,
ast_event_iterator_get_ie_bitflags(&i));
default:
break;
}

321
tests/test_event.c
Unescape View File

@ -25,21 +25,14 @@
* \ingroup tests
*
* \todo API Calls not yet touched by a test: XXX TODO
* - ast_event_queue_and_cache()
* - ast_event_get_cached()
* - ast_event_report_subs()
* - ast_event_dump_cache()
* - ast_event_get_ie_type_name()
* - ast_event_get_ie_pltype()
* - ast_event_str_to_event_type()
* - ast_event_str_to_ie_type()
* - ast_event_iterator_init()
* - ast_event_iterator_next()
* - ast_event_iterator_get_ie_type()
* - ast_event_iterator_get_ie_uint()
* - ast_event_iterator_get_ie_bitflags()
* - ast_event_iterator_get_ie_str()
* - ast_event_iterator_get_ie_raw()
*/
/*** MODULEINFO
@ -58,7 +51,7 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
static int check_event(struct ast_event *event, struct ast_test *test,
enum ast_event_type expected_type, const char *type_name,
const char *str, uint32_t uint, uint32_t bitflags)
const char *str, uint32_t uint)
{
enum ast_event_type type;
const void *foo;
@ -71,46 +64,27 @@ static int check_event(struct ast_event *event, struct ast_test *test,
return -1;
}
/* Check #2: Check string representation of event type */
if (strcmp(type_name, ast_event_get_type_name(event))) {
ast_test_status_update(test, "Didn't get expected type name: '%s' != '%s'\n",
type_name, ast_event_get_type_name(event));
return -1;
}
/* Check #3: Check for automatically included EID */
if (memcmp(&ast_eid_default, ast_event_get_ie_raw(event, AST_EVENT_IE_EID), sizeof(ast_eid_default))) {
ast_test_status_update(test, "Failed to get EID\n");
return -1;
}
/* Check #4: Check for the string IE */
if (strcmp(str, ast_event_get_ie_str(event, AST_EVENT_IE_MAILBOX))) {
if (strcmp(str, ast_event_get_ie_str(event, AST_EVENT_IE_CEL_USEREVENT_NAME))) {
ast_test_status_update(test, "Failed to get string IE.\n");
return -1;
}
/* Check #5: Check for the uint IE */
if (uint != ast_event_get_ie_uint(event, AST_EVENT_IE_NEWMSGS)) {
if (uint != ast_event_get_ie_uint(event, AST_EVENT_IE_CEL_AMAFLAGS)) {
ast_test_status_update(test, "Failed to get uint IE.\n");
return -1;
}
/* Check #6: Check for the bitflags IE */
if (bitflags != ast_event_get_ie_bitflags(event, AST_EVENT_IE_OLDMSGS)) {
ast_test_status_update(test, "Failed to get bitflags IE.\n");
return -1;
}
/* Check #7: Check if a check for a str IE that isn't there works */
if ((foo = ast_event_get_ie_str(event, AST_EVENT_IE_DEVICE))) {
ast_test_status_update(test, "DEVICE IE check returned non-NULL %p\n", foo);
/* Check #6: Check if a check for a str IE that isn't there works */
if ((foo = ast_event_get_ie_str(event, AST_EVENT_IE_CEL_CIDNAME))) {
ast_test_status_update(test, "CEL_CIDNAME IE check returned non-NULL %p\n", foo);
return -1;
}
/* Check #8: Check if a check for a uint IE that isn't there returns 0 */
if (ast_event_get_ie_uint(event, AST_EVENT_IE_STATE)) {
ast_test_status_update(test, "OLDMSGS IE should be 0\n");
/* Check #7: Check if a check for a uint IE that isn't there returns 0 */
if (ast_event_get_ie_uint(event, AST_EVENT_IE_CEL_EVENT_TIME_USEC)) {
ast_test_status_update(test, "UNIQUEID IE should be 0\n");
return -1;
}
@ -130,7 +104,6 @@ AST_TEST_DEFINE(event_new_test)
static const enum ast_event_type type = AST_EVENT_CUSTOM;
static const char str[] = "SIP/alligatormittens";
static const uint32_t uint = 0xb00bface;
static const uint32_t bitflags = 0x12488421;
switch (cmd) {
case TEST_INIT:
@ -160,34 +133,27 @@ AST_TEST_DEFINE(event_new_test)
goto return_cleanup;
}
if (ast_event_append_ie_str(&event, AST_EVENT_IE_MAILBOX, str)) {
if (ast_event_append_ie_str(&event, AST_EVENT_IE_CEL_USEREVENT_NAME, str)) {
ast_test_status_update(test, "Failed to append str IE\n");
res = AST_TEST_FAIL;
goto return_cleanup;
}
if (ast_event_append_ie_uint(&event, AST_EVENT_IE_NEWMSGS, uint)) {
if (ast_event_append_ie_uint(&event, AST_EVENT_IE_CEL_AMAFLAGS, uint)) {
ast_test_status_update(test, "Failed to append uint IE\n");
res = AST_TEST_FAIL;
goto return_cleanup;
}
if (ast_event_append_ie_bitflags(&event, AST_EVENT_IE_OLDMSGS, bitflags)) {
ast_test_status_update(test, "Failed to append bitflags IE\n");
res = AST_TEST_FAIL;
goto return_cleanup;
}
if (check_event(event, test, type, "Custom", str, uint, bitflags)) {
if (check_event(event, test, type, "Custom", str, uint)) {
ast_test_status_update(test, "Dynamically generated event broken\n");
res = AST_TEST_FAIL;
goto return_cleanup;
}
event2 = ast_event_new(type,
AST_EVENT_IE_MAILBOX, AST_EVENT_IE_PLTYPE_STR, str,
AST_EVENT_IE_NEWMSGS, AST_EVENT_IE_PLTYPE_UINT, uint,
AST_EVENT_IE_OLDMSGS, AST_EVENT_IE_PLTYPE_BITFLAGS, bitflags,
AST_EVENT_IE_CEL_USEREVENT_NAME, AST_EVENT_IE_PLTYPE_STR, str,
AST_EVENT_IE_CEL_AMAFLAGS, AST_EVENT_IE_PLTYPE_UINT, uint,
AST_EVENT_IE_END);
if (!event2) {
@ -196,7 +162,7 @@ AST_TEST_DEFINE(event_new_test)
goto return_cleanup;
}
if (check_event(event2, test, type, "Custom", str, uint, bitflags)) {
if (check_event(event2, test, type, "Custom", str, uint)) {
ast_test_status_update(test, "Statically generated event broken\n");
res = AST_TEST_FAIL;
goto return_cleanup;
@ -240,7 +206,6 @@ enum test_subs_class_type {
TEST_SUBS_CUSTOM_STR,
TEST_SUBS_CUSTOM_RAW,
TEST_SUBS_CUSTOM_UINT,
TEST_SUBS_CUSTOM_BITFLAGS,
TEST_SUBS_CUSTOM_EXISTS,
TEST_SUBS_CUSTOM_DYNAMIC,
TEST_SUBS_CUSTOM_ANY,
@ -268,8 +233,6 @@ static const char *test_subs_class_type_str(enum test_subs_class_type val)
return "TEST_SUBS_CUSTOM_RAW";
case TEST_SUBS_CUSTOM_UINT:
return "TEST_SUBS_CUSTOM_UINT";
case TEST_SUBS_CUSTOM_BITFLAGS:
return "TEST_SUBS_CUSTOM_BITFLAGS";
case TEST_SUBS_CUSTOM_EXISTS:
return "TEST_SUBS_CUSTOM_EXISTS";
case TEST_SUBS_CUSTOM_DYNAMIC:
@ -312,9 +275,6 @@ AST_TEST_DEFINE(event_sub_test)
[TEST_SUBS_CUSTOM_UINT] = {
.expected_count = 1,
},
[TEST_SUBS_CUSTOM_BITFLAGS] = {
.expected_count = 4,
},
[TEST_SUBS_CUSTOM_EXISTS] = {
.expected_count = 2,
},
@ -322,7 +282,7 @@ AST_TEST_DEFINE(event_sub_test)
.expected_count = 1,
},
[TEST_SUBS_CUSTOM_ANY] = {
.expected_count = 6,
.expected_count = 5,
},
};
@ -351,12 +311,12 @@ AST_TEST_DEFINE(event_sub_test)
/*
* Subscription TEST_SUBS_CUSTOM_STR:
* - allocate normally
* - subscribe to CUSTOM events with a DEVICE STR IE check
* - subscribe to CUSTOM events with a CEL_CIDNAME STR IE check
*/
ast_test_status_update(test, "Adding TEST_SUBS_CUSTOM_STR subscription\n");
test_subs[TEST_SUBS_CUSTOM_STR].sub = ast_event_subscribe(AST_EVENT_CUSTOM, event_sub_cb,
test_subs_class_type_str(TEST_SUBS_CUSTOM_STR), &test_subs[TEST_SUBS_CUSTOM_STR].data,
AST_EVENT_IE_DEVICE, AST_EVENT_IE_PLTYPE_STR, "FOO/bar",
AST_EVENT_IE_CEL_CIDNAME, AST_EVENT_IE_PLTYPE_STR, "FOO/bar",
AST_EVENT_IE_END);
if (!test_subs[TEST_SUBS_CUSTOM_STR].sub) {
ast_test_status_update(test, "Failed to create TEST_SUBS_CUSTOM_STR subscription\n");
@ -364,14 +324,6 @@ AST_TEST_DEFINE(event_sub_test)
goto return_cleanup;
}
if (strcmp(ast_event_subscriber_get_description(test_subs[TEST_SUBS_CUSTOM_STR].sub),
test_subs_class_type_str(TEST_SUBS_CUSTOM_STR))) {
ast_test_status_update(test,
"Unexpected subscription description on TEST_SUBS_CUSTOM_STR subscription\n");
res = AST_TEST_FAIL;
goto return_cleanup;
}
ast_test_status_update(test, "Check that a CUSTOM subscriber exists\n");
sub_res = ast_event_check_subscriber(AST_EVENT_CUSTOM,
AST_EVENT_IE_END);
@ -384,12 +336,12 @@ AST_TEST_DEFINE(event_sub_test)
/*
* Subscription TEST_SUBS_ALL_STR:
* - allocate normally
* - subscribe to ALL events with a DEVICE STR IE check
* - subscribe to ALL events with a CEL_CIDNAME STR IE check
*/
ast_test_status_update(test, "Adding TEST_SUBS_ALL_STR subscription\n");
test_subs[TEST_SUBS_ALL_STR].sub = ast_event_subscribe(AST_EVENT_ALL, event_sub_cb,
test_subs_class_type_str(TEST_SUBS_ALL_STR), &test_subs[TEST_SUBS_ALL_STR].data,
AST_EVENT_IE_DEVICE, AST_EVENT_IE_PLTYPE_STR, "FOO/bar",
AST_EVENT_IE_CEL_CIDNAME, AST_EVENT_IE_PLTYPE_STR, "FOO/bar",
AST_EVENT_IE_END);
if (!test_subs[TEST_SUBS_ALL_STR].sub) {
ast_test_status_update(test, "Failed to create TEST_SUBS_ALL_STR subscription\n");
@ -397,23 +349,15 @@ AST_TEST_DEFINE(event_sub_test)
goto return_cleanup;
}
if (strcmp(ast_event_subscriber_get_description(test_subs[TEST_SUBS_ALL_STR].sub),
test_subs_class_type_str(TEST_SUBS_ALL_STR))) {
ast_test_status_update(test,
"Unexpected subscription description on TEST_SUBS_ALL_STR subscription\n");
res = AST_TEST_FAIL;
goto return_cleanup;
}
/*
* Subscription TEST_SUBS_CUSTOM_RAW:
* - allocate normally
* - subscribe to CUSTOM events with a MAILBOX RAW IE check
* - subscribe to CUSTOM events with a CEL_USEREVENT_NAME RAW IE check
*/
ast_test_status_update(test, "Adding TEST_SUBS_CUSTOM_RAW subscription\n");
test_subs[TEST_SUBS_CUSTOM_RAW].sub = ast_event_subscribe(AST_EVENT_CUSTOM, event_sub_cb,
test_subs_class_type_str(TEST_SUBS_CUSTOM_RAW), &test_subs[TEST_SUBS_CUSTOM_RAW].data,
AST_EVENT_IE_MAILBOX, AST_EVENT_IE_PLTYPE_RAW, "FOO/bar", sizeof("FOO/bar"),
AST_EVENT_IE_CEL_USEREVENT_NAME, AST_EVENT_IE_PLTYPE_RAW, "FOO/bar", sizeof("FOO/bar"),
AST_EVENT_IE_END);
if (!test_subs[TEST_SUBS_CUSTOM_RAW].sub) {
ast_test_status_update(test, "Failed to create TEST_SUBS_CUSTOM_RAW subscription\n");
@ -421,23 +365,15 @@ AST_TEST_DEFINE(event_sub_test)
goto return_cleanup;
}
if (strcmp(ast_event_subscriber_get_description(test_subs[TEST_SUBS_CUSTOM_RAW].sub),
test_subs_class_type_str(TEST_SUBS_CUSTOM_RAW))) {
ast_test_status_update(test,
"Unexpected subscription description on TEST_SUBS_CUSTOM_RAW subscription\n");
res = AST_TEST_FAIL;
goto return_cleanup;
}
/*
* Subscription TEST_SUBS_CUSTOM_UINT:
* - allocate normally
* - subscribe to CUSTOM events with a NEWMSGS UINT IE check
* - subscribe to CUSTOM events with a CEL_AMAFLAGS UINT IE check
*/
ast_test_status_update(test, "Adding TEST_SUBS_CUSTOM_UINT subscription\n");
test_subs[TEST_SUBS_CUSTOM_UINT].sub = ast_event_subscribe(AST_EVENT_CUSTOM, event_sub_cb,
test_subs_class_type_str(TEST_SUBS_CUSTOM_UINT), &test_subs[TEST_SUBS_CUSTOM_UINT].data,
AST_EVENT_IE_NEWMSGS, AST_EVENT_IE_PLTYPE_UINT, 5,
AST_EVENT_IE_CEL_AMAFLAGS, AST_EVENT_IE_PLTYPE_UINT, 5,
AST_EVENT_IE_END);
if (!test_subs[TEST_SUBS_CUSTOM_UINT].sub) {
ast_test_status_update(test, "Failed to create TEST_SUBS_CUSTOM_UINT subscription\n");
@ -445,48 +381,15 @@ AST_TEST_DEFINE(event_sub_test)
goto return_cleanup;
}
if (strcmp(ast_event_subscriber_get_description(test_subs[TEST_SUBS_CUSTOM_UINT].sub),
test_subs_class_type_str(TEST_SUBS_CUSTOM_UINT))) {
ast_test_status_update(test,
"Unexpected subscription description on TEST_SUBS_CUSTOM_UINT subscription\n");
res = AST_TEST_FAIL;
goto return_cleanup;
}
/*
* Subscription TEST_SUBS_CUSTOM_BITFLAGS:
* - allocate normally
* - subscribe to CUSTOM events with a NEWMSGS BITFLAGS IE check
*/
ast_test_status_update(test, "Adding TEST_SUBS_CUSTOM_BITFLAGS subscription\n");
test_subs[TEST_SUBS_CUSTOM_BITFLAGS].sub = ast_event_subscribe(AST_EVENT_CUSTOM, event_sub_cb,
test_subs_class_type_str(TEST_SUBS_CUSTOM_BITFLAGS), &test_subs[TEST_SUBS_CUSTOM_BITFLAGS].data,
AST_EVENT_IE_NEWMSGS, AST_EVENT_IE_PLTYPE_BITFLAGS, 0x06,
AST_EVENT_IE_END);
if (!test_subs[TEST_SUBS_CUSTOM_BITFLAGS].sub) {
ast_test_status_update(test, "Failed to create TEST_SUBS_CUSTOM_BITFLAGS subscription\n");
res = AST_TEST_FAIL;
goto return_cleanup;
}
if (strcmp(ast_event_subscriber_get_description(test_subs[TEST_SUBS_CUSTOM_BITFLAGS].sub),
test_subs_class_type_str(TEST_SUBS_CUSTOM_BITFLAGS))) {
ast_test_status_update(test,
"Unexpected subscription description on TEST_SUBS_CUSTOM_BITFLAGS subscription\n");
res = AST_TEST_FAIL;
goto return_cleanup;
}
/*
* Subscription TEST_SUBS_CUSTOM_EXISTS:
* - allocate normally
* - subscribe to CUSTOM events with a NEWMSGS UINT and OLDMSGS EXISTS IE check
* - subscribe to CUSTOM events with a CEL_AMAFLAGS UINT and UNIQUEID EXISTS IE check
*/
ast_test_status_update(test, "Adding TEST_SUBS_CUSTOM_EXISTS subscription\n");
test_subs[TEST_SUBS_CUSTOM_EXISTS].sub = ast_event_subscribe(AST_EVENT_CUSTOM, event_sub_cb,
test_subs_class_type_str(TEST_SUBS_CUSTOM_EXISTS), &test_subs[TEST_SUBS_CUSTOM_EXISTS].data,
AST_EVENT_IE_NEWMSGS, AST_EVENT_IE_PLTYPE_UINT, 4,
AST_EVENT_IE_OLDMSGS, AST_EVENT_IE_PLTYPE_EXISTS,
AST_EVENT_IE_CEL_AMAFLAGS, AST_EVENT_IE_PLTYPE_UINT, 4,
AST_EVENT_IE_END);
if (!test_subs[TEST_SUBS_CUSTOM_EXISTS].sub) {
ast_test_status_update(test, "Failed to create TEST_SUBS_CUSTOM_EXISTS subscription\n");
@ -494,14 +397,6 @@ AST_TEST_DEFINE(event_sub_test)
goto return_cleanup;
}
if (strcmp(ast_event_subscriber_get_description(test_subs[TEST_SUBS_CUSTOM_EXISTS].sub),
test_subs_class_type_str(TEST_SUBS_CUSTOM_EXISTS))) {
ast_test_status_update(test,
"Unexpected subscription description on TEST_SUBS_CUSTOM_EXISTS subscription\n");
res = AST_TEST_FAIL;
goto return_cleanup;
}
/* For the sake of exercising destruction before activation */
test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub = ast_event_subscribe_new(AST_EVENT_CUSTOM,
event_sub_cb, &test_subs[TEST_SUBS_CUSTOM_DYNAMIC].data);
@ -527,17 +422,7 @@ AST_TEST_DEFINE(event_sub_test)
goto return_cleanup;
}
if (strcmp(ast_event_subscriber_get_description(test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub),
"")) {
ast_event_sub_destroy(test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub);
test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub = NULL;
ast_test_status_update(test,
"Unexpected subscription description on TEST_SUBS_CUSTOM_DYNAMIC subscription\n");
res = AST_TEST_FAIL;
goto return_cleanup;
}
if (ast_event_sub_append_ie_uint(test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub, AST_EVENT_IE_NEWMSGS, 4)) {
if (ast_event_sub_append_ie_uint(test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub, AST_EVENT_IE_CEL_AMAFLAGS, 4)) {
ast_event_sub_destroy(test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub);
test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub = NULL;
ast_test_status_update(test, "Failed to append UINT IE to TEST_SUBS_CUSTOM_DYNAMIC subscription\n");
@ -545,15 +430,7 @@ AST_TEST_DEFINE(event_sub_test)
goto return_cleanup;
}
if (ast_event_sub_append_ie_bitflags(test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub, AST_EVENT_IE_OLDMSGS, 1)) {
ast_event_sub_destroy(test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub);
test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub = NULL;
ast_test_status_update(test, "Failed to append BITFLAGS IE to TEST_SUBS_CUSTOM_DYNAMIC subscription\n");
res = AST_TEST_FAIL;
goto return_cleanup;
}
if (ast_event_sub_append_ie_str(test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub, AST_EVENT_IE_DEVICE, "FOO/bar")) {
if (ast_event_sub_append_ie_str(test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub, AST_EVENT_IE_CEL_CIDNAME, "FOO/bar")) {
ast_event_sub_destroy(test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub);
test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub = NULL;
ast_test_status_update(test, "Failed to append STR IE to TEST_SUBS_CUSTOM_DYNAMIC subscription\n");
@ -561,7 +438,7 @@ AST_TEST_DEFINE(event_sub_test)
goto return_cleanup;
}
if (ast_event_sub_append_ie_raw(test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub, AST_EVENT_IE_MAILBOX, "800 km",
if (ast_event_sub_append_ie_raw(test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub, AST_EVENT_IE_CEL_USEREVENT_NAME, "800 km",
strlen("800 km"))) {
ast_event_sub_destroy(test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub);
test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub = NULL;
@ -570,14 +447,6 @@ AST_TEST_DEFINE(event_sub_test)
goto return_cleanup;
}
if (ast_event_sub_append_ie_exists(test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub, AST_EVENT_IE_STATE)) {
ast_event_sub_destroy(test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub);
test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub = NULL;
ast_test_status_update(test, "Failed to append EXISTS IE to TEST_SUBS_CUSTOM_DYNAMIC subscription\n");
res = AST_TEST_FAIL;
goto return_cleanup;
}
if (ast_event_sub_activate(test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub)) {
ast_event_sub_destroy(test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub);
test_subs[TEST_SUBS_CUSTOM_DYNAMIC].sub = NULL;
@ -593,34 +462,15 @@ AST_TEST_DEFINE(event_sub_test)
/* Check STR matching. */
sub_res = ast_event_check_subscriber(AST_EVENT_CUSTOM,
AST_EVENT_IE_DEVICE, AST_EVENT_IE_PLTYPE_STR, "FOO/bar",
AST_EVENT_IE_CEL_CIDNAME, AST_EVENT_IE_PLTYPE_STR, "FOO/bar",
AST_EVENT_IE_END);
if (sub_res != AST_EVENT_SUB_EXISTS) {
ast_test_status_update(test, "Str FOO/bar subscription did not exist\n");
res = AST_TEST_FAIL;
}
/* Make sure that the tech portion of the device string is case-insensitive */
sub_res = ast_event_check_subscriber(AST_EVENT_CUSTOM,
AST_EVENT_IE_DEVICE, AST_EVENT_IE_PLTYPE_STR, "foo/bar",
AST_EVENT_IE_END);
if (sub_res != AST_EVENT_SUB_EXISTS) {
ast_test_status_update(test, "Str FOO/bar subscription lacks proper case-sensitivity for device strings\n");
res = AST_TEST_FAIL;
}
/* Make sure that the non-tech portion of the device string is case-sensitive
* and fails to match appropriately */
sub_res = ast_event_check_subscriber(AST_EVENT_CUSTOM,
AST_EVENT_IE_DEVICE, AST_EVENT_IE_PLTYPE_STR, "FOO/BAR",
AST_EVENT_IE_END);
if (sub_res == AST_EVENT_SUB_EXISTS) {
ast_test_status_update(test, "Str FOO/bar subscription lacks proper case-sensitivity for device strings\n");
res = AST_TEST_FAIL;
}
sub_res = ast_event_check_subscriber(AST_EVENT_CUSTOM,
AST_EVENT_IE_DEVICE, AST_EVENT_IE_PLTYPE_STR, "Money",
AST_EVENT_IE_CEL_CIDNAME, AST_EVENT_IE_PLTYPE_STR, "Money",
AST_EVENT_IE_END);
if (sub_res != AST_EVENT_SUB_NONE) {
ast_test_status_update(test, "Str Money subscription should not exist! (%d)\n",
@ -630,7 +480,7 @@ AST_TEST_DEFINE(event_sub_test)
/* Check RAW matching. */
sub_res = ast_event_check_subscriber(AST_EVENT_CUSTOM,
AST_EVENT_IE_MAILBOX, AST_EVENT_IE_PLTYPE_RAW, "FOO/bar", sizeof("FOO/bar"),
AST_EVENT_IE_CEL_USEREVENT_NAME, AST_EVENT_IE_PLTYPE_RAW, "FOO/bar", sizeof("FOO/bar"),
AST_EVENT_IE_END);
if (sub_res != AST_EVENT_SUB_EXISTS) {
ast_test_status_update(test, "Raw FOO/bar subscription did not exist\n");
@ -638,7 +488,7 @@ AST_TEST_DEFINE(event_sub_test)
}
sub_res = ast_event_check_subscriber(AST_EVENT_CUSTOM,
AST_EVENT_IE_MAILBOX, AST_EVENT_IE_PLTYPE_RAW, "FOO/bar", sizeof("FOO/bar") - 1,
AST_EVENT_IE_CEL_USEREVENT_NAME, AST_EVENT_IE_PLTYPE_RAW, "FOO/bar", sizeof("FOO/bar") - 1,
AST_EVENT_IE_END);
if (sub_res != AST_EVENT_SUB_NONE) {
ast_test_status_update(test, "Raw FOO/bar-1 subscription should not exist! (%d)\n",
@ -647,7 +497,7 @@ AST_TEST_DEFINE(event_sub_test)
}
sub_res = ast_event_check_subscriber(AST_EVENT_CUSTOM,
AST_EVENT_IE_MAILBOX, AST_EVENT_IE_PLTYPE_RAW, "Monkeys", sizeof("Monkeys"),
AST_EVENT_IE_CEL_USEREVENT_NAME, AST_EVENT_IE_PLTYPE_RAW, "Monkeys", sizeof("Monkeys"),
AST_EVENT_IE_END);
if (sub_res != AST_EVENT_SUB_NONE) {
ast_test_status_update(test, "Raw Monkeys subscription should not exist! (%d)\n",
@ -657,7 +507,7 @@ AST_TEST_DEFINE(event_sub_test)
/* Check UINT matching. */
sub_res = ast_event_check_subscriber(AST_EVENT_CUSTOM,
AST_EVENT_IE_NEWMSGS, AST_EVENT_IE_PLTYPE_UINT, 5,
AST_EVENT_IE_CEL_AMAFLAGS, AST_EVENT_IE_PLTYPE_UINT, 5,
AST_EVENT_IE_END);
if (sub_res != AST_EVENT_SUB_EXISTS) {
ast_test_status_update(test, "UINT=5 subscription did not exist\n");
@ -665,7 +515,7 @@ AST_TEST_DEFINE(event_sub_test)
}
sub_res = ast_event_check_subscriber(AST_EVENT_CUSTOM,
AST_EVENT_IE_NEWMSGS, AST_EVENT_IE_PLTYPE_UINT, 1,
AST_EVENT_IE_CEL_AMAFLAGS, AST_EVENT_IE_PLTYPE_UINT, 1,
AST_EVENT_IE_END);
if (sub_res != AST_EVENT_SUB_NONE) {
ast_test_status_update(test, "UINT=1 subscription should not exist! (%d)\n",
@ -673,43 +523,6 @@ AST_TEST_DEFINE(event_sub_test)
res = AST_TEST_FAIL;
}
/* Check BITFLAGS matching. */
sub_res = ast_event_check_subscriber(AST_EVENT_CUSTOM,
AST_EVENT_IE_NEWMSGS, AST_EVENT_IE_PLTYPE_BITFLAGS, 2,
AST_EVENT_IE_END);
if (sub_res != AST_EVENT_SUB_EXISTS) {
ast_test_status_update(test, "BITFLAGS=2 subscription did not exist\n");
res = AST_TEST_FAIL;
}
sub_res = ast_event_check_subscriber(AST_EVENT_CUSTOM,
AST_EVENT_IE_NEWMSGS, AST_EVENT_IE_PLTYPE_BITFLAGS, 8,
AST_EVENT_IE_END);
if (sub_res != AST_EVENT_SUB_NONE) {
ast_test_status_update(test, "BITFLAGS=8 subscription should not exist! (%d)\n",
sub_res);
res = AST_TEST_FAIL;
}
/* Check EXISTS matching. */
sub_res = ast_event_check_subscriber(AST_EVENT_CUSTOM,
AST_EVENT_IE_NEWMSGS, AST_EVENT_IE_PLTYPE_UINT, 4,
AST_EVENT_IE_OLDMSGS, AST_EVENT_IE_PLTYPE_UINT, 100,
AST_EVENT_IE_END);
if (sub_res != AST_EVENT_SUB_EXISTS) {
ast_test_status_update(test, "EXISTS subscription did not exist\n");
res = AST_TEST_FAIL;
}
sub_res = ast_event_check_subscriber(AST_EVENT_CUSTOM,
AST_EVENT_IE_NEWMSGS, AST_EVENT_IE_PLTYPE_UINT, 4,
AST_EVENT_IE_END);
if (sub_res != AST_EVENT_SUB_NONE) {
ast_test_status_update(test, "EXISTS subscription should not exist! (%d)\n",
sub_res);
res = AST_TEST_FAIL;
}
ast_test_status_update(test, "Special event posting test\n");
/*
@ -719,8 +532,8 @@ AST_TEST_DEFINE(event_sub_test)
* TEST_SUBS_CUSTOM_RAW
*/
event = ast_event_new(AST_EVENT_CUSTOM,
AST_EVENT_IE_DEVICE, AST_EVENT_IE_PLTYPE_STR, "Mula",
AST_EVENT_IE_MAILBOX, AST_EVENT_IE_PLTYPE_RAW, "FOO/bar", sizeof("FOO/bar"),
AST_EVENT_IE_CEL_CIDNAME, AST_EVENT_IE_PLTYPE_STR, "Mula",
AST_EVENT_IE_CEL_USEREVENT_NAME, AST_EVENT_IE_PLTYPE_RAW, "FOO/bar", sizeof("FOO/bar"),
AST_EVENT_IE_END);
if (!event) {
ast_test_status_update(test, "Failed to create event\n");
@ -753,14 +566,6 @@ AST_TEST_DEFINE(event_sub_test)
goto return_cleanup;
}
if (strcmp(ast_event_subscriber_get_description(test_subs[TEST_SUBS_CUSTOM_ANY].sub),
test_subs_class_type_str(TEST_SUBS_CUSTOM_ANY))) {
ast_test_status_update(test,
"Unexpected subscription description on TEST_SUBS_CUSTOM_ANY subscription\n");
res = AST_TEST_FAIL;
goto return_cleanup;
}
/*
* Fire off some events and track what was received in the callback
*/
@ -775,8 +580,8 @@ AST_TEST_DEFINE(event_sub_test)
* TEST_SUBS_CUSTOM_ANY
*/
event = ast_event_new(AST_EVENT_CUSTOM,
AST_EVENT_IE_MAILBOX, AST_EVENT_IE_PLTYPE_RAW, "FOO/bar", sizeof("FOO/bar") - 1,
AST_EVENT_IE_DEVICE, AST_EVENT_IE_PLTYPE_STR, "FOO/bar",
AST_EVENT_IE_CEL_USEREVENT_NAME, AST_EVENT_IE_PLTYPE_RAW, "FOO/bar", sizeof("FOO/bar") - 1,
AST_EVENT_IE_CEL_CIDNAME, AST_EVENT_IE_PLTYPE_STR, "FOO/bar",
AST_EVENT_IE_END);
if (!event) {
ast_test_status_update(test, "Failed to create event\n");
@ -799,8 +604,8 @@ AST_TEST_DEFINE(event_sub_test)
* TEST_SUBS_CUSTOM_ANY
*/
event = ast_event_new(AST_EVENT_CUSTOM,
AST_EVENT_IE_DEVICE, AST_EVENT_IE_PLTYPE_STR, "Misery",
AST_EVENT_IE_MAILBOX, AST_EVENT_IE_PLTYPE_RAW, "FOO/bar", sizeof("FOO/bar"),
AST_EVENT_IE_CEL_CIDNAME, AST_EVENT_IE_PLTYPE_STR, "Misery",
AST_EVENT_IE_CEL_USEREVENT_NAME, AST_EVENT_IE_PLTYPE_RAW, "FOO/bar", sizeof("FOO/bar"),
AST_EVENT_IE_END);
if (!event) {
ast_test_status_update(test, "Failed to create event\n");
@ -820,34 +625,10 @@ AST_TEST_DEFINE(event_sub_test)
*
* Matching subscriptions:
* TEST_SUBS_CUSTOM_UINT
* TEST_SUBS_CUSTOM_BITFLAGS
* TEST_SUBS_CUSTOM_ANY
*/
event = ast_event_new(AST_EVENT_CUSTOM,
AST_EVENT_IE_NEWMSGS, AST_EVENT_IE_PLTYPE_UINT, 5,
AST_EVENT_IE_END);
if (!event) {
ast_test_status_update(test, "Failed to create event\n");
res = AST_TEST_FAIL;
goto return_cleanup;
}
if (ast_event_queue(event)) {
ast_event_destroy(event);
event = NULL;
ast_test_status_update(test, "Failed to queue event\n");
res = AST_TEST_FAIL;
goto return_cleanup;
}
/*
* Event to check BITFLAGS matching.
*
* Matching subscriptions:
* TEST_SUBS_CUSTOM_BITFLAGS
* TEST_SUBS_CUSTOM_ANY
*/
event = ast_event_new(AST_EVENT_CUSTOM,
AST_EVENT_IE_NEWMSGS, AST_EVENT_IE_PLTYPE_UINT, 4,
AST_EVENT_IE_CEL_AMAFLAGS, AST_EVENT_IE_PLTYPE_UINT, 5,
AST_EVENT_IE_END);
if (!event) {
ast_test_status_update(test, "Failed to create event\n");
@ -867,12 +648,11 @@ AST_TEST_DEFINE(event_sub_test)
*
* Matching subscriptions:
* TEST_SUBS_CUSTOM_EXISTS
* TEST_SUBS_CUSTOM_BITFLAGS
* TEST_SUBS_CUSTOM_ANY
*/
event = ast_event_new(AST_EVENT_CUSTOM,
AST_EVENT_IE_NEWMSGS, AST_EVENT_IE_PLTYPE_UINT, 4,
AST_EVENT_IE_OLDMSGS, AST_EVENT_IE_PLTYPE_UINT, 4,
AST_EVENT_IE_CEL_AMAFLAGS, AST_EVENT_IE_PLTYPE_UINT, 4,
AST_EVENT_IE_UNIQUEID, AST_EVENT_IE_PLTYPE_UINT, 4,
AST_EVENT_IE_END);
if (!event) {
ast_test_status_update(test, "Failed to create event\n");
@ -892,18 +672,17 @@ AST_TEST_DEFINE(event_sub_test)
*
* Matching subscriptions:
* TEST_SUBS_CUSTOM_DYNAMIC
* TEST_SUBS_CUSTOM_BITFLAGS
* TEST_SUBS_CUSTOM_EXISTS
* TEST_SUBS_ALL_STR
* TEST_SUBS_CUSTOM_STR
* TEST_SUBS_CUSTOM_ANY
*/
event = ast_event_new(AST_EVENT_CUSTOM,
AST_EVENT_IE_NEWMSGS, AST_EVENT_IE_PLTYPE_UINT, 4,
AST_EVENT_IE_OLDMSGS, AST_EVENT_IE_PLTYPE_UINT, 5,
AST_EVENT_IE_MAILBOX, AST_EVENT_IE_PLTYPE_RAW, "800 km", strlen("800 km"),
AST_EVENT_IE_DEVICE, AST_EVENT_IE_PLTYPE_STR, "FOO/bar",
AST_EVENT_IE_STATE, AST_EVENT_IE_PLTYPE_UINT, 5,
AST_EVENT_IE_CEL_AMAFLAGS, AST_EVENT_IE_PLTYPE_UINT, 4,
AST_EVENT_IE_UNIQUEID, AST_EVENT_IE_PLTYPE_UINT, 5,
AST_EVENT_IE_CEL_USEREVENT_NAME, AST_EVENT_IE_PLTYPE_RAW, "800 km", strlen("800 km"),
AST_EVENT_IE_CEL_CIDNAME, AST_EVENT_IE_PLTYPE_STR, "FOO/bar",
AST_EVENT_IE_CEL_EVENT_TIME_USEC, AST_EVENT_IE_PLTYPE_UINT, 5,
AST_EVENT_IE_END);
if (!event) {
ast_test_status_update(test, "Failed to create event\n");

Write Preview
Loading…
Cancel
Save