EventConsumer Class Reference

#include <switch_cpp.h>

Collaboration diagram for EventConsumer:

[legend]

Public Member Functions
	EventConsumer (const char *event_name=NULL, const char *subclass_name="")
	~EventConsumer ()
int	bind (const char *event_name, const char *subclass_name="")
Event *	pop (int block=0, int timeout=0)
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

---

Detailed Description

Definition at line 177 of file switch_cpp.h.

---

Constructor & Destructor Documentation

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

Definition at line 53 of file switch_cpp.cpp.

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

{

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

}

EventConsumer::~EventConsumer

(

)

Definition at line 111 of file switch_cpp.cpp.

References enodes, events, node_index, pool, switch_core_destroy_memory_pool, switch_event_unbind(), and switch_queue_interrupt_all().

{
        uint32_t i;

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

        if (events) {
                switch_queue_interrupt_all(events);
        }

        switch_core_destroy_memory_pool(&pool);
}

---

Member Function Documentation

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

Definition at line 66 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_name_event(), SWITCH_STATUS_SUCCESS, switch_str_nil, and zstr.

Referenced by EventConsumer().

{
        switch_event_types_t event_id = SWITCH_EVENT_CUSTOM;
        switch_name_event(event_name, &event_id);


        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;
        } else {
                switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Cannot bind to %s %s\n", event_name, switch_str_nil(subclass_name));
                return 0;
        }
}

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

Definition at line 88 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 (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;
}

---

Field Documentation

char* EventConsumer::e_callback

Definition at line 183 of file switch_cpp.h.

char* EventConsumer::e_cb_arg

Definition at line 185 of file switch_cpp.h.

switch_event_types_t EventConsumer::e_event_id

Definition at line 182 of file switch_cpp.h.

char* EventConsumer::e_subclass_name

Definition at line 184 of file switch_cpp.h.

switch_event_node_t* EventConsumer::enodes[SWITCH_EVENT_ALL+1]

Definition at line 186 of file switch_cpp.h.

Referenced by ~EventConsumer().

switch_queue_t* EventConsumer::events

Definition at line 181 of file switch_cpp.h.

Referenced by event_handler(), EventConsumer(), and ~EventConsumer().

uint32_t EventConsumer::node_index

Definition at line 187 of file switch_cpp.h.

Referenced by EventConsumer(), and ~EventConsumer().

switch_memory_pool_t* EventConsumer::pool [protected]

Definition at line 179 of file switch_cpp.h.

Referenced by EventConsumer(), and ~EventConsumer().

---

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

• switch_cpp.h
• switch_cpp.cpp

---