diff options
Diffstat (limited to 'src/lib/openjpip/openjpip.c')
| -rw-r--r-- | src/lib/openjpip/openjpip.c | 648 |
1 files changed, 341 insertions, 307 deletions
diff --git a/src/lib/openjpip/openjpip.c b/src/lib/openjpip/openjpip.c index 6932dfa7..7fa53136 100644 --- a/src/lib/openjpip/openjpip.c +++ b/src/lib/openjpip/openjpip.c @@ -55,396 +55,430 @@ #ifdef SERVER -server_record_t * init_JPIPserver( int tcp_auxport, int udp_auxport) +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) +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 * 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) +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 add_EORmsg(int fd, QR_t *qr); -void send_responsedata( server_record_t *rec, 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) +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) +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) +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( targets) - print_alltarget( rec->targetlist); + if (sessions) { + print_allsession(rec->sessionlist); + } + + if (targets) { + print_alltarget(rec->targetlist); + } } #endif /*SERVER*/ #ifndef SERVER -dec_server_record_t * OPJ_CALLCONV init_dec_server( int port) +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) +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 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 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 * 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->msgqueue = gene_msgqueue( OPJ_TRUE, NULL); - - if( jp2) - dec->metadatalist = gene_metadatalist(); + dec = (jpip_dec_param_t *)opj_calloc(1, sizeof(jpip_dec_param_t)); - return dec; + dec->msgqueue = gene_msgqueue(OPJ_TRUE, NULL); + + if (jp2) { + dec->metadatalist = gene_metadatalist(); + } + + return dec; } -OPJ_BOOL OPJ_CALLCONV fread_jpip( const char fname[], jpip_dec_param_t *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) +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) +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) +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( 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 (messages) { + print_msgqueue(dec->msgqueue); + } + + 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); + } } -void OPJ_CALLCONV destroy_jpipdecoder( jpip_dec_param_t **dec) +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) +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){ - 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); + 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); + + return parse_jp2file(fd); } -void OPJ_CALLCONV destroy_index( index_t **idx) +void OPJ_CALLCONV destroy_index(index_t **idx) { - delete_index( idx); + delete_index(idx); } -void OPJ_CALLCONV output_index( index_t *index) +void OPJ_CALLCONV output_index(index_t *index) { - print_index( *index); + print_index(*index); } #endif /*SERVER*/ |