kenmirrors/freeswitch
1
0
Fork 0
mirror of https://github.com/signalwire/freeswitch.git synced 2025-04-29 13:43:07 +00:00
Code Issues Projects Releases Wiki Activity

mod_fifo: Tighten up some whitespace

Browse Source
This commit is contained in:
Travis Cross 2014-05-26 14:42:06 +00:00
parent e677da5870
commit e241477860
1 changed files with 0 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/mod/applications/mod_fifo/mod_fifo.c
View File

@ -166,37 +166,26 @@ static void change_pos(switch_event_t *event, int pos)
char tmp[30] = ""; char tmp[30] = "";
if (zstr(uuid)) return; if (zstr(uuid)) return;
if (!(session = switch_core_session_locate(uuid))) { if (!(session = switch_core_session_locate(uuid))) {
return; return;
} }
channel = switch_core_session_get_channel(session); channel = switch_core_session_get_channel(session);
switch_snprintf(tmp, sizeof(tmp), "%d", pos); switch_snprintf(tmp, sizeof(tmp), "%d", pos);
switch_channel_set_variable(channel, "fifo_position", tmp); switch_channel_set_variable(channel, "fifo_position", tmp);
switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "fifo_position", tmp); switch_event_add_header_string(event, SWITCH_STACK_BOTTOM, "fifo_position", tmp);
switch_core_session_rwunlock(session); switch_core_session_rwunlock(session);
} }
static switch_status_t fifo_queue_push(fifo_queue_t *queue, switch_event_t *ptr) static switch_status_t fifo_queue_push(fifo_queue_t *queue, switch_event_t *ptr)
{ {
switch_mutex_lock(queue->mutex); switch_mutex_lock(queue->mutex);
if (queue->idx == queue->nelm) { if (queue->idx == queue->nelm) {
switch_mutex_unlock(queue->mutex); switch_mutex_unlock(queue->mutex);
return SWITCH_STATUS_FALSE; return SWITCH_STATUS_FALSE;
} }
queue->data[queue->idx++] = ptr; queue->data[queue->idx++] = ptr;
switch_mutex_unlock(queue->mutex); switch_mutex_unlock(queue->mutex);
return SWITCH_STATUS_SUCCESS; return SWITCH_STATUS_SUCCESS;
} }
static int fifo_queue_size(fifo_queue_t *queue) static int fifo_queue_size(fifo_queue_t *queue)
@ -205,7 +194,6 @@ static int fifo_queue_size(fifo_queue_t *queue)
switch_mutex_lock(queue->mutex); switch_mutex_lock(queue->mutex);
s = queue->idx; s = queue->idx;
switch_mutex_unlock(queue->mutex); switch_mutex_unlock(queue->mutex);
return s; return s;
} }
@ -248,9 +236,7 @@ static switch_status_t fifo_queue_pop(fifo_queue_t *queue, switch_event_t **pop,
} }
switch_mutex_unlock(queue->mutex); switch_mutex_unlock(queue->mutex);
return SWITCH_STATUS_SUCCESS; return SWITCH_STATUS_SUCCESS;
} }