switch_mutex_lock(listen_list.mutex);
for (l = listen_list.listeners; l; l = l->next) {
- if (switch_test_flag(l, LFLAG_EVENTS) && (l->event_list[(uint8_t)event->event_id] || l->event_list[(uint8_t)SWITCH_EVENT_ALL])) {
+ uint8_t send = 0;
+
+ if (!switch_test_flag(l, LFLAG_EVENTS)) {
+ continue;
+ }
+
+ if (l->event_list[(uint8_t)SWITCH_EVENT_ALL]) {
+ send = 1;
+ } else if ((l->event_list[(uint8_t)event->event_id])) {
if (event->event_id != SWITCH_EVENT_CUSTOM || (event->subclass && switch_core_hash_find(l->event_hash, event->subclass->name))) {
- if (switch_event_dup(&clone, event) == SWITCH_STATUS_SUCCESS) {
- switch_queue_push(l->event_queue, clone);
- } else {
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Memory Error!\n");
- }
+ send = 1;
}
}
+
+ if (send) {
+ if (switch_event_dup(&clone, event) == SWITCH_STATUS_SUCCESS) {
+ switch_queue_push(l->event_queue, clone);
+ } else {
+ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "Memory Error!\n");
+ }
+ }
+
}
switch_mutex_unlock(listen_list.mutex);
}
SWITCH_MOD_DECLARE(switch_status_t) switch_module_shutdown(void)
{
+ listener_t *l;
+
+ switch_mutex_lock(listen_list.mutex);
+ for (l = listen_list.listeners; l; l = l->next) {
+ close_socket(&l->sock);
+ }
+ switch_mutex_unlock(listen_list.mutex);
close_socket(&listen_list.sock);
}
}
-static void parse_command(listener_t *listener, char *cmd, char *reply, uint32_t reply_len)
+static switch_status_t read_packet(listener_t *listener, switch_event_t **event, uint32_t timeout)
{
+ switch_size_t mlen;
+ char mbuf[1024] = "";
+ char buf[1024] = "";
+ switch_size_t len;
+ switch_status_t status = SWITCH_STATUS_SUCCESS;
+ int count = 0, bytes = 0;
+ uint32_t elapsed = 0;
+ time_t start = 0;
+ void *pop;
+ char *ptr;
+ uint8_t crcount = 0;
+
+ *event = NULL;
+ start = time(NULL);
+ ptr = mbuf;
+
+ while(listener->sock) {
+ uint8_t do_sleep = 1;
+ mlen = 1;
+ status = switch_socket_recv(listener->sock, ptr, &mlen);
+
+ if (status != SWITCH_STATUS_BREAK && status != SWITCH_STATUS_SUCCESS) {
+ return status;
+ }
+
+ if (status != SWITCH_STATUS_BREAK && mlen) {
+ bytes++;
+
+ if (*mbuf == '\r' || *mbuf == '\n') { /* bah */
+ ptr = mbuf;
+ continue;
+ }
+
+ if (*ptr == '\n') {
+ crcount++;
+ } else if (*ptr != '\r') {
+ crcount = 0;
+ }
+ ptr++;
+ if (crcount == 2) {
+ char *next;
+ char *cur = mbuf;
+
+ while(cur) {
+ if ((next = strchr(cur, '\r')) || (next = strchr(cur, '\n'))) {
+ while (*next == '\r' || *next == '\n') {
+ next++;
+ }
+ }
+ count++;
+ if (count == 1) {
+ switch_event_create(event, SWITCH_EVENT_MESSAGE);
+ switch_event_add_header(*event, SWITCH_STACK_BOTTOM, "Command", mbuf);
+ } else {
+ char *var, *val;
+ var = mbuf;
+ if ((val = strchr(var, ':'))) {
+ *val++ = '\0';
+ while(*val == ' ') {
+ val++;
+ }
+ }
+ if (var && val) {
+ switch_event_add_header(*event, SWITCH_STACK_BOTTOM, var, val);
+ }
+ }
+
+ cur = next;
+ }
+ break;
+ }
+ }
+
+ if (timeout) {
+ elapsed = (uint32_t)(time(NULL) - start);
+ if (elapsed >= timeout) {
+ switch_clear_flag_locked(listener, LFLAG_RUNNING);
+ return SWITCH_STATUS_FALSE;
+ }
+ }
+
+ if (!*mbuf) {
+ if (switch_test_flag(listener, LFLAG_LOG)) {
+ if (switch_queue_trypop(listener->log_queue, &pop) == SWITCH_STATUS_SUCCESS) {
+ char *data = (char *) pop;
+
+
+ if (data) {
+ snprintf(buf, sizeof(buf), "Content-Type: log/data\nContent-Length: %"APR_SSIZE_T_FMT"\n\n", strlen(data));
+ len = strlen(buf) + 1;
+ switch_socket_send(listener->sock, buf, &len);
+ len = strlen(data) + 1;
+ switch_socket_send(listener->sock, data, &len);
+
+ free(data);
+ }
+ do_sleep = 0;
+ }
+ }
+
+ if (switch_test_flag(listener, LFLAG_EVENTS)) {
+ if (switch_queue_trypop(listener->event_queue, &pop) == SWITCH_STATUS_SUCCESS) {
+ char hbuf[512];
+ switch_event_t *event = (switch_event_t *) pop;
+ char *etype, *packet, *xmlstr = NULL;
+
+ do_sleep = 0;
+ if (listener->format == EVENT_FORMAT_PLAIN) {
+ etype = "plain";
+ switch_event_serialize(event, buf, sizeof(buf), NULL);
+ packet = buf;
+ } else {
+ switch_xml_t xml;
+ etype = "xml";
+
+ if ((xml = switch_event_xmlize(event, NULL))) {
+ xmlstr = switch_xml_toxml(xml);
+ packet = xmlstr;
+ switch_xml_free(xml);
+ } else {
+ switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "XML ERROR!\n");
+ continue;
+ }
+ }
+
+ len = strlen(packet) + 1;
+
+ snprintf(hbuf, sizeof(hbuf), "Content-Length: %"APR_SSIZE_T_FMT"\n"
+ "Content-Type: text/event-%s\n"
+ "\n", len, etype);
+
+ len = strlen(hbuf) + 1;
+ switch_socket_send(listener->sock, hbuf, &len);
+
+ len = strlen(packet) + 1;
+ switch_socket_send(listener->sock, packet, &len);
+
+ if (xmlstr) {
+ free(xmlstr);
+ }
+ }
+ }
+ }
+ if (do_sleep) {
+ switch_yield(1000);
+ }
+ }
+
+ return status;
+
+}
+
+static switch_status_t parse_command(listener_t *listener, switch_event_t *event, char *reply, uint32_t reply_len)
+{
+ switch_status_t status = SWITCH_STATUS_SUCCESS;
+ char *cmd = switch_event_get_header(event, "command");
+
*reply = '\0';
if (!strncasecmp(cmd, "exit", 4)) {
switch_socket_send(listener->sock, buf, &len);
len = strlen(listener->retbuf) + 1;
switch_socket_send(listener->sock, listener->retbuf, &len);
- return;
+ return SWITCH_STATUS_SUCCESS;
}
} else if (!strncasecmp(cmd, "log", 3)) {
}
done:
+ if (event) {
+ switch_event_destroy(&event);
+ }
+
if (switch_strlen_zero(reply)) {
snprintf(reply, reply_len, "-ERR command not found");
}
+ return status;
}
static void *SWITCH_THREAD_FUNC listener_run(switch_thread_t *thread, void *obj)
char buf[1024];
switch_size_t len;
switch_status_t status;
- void *pop;
- uint32_t elapsed;
- time_t start = 0;
+ switch_event_t *event;
char reply[512] = "";
assert(listener != NULL);
len = strlen(buf) + 1;
switch_socket_send(listener->sock, buf, &len);
- start = time(NULL);
-
- while(!switch_test_flag(listener, LFLAG_AUTHED)) {
- len = sizeof(buf);
- memset(buf, 0, len);
- status = switch_socket_recv(listener->sock, buf, &len);
- if (status != SWITCH_STATUS_SUCCESS && status != SWITCH_STATUS_BREAK) {
- break;
- }
- if (len) {
- parse_command(listener, buf, reply, sizeof(reply));
- if (!switch_strlen_zero(reply)) {
- snprintf(buf, sizeof(buf), "Content-Type: command/reply\nReply-Text: %s\n\n", reply);
- len = strlen(buf) + 1;
- switch_socket_send(listener->sock, buf, &len);
- }
+ while (!switch_test_flag(listener, LFLAG_AUTHED)) {
+
+ status = read_packet(listener, &event, 25);
+ if (status != SWITCH_STATUS_SUCCESS) {
goto done;
}
-
- if (status == SWITCH_STATUS_BREAK) {
- elapsed = (uint32_t)(time(NULL) - start);
- if (elapsed >= 15) {
- switch_clear_flag_locked(listener, LFLAG_RUNNING);
- break;
- }
-
- //switch_yield(1000);
+ if (!event) {
continue;
}
-
+ if (parse_command(listener, event, reply, sizeof(reply)) != SWITCH_STATUS_SUCCESS) {
+ switch_clear_flag_locked(listener, LFLAG_RUNNING);
+ goto done;
+ }
+ if (!switch_strlen_zero(reply)) {
+ snprintf(buf, sizeof(buf), "Content-Type: command/reply\nReply-Text: %s\n\n", reply);
+ len = strlen(buf) + 1;
+ switch_socket_send(listener->sock, buf, &len);
+ }
+ break;
}
- done:
while(switch_test_flag(listener, LFLAG_RUNNING) && listen_list.ready) {
- uint8_t do_sleep = 1;
+ switch_event_t *event;
+
len = sizeof(buf);
memset(buf, 0, len);
- status = switch_socket_recv(listener->sock, buf, &len);
+ status = read_packet(listener, &event, 0);
- if (!len && status != SWITCH_STATUS_BREAK) {
+ if (status != SWITCH_STATUS_SUCCESS) {
break;
}
-
- if (len) {
- parse_command(listener, buf, reply, sizeof(reply));
- if (!switch_strlen_zero(reply)) {
- snprintf(buf, sizeof(buf), "Content-Type: command/reply\nReply-Text: %s\n\n", reply);
- len = strlen(buf) + 1;
- switch_socket_send(listener->sock, buf, &len);
- }
+
+ if (!event) {
continue;
}
- if (switch_test_flag(listener, LFLAG_LOG)) {
- if (switch_queue_trypop(listener->log_queue, &pop) == SWITCH_STATUS_SUCCESS) {
- char *data = (char *) pop;
- if (data) {
- snprintf(buf, sizeof(buf), "Content-Type: log/data\nContent-Length: %"APR_SSIZE_T_FMT"\n\n", strlen(data));
- len = strlen(buf) + 1;
- switch_socket_send(listener->sock, buf, &len);
- len = strlen(data) + 1;
- switch_socket_send(listener->sock, data, &len);
-
- free(data);
- }
- do_sleep = 0;
- }
+ if (parse_command(listener, event, reply, sizeof(reply)) != SWITCH_STATUS_SUCCESS) {
+ switch_clear_flag_locked(listener, LFLAG_RUNNING);
+ break;
}
- if (switch_test_flag(listener, LFLAG_EVENTS)) {
- if (switch_queue_trypop(listener->event_queue, &pop) == SWITCH_STATUS_SUCCESS) {
- char hbuf[512];
- switch_event_t *event = (switch_event_t *) pop;
- char *etype, *packet, *xmlstr = NULL;
-
- do_sleep = 0;
- if (listener->format == EVENT_FORMAT_PLAIN) {
- etype = "plain";
- switch_event_serialize(event, buf, sizeof(buf), NULL);
- packet = buf;
- } else {
- switch_xml_t xml;
- etype = "xml";
-
- if ((xml = switch_event_xmlize(event, NULL))) {
- xmlstr = switch_xml_toxml(xml);
- packet = xmlstr;
- switch_xml_free(xml);
- } else {
- switch_log_printf(SWITCH_CHANNEL_LOG, SWITCH_LOG_ERROR, "XML ERROR!\n");
- continue;
- }
- }
-
- len = strlen(packet) + 1;
-
- snprintf(hbuf, sizeof(hbuf), "Content-Length: %"APR_SSIZE_T_FMT"\n"
- "Content-Type: text/event-%s\n"
- "\n", len, etype);
-
- len = strlen(hbuf) + 1;
- switch_socket_send(listener->sock, hbuf, &len);
-
- len = strlen(packet) + 1;
- switch_socket_send(listener->sock, packet, &len);
-
- switch_event_destroy(&event);
-
- if (xmlstr) {
- free(xmlstr);
- }
- }
- }
- if (do_sleep) {
- switch_yield(1000);
+ if (!switch_strlen_zero(reply)) {
+ snprintf(buf, sizeof(buf), "Content-Type: command/reply\nReply-Text: %s\n\n", reply);
+ len = strlen(buf) + 1;
+ switch_socket_send(listener->sock, buf, &len);
}
+
}
+ done:
+
remove_listener(listener);
close_socket(&listener->sock);
projects / thirdparty / freeswitch.git / commitdiff
