walkero
/
openjpeg
1
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity

add documentations

This commit is contained in:
Kaori Hagihara 2011-07-05 12:25:37 +00:00
parent 0a9cd082db
commit 6230ec13b4
2 changed files with 35 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
applications/jpip/libopenjpip/msgqueue_manager.c
View File

@ -49,6 +49,9 @@
#define logstream stderr #define logstream stderr
#endif //SERVER #endif //SERVER
#define PRECINCT_MSG 0
#define EXT_PRECINCT_MSG 1
#define TILE_HEADER_MSG 2
#define TILE_MSG 4 #define TILE_MSG 4
#define EXT_TILE_MSG 5 #define EXT_TILE_MSG 5
#define MAINHEADER_MSG 6 #define MAINHEADER_MSG 6
@ -658,17 +661,26 @@ message_param_t * search_message( Byte8_t class_id, Byte8_t in_class_id, Byte8_t
*/ */
void delete_message_in_msgqueue( message_param_t **message, msgqueue_param_t *msgqueue); void delete_message_in_msgqueue( message_param_t **message, msgqueue_param_t *msgqueue);
Byte_t * recons_codestream( msgqueue_param_t *msgqueue, Byte_t *stream, Byte8_t csn, int minlev, Byte8_t *codelen); /**
* reconstruct j2k codestream from JPT- (in future, JPP-) stream
*
* @param[in] msgqueue message queue pointer
* @param[in] jpipstream original JPT- JPP- stream
* @param[in] csn codestream number
* @param[in] minlev minimum decomposition level
* @param[out] codelen codestream length
* @return generated reconstructed j2k codestream
*/
Byte_t * recons_codestream( msgqueue_param_t *msgqueue, Byte_t *jpipstream, Byte8_t csn, int minlev, Byte8_t *codelen);
// usable only to JPT-stream messages Byte_t * recons_j2k( msgqueue_param_t *msgqueue, Byte_t *jpipstream, Byte8_t csn, int minlev, Byte8_t *j2klen)
Byte_t * recons_j2k( msgqueue_param_t *msgqueue, Byte_t *stream, Byte8_t csn, int minlev, Byte8_t *j2klen)
{ {
Byte_t *j2kstream = NULL; Byte_t *j2kstream = NULL;
if( !msgqueue) if( !msgqueue)
return NULL; return NULL;
j2kstream = recons_codestream( msgqueue, stream, csn, minlev, j2klen); j2kstream = recons_codestream( msgqueue, jpipstream, csn, minlev, j2klen);
return j2kstream; return j2kstream;
} }
@ -676,7 +688,7 @@ Byte_t * recons_j2k( msgqueue_param_t *msgqueue, Byte_t *stream, Byte8_t csn, in
Byte_t * add_emptyboxstream( placeholder_param_t *phld, Byte_t *jp2stream, Byte8_t *jp2len); Byte_t * add_emptyboxstream( placeholder_param_t *phld, Byte_t *jp2stream, Byte8_t *jp2len);
Byte_t * add_msgstream( message_param_t *message, Byte_t *origstream, Byte_t *j2kstream, Byte8_t *j2klen); Byte_t * add_msgstream( message_param_t *message, Byte_t *origstream, Byte_t *j2kstream, Byte8_t *j2klen);
Byte_t * recons_jp2( msgqueue_param_t *msgqueue, Byte_t *stream, Byte8_t csn, Byte8_t *jp2len) Byte_t * recons_jp2( msgqueue_param_t *msgqueue, Byte_t *jpipstream, Byte8_t csn, Byte8_t *jp2len)
{ {
message_param_t *ptr; message_param_t *ptr;
Byte_t *jp2stream = NULL; Byte_t *jp2stream = NULL;
@ -700,11 +712,11 @@ Byte_t * recons_jp2( msgqueue_param_t *msgqueue, Byte_t *stream, Byte8_t csn, By
else else
jp2stream = add_emptyboxstream( ptr->phld, jp2stream, jp2len); // header only jp2stream = add_emptyboxstream( ptr->phld, jp2stream, jp2len); // header only
} }
jp2stream = add_msgstream( ptr, stream, jp2stream, jp2len); jp2stream = add_msgstream( ptr, jpipstream, jp2stream, jp2len);
ptr = ptr->next; ptr = ptr->next;
} }
codestream = recons_codestream( msgqueue, stream, csn, 0, &codelen); codestream = recons_codestream( msgqueue, jpipstream, csn, 0, &codelen);
if( jp2cDBoxOffset != 0 && codelen <= jp2cDBoxlen) if( jp2cDBoxOffset != 0 && codelen <= jp2cDBoxlen)
memcpy( jp2stream+jp2cDBoxOffset, codestream, codelen); memcpy( jp2stream+jp2cDBoxOffset, codestream, codelen);
@ -718,7 +730,9 @@ int get_last_tileID( msgqueue_param_t *msgqueue, Byte8_t csn);
Byte_t * add_emptytilestream( const int tileID, Byte_t *j2kstream, Byte8_t *j2klen); Byte_t * add_emptytilestream( const int tileID, Byte_t *j2kstream, Byte8_t *j2klen);
Byte_t * add_EOC( Byte_t *j2kstream, Byte8_t *j2klen); Byte_t * add_EOC( Byte_t *j2kstream, Byte8_t *j2klen);
Byte_t * recons_codestream( msgqueue_param_t *msgqueue, Byte_t *stream, Byte8_t csn, int minlev, Byte8_t *codelen) // usable only to JPT-stream messages
// PRECINCT_MSG, EXT_PRECINCT_MSG, TILE_HEADER_MSG need to be handled
Byte_t * recons_codestream( msgqueue_param_t *msgqueue, Byte_t *jpipstream, Byte8_t csn, int minlev, Byte8_t *codelen)
{ {
message_param_t *ptr; message_param_t *ptr;
Byte_t *codestream = NULL; Byte_t *codestream = NULL;

8
applications/jpip/libopenjpip/msgqueue_manager.h
View File

@ -143,25 +143,25 @@ void parse_metamsg( msgqueue_param_t *msgqueue, Byte_t *stream, Byte8_t streamle
* reconstruct j2k codestream from message queue * reconstruct j2k codestream from message queue
* *
* @param[in] msgqueue message queue pointer * @param[in] msgqueue message queue pointer
* @param[in] stream original stream * @param[in] jpipstream original jpt- jpp- stream
* @param[in] csn codestream number * @param[in] csn codestream number
* @param[in] minlev minimum decomposition level * @param[in] minlev minimum decomposition level
* @param[out] j2klen pointer to the j2k codestream length * @param[out] j2klen pointer to the j2k codestream length
* @return generated reconstructed j2k codestream * @return generated reconstructed j2k codestream
*/ */
Byte_t * recons_j2k( msgqueue_param_t *msgqueue, Byte_t *stream, Byte8_t csn, int minlev, Byte8_t *j2klen); Byte_t * recons_j2k( msgqueue_param_t *msgqueue, Byte_t *jpipstream, Byte8_t csn, int minlev, Byte8_t *j2klen);
/** /**
* reconstruct jp2 file codestream from message queue * reconstruct jp2 file codestream from message queue
* *
* @param[in] msgqueue message queue pointer * @param[in] msgqueue message queue pointer
* @param[in] stream original stream * @param[in] jpipstream original jpt- jpp- stream
* @param[in] csn codestream number * @param[in] csn codestream number
* @param[out] jp2len pointer to the jp2 codestream length * @param[out] jp2len pointer to the jp2 codestream length
* @return generated reconstructed jp2 codestream * @return generated reconstructed jp2 codestream
*/ */
Byte_t * recons_jp2( msgqueue_param_t *msgqueue, Byte_t *stream, Byte8_t csn, Byte8_t *jp2len); Byte_t * recons_jp2( msgqueue_param_t *msgqueue, Byte_t *jpipstream, Byte8_t csn, Byte8_t *jp2len);
#endif /* !MSGQUEUE_MANAGER_H_ */ #endif /* !MSGQUEUE_MANAGER_H_ */