diff options
Diffstat (limited to 'src/lib/openjpip/openjpip.c')
| -rw-r--r-- | src/lib/openjpip/openjpip.c | 563 |
1 files changed, 281 insertions, 282 deletions
diff --git a/src/lib/openjpip/openjpip.c b/src/lib/openjpip/openjpip.c index 6932dfa7..43e8e32e 100644 --- a/src/lib/openjpip/openjpip.c +++ b/src/lib/openjpip/openjpip.c @@ -57,152 +57,152 @@ server_record_t * init_JPIPserver( int tcp_auxport, int udp_auxport) { - server_record_t *record = (server_record_t *)opj_malloc( sizeof(server_record_t)); - - record->sessionlist = gene_sessionlist(); - record->targetlist = gene_targetlist(); - record->auxtrans = init_aux_transport( tcp_auxport, udp_auxport); - - return record; + server_record_t *record = (server_record_t *)opj_malloc( sizeof(server_record_t)); + + record->sessionlist = gene_sessionlist(); + record->targetlist = gene_targetlist(); + record->auxtrans = init_aux_transport( tcp_auxport, udp_auxport); + + return record; } void terminate_JPIPserver( server_record_t **rec) { - delete_sessionlist( &(*rec)->sessionlist); - delete_targetlist( &(*rec)->targetlist); - close_aux_transport( (*rec)->auxtrans); - - opj_free( *rec); + delete_sessionlist( &(*rec)->sessionlist); + delete_targetlist( &(*rec)->targetlist); + close_aux_transport( (*rec)->auxtrans); + + opj_free( *rec); } QR_t * parse_querystring( const char *query_string) { - QR_t *qr; + QR_t *qr; - qr = (QR_t *)opj_malloc( sizeof(QR_t)); - - qr->query = parse_query( query_string); - qr->msgqueue = NULL; - qr->channel = NULL; + qr = (QR_t *)opj_malloc( sizeof(QR_t)); - return qr; + qr->query = parse_query( query_string); + qr->msgqueue = NULL; + qr->channel = NULL; + + return qr; } OPJ_BOOL process_JPIPrequest( server_record_t *rec, QR_t *qr) { - target_param_t *target = NULL; - session_param_t *cursession = NULL; - channel_param_t *curchannel = NULL; - - if( qr->query->target || qr->query->tid){ - if( !identify_target( *(qr->query), rec->targetlist, &target)) - return OPJ_FALSE; - } - - if( qr->query->cid){ - if( !associate_channel( *(qr->query), rec->sessionlist, &cursession, &curchannel)) - return OPJ_FALSE; - qr->channel = curchannel; - } - - if( qr->query->cnew != non){ - if( !open_channel( *(qr->query), rec->sessionlist, rec->auxtrans, target, &cursession, &curchannel)) - return OPJ_FALSE; - qr->channel = curchannel; - } - - if( qr->query->cclose) - if( !close_channel( *(qr->query), rec->sessionlist, &cursession, &curchannel)) - return OPJ_FALSE; - - if( (qr->query->fx > 0 && qr->query->fy > 0) || qr->query->box_type[0][0] != 0 || qr->query->len > 0) - if( !gene_JPIPstream( *(qr->query), target, cursession, curchannel, &qr->msgqueue)) - return OPJ_FALSE; - - return OPJ_TRUE; + target_param_t *target = NULL; + session_param_t *cursession = NULL; + channel_param_t *curchannel = NULL; + + if( qr->query->target || qr->query->tid) { + if( !identify_target( *(qr->query), rec->targetlist, &target)) + return OPJ_FALSE; + } + + if( qr->query->cid) { + if( !associate_channel( *(qr->query), rec->sessionlist, &cursession, &curchannel)) + return OPJ_FALSE; + qr->channel = curchannel; + } + + if( qr->query->cnew != non) { + if( !open_channel( *(qr->query), rec->sessionlist, rec->auxtrans, target, &cursession, &curchannel)) + return OPJ_FALSE; + qr->channel = curchannel; + } + + if( qr->query->cclose) + if( !close_channel( *(qr->query), rec->sessionlist, &cursession, &curchannel)) + return OPJ_FALSE; + + if( (qr->query->fx > 0 && qr->query->fy > 0) || qr->query->box_type[0][0] != 0 || qr->query->len > 0) + if( !gene_JPIPstream( *(qr->query), target, cursession, curchannel, &qr->msgqueue)) + return OPJ_FALSE; + + return OPJ_TRUE; } void add_EORmsg( int fd, QR_t *qr); void send_responsedata( server_record_t *rec, QR_t *qr) { - int fd; - const char tmpfname[] = "tmpjpipstream.jpp"; - Byte_t *jpipstream; - Byte8_t len_of_jpipstream; - - if( (fd = open( tmpfname, O_RDWR|O_CREAT|O_EXCL, S_IRWXU)) == -1){ - fprintf( FCGI_stderr, "file open error %s", tmpfname); - fprintf( FCGI_stdout, "Status: 503\r\n"); - fprintf( FCGI_stdout, "Reason: Implementation failed\r\n"); + int fd; + const char tmpfname[] = "tmpjpipstream.jpp"; + Byte_t *jpipstream; + Byte8_t len_of_jpipstream; + + if( (fd = open( tmpfname, O_RDWR|O_CREAT|O_EXCL, S_IRWXU)) == -1) { + fprintf( FCGI_stderr, "file open error %s", tmpfname); + fprintf( FCGI_stdout, "Status: 503\r\n"); + fprintf( FCGI_stdout, "Reason: Implementation failed\r\n"); + return; + } + + recons_stream_from_msgqueue( qr->msgqueue, fd); + + add_EORmsg( fd, qr); /* needed at least for tcp and udp */ + + len_of_jpipstream = (Byte8_t)get_filesize( fd); + jpipstream = fetch_bytes( fd, 0, len_of_jpipstream); + + close( fd); + remove( tmpfname); + + fprintf( FCGI_stdout, "\r\n"); + + if( len_of_jpipstream) { + + if( qr->channel) + if( qr->channel->aux == tcp || qr->channel->aux == udp) { + send_responsedata_on_aux( qr->channel->aux==tcp, rec->auxtrans, qr->channel->cid, jpipstream, len_of_jpipstream, 1000); /* 1KB per frame*/ + return; + } + + if( fwrite( jpipstream, len_of_jpipstream, 1, FCGI_stdout) != 1) + fprintf( FCGI_stderr, "Error: failed to write jpipstream\n"); + } + + opj_free( jpipstream); + return; - } - - recons_stream_from_msgqueue( qr->msgqueue, fd); - - add_EORmsg( fd, qr); /* needed at least for tcp and udp */ - - len_of_jpipstream = (Byte8_t)get_filesize( fd); - jpipstream = fetch_bytes( fd, 0, len_of_jpipstream); - - close( fd); - remove( tmpfname); - - fprintf( FCGI_stdout, "\r\n"); - - if( len_of_jpipstream){ - - if( qr->channel) - if( qr->channel->aux == tcp || qr->channel->aux == udp){ - send_responsedata_on_aux( qr->channel->aux==tcp, rec->auxtrans, qr->channel->cid, jpipstream, len_of_jpipstream, 1000); /* 1KB per frame*/ - return; - } - - if( fwrite( jpipstream, len_of_jpipstream, 1, FCGI_stdout) != 1) - fprintf( FCGI_stderr, "Error: failed to write jpipstream\n"); - } - - opj_free( jpipstream); - - return; } void add_EORmsg( int fd, QR_t *qr) { - unsigned char EOR[3]; - - if( qr->channel){ - EOR[0] = 0x00; - EOR[1] = is_allsent( *(qr->channel->cachemodel)) ? 0x01 : 0x02; - EOR[2] = 0x00; - if( write( fd, EOR, 3) != 3) - fprintf( FCGI_stderr, "Error: failed to write EOR message\n"); - } + unsigned char EOR[3]; + + if( qr->channel) { + EOR[0] = 0x00; + EOR[1] = is_allsent( *(qr->channel->cachemodel)) ? 0x01 : 0x02; + EOR[2] = 0x00; + if( write( fd, EOR, 3) != 3) + fprintf( FCGI_stderr, "Error: failed to write EOR message\n"); + } } void end_QRprocess( server_record_t *rec, QR_t **qr) { - /* TODO: record client preferences if necessary*/ - (void)rec; /* unused */ - delete_query( &((*qr)->query)); - delete_msgqueue( &((*qr)->msgqueue)); - opj_free( *qr); + /* TODO: record client preferences if necessary*/ + (void)rec; /* unused */ + delete_query( &((*qr)->query)); + delete_msgqueue( &((*qr)->msgqueue)); + opj_free( *qr); } void local_log( OPJ_BOOL query, OPJ_BOOL messages, OPJ_BOOL sessions, OPJ_BOOL targets, QR_t *qr, server_record_t *rec) { - if( query) - print_queryparam( *qr->query); + if( query) + print_queryparam( *qr->query); + + if( messages) + print_msgqueue( qr->msgqueue); - if( messages) - print_msgqueue( qr->msgqueue); + if( sessions) + print_allsession( rec->sessionlist); - if( sessions) - print_allsession( rec->sessionlist); - - if( targets) - print_alltarget( rec->targetlist); + if( targets) + print_alltarget( rec->targetlist); } #endif /*SERVER*/ @@ -211,240 +211,239 @@ void local_log( OPJ_BOOL query, OPJ_BOOL messages, OPJ_BOOL sessions, OPJ_BOOL t dec_server_record_t * OPJ_CALLCONV init_dec_server( int port) { - dec_server_record_t *record = (dec_server_record_t *)opj_malloc( sizeof(dec_server_record_t)); + dec_server_record_t *record = (dec_server_record_t *)opj_malloc( sizeof(dec_server_record_t)); - record->cachelist = gene_cachelist(); - record->jpipstream = NULL; - record->jpipstreamlen = 0; - record->msgqueue = gene_msgqueue( OPJ_TRUE, NULL); - record->listening_socket = open_listeningsocket( (uint16_t)port); + record->cachelist = gene_cachelist(); + record->jpipstream = NULL; + record->jpipstreamlen = 0; + record->msgqueue = gene_msgqueue( OPJ_TRUE, NULL); + record->listening_socket = open_listeningsocket( (uint16_t)port); - return record; + return record; } void OPJ_CALLCONV terminate_dec_server( dec_server_record_t **rec) { - delete_cachelist( &(*rec)->cachelist); - opj_free( (*rec)->jpipstream); - - if( (*rec)->msgqueue) - delete_msgqueue( &((*rec)->msgqueue)); - - if( close_socket( (*rec)->listening_socket) != 0) - perror("close"); - - opj_free( *rec); + delete_cachelist( &(*rec)->cachelist); + opj_free( (*rec)->jpipstream); + + if( (*rec)->msgqueue) + delete_msgqueue( &((*rec)->msgqueue)); + + if( close_socket( (*rec)->listening_socket) != 0) + perror("close"); + + opj_free( *rec); } client_t OPJ_CALLCONV accept_connection( dec_server_record_t *rec) { - client_t client; - - client = accept_socket( rec->listening_socket); - if( client == -1) - fprintf( stderr, "error: failed to connect to client\n"); - - return client; + client_t client; + + client = accept_socket( rec->listening_socket); + if( client == -1) + fprintf( stderr, "error: failed to connect to client\n"); + + return client; } OPJ_BOOL OPJ_CALLCONV handle_clientreq( client_t client, dec_server_record_t *rec) { - OPJ_BOOL quit = OPJ_FALSE; - msgtype_t msgtype = identify_clientmsg( client); - - switch( msgtype){ - case JPIPSTREAM: - handle_JPIPstreamMSG( client, rec->cachelist, &rec->jpipstream, &rec->jpipstreamlen, rec->msgqueue); - break; - - case PNMREQ: - handle_PNMreqMSG( client, rec->jpipstream, rec->msgqueue, rec->cachelist); - break; - - case XMLREQ: - handle_XMLreqMSG( client, rec->jpipstream, rec->cachelist); - break; - - case TIDREQ: - handle_TIDreqMSG( client, rec->cachelist); - break; - - case CIDREQ: - handle_CIDreqMSG( client, rec->cachelist); - break; - - case CIDDST: - handle_dstCIDreqMSG( client, rec->cachelist); - break; - - case SIZREQ: - handle_SIZreqMSG( client, rec->jpipstream, rec->msgqueue, rec->cachelist); - break; - - case JP2SAVE: - handle_JP2saveMSG( client, rec->cachelist, rec->msgqueue, rec->jpipstream); - break; - - case QUIT: - quit = OPJ_TRUE; - save_codestream( rec->jpipstream, rec->jpipstreamlen, "jpt"); - break; - case MSGERROR: - break; - } - - fprintf( stderr, "\t end of the connection\n\n"); - if( close_socket(client) != 0){ - perror("close"); - return OPJ_FALSE; - } - - if( quit) - return OPJ_FALSE; - - return OPJ_TRUE; + OPJ_BOOL quit = OPJ_FALSE; + msgtype_t msgtype = identify_clientmsg( client); + + switch( msgtype) { + case JPIPSTREAM: + handle_JPIPstreamMSG( client, rec->cachelist, &rec->jpipstream, &rec->jpipstreamlen, rec->msgqueue); + break; + + case PNMREQ: + handle_PNMreqMSG( client, rec->jpipstream, rec->msgqueue, rec->cachelist); + break; + + case XMLREQ: + handle_XMLreqMSG( client, rec->jpipstream, rec->cachelist); + break; + + case TIDREQ: + handle_TIDreqMSG( client, rec->cachelist); + break; + + case CIDREQ: + handle_CIDreqMSG( client, rec->cachelist); + break; + + case CIDDST: + handle_dstCIDreqMSG( client, rec->cachelist); + break; + + case SIZREQ: + handle_SIZreqMSG( client, rec->jpipstream, rec->msgqueue, rec->cachelist); + break; + + case JP2SAVE: + handle_JP2saveMSG( client, rec->cachelist, rec->msgqueue, rec->jpipstream); + break; + + case QUIT: + quit = OPJ_TRUE; + save_codestream( rec->jpipstream, rec->jpipstreamlen, "jpt"); + break; + case MSGERROR: + break; + } + + fprintf( stderr, "\t end of the connection\n\n"); + if( close_socket(client) != 0) { + perror("close"); + return OPJ_FALSE; + } + + if( quit) + return OPJ_FALSE; + + return OPJ_TRUE; } jpip_dec_param_t * OPJ_CALLCONV init_jpipdecoder( OPJ_BOOL jp2) { - jpip_dec_param_t *dec; - - dec = (jpip_dec_param_t *)opj_calloc( 1, sizeof(jpip_dec_param_t)); + jpip_dec_param_t *dec; + + dec = (jpip_dec_param_t *)opj_calloc( 1, sizeof(jpip_dec_param_t)); + + dec->msgqueue = gene_msgqueue( OPJ_TRUE, NULL); - dec->msgqueue = gene_msgqueue( OPJ_TRUE, NULL); - - if( jp2) - dec->metadatalist = gene_metadatalist(); + if( jp2) + dec->metadatalist = gene_metadatalist(); - return dec; + return dec; } OPJ_BOOL OPJ_CALLCONV fread_jpip( const char fname[], jpip_dec_param_t *dec) { - int infd; - - if(( infd = open( fname, O_RDONLY)) == -1){ - fprintf( stderr, "file %s not exist\n", fname); - return OPJ_FALSE; - } - - if(!(dec->jpiplen = (Byte8_t)get_filesize(infd))) - return OPJ_FALSE; - - dec->jpipstream = (Byte_t *)opj_malloc( dec->jpiplen); - - if( read( infd, dec->jpipstream, dec->jpiplen) != (int)dec->jpiplen){ - fprintf( stderr, "file reading error\n"); - opj_free( dec->jpipstream); - return OPJ_FALSE; - } - - close(infd); - - return OPJ_TRUE; + int infd; + + if(( infd = open( fname, O_RDONLY)) == -1) { + fprintf( stderr, "file %s not exist\n", fname); + return OPJ_FALSE; + } + + if(!(dec->jpiplen = (Byte8_t)get_filesize(infd))) + return OPJ_FALSE; + + dec->jpipstream = (Byte_t *)opj_malloc( dec->jpiplen); + + if( read( infd, dec->jpipstream, dec->jpiplen) != (int)dec->jpiplen) { + fprintf( stderr, "file reading error\n"); + opj_free( dec->jpipstream); + return OPJ_FALSE; + } + + close(infd); + + return OPJ_TRUE; } void OPJ_CALLCONV decode_jpip( jpip_dec_param_t *dec) { - parse_JPIPstream( dec->jpipstream, dec->jpiplen, 0, dec->msgqueue); - - if( dec->metadatalist){ /* JP2 encoding*/ - parse_metamsg( dec->msgqueue, dec->jpipstream, dec->jpiplen, dec->metadatalist); - dec->ihdrbox = gene_ihdrbox( dec->metadatalist, dec->jpipstream); - - dec->jp2kstream = recons_jp2( dec->msgqueue, dec->jpipstream, dec->msgqueue->first->csn, &dec->jp2klen); - } - else /* J2k encoding */ - /* Notice: arguments fw, fh need to be set for LRCP, PCRL, CPRL*/ - dec->jp2kstream = recons_j2k( dec->msgqueue, dec->jpipstream, dec->msgqueue->first->csn, 0, 0, &dec->jp2klen); + parse_JPIPstream( dec->jpipstream, dec->jpiplen, 0, dec->msgqueue); + + if( dec->metadatalist) { /* JP2 encoding*/ + parse_metamsg( dec->msgqueue, dec->jpipstream, dec->jpiplen, dec->metadatalist); + dec->ihdrbox = gene_ihdrbox( dec->metadatalist, dec->jpipstream); + + dec->jp2kstream = recons_jp2( dec->msgqueue, dec->jpipstream, dec->msgqueue->first->csn, &dec->jp2klen); + } else /* J2k encoding */ + /* Notice: arguments fw, fh need to be set for LRCP, PCRL, CPRL*/ + dec->jp2kstream = recons_j2k( dec->msgqueue, dec->jpipstream, dec->msgqueue->first->csn, 0, 0, &dec->jp2klen); } OPJ_BOOL OPJ_CALLCONV fwrite_jp2k( const char fname[], jpip_dec_param_t *dec) { - int outfd; - + int outfd; + #ifdef _WIN32 - if(( outfd = open( fname, O_WRONLY|O_CREAT, _S_IREAD | _S_IWRITE)) == -1){ + if(( outfd = open( fname, O_WRONLY|O_CREAT, _S_IREAD | _S_IWRITE)) == -1) { #else - if(( outfd = open( fname, O_WRONLY|O_CREAT, S_IRWXU|S_IRWXG)) == -1){ + if(( outfd = open( fname, O_WRONLY|O_CREAT, S_IRWXU|S_IRWXG)) == -1) { #endif - fprintf( stderr, "file %s open error\n", fname); - return OPJ_FALSE; - } - - if( write( outfd, dec->jp2kstream, dec->jp2klen) != (int)dec->jp2klen) - fprintf( stderr, "j2k file write error\n"); + fprintf( stderr, "file %s open error\n", fname); + return OPJ_FALSE; + } + + if( write( outfd, dec->jp2kstream, dec->jp2klen) != (int)dec->jp2klen) + fprintf( stderr, "j2k file write error\n"); - close(outfd); + close(outfd); - return OPJ_TRUE; + return OPJ_TRUE; } void OPJ_CALLCONV output_log( OPJ_BOOL messages, OPJ_BOOL metadata, OPJ_BOOL ihdrbox, jpip_dec_param_t *dec) { - if( messages) - print_msgqueue( dec->msgqueue); + if( messages) + print_msgqueue( dec->msgqueue); - if( metadata) - print_allmetadata( dec->metadatalist); + if( metadata) + print_allmetadata( dec->metadatalist); - if( ihdrbox){ - printf("W*H: %d*%d\n", dec->ihdrbox->height, dec->ihdrbox->width); - printf("NC: %d, bpc: %d\n", dec->ihdrbox->nc, dec->ihdrbox->bpc); - } + if( ihdrbox) { + printf("W*H: %d*%d\n", dec->ihdrbox->height, dec->ihdrbox->width); + printf("NC: %d, bpc: %d\n", dec->ihdrbox->nc, dec->ihdrbox->bpc); + } } void OPJ_CALLCONV destroy_jpipdecoder( jpip_dec_param_t **dec) { - opj_free( (*dec)->jpipstream); - delete_msgqueue( &(*dec)->msgqueue); - if( (*dec)->metadatalist){ - delete_metadatalist( &(*dec)->metadatalist); - opj_free( (*dec)->ihdrbox); - } - - opj_free( (*dec)->jp2kstream); - opj_free( *dec); + opj_free( (*dec)->jpipstream); + delete_msgqueue( &(*dec)->msgqueue); + if( (*dec)->metadatalist) { + delete_metadatalist( &(*dec)->metadatalist); + opj_free( (*dec)->ihdrbox); + } + + opj_free( (*dec)->jp2kstream); + opj_free( *dec); } index_t * OPJ_CALLCONV get_index_from_JP2file( int fd) { - char *data; - - /* Check resource is a JP family file.*/ - if( lseek( fd, 0, SEEK_SET)==-1){ - fprintf( stderr, "Error: File broken (lseek error)\n"); - return NULL; - } - - data = (char *)opj_malloc( 12); /* size of header*/ - if( read( fd, data, 12) != 12){ + char *data; + + /* Check resource is a JP family file.*/ + if( lseek( fd, 0, SEEK_SET)==-1) { + fprintf( stderr, "Error: File broken (lseek error)\n"); + return NULL; + } + + data = (char *)opj_malloc( 12); /* size of header*/ + if( read( fd, data, 12) != 12) { + opj_free( data); + fprintf( stderr, "Error: File broken (read error)\n"); + return NULL; + } + + if( *data || *(data + 1) || *(data + 2) || + *(data + 3) != 12 || strncmp (data + 4, "jP \r\n\x87\n", 8)) { + opj_free( data); + fprintf( stderr, "Error: No JPEG 2000 Signature box in this file\n"); + return NULL; + } opj_free( data); - fprintf( stderr, "Error: File broken (read error)\n"); - return NULL; - } - - if( *data || *(data + 1) || *(data + 2) || - *(data + 3) != 12 || strncmp (data + 4, "jP \r\n\x87\n", 8)){ - opj_free( data); - fprintf( stderr, "Error: No JPEG 2000 Signature box in this file\n"); - return NULL; - } - opj_free( data); - - return parse_jp2file( fd); + + return parse_jp2file( fd); } void OPJ_CALLCONV destroy_index( index_t **idx) { - delete_index( idx); + delete_index( idx); } void OPJ_CALLCONV output_index( index_t *index) { - print_index( *index); + print_index( *index); } #endif /*SERVER*/ |