diff options
| author | Even Rouault <even.rouault@spatialys.com> | 2017-05-09 15:44:46 +0200 |
|---|---|---|
| committer | Even Rouault <even.rouault@spatialys.com> | 2017-05-09 20:46:20 +0200 |
| commit | 563bd8499e63db976ca8358216138647593354bc (patch) | |
| tree | 003599ed2b0cffd932d2122c3f72c142070efafd /src/lib/openjpip/channel_manager.c | |
| parent | d4e54e9f35d532062533f1d369c159810b01d224 (diff) | |
Reformat whole codebase with astyle.options (#128)
Diffstat (limited to 'src/lib/openjpip/channel_manager.c')
| -rw-r--r-- | src/lib/openjpip/channel_manager.c | 214 |
1 files changed, 113 insertions, 101 deletions
diff --git a/src/lib/openjpip/channel_manager.c b/src/lib/openjpip/channel_manager.c index b4344b92..69a56f23 100644 --- a/src/lib/openjpip/channel_manager.c +++ b/src/lib/openjpip/channel_manager.c @@ -47,134 +47,146 @@ channellist_param_t * gene_channellist(void) { - channellist_param_t *channellist; + channellist_param_t *channellist; - channellist = (channellist_param_t *)opj_malloc( sizeof(channellist_param_t)); - - channellist->first = NULL; - channellist->last = NULL; + channellist = (channellist_param_t *)opj_malloc(sizeof(channellist_param_t)); - return channellist; + channellist->first = NULL; + channellist->last = NULL; + + return channellist; } -channel_param_t * gene_channel( query_param_t query_param, auxtrans_param_t auxtrans, cachemodel_param_t *cachemodel, channellist_param_t *channellist) +channel_param_t * gene_channel(query_param_t query_param, + auxtrans_param_t auxtrans, cachemodel_param_t *cachemodel, + channellist_param_t *channellist) { - channel_param_t *channel; - const char transport[4][10] = { "non", "http", "http-tcp", "http-udp"}; - - if( !cachemodel){ - fprintf( FCGI_stdout, "Status: 404\r\n"); - fprintf( FCGI_stdout, "Reason: cnew cancelled\r\n"); - return NULL; - } - - channel = (channel_param_t *)opj_malloc( sizeof(channel_param_t)); - channel->cachemodel = cachemodel; - - /* set channel ID and get present time */ - snprintf( channel->cid, MAX_LENOFCID, "%x%x", (unsigned int)time( &channel->start_tm), (unsigned int)rand()); - - channel->aux = query_param.cnew; - - /* only tcp implemented for now */ - if( channel->aux == udp) - channel->aux = tcp; - - channel->next=NULL; - - set_channel_variable_param( query_param, channel); - - if( channellist->first != NULL) - channellist->last->next = channel; - else - channellist->first = channel; - channellist->last = channel; - - fprintf( FCGI_stdout, "JPIP-cnew: cid=%s", channel->cid); - fprintf( FCGI_stdout, ",transport=%s", transport[channel->aux]); - - if( channel->aux == tcp || channel->aux == udp) - fprintf( FCGI_stdout, ",auxport=%d", channel->aux==tcp ? auxtrans.tcpauxport : auxtrans.udpauxport); - - fprintf( FCGI_stdout, "\r\n"); - - return channel; + channel_param_t *channel; + const char transport[4][10] = { "non", "http", "http-tcp", "http-udp"}; + + if (!cachemodel) { + fprintf(FCGI_stdout, "Status: 404\r\n"); + fprintf(FCGI_stdout, "Reason: cnew cancelled\r\n"); + return NULL; + } + + channel = (channel_param_t *)opj_malloc(sizeof(channel_param_t)); + channel->cachemodel = cachemodel; + + /* set channel ID and get present time */ + snprintf(channel->cid, MAX_LENOFCID, "%x%x", + (unsigned int)time(&channel->start_tm), (unsigned int)rand()); + + channel->aux = query_param.cnew; + + /* only tcp implemented for now */ + if (channel->aux == udp) { + channel->aux = tcp; + } + + channel->next = NULL; + + set_channel_variable_param(query_param, channel); + + if (channellist->first != NULL) { + channellist->last->next = channel; + } else { + channellist->first = channel; + } + channellist->last = channel; + + fprintf(FCGI_stdout, "JPIP-cnew: cid=%s", channel->cid); + fprintf(FCGI_stdout, ",transport=%s", transport[channel->aux]); + + if (channel->aux == tcp || channel->aux == udp) { + fprintf(FCGI_stdout, ",auxport=%d", + channel->aux == tcp ? auxtrans.tcpauxport : auxtrans.udpauxport); + } + + fprintf(FCGI_stdout, "\r\n"); + + return channel; } -void set_channel_variable_param( query_param_t query_param, channel_param_t *channel) +void set_channel_variable_param(query_param_t query_param, + channel_param_t *channel) { - /* set roi information */ - (void)query_param; - (void)channel; + /* set roi information */ + (void)query_param; + (void)channel; } -void delete_channel( channel_param_t **channel, channellist_param_t *channellist) +void delete_channel(channel_param_t **channel, channellist_param_t *channellist) { - channel_param_t *ptr; + channel_param_t *ptr; - if( *channel == channellist->first) - channellist->first = (*channel)->next; - else{ - ptr = channellist->first; - while( ptr->next != *channel){ - ptr=ptr->next; + if (*channel == channellist->first) { + channellist->first = (*channel)->next; + } else { + ptr = channellist->first; + while (ptr->next != *channel) { + ptr = ptr->next; + } + + ptr->next = (*channel)->next; + + if (*channel == channellist->last) { + channellist->last = ptr; + } } - - ptr->next = (*channel)->next; - - if( *channel == channellist->last) - channellist->last = ptr; - } #ifndef SERVER - fprintf( logstream, "local log: channel: %s deleted\n", (*channel)->cid); + fprintf(logstream, "local log: channel: %s deleted\n", (*channel)->cid); #endif - opj_free(*channel); + opj_free(*channel); } -void delete_channellist( channellist_param_t **channellist) +void delete_channellist(channellist_param_t **channellist) { - channel_param_t *channelPtr, *channelNext; - - channelPtr = (*channellist)->first; - while( channelPtr != NULL){ - channelNext=channelPtr->next; + channel_param_t *channelPtr, *channelNext; + + channelPtr = (*channellist)->first; + while (channelPtr != NULL) { + channelNext = channelPtr->next; #ifndef SERVER - fprintf( logstream, "local log: channel %s deleted!\n", channelPtr->cid); + fprintf(logstream, "local log: channel %s deleted!\n", channelPtr->cid); #endif - opj_free(channelPtr); - channelPtr=channelNext; - } - opj_free( *channellist); + opj_free(channelPtr); + channelPtr = channelNext; + } + opj_free(*channellist); } -void print_allchannel( channellist_param_t *channellist) +void print_allchannel(channellist_param_t *channellist) { - channel_param_t *ptr; + channel_param_t *ptr; - ptr = channellist->first; - while( ptr != NULL){ - fprintf( logstream,"channel-ID=%s \t target=%s\n", ptr->cid, ptr->cachemodel->target->targetname); - ptr=ptr->next; - } + ptr = channellist->first; + while (ptr != NULL) { + fprintf(logstream, "channel-ID=%s \t target=%s\n", ptr->cid, + ptr->cachemodel->target->targetname); + ptr = ptr->next; + } } -channel_param_t * search_channel( const char cid[], channellist_param_t *channellist) +channel_param_t * search_channel(const char cid[], + channellist_param_t *channellist) { - channel_param_t *foundchannel; - - foundchannel = channellist->first; - - while( foundchannel != NULL){ - - if( strcmp( cid, foundchannel->cid) == 0) - return foundchannel; - - foundchannel = foundchannel->next; - } - fprintf( FCGI_stdout, "Status: 503\r\n"); - fprintf( FCGI_stdout, "Reason: Channel %s not found in this session\r\n", cid); - - return NULL; + channel_param_t *foundchannel; + + foundchannel = channellist->first; + + while (foundchannel != NULL) { + + if (strcmp(cid, foundchannel->cid) == 0) { + return foundchannel; + } + + foundchannel = foundchannel->next; + } + fprintf(FCGI_stdout, "Status: 503\r\n"); + fprintf(FCGI_stdout, "Reason: Channel %s not found in this session\r\n", cid); + + return NULL; } |
