diff options
| author | Antonin Descampe <antonin@gmail.com> | 2016-01-25 23:22:06 +0100 |
|---|---|---|
| committer | Antonin Descampe <antonin@gmail.com> | 2016-01-25 23:22:06 +0100 |
| commit | 0febbff19e05cb1a6c2613eee76ad46a669c96cd (patch) | |
| tree | b6442d01348e2ba6404d0fd6abcc4eb6d6cc1390 /src/lib/openjpip/jpipstream_manager.c | |
| parent | bede1568b197021bb576b935422af6c1d0a79e21 (diff) | |
processed all c/h files through astyle with opj_astyle.cfgcodingstyle
Diffstat (limited to 'src/lib/openjpip/jpipstream_manager.c')
| -rw-r--r-- | src/lib/openjpip/jpipstream_manager.c | 133 |
1 files changed, 65 insertions, 68 deletions
diff --git a/src/lib/openjpip/jpipstream_manager.c b/src/lib/openjpip/jpipstream_manager.c index 3929b495..8bb1e628 100644 --- a/src/lib/openjpip/jpipstream_manager.c +++ b/src/lib/openjpip/jpipstream_manager.c @@ -40,96 +40,93 @@ Byte_t * update_JPIPstream( Byte_t *newstream, OPJ_SIZE_T newstreamlen, Byte_t *cache_stream, OPJ_SIZE_T *streamlen) { - Byte_t *stream = (Byte_t *)opj_malloc( (*streamlen)+newstreamlen); - if( *streamlen > 0) - memcpy( stream, cache_stream, *streamlen); - memcpy( stream+(*streamlen), newstream, newstreamlen); - *streamlen += newstreamlen; - - if(cache_stream) - opj_free( cache_stream); - - return stream; + Byte_t *stream = (Byte_t *)opj_malloc( (*streamlen)+newstreamlen); + if( *streamlen > 0) + memcpy( stream, cache_stream, *streamlen); + memcpy( stream+(*streamlen), newstream, newstreamlen); + *streamlen += newstreamlen; + + if(cache_stream) + opj_free( cache_stream); + + return stream; } void save_codestream( Byte_t *codestream, OPJ_SIZE_T streamlen, const char *fmt) { - time_t timer; - struct tm *t_st; - char filename[20]; - FILE *fp; - - time(&timer); - t_st = localtime( &timer); - - sprintf( filename, "%4d%02d%02d%02d%02d%02d.%.3s", t_st->tm_year+1900, t_st->tm_mon+1, t_st->tm_mday, t_st->tm_hour, t_st->tm_min, t_st->tm_sec, fmt); - - fp = fopen( filename, "wb"); - if( fwrite( codestream, streamlen, 1, fp) != 1) - fprintf( stderr, "Error: failed to write codestream to file %s\n", filename); - fclose( fp); + time_t timer; + struct tm *t_st; + char filename[20]; + FILE *fp; + + time(&timer); + t_st = localtime( &timer); + + sprintf( filename, "%4d%02d%02d%02d%02d%02d.%.3s", t_st->tm_year+1900, t_st->tm_mon+1, t_st->tm_mday, t_st->tm_hour, t_st->tm_min, t_st->tm_sec, fmt); + + fp = fopen( filename, "wb"); + if( fwrite( codestream, streamlen, 1, fp) != 1) + fprintf( stderr, "Error: failed to write codestream to file %s\n", filename); + fclose( fp); } Byte_t * jpipstream_to_pnm( Byte_t *jpipstream, msgqueue_param_t *msgqueue, Byte8_t csn, int fw, int fh, ihdrbox_param_t **ihdrbox) { - Byte_t *pnmstream; - Byte_t *j2kstream; /* j2k or jp2 codestream */ - Byte8_t j2klen; - size_t retlen; - FILE *fp; - const char j2kfname[] = "tmp.j2k"; - - fp = fopen( j2kfname, "w+b"); - if( !fp ) - { - return NULL; + Byte_t *pnmstream; + Byte_t *j2kstream; /* j2k or jp2 codestream */ + Byte8_t j2klen; + size_t retlen; + FILE *fp; + const char j2kfname[] = "tmp.j2k"; + + fp = fopen( j2kfname, "w+b"); + if( !fp ) { + return NULL; } - j2kstream = recons_j2k( msgqueue, jpipstream, csn, fw, fh, &j2klen); - if( !j2kstream ) - { - fclose(fp); - remove( j2kfname); - return NULL; + j2kstream = recons_j2k( msgqueue, jpipstream, csn, fw, fh, &j2klen); + if( !j2kstream ) { + fclose(fp); + remove( j2kfname); + return NULL; } - retlen = fwrite( j2kstream, 1, j2klen, fp); - opj_free( j2kstream); - fclose(fp); - if( retlen != j2klen ) - { - remove( j2kfname); - return NULL; + retlen = fwrite( j2kstream, 1, j2klen, fp); + opj_free( j2kstream); + fclose(fp); + if( retlen != j2klen ) { + remove( j2kfname); + return NULL; } - pnmstream = j2k_to_pnm( j2kfname, ihdrbox); + pnmstream = j2k_to_pnm( j2kfname, ihdrbox); - remove( j2kfname); + remove( j2kfname); - return pnmstream; + return pnmstream; } ihdrbox_param_t * get_SIZ_from_jpipstream( Byte_t *jpipstream, msgqueue_param_t *msgqueue, Byte8_t csn) { - ihdrbox_param_t *ihdrbox; - Byte_t *j2kstream; - Byte8_t j2klen; - SIZmarker_param_t SIZ; + ihdrbox_param_t *ihdrbox; + Byte_t *j2kstream; + Byte8_t j2klen; + SIZmarker_param_t SIZ; + + j2kstream = recons_j2kmainhead( msgqueue, jpipstream, csn, &j2klen); + if( !get_mainheader_from_j2kstream( j2kstream, &SIZ, NULL)) { + opj_free( j2kstream); + return NULL; + } - j2kstream = recons_j2kmainhead( msgqueue, jpipstream, csn, &j2klen); - if( !get_mainheader_from_j2kstream( j2kstream, &SIZ, NULL)){ - opj_free( j2kstream); - return NULL; - } + ihdrbox = (ihdrbox_param_t *)opj_malloc( sizeof(ihdrbox_param_t)); - ihdrbox = (ihdrbox_param_t *)opj_malloc( sizeof(ihdrbox_param_t)); + ihdrbox->width = SIZ.Xsiz; + ihdrbox->height = SIZ.Ysiz; + ihdrbox->nc = SIZ.Csiz; + ihdrbox->bpc = SIZ.Ssiz[0]; - ihdrbox->width = SIZ.Xsiz; - ihdrbox->height = SIZ.Ysiz; - ihdrbox->nc = SIZ.Csiz; - ihdrbox->bpc = SIZ.Ssiz[0]; - - opj_free( j2kstream); + opj_free( j2kstream); - return ihdrbox; + return ihdrbox; } |
