applications/jpip/libopenjpip/channel_manager.c

   1 /*
   2  * $Id: channel_manager.c 44 2011-02-15 12:32:29Z kaori $
   3  *
   4  * Copyright (c) 2002-2011, Communications and Remote Sensing Laboratory, Universite catholique de Louvain (UCL), Belgium
   5  * Copyright (c) 2002-2011, Professor Benoit Macq
   6  * Copyright (c) 2010-2011, Kaori Hagihara
   7  * All rights reserved.
   8  *
   9  * Redistribution and use in source and binary forms, with or without
  10  * modification, are permitted provided that the following conditions
  11  * are met:
  12  * 1. Redistributions of source code must retain the above copyright
  13  *    notice, this list of conditions and the following disclaimer.
  14  * 2. Redistributions in binary form must reproduce the above copyright
  15  *    notice, this list of conditions and the following disclaimer in the
  16  *    documentation and/or other materials provided with the distribution.
  17  *
  18  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS `AS IS'
  19  * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  20  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  21  * ARE DISCLAIMED.  IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
  22  * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
  23  * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
  24  * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
  25  * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
  26  * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
  27  * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
  28  * POSSIBILITY OF SUCH DAMAGE.
  29  */
  30
  31 #include <stdlib.h>
  32 #include <string.h>
  33 #include <stdio.h>
  34 #include "channel_manager.h"
  35
  36 #ifdef SERVER
  37 #include "fcgi_stdio.h"
  38 #define logstream FCGI_stdout
  39 #else
  40 #define FCGI_stdout stdout
  41 #define FCGI_stderr stderr
  42 #define logstream stderr
  43 #endif //SERVER
  44
  45 channellist_param_t * gene_channellist()
  46 {
  47   channellist_param_t *channellist;
  48
  49   channellist = (channellist_param_t *)malloc( sizeof(channellist_param_t));
  50
  51   channellist->first = NULL;
  52   channellist->last  = NULL;
  53
  54   return channellist;
  55 }
  56
  57 channel_param_t * gene_channel( query_param_t query_param, cachemodel_param_t *cachemodel, channellist_param_t *channellist)
  58 {
  59   channel_param_t *channel;
  60
  61   if( !cachemodel){
  62     fprintf( FCGI_stdout, "Status: 404\r\n");
  63     fprintf( FCGI_stdout, "Reason: cnew cancelled\r\n");
  64     return NULL;
  65   }
  66
  67   channel = (channel_param_t *)malloc( sizeof(channel_param_t));
  68   channel->cachemodel = cachemodel;
  69
  70   // set channel ID and get present time
  71   snprintf( channel->cid, MAX_LENOFCID, "%x%x", (unsigned int)time( &channel->start_tm), (unsigned int)rand());
  72
  73   channel->next=NULL;
  74
  75   set_channel_variable_param( query_param, channel);
  76
  77   if( channellist->first != NULL)
  78     channellist->last->next = channel;
  79   else
  80     channellist->first = channel;
  81   channellist->last = channel;
  82
  83   fprintf( FCGI_stdout, "JPIP-cnew: cid=%s", channel->cid);
  84   // only http implemented for now
  85   fprintf( FCGI_stdout, ",transport=http\r\n");
  86
  87   return channel;
  88 }
  89
  90
  91 void set_channel_variable_param( query_param_t query_param, channel_param_t *channel)
  92 {
  93   // set roi information
  94 }
  95
  96
  97 void delete_channel( channel_param_t **channel, channellist_param_t *channellist)
  98 {
  99   channel_param_t *ptr;
 100
 101   if( *channel == channellist->first)
 102     channellist->first = (*channel)->next;
 103   else{
 104     ptr = channellist->first;
 105     while( ptr->next != *channel){
 106       ptr=ptr->next;
 107     }
 108
 109     ptr->next = (*channel)->next;
 110
 111     if( *channel == channellist->last)
 112       channellist->last = ptr;
 113   }
 114 #ifndef SERVER
 115   fprintf( logstream, "local log: channel: %s deleted\n", (*channel)->cid);
 116 #endif
 117   free(*channel);
 118 }
 119
 120 void delete_channellist( channellist_param_t **channellist)
 121 {
 122   channel_param_t *channelPtr, *channelNext;
 123
 124   channelPtr = (*channellist)->first;
 125   while( channelPtr != NULL){
 126     channelNext=channelPtr->next;
 127 #ifndef SERVER
 128       fprintf( logstream, "local log: channel %s deleted!\n", channelPtr->cid);
 129 #endif
 130       free(channelPtr);
 131       channelPtr=channelNext;
 132   }
 133   free( *channellist);
 134 }
 135
 136 void print_allchannel( channellist_param_t *channellist)
 137 {
 138   channel_param_t *ptr;
 139
 140   ptr = channellist->first;
 141   while( ptr != NULL){
 142     fprintf( logstream,"channel-ID=%s \t target=%s\n", ptr->cid, ptr->cachemodel->target->filename);
 143     ptr=ptr->next;
 144   }
 145 }
 146
 147 channel_param_t * search_channel( char cid[], channellist_param_t *channellist)
 148 {
 149   channel_param_t *foundchannel;
 150
 151   foundchannel = channellist->first;
 152
 153   while( foundchannel != NULL){
 154
 155     if( strcmp( cid, foundchannel->cid) == 0)
 156       return foundchannel;
 157
 158     foundchannel = foundchannel->next;
 159   }
 160   fprintf( FCGI_stdout, "Status: 503\r\n");
 161   fprintf( FCGI_stdout, "Reason: Channel %s not found in this session\r\n", cid);
 162
 163   return NULL;
 164 }