summaryrefslogtreecommitdiff
path: root/src/lib/openjpip/session_manager.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/lib/openjpip/session_manager.c')
-rw-r--r--src/lib/openjpip/session_manager.c202
1 files changed, 101 insertions, 101 deletions
diff --git a/src/lib/openjpip/session_manager.c b/src/lib/openjpip/session_manager.c
index e48873e8..a0b7c57a 100644
--- a/src/lib/openjpip/session_manager.c
+++ b/src/lib/openjpip/session_manager.c
@@ -46,151 +46,151 @@
sessionlist_param_t * gene_sessionlist(void)
{
- sessionlist_param_t *sessionlist;
+ sessionlist_param_t *sessionlist;
- sessionlist = (sessionlist_param_t *)opj_malloc( sizeof(sessionlist_param_t));
-
- sessionlist->first = NULL;
- sessionlist->last = NULL;
+ sessionlist = (sessionlist_param_t *)opj_malloc( sizeof(sessionlist_param_t));
- return sessionlist;
+ sessionlist->first = NULL;
+ sessionlist->last = NULL;
+
+ return sessionlist;
}
session_param_t * gene_session( sessionlist_param_t *sessionlist)
{
- session_param_t *session;
-
- session = (session_param_t *)opj_malloc( sizeof(session_param_t));
-
- session->channellist = gene_channellist();
- session->cachemodellist = gene_cachemodellist();
-
- session->next = NULL;
-
- if( sessionlist->first) /* there are one or more entries */
- sessionlist->last->next = session;
- else /* first entry */
- sessionlist->first = session;
- sessionlist->last = session;
-
- return session;
+ session_param_t *session;
+
+ session = (session_param_t *)opj_malloc( sizeof(session_param_t));
+
+ session->channellist = gene_channellist();
+ session->cachemodellist = gene_cachemodellist();
+
+ session->next = NULL;
+
+ if( sessionlist->first) /* there are one or more entries */
+ sessionlist->last->next = session;
+ else /* first entry */
+ sessionlist->first = session;
+ sessionlist->last = session;
+
+ return session;
}
-OPJ_BOOL search_session_and_channel( char cid[],
- sessionlist_param_t *sessionlist,
- session_param_t **foundsession,
- channel_param_t **foundchannel)
+OPJ_BOOL search_session_and_channel( char cid[],
+ sessionlist_param_t *sessionlist,
+ session_param_t **foundsession,
+ channel_param_t **foundchannel)
{
- *foundsession = sessionlist->first;
-
- while( *foundsession != NULL){
-
- *foundchannel = (*foundsession)->channellist->first;
-
- while( *foundchannel != NULL){
-
- if( strcmp( cid, (*foundchannel)->cid) == 0)
- return OPJ_TRUE;
-
- *foundchannel = (*foundchannel)->next;
+ *foundsession = sessionlist->first;
+
+ while( *foundsession != NULL) {
+
+ *foundchannel = (*foundsession)->channellist->first;
+
+ while( *foundchannel != NULL) {
+
+ if( strcmp( cid, (*foundchannel)->cid) == 0)
+ return OPJ_TRUE;
+
+ *foundchannel = (*foundchannel)->next;
+ }
+ *foundsession = (*foundsession)->next;
}
- *foundsession = (*foundsession)->next;
- }
-
- fprintf( FCGI_stdout, "Status: 503\r\n");
- fprintf( FCGI_stdout, "Reason: Channel %s not found\r\n", cid);
- return OPJ_FALSE;
+ fprintf( FCGI_stdout, "Status: 503\r\n");
+ fprintf( FCGI_stdout, "Reason: Channel %s not found\r\n", cid);
+
+ return OPJ_FALSE;
}
void insert_cachemodel_into_session( session_param_t *session, cachemodel_param_t *cachemodel)
{
- if(!cachemodel)
- return;
+ if(!cachemodel)
+ return;
#ifndef SERVER
- fprintf( logstream, "local log: insert cachemodel into session\n");
+ fprintf( logstream, "local log: insert cachemodel into session\n");
#endif
- if( session->cachemodellist->first != NULL)
- session->cachemodellist->last->next = cachemodel;
- else
- session->cachemodellist->first = cachemodel;
- session->cachemodellist->last = cachemodel;
+ if( session->cachemodellist->first != NULL)
+ session->cachemodellist->last->next = cachemodel;
+ else
+ session->cachemodellist->first = cachemodel;
+ session->cachemodellist->last = cachemodel;
}
OPJ_BOOL delete_session( session_param_t **session, sessionlist_param_t *sessionlist)
{
- session_param_t *ptr;
+ session_param_t *ptr;
- if( *session == NULL)
- return OPJ_FALSE;
+ if( *session == NULL)
+ return OPJ_FALSE;
- if( *session == sessionlist->first)
- sessionlist->first = (*session)->next;
- else{
- ptr = sessionlist->first;
- while( ptr->next != *session)
- ptr = ptr->next;
- ptr->next = (*session)->next;
+ if( *session == sessionlist->first)
+ sessionlist->first = (*session)->next;
+ else {
+ ptr = sessionlist->first;
+ while( ptr->next != *session)
+ ptr = ptr->next;
+ ptr->next = (*session)->next;
+
+ if( *session == sessionlist->last)
+ sessionlist->last = ptr;
+ }
- if( *session == sessionlist->last)
- sessionlist->last = ptr;
- }
-
- delete_channellist( &((*session)->channellist));
- delete_cachemodellist( &((*session)->cachemodellist));
+ delete_channellist( &((*session)->channellist));
+ delete_cachemodellist( &((*session)->cachemodellist));
#ifndef SERVER
- fprintf( logstream, "local log: session: %p deleted!\n", (void *)(*session));
+ fprintf( logstream, "local log: session: %p deleted!\n", (void *)(*session));
#endif
- opj_free( *session);
+ opj_free( *session);
- return OPJ_TRUE;
+ return OPJ_TRUE;
}
void delete_sessionlist( sessionlist_param_t **sessionlist)
-{
- session_param_t *sessionPtr, *sessionNext;
+{
+ session_param_t *sessionPtr, *sessionNext;
- sessionPtr = (*sessionlist)->first;
- while( sessionPtr != NULL){
- sessionNext=sessionPtr->next;
+ sessionPtr = (*sessionlist)->first;
+ while( sessionPtr != NULL) {
+ sessionNext=sessionPtr->next;
- delete_channellist( &(sessionPtr->channellist));
- delete_cachemodellist( &(sessionPtr->cachemodellist));
+ delete_channellist( &(sessionPtr->channellist));
+ delete_cachemodellist( &(sessionPtr->cachemodellist));
#ifndef SERVER
- fprintf( logstream, "local log: session: %p deleted!\n", (void *)sessionPtr);
+ fprintf( logstream, "local log: session: %p deleted!\n", (void *)sessionPtr);
#endif
- opj_free( sessionPtr);
+ opj_free( sessionPtr);
- sessionPtr=sessionNext;
- }
+ sessionPtr=sessionNext;
+ }
- (*sessionlist)->first = NULL;
- (*sessionlist)->last = NULL;
+ (*sessionlist)->first = NULL;
+ (*sessionlist)->last = NULL;
- opj_free(*sessionlist);
+ opj_free(*sessionlist);
}
void print_allsession( sessionlist_param_t *sessionlist)
{
- session_param_t *ptr;
- cachemodel_param_t *cachemodel;
- int i=0;
-
- fprintf( logstream, "SESSIONS info:\n");
-
- ptr = sessionlist->first;
- while( ptr != NULL){
- fprintf( logstream, "session No.%d\n", i++);
- print_allchannel( ptr->channellist);
- cachemodel = ptr->cachemodellist->first;
- while( cachemodel){
- print_target( cachemodel->target);
- cachemodel = cachemodel->next;
+ session_param_t *ptr;
+ cachemodel_param_t *cachemodel;
+ int i=0;
+
+ fprintf( logstream, "SESSIONS info:\n");
+
+ ptr = sessionlist->first;
+ while( ptr != NULL) {
+ fprintf( logstream, "session No.%d\n", i++);
+ print_allchannel( ptr->channellist);
+ cachemodel = ptr->cachemodellist->first;
+ while( cachemodel) {
+ print_target( cachemodel->target);
+ cachemodel = cachemodel->next;
+ }
+ ptr=ptr->next;
}
- ptr=ptr->next;
- }
}