diff options
| author | Even Rouault <even.rouault@spatialys.com> | 2017-05-15 12:21:30 +0200 |
|---|---|---|
| committer | Even Rouault <even.rouault@spatialys.com> | 2017-05-15 12:21:30 +0200 |
| commit | 3c2972f924857016bb454201c7e92f25de9105ee (patch) | |
| tree | dee91c4c200c2e97c83fd4c46588bf923f23852c /src/lib/openjpip/msgqueue_manager.h | |
| parent | 28d2eabca79d06378843d1e94fecfb4a5e22178d (diff) | |
Reformat: apply reformattin on .h files (#128)
Diffstat (limited to 'src/lib/openjpip/msgqueue_manager.h')
| -rw-r--r-- | src/lib/openjpip/msgqueue_manager.h | 73 |
1 files changed, 40 insertions, 33 deletions
diff --git a/src/lib/openjpip/msgqueue_manager.h b/src/lib/openjpip/msgqueue_manager.h index 54cb4f95..ad97828d 100644 --- a/src/lib/openjpip/msgqueue_manager.h +++ b/src/lib/openjpip/msgqueue_manager.h @@ -3,7 +3,7 @@ * * Copyright (c) 2002-2014, Universite catholique de Louvain (UCL), Belgium * Copyright (c) 2002-2014, Professor Benoit Macq - * Copyright (c) 2010-2011, Kaori Hagihara + * Copyright (c) 2010-2011, Kaori Hagihara * Copyright (c) 2011, Lucian Corlaciu, GSoC * All rights reserved. * @@ -29,8 +29,8 @@ * POSSIBILITY OF SUCH DAMAGE. */ -#ifndef MSGQUEUE_MANAGER_H_ -# define MSGQUEUE_MANAGER_H_ +#ifndef MSGQUEUE_MANAGER_H_ +# define MSGQUEUE_MANAGER_H_ #include "byte_manager.h" #include "cachemodel_manager.h" @@ -45,25 +45,26 @@ #define METADATA_MSG 8 /** message parameters */ -typedef struct message_param{ - OPJ_BOOL last_byte; /**< if message contains the last byte of the data-bin*/ - Byte8_t in_class_id; /**< in-class identifier A.2.3*/ - Byte8_t class_id; /**< class identifiers */ - Byte8_t csn; /**< index of the codestream*/ - Byte8_t bin_offset; /**< offset of the data in this message from the start of the data-bin*/ - Byte8_t length; /**< message byte length*/ - Byte8_t aux; /**<*/ - OPJ_OFF_T res_offset; /**< offset in the resource*/ - placeholder_param_t *phld; /**< placeholder pointer in index*/ - struct message_param *next; /**< pointer to the next message*/ +typedef struct message_param { + OPJ_BOOL + last_byte; /**< if message contains the last byte of the data-bin*/ + Byte8_t in_class_id; /**< in-class identifier A.2.3*/ + Byte8_t class_id; /**< class identifiers */ + Byte8_t csn; /**< index of the codestream*/ + Byte8_t bin_offset; /**< offset of the data in this message from the start of the data-bin*/ + Byte8_t length; /**< message byte length*/ + Byte8_t aux; /**<*/ + OPJ_OFF_T res_offset; /**< offset in the resource*/ + placeholder_param_t *phld; /**< placeholder pointer in index*/ + struct message_param *next; /**< pointer to the next message*/ } message_param_t; /** message queue parameters */ -typedef struct msgqueue_param{ - message_param_t *first; /**< first message pointer of the list*/ - message_param_t *last; /**< last message pointer of the list*/ - OPJ_BOOL stateless; /**< if this is a stateless message queue*/ - cachemodel_param_t *cachemodel; /**< reference cachemodel pointer*/ +typedef struct msgqueue_param { + message_param_t *first; /**< first message pointer of the list*/ + message_param_t *last; /**< last message pointer of the list*/ + OPJ_BOOL stateless; /**< if this is a stateless message queue*/ + cachemodel_param_t *cachemodel; /**< reference cachemodel pointer*/ } msgqueue_param_t; /** @@ -73,14 +74,15 @@ typedef struct msgqueue_param{ * @param[in] cachemodel cachemodel pointer * @return generated message queue pointer */ -msgqueue_param_t * gene_msgqueue( OPJ_BOOL stateless, cachemodel_param_t *cachemodel); +msgqueue_param_t * gene_msgqueue(OPJ_BOOL stateless, + cachemodel_param_t *cachemodel); /** * delete message queue * * @param[in] msgqueue address of the message queue pointer */ -void delete_msgqueue( msgqueue_param_t **msgqueue); +void delete_msgqueue(msgqueue_param_t **msgqueue); /** * delete a message in msgqueue @@ -88,14 +90,15 @@ void delete_msgqueue( msgqueue_param_t **msgqueue); * @param[in] message address of the deleting message pointer * @param[in] msgqueue message queue pointer */ -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); /** * print message queue * * @param[in] msgqueue message queue pointer */ -void print_msgqueue( msgqueue_param_t *msgqueue); +void print_msgqueue(msgqueue_param_t *msgqueue); /** @@ -103,7 +106,7 @@ void print_msgqueue( msgqueue_param_t *msgqueue); * * @param[in,out] msgqueue message queue pointer */ -void enqueue_mainheader( msgqueue_param_t *msgqueue); +void enqueue_mainheader(msgqueue_param_t *msgqueue); /** * enqueue tile headers data-bin into message queue @@ -111,7 +114,7 @@ void enqueue_mainheader( msgqueue_param_t *msgqueue); * @param[in] tile_id tile id starting from 0 * @param[in,out] msgqueue message queue pointer */ -void enqueue_tileheader( int tile_id, msgqueue_param_t *msgqueue); +void enqueue_tileheader(int tile_id, msgqueue_param_t *msgqueue); /** * enqueue tile data-bin into message queue @@ -120,7 +123,7 @@ void enqueue_tileheader( int tile_id, msgqueue_param_t *msgqueue); * @param[in] level decomposition level * @param[in,out] msgqueue message queue pointer */ -void enqueue_tile( Byte4_t tile_id, int level, msgqueue_param_t *msgqueue); +void enqueue_tile(Byte4_t tile_id, int level, msgqueue_param_t *msgqueue); /** * enqueue precinct data-bin into message queue @@ -131,7 +134,8 @@ void enqueue_tile( Byte4_t tile_id, int level, msgqueue_param_t *msgqueue); * @param[in] layers num of layers * @param[in,out] msgqueue message queue */ -void enqueue_precinct( int seq_id, int tile_id, int comp_id, int layers, msgqueue_param_t *msgqueue); +void enqueue_precinct(int seq_id, int tile_id, int comp_id, int layers, + msgqueue_param_t *msgqueue); /** @@ -140,7 +144,7 @@ void enqueue_precinct( int seq_id, int tile_id, int comp_id, int layers, msgqueu * @param[in] meta_id metadata-bin id * @param[in,out] msgqueue message queue pointer */ -void enqueue_metadata( Byte8_t meta_id, msgqueue_param_t *msgqueue); +void enqueue_metadata(Byte8_t meta_id, msgqueue_param_t *msgqueue); /** @@ -149,7 +153,7 @@ void enqueue_metadata( Byte8_t meta_id, msgqueue_param_t *msgqueue); * @param[in] msgqueue message queue pointer * @param[in] tmpfd file discriptor to write JPT/JPP-stream */ -void recons_stream_from_msgqueue( msgqueue_param_t *msgqueue, int tmpfd); +void recons_stream_from_msgqueue(msgqueue_param_t *msgqueue, int tmpfd); /** @@ -160,7 +164,8 @@ void recons_stream_from_msgqueue( msgqueue_param_t *msgqueue, int tmpfd); * @param[in] offset offset of the stream from the whole beginning * @param[in,out] msgqueue adding message queue pointer */ -void parse_JPIPstream( Byte_t *JPIPstream, Byte8_t streamlen, OPJ_OFF_T offset, msgqueue_param_t *msgqueue); +void parse_JPIPstream(Byte_t *JPIPstream, Byte8_t streamlen, OPJ_OFF_T offset, + msgqueue_param_t *msgqueue); /** * parse JPT- JPP- stream to message queue @@ -170,7 +175,8 @@ void parse_JPIPstream( Byte_t *JPIPstream, Byte8_t streamlen, OPJ_OFF_T offset, * @param[in] streamlen stream length * @param[in] metadatalist adding metadata list pointer */ -void parse_metamsg( msgqueue_param_t *msgqueue, Byte_t *stream, Byte8_t streamlen, metadatalist_param_t *metadatalist); +void parse_metamsg(msgqueue_param_t *msgqueue, Byte_t *stream, + Byte8_t streamlen, metadatalist_param_t *metadatalist); /** * compute precinct ID A.3.2.1 @@ -182,6 +188,7 @@ void parse_metamsg( msgqueue_param_t *msgqueue, Byte_t *stream, Byte8_t streamle * @param[in] num_tiles total number of tiles * @return precicnt id */ -Byte8_t comp_precinct_id( int t, int c, int s, int num_components, int num_tiles); +Byte8_t comp_precinct_id(int t, int c, int s, int num_components, + int num_tiles); -#endif /* !MSGQUEUE_MANAGER_H_ */ +#endif /* !MSGQUEUE_MANAGER_H_ */ |
