EventConsumer Class Reference

#include <switch_cpp.h>

Collaboration diagram for EventConsumer:

Public Member Functions
	EventConsumer (const char *event_name=NULL, const char *subclass_name="", int len=5000)
	~EventConsumer ()
int	bind (const char *event_name, const char *subclass_name="")
Event *	pop (int block=0, int timeout=0)
void	cleanup ()
	EventConsumer (const char *event_name=NULL, const char *subclass_name="", int len=5000)
	~EventConsumer ()
int	bind (const char *event_name, const char *subclass_name="")
Event *	pop (int block=0, int timeout=0)
void	cleanup ()

Data Fields
switch_queue_t *	events
switch_event_types_t	e_event_id
char *	e_callback
char *	e_subclass_name
char *	e_cb_arg
switch_event_node_t *	enodes [SWITCH_EVENT_ALL+1]
uint32_t	node_index

Protected Attributes
switch_memory_pool_t *	pool
int	ready

Detailed Description

Definition at line 182 of file switch_cpp.h.

Constructor & Destructor Documentation

EventConsumer::EventConsumer	(	const char *	event_name = NULL,
		const char *	subclass_name = "",
		int	len = 5000
	)

Definition at line 54 of file switch_cpp.cpp.

References bind(), events, node_index, pool, ready, switch_core_new_memory_pool, switch_queue_create(), and zstr.

{

        switch_core_new_memory_pool(&pool);     
        switch_queue_create(&events, len, pool);
        node_index = 0;
        ready = 1;
        
        if (!zstr(event_name)) {
                bind(event_name, subclass_name);
        }
}

EventConsumer::~EventConsumer

(

)

Definition at line 156 of file switch_cpp.cpp.

References cleanup().

{
        cleanup();
}

EventConsumer::EventConsumer	(	const char *	event_name = NULL,
		const char *	subclass_name = "",
		int	len = 5000
	)

EventConsumer::~EventConsumer

(

)

Member Function Documentation

int EventConsumer::bind	(	const char *	event_name,
		const char *	subclass_name = ""
	)

Definition at line 67 of file switch_cpp.cpp.

References event_handler(), SWITCH_CHANNEL_LOG, SWITCH_EVENT_ALL, switch_event_bind_removable(), SWITCH_EVENT_CUSTOM, SWITCH_LOG_ERROR, SWITCH_LOG_NOTICE, switch_log_printf(), SWITCH_LOG_WARNING, switch_name_event(), SWITCH_STATUS_SUCCESS, switch_str_nil, and zstr.

Referenced by EventConsumer().

{
        switch_event_types_t event_id = SWITCH_EVENT_CUSTOM;

        if (!ready) {
                return 0;
        }

        if (switch_name_event(event_name, &event_id) != SWITCH_STATUS_SUCCESS) {
                switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_WARNING, "Can't bind to %s, event not found\n", event_name);
                return 0;
        }

        if (zstr(subclass_name)) {
                subclass_name = NULL;
        }
        
        if (node_index <= SWITCH_EVENT_ALL && 
                switch_event_bind_removable(__FILE__, event_id, subclass_name, event_handler, this, &enodes[node_index]) == SWITCH_STATUS_SUCCESS) {
                switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_NOTICE, "bound to %s %s\n", event_name, switch_str_nil(subclass_name));
                node_index++;
                return 1;
        }

        switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Cannot bind to %s %s\n", event_name, switch_str_nil(subclass_name));
        return 0;
}

int EventConsumer::bind	(	const char *	event_name,
		const char *	subclass_name = ""
	)

void EventConsumer::cleanup

(

)

void EventConsumer::cleanup

(

)

Definition at line 123 of file switch_cpp.cpp.

References pool, switch_core_destroy_memory_pool, switch_event_destroy(), switch_event_unbind(), switch_queue_interrupt_all(), switch_queue_trypop(), and SWITCH_STATUS_SUCCESS.

Referenced by ~EventConsumer().

{

        uint32_t i;
        void *pop;

        if (!ready) {
                return;
        }       

        ready = 0;

        for (i = 0; i < node_index; i++) {
                switch_event_unbind(&enodes[i]);
        }

        node_index = 0;

        if (events) {
                switch_queue_interrupt_all(events);
        }

        while(switch_queue_trypop(events, &pop) == SWITCH_STATUS_SUCCESS) {
                switch_event_t *event = (switch_event_t *) pop;
                switch_event_destroy(&event);
        }


        switch_core_destroy_memory_pool(&pool);

}

Event * EventConsumer::pop	(	int	block = 0,
		int	timeout = 0
	)

Definition at line 96 of file switch_cpp.cpp.

References switch_queue_pop(), switch_queue_pop_timeout(), and switch_queue_trypop().

{
        void *pop = NULL;
        Event *ret = NULL;
        switch_event_t *event;

        if (!ready) {
                return NULL;
        }
        
        if (block) {
                if (timeout > 0) {
                        switch_queue_pop_timeout(events, &pop, (switch_interval_time_t) timeout * 1000); // millisec rather than microsec
                } else {
                        switch_queue_pop(events, &pop);
                }
        } else {
                switch_queue_trypop(events, &pop);
        }

        if ((event = (switch_event_t *) pop)) {
                ret = new Event(event, 1);
        }

        return ret;
}

Event* EventConsumer::pop	(	int	block = 0,
		int	timeout = 0
	)

Field Documentation

char * EventConsumer::e_callback

Definition at line 189 of file switch_cpp.h.

char * EventConsumer::e_cb_arg

Definition at line 191 of file switch_cpp.h.

switch_event_types_t EventConsumer::e_event_id

Definition at line 188 of file switch_cpp.h.

char * EventConsumer::e_subclass_name

Definition at line 190 of file switch_cpp.h.

switch_event_node_t * EventConsumer::enodes

Definition at line 192 of file switch_cpp.h.

switch_queue_t * EventConsumer::events

Definition at line 187 of file switch_cpp.h.

Referenced by event_handler(), and EventConsumer().

uint32_t EventConsumer::node_index

Definition at line 193 of file switch_cpp.h.

Referenced by EventConsumer().

switch_memory_pool_t * EventConsumer::pool

protected

Definition at line 184 of file switch_cpp.h.

Referenced by EventConsumer().

int EventConsumer::ready

protected

Definition at line 185 of file switch_cpp.h.

Referenced by EventConsumer().

---

The documentation for this class was generated from the following files:

• switch_cpp.h
• switch_swigable_cpp.h
• switch_cpp.cpp