diff options
Diffstat (limited to 'tinyMEDIA/src/tmedia_consumer.c')
| -rwxr-xr-x | tinyMEDIA/src/tmedia_consumer.c | 266 |
1 files changed, 133 insertions, 133 deletions
diff --git a/tinyMEDIA/src/tmedia_consumer.c b/tinyMEDIA/src/tmedia_consumer.c index 215a959..96f42be 100755 --- a/tinyMEDIA/src/tmedia_consumer.c +++ b/tinyMEDIA/src/tmedia_consumer.c @@ -1,18 +1,18 @@ /* * Copyright (C) 2010-2014 Mamadou DIOP -* +* * This file is part of Open Source Doubango Framework. * * DOUBANGO is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. -* +* * DOUBANGO is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. -* +* * You should have received a copy of the GNU General Public License * along with DOUBANGO. * @@ -42,19 +42,19 @@ static const tmedia_consumer_plugin_def_t* __tmedia_consumer_plugins[TMED_CONSUM */ int tmedia_consumer_init(tmedia_consumer_t* self) { - if(!self){ - TSK_DEBUG_ERROR("Invalid parameter"); - return -1; - } + if(!self) { + TSK_DEBUG_ERROR("Invalid parameter"); + return -1; + } - self->video.in.chroma = TMEDIA_CONSUMER_CHROMA_DEFAULT; - self->video.display.chroma = TMEDIA_CONSUMER_CHROMA_DEFAULT; + self->video.in.chroma = TMEDIA_CONSUMER_CHROMA_DEFAULT; + self->video.display.chroma = TMEDIA_CONSUMER_CHROMA_DEFAULT; - self->audio.bits_per_sample = TMEDIA_CONSUMER_BITS_PER_SAMPLE_DEFAULT; - self->audio.ptime = tmedia_defaults_get_audio_ptime(); - self->audio.volume = tmedia_defaults_get_volume(); + self->audio.bits_per_sample = TMEDIA_CONSUMER_BITS_PER_SAMPLE_DEFAULT; + self->audio.ptime = tmedia_defaults_get_audio_ptime(); + self->audio.volume = tmedia_defaults_get_volume(); - return 0; + return 0; } /**@ingroup tmedia_consumer_group @@ -62,11 +62,11 @@ int tmedia_consumer_init(tmedia_consumer_t* self) */ int tmedia_consumer_set(tmedia_consumer_t *self, const tmedia_param_t* param) { - if(!self || !self->plugin || !self->plugin->set || !param){ - TSK_DEBUG_ERROR("Invalid parameter"); - return -1; - } - return self->plugin->set(self, param); + if(!self || !self->plugin || !self->plugin->set || !param) { + TSK_DEBUG_ERROR("Invalid parameter"); + return -1; + } + return self->plugin->set(self, param); } /**@ingroup tmedia_consumer_group @@ -77,15 +77,15 @@ int tmedia_consumer_set(tmedia_consumer_t *self, const tmedia_param_t* param) */ int tmedia_consumer_prepare(tmedia_consumer_t *self, const tmedia_codec_t* codec) { - int ret; - if(!self || !self->plugin || !self->plugin->prepare || !codec){ - TSK_DEBUG_ERROR("Invalid parameter"); - return -1; - } - if((ret = self->plugin->prepare(self, codec)) == 0){ - self->is_prepared = tsk_true; - } - return ret; + int ret; + if(!self || !self->plugin || !self->plugin->prepare || !codec) { + TSK_DEBUG_ERROR("Invalid parameter"); + return -1; + } + if((ret = self->plugin->prepare(self, codec)) == 0) { + self->is_prepared = tsk_true; + } + return ret; } /**@ingroup tmedia_consumer_group @@ -95,15 +95,15 @@ int tmedia_consumer_prepare(tmedia_consumer_t *self, const tmedia_codec_t* codec */ int tmedia_consumer_start(tmedia_consumer_t *self) { - int ret; - if (!self || !self->plugin || !self->plugin->start) { - TSK_DEBUG_ERROR("Invalid parameter"); - return -1; - } - if ((ret = self->plugin->start(self)) == 0) { - self->is_started = tsk_true; - } - return ret; + int ret; + if (!self || !self->plugin || !self->plugin->start) { + TSK_DEBUG_ERROR("Invalid parameter"); + return -1; + } + if ((ret = self->plugin->start(self)) == 0) { + self->is_started = tsk_true; + } + return ret; } /**@ingroup tmedia_consumer_group @@ -114,11 +114,11 @@ int tmedia_consumer_start(tmedia_consumer_t *self) */ int tmedia_consumer_consume(tmedia_consumer_t* self, const void* buffer, tsk_size_t size, const tsk_object_t* proto_hdr) { - if(!self || !self->plugin || !self->plugin->consume){ - TSK_DEBUG_ERROR("Invalid parameter"); - return -1; - } - return self->plugin->consume(self, buffer, size, proto_hdr); + if(!self || !self->plugin || !self->plugin->consume) { + TSK_DEBUG_ERROR("Invalid parameter"); + return -1; + } + return self->plugin->consume(self, buffer, size, proto_hdr); } /**@ingroup tmedia_consumer_group @@ -128,11 +128,11 @@ int tmedia_consumer_consume(tmedia_consumer_t* self, const void* buffer, tsk_siz */ int tmedia_consumer_pause(tmedia_consumer_t *self) { - if(!self || !self->plugin || !self->plugin->pause){ - TSK_DEBUG_ERROR("Invalid parameter"); - return -1; - } - return self->plugin->pause(self); + if(!self || !self->plugin || !self->plugin->pause) { + TSK_DEBUG_ERROR("Invalid parameter"); + return -1; + } + return self->plugin->pause(self); } @@ -143,15 +143,15 @@ int tmedia_consumer_pause(tmedia_consumer_t *self) */ int tmedia_consumer_stop(tmedia_consumer_t *self) { - int ret; - if (!self || !self->plugin || !self->plugin->stop) { - TSK_DEBUG_ERROR("Invalid parameter"); - return -1; - } - if ((ret = self->plugin->stop(self)) == 0) { - self->is_started = tsk_false; - } - return ret; + int ret; + if (!self || !self->plugin || !self->plugin->stop) { + TSK_DEBUG_ERROR("Invalid parameter"); + return -1; + } + if ((ret = self->plugin->stop(self)) == 0) { + self->is_started = tsk_false; + } + return ret; } @@ -164,11 +164,11 @@ int tmedia_consumer_stop(tmedia_consumer_t *self) */ int tmedia_consumer_deinit(tmedia_consumer_t* self) { - if(!self){ - TSK_DEBUG_ERROR("Invalid parameter"); - return -1; - } - return 0; + if(!self) { + TSK_DEBUG_ERROR("Invalid parameter"); + return -1; + } + return 0; } /**@ingroup tmedia_consumer_group @@ -179,22 +179,22 @@ int tmedia_consumer_deinit(tmedia_consumer_t* self) */ tmedia_consumer_t* tmedia_consumer_create(tmedia_type_t type, uint64_t session_id) { - tmedia_consumer_t* consumer = tsk_null; - const tmedia_consumer_plugin_def_t* plugin; - tsk_size_t i = 0; + tmedia_consumer_t* consumer = tsk_null; + const tmedia_consumer_plugin_def_t* plugin; + tsk_size_t i = 0; - while((i < TMED_CONSUMER_MAX_PLUGINS) && (plugin = __tmedia_consumer_plugins[i++])){ - if(plugin->objdef && plugin->type == type){ - if((consumer = tsk_object_new(plugin->objdef))){ - /* initialize the newly created consumer */ - consumer->plugin = plugin; - consumer->session_id = session_id; - break; - } - } - } + while((i < TMED_CONSUMER_MAX_PLUGINS) && (plugin = __tmedia_consumer_plugins[i++])) { + if(plugin->objdef && plugin->type == type) { + if((consumer = tsk_object_new(plugin->objdef))) { + /* initialize the newly created consumer */ + consumer->plugin = plugin; + consumer->session_id = session_id; + break; + } + } + } - return consumer; + return consumer; } /**@ingroup tmedia_consumer_group @@ -205,22 +205,22 @@ tmedia_consumer_t* tmedia_consumer_create(tmedia_type_t type, uint64_t session_i */ int tmedia_consumer_plugin_register(const tmedia_consumer_plugin_def_t* plugin) { - tsk_size_t i; - if(!plugin){ - TSK_DEBUG_ERROR("Invalid parameter"); - return -1; - } + tsk_size_t i; + if(!plugin) { + TSK_DEBUG_ERROR("Invalid parameter"); + return -1; + } - /* add or replace the plugin */ - for(i = 0; i<TMED_CONSUMER_MAX_PLUGINS; i++){ - if(!__tmedia_consumer_plugins[i] || (__tmedia_consumer_plugins[i] == plugin)){ - __tmedia_consumer_plugins[i] = plugin; - return 0; - } - } - - TSK_DEBUG_ERROR("There are already %d plugins.", TMED_CONSUMER_MAX_PLUGINS); - return -2; + /* add or replace the plugin */ + for(i = 0; i<TMED_CONSUMER_MAX_PLUGINS; i++) { + if(!__tmedia_consumer_plugins[i] || (__tmedia_consumer_plugins[i] == plugin)) { + __tmedia_consumer_plugins[i] = plugin; + return 0; + } + } + + TSK_DEBUG_ERROR("There are already %d plugins.", TMED_CONSUMER_MAX_PLUGINS); + return -2; } /**@ingroup tmedia_consumer_group @@ -230,35 +230,35 @@ int tmedia_consumer_plugin_register(const tmedia_consumer_plugin_def_t* plugin) */ int tmedia_consumer_plugin_unregister(const tmedia_consumer_plugin_def_t* plugin) { - tsk_size_t i; - tsk_bool_t found = tsk_false; - if(!plugin){ - TSK_DEBUG_ERROR("Invalid Parameter"); - return -1; - } + tsk_size_t i; + tsk_bool_t found = tsk_false; + if(!plugin) { + TSK_DEBUG_ERROR("Invalid Parameter"); + return -1; + } - /* find the plugin to unregister */ - for(i = 0; i<TMED_CONSUMER_MAX_PLUGINS && __tmedia_consumer_plugins[i]; i++){ - if(__tmedia_consumer_plugins[i] == plugin){ - __tmedia_consumer_plugins[i] = tsk_null; - found = tsk_true; - break; - } - } + /* find the plugin to unregister */ + for(i = 0; i<TMED_CONSUMER_MAX_PLUGINS && __tmedia_consumer_plugins[i]; i++) { + if(__tmedia_consumer_plugins[i] == plugin) { + __tmedia_consumer_plugins[i] = tsk_null; + found = tsk_true; + break; + } + } - /* compact */ - if(found){ - for(; i<(TMED_CONSUMER_MAX_PLUGINS - 1); i++){ - if(__tmedia_consumer_plugins[i+1]){ - __tmedia_consumer_plugins[i] = __tmedia_consumer_plugins[i+1]; - } - else{ - break; - } - } - __tmedia_consumer_plugins[i] = tsk_null; - } - return (found ? 0 : -2); + /* compact */ + if(found) { + for(; i<(TMED_CONSUMER_MAX_PLUGINS - 1); i++) { + if(__tmedia_consumer_plugins[i+1]) { + __tmedia_consumer_plugins[i] = __tmedia_consumer_plugins[i+1]; + } + else { + break; + } + } + __tmedia_consumer_plugins[i] = tsk_null; + } + return (found ? 0 : -2); } /**@ingroup tmedia_consumer_group @@ -268,21 +268,21 @@ int tmedia_consumer_plugin_unregister(const tmedia_consumer_plugin_def_t* plugin */ int tmedia_consumer_plugin_unregister_by_type(tmedia_type_t type) { - int i, j; - - /* find the plugin to unregister */ - for (i = 0; i < TMED_CONSUMER_MAX_PLUGINS && __tmedia_consumer_plugins[i]; ) { - if ((__tmedia_consumer_plugins[i]->type & type) == __tmedia_consumer_plugins[i]->type) { - __tmedia_consumer_plugins[i] = tsk_null; - /* compact */ - for (j = i; j < (TMED_CONSUMER_MAX_PLUGINS - 1) && __tmedia_consumer_plugins[j + 1]; ++j) { - __tmedia_consumer_plugins[j] = __tmedia_consumer_plugins[j + 1]; - } - __tmedia_consumer_plugins[j] = tsk_null; - } - else { - ++i; - } - } - return 0; + int i, j; + + /* find the plugin to unregister */ + for (i = 0; i < TMED_CONSUMER_MAX_PLUGINS && __tmedia_consumer_plugins[i]; ) { + if ((__tmedia_consumer_plugins[i]->type & type) == __tmedia_consumer_plugins[i]->type) { + __tmedia_consumer_plugins[i] = tsk_null; + /* compact */ + for (j = i; j < (TMED_CONSUMER_MAX_PLUGINS - 1) && __tmedia_consumer_plugins[j + 1]; ++j) { + __tmedia_consumer_plugins[j] = __tmedia_consumer_plugins[j + 1]; + } + __tmedia_consumer_plugins[j] = tsk_null; + } + else { + ++i; + } + } + return 0; } |
