diff options
author | Richard Mudgett <rmudgett@digium.com> | 2013-01-25 19:29:04 +0000 |
---|---|---|
committer | Richard Mudgett <rmudgett@digium.com> | 2013-01-25 19:29:04 +0000 |
commit | 7bb540dc8099b000ffef973dca8a0dd701fc47d6 (patch) | |
tree | c056c56406eef147d92eef39199ee16b37d22d76 /bridges | |
parent | 6300c37152081447cc6c034a580db344e2f10bea (diff) |
More trivial bridge code cleanup.
* Breaking long lines
* Word wrapping comment blocks.
* Removing redundant initializers.
* Debug message wording.
git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@380108 65c4cc65-6c06-0410-ace0-fbb531ad65f3
Diffstat (limited to 'bridges')
-rw-r--r-- | bridges/bridge_multiplexed.c | 21 | ||||
-rw-r--r-- | bridges/bridge_simple.c | 3 | ||||
-rw-r--r-- | bridges/bridge_softmix.c | 28 |
3 files changed, 32 insertions, 20 deletions
diff --git a/bridges/bridge_multiplexed.c b/bridges/bridge_multiplexed.c index bce93cef6..c251e2d26 100644 --- a/bridges/bridge_multiplexed.c +++ b/bridges/bridge_multiplexed.c @@ -100,11 +100,13 @@ static int multiplexed_bridge_create(struct ast_bridge *bridge) ao2_lock(multiplexed_threads); /* Try to find an existing thread to handle our additional channels */ - if (!(multiplexed_thread = ao2_callback(multiplexed_threads, 0, find_multiplexed_thread, NULL))) { + multiplexed_thread = ao2_callback(multiplexed_threads, 0, find_multiplexed_thread, NULL); + if (!multiplexed_thread) { int flags; /* If we failed we will have to create a new one from scratch */ - if (!(multiplexed_thread = ao2_alloc(sizeof(*multiplexed_thread), destroy_multiplexed_thread))) { + multiplexed_thread = ao2_alloc(sizeof(*multiplexed_thread), destroy_multiplexed_thread); + if (!multiplexed_thread) { ast_debug(1, "Failed to find or create a new multiplexed thread for bridge '%p'\n", bridge); ao2_unlock(multiplexed_threads); return -1; @@ -207,11 +209,14 @@ static void *multiplexed_thread_function(void *data) ast_debug(1, "Starting actual thread for multiplexed thread '%p'\n", multiplexed_thread); while (multiplexed_thread->thread != AST_PTHREADT_STOP) { - struct ast_channel *winner = NULL, *first = multiplexed_thread->chans[0]; - int to = -1, outfd = -1; + struct ast_channel *winner; + struct ast_channel *first = multiplexed_thread->chans[0]; + int to = -1; + int outfd = -1; /* Move channels around so not just the first one gets priority */ - memmove(multiplexed_thread->chans, multiplexed_thread->chans + 1, sizeof(struct ast_channel *) * (multiplexed_thread->service_count - 1)); + memmove(multiplexed_thread->chans, multiplexed_thread->chans + 1, + sizeof(struct ast_channel *) * (multiplexed_thread->service_count - 1)); multiplexed_thread->chans[multiplexed_thread->service_count - 1] = first; multiplexed_thread->waiting = 1; @@ -233,8 +238,9 @@ static void *multiplexed_thread_function(void *data) } } if (winner && ast_channel_internal_bridge(winner)) { - struct ast_bridge *bridge = ast_channel_internal_bridge(winner); + struct ast_bridge *bridge; int stop = 0; + ao2_unlock(multiplexed_thread); while ((bridge = ast_channel_internal_bridge(winner)) && ao2_trylock(bridge)) { sched_yield(); @@ -310,7 +316,8 @@ static void multiplexed_add_or_remove(struct multiplexed_thread *multiplexed_thr /*! \brief Join function which actually adds the channel into the array to be monitored */ static int multiplexed_bridge_join(struct ast_bridge *bridge, struct ast_bridge_channel *bridge_channel) { - struct ast_channel *c0 = AST_LIST_FIRST(&bridge->channels)->chan, *c1 = AST_LIST_LAST(&bridge->channels)->chan; + struct ast_channel *c0 = AST_LIST_FIRST(&bridge->channels)->chan; + struct ast_channel *c1 = AST_LIST_LAST(&bridge->channels)->chan; struct multiplexed_thread *multiplexed_thread = bridge->bridge_pvt; ast_debug(1, "Adding channel '%s' to multiplexed thread '%p' for monitoring\n", ast_channel_name(bridge_channel->chan), multiplexed_thread); diff --git a/bridges/bridge_simple.c b/bridges/bridge_simple.c index 93864e6de..947983bae 100644 --- a/bridges/bridge_simple.c +++ b/bridges/bridge_simple.c @@ -47,7 +47,8 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$") static int simple_bridge_join(struct ast_bridge *bridge, struct ast_bridge_channel *bridge_channel) { - struct ast_channel *c0 = AST_LIST_FIRST(&bridge->channels)->chan, *c1 = AST_LIST_LAST(&bridge->channels)->chan; + struct ast_channel *c0 = AST_LIST_FIRST(&bridge->channels)->chan; + struct ast_channel *c1 = AST_LIST_LAST(&bridge->channels)->chan; /* If this is the first channel we can't make it compatible... unless we make it compatible with itself O.o */ if (AST_LIST_FIRST(&bridge->channels) == AST_LIST_LAST(&bridge->channels)) { diff --git a/bridges/bridge_softmix.c b/bridges/bridge_softmix.c index a04388f4c..613601a1f 100644 --- a/bridges/bridge_softmix.c +++ b/bridges/bridge_softmix.c @@ -284,7 +284,8 @@ static void softmix_process_write_audio(struct softmix_translate_helper *trans_h static void softmix_translate_helper_cleanup(struct softmix_translate_helper *trans_helper) { - struct softmix_translate_helper_entry *entry = NULL; + struct softmix_translate_helper_entry *entry; + AST_LIST_TRAVERSE(&trans_helper->entries, entry, entry) { if (entry->out_frame) { ast_frfree(entry->out_frame); @@ -328,8 +329,10 @@ static int softmix_bridge_create(struct ast_bridge *bridge) /*! \brief Function called when a bridge is destroyed */ static int softmix_bridge_destroy(struct ast_bridge *bridge) { - struct softmix_bridge_data *softmix_data = bridge->bridge_pvt; - if (!bridge->bridge_pvt) { + struct softmix_bridge_data *softmix_data; + + softmix_data = bridge->bridge_pvt; + if (!softmix_data) { return -1; } ao2_ref(softmix_data, -1); @@ -382,7 +385,7 @@ static void set_softmix_bridge_data(int rate, int interval, struct ast_bridge_ch /*! \brief Function called when a channel is joined into the bridge */ static int softmix_bridge_join(struct ast_bridge *bridge, struct ast_bridge_channel *bridge_channel) { - struct softmix_channel *sc = NULL; + struct softmix_channel *sc; struct softmix_bridge_data *softmix_data = bridge->bridge_pvt; /* Create a new softmix_channel structure and allocate various things on it */ @@ -718,7 +721,7 @@ static int softmix_mixing_array_init(struct softmix_mixing_array *mixing_array, memset(mixing_array, 0, sizeof(*mixing_array)); mixing_array->max_num_entries = starting_num_entries; if (!(mixing_array->buffers = ast_calloc(mixing_array->max_num_entries, sizeof(int16_t *)))) { - ast_log(LOG_NOTICE, "Failed to allocate softmix mixing structure. \n"); + ast_log(LOG_NOTICE, "Failed to allocate softmix mixing structure.\n"); return -1; } return 0; @@ -735,7 +738,7 @@ static int softmix_mixing_array_grow(struct softmix_mixing_array *mixing_array, /* give it some room to grow since memory is cheap but allocations can be expensive */ mixing_array->max_num_entries = num_entries; if (!(tmp = ast_realloc(mixing_array->buffers, (mixing_array->max_num_entries * sizeof(int16_t *))))) { - ast_log(LOG_NOTICE, "Failed to re-allocate softmix mixing structure. \n"); + ast_log(LOG_NOTICE, "Failed to re-allocate softmix mixing structure.\n"); return -1; } mixing_array->buffers = tmp; @@ -747,7 +750,7 @@ static int softmix_bridge_thread(struct ast_bridge *bridge) { struct softmix_stats stats = { { 0 }, }; struct softmix_mixing_array mixing_array; - struct softmix_bridge_data *softmix_data = bridge->bridge_pvt; + struct softmix_bridge_data *softmix_data; struct ast_timer *timer; struct softmix_translate_helper trans_helper; int16_t buf[MAX_DATALEN]; @@ -757,7 +760,8 @@ static int softmix_bridge_thread(struct ast_bridge *bridge) int i, x; int res = -1; - if (!(softmix_data = bridge->bridge_pvt)) { + softmix_data = bridge->bridge_pvt; + if (!softmix_data) { goto softmix_cleanup; } @@ -769,12 +773,11 @@ static int softmix_bridge_thread(struct ast_bridge *bridge) /* Give the mixing array room to grow, memory is cheap but allocations are expensive. */ if (softmix_mixing_array_init(&mixing_array, bridge->num + 10)) { - ast_log(LOG_NOTICE, "Failed to allocate softmix mixing structure. \n"); goto softmix_cleanup; } while (!bridge->stop && !bridge->refresh && bridge->array_num) { - struct ast_bridge_channel *bridge_channel = NULL; + struct ast_bridge_channel *bridge_channel; int timeout = -1; enum ast_format_id cur_slin_id = ast_format_slin_by_rate(softmix_data->internal_rate); unsigned int softmix_samples = SOFTMIX_SAMPLES(softmix_data->internal_rate, softmix_data->internal_mixing_interval); @@ -790,7 +793,8 @@ static int softmix_bridge_thread(struct ast_bridge *bridge) } /* Grow the mixing array buffer as participants are added. */ - if (mixing_array.max_num_entries < bridge->num && softmix_mixing_array_grow(&mixing_array, bridge->num + 5)) { + if (mixing_array.max_num_entries < bridge->num + && softmix_mixing_array_grow(&mixing_array, bridge->num + 5)) { goto softmix_cleanup; } @@ -887,7 +891,7 @@ static int softmix_bridge_thread(struct ast_bridge *bridge) /* Wait for the timing source to tell us to wake up and get things done */ ast_waitfor_n_fd(&timingfd, 1, &timeout, NULL); if (ast_timer_ack(timer, 1) < 0) { - ast_log(LOG_ERROR, "Failed to acknowledge timer in softmix bridge\n"); + ast_log(LOG_ERROR, "Failed to acknowledge timer in softmix bridge.\n"); ao2_lock(bridge); goto softmix_cleanup; } |