OpenJPEG  2.4.0
Data Structures | Macros | Typedefs | Functions
msgqueue_manager.h File Reference
#include "byte_manager.h"
#include "cachemodel_manager.h"
#include "placeholder_manager.h"

Go to the source code of this file.

Data Structures

struct  message_param
 message parameters More...
 
struct  msgqueue_param
 message queue parameters More...
 

Macros

#define PRECINCT_MSG   0
 
#define EXT_PRECINCT_MSG   1
 
#define TILE_HEADER_MSG   2
 
#define TILE_MSG   4
 
#define EXT_TILE_MSG   5
 
#define MAINHEADER_MSG   6
 
#define METADATA_MSG   8
 

Typedefs

typedef struct message_param message_param_t
 message parameters More...
 
typedef struct msgqueue_param msgqueue_param_t
 message queue parameters More...
 

Functions

msgqueue_param_tgene_msgqueue (OPJ_BOOL stateless, cachemodel_param_t *cachemodel)
 generate message queue More...
 
void delete_msgqueue (msgqueue_param_t **msgqueue)
 delete message queue More...
 
void delete_message_in_msgqueue (message_param_t **message, msgqueue_param_t *msgqueue)
 delete a message in msgqueue More...
 
void print_msgqueue (msgqueue_param_t *msgqueue)
 print message queue More...
 
void enqueue_mainheader (msgqueue_param_t *msgqueue)
 enqueue main header data-bin into message queue More...
 
void enqueue_tileheader (int tile_id, msgqueue_param_t *msgqueue)
 enqueue tile headers data-bin into message queue More...
 
void enqueue_tile (Byte4_t tile_id, int level, msgqueue_param_t *msgqueue)
 enqueue tile data-bin into message queue More...
 
void enqueue_precinct (int seq_id, int tile_id, int comp_id, int layers, msgqueue_param_t *msgqueue)
 enqueue precinct data-bin into message queue More...
 
void enqueue_metadata (Byte8_t meta_id, msgqueue_param_t *msgqueue)
 enqueue Metadata-bin into message queue More...
 
void recons_stream_from_msgqueue (msgqueue_param_t *msgqueue, int tmpfd)
 reconstruct JPT/JPP-stream from message queue More...
 
void parse_JPIPstream (Byte_t *JPIPstream, Byte8_t streamlen, OPJ_OFF_T offset, msgqueue_param_t *msgqueue)
 parse JPT- JPP- stream to message queue More...
 
void parse_metamsg (msgqueue_param_t *msgqueue, Byte_t *stream, Byte8_t streamlen, metadatalist_param_t *metadatalist)
 parse JPT- JPP- stream to message queue More...
 
Byte8_t comp_precinct_id (int t, int c, int s, int num_components, int num_tiles)
 compute precinct ID A.3.2.1 More...
 

Macro Definition Documentation

#define EXT_PRECINCT_MSG   1
#define EXT_TILE_MSG   5
#define MAINHEADER_MSG   6
#define METADATA_MSG   8
#define PRECINCT_MSG   0
#define TILE_HEADER_MSG   2
#define TILE_MSG   4

Typedef Documentation

message parameters

message queue parameters

Function Documentation

Byte8_t comp_precinct_id ( int  t,
int  c,
int  s,
int  num_components,
int  num_tiles 
)

compute precinct ID A.3.2.1

Parameters
[in]ttile index
[in]ccomponent index
[in]ssequence number
[in]num_componentstotal number of components
[in]num_tilestotal number of tiles
Returns
precicnt id

References enqueue_box(), enqueue_boxcontents(), and enqueue_phld().

Referenced by enqueue_precinct(), recons_packet(), and recons_precinct().

void delete_message_in_msgqueue ( message_param_t **  message,
msgqueue_param_t msgqueue 
)

delete a message in msgqueue

Parameters
[in]messageaddress of the deleting message pointer
[in]msgqueuemessage queue pointer

References msgqueue_param::first, msgqueue_param::last, message_param::next, and opj_free().

void delete_msgqueue ( msgqueue_param_t **  msgqueue)

delete message queue

Parameters
[in]msgqueueaddress of the message queue pointer

References delete_cachemodel(), message_param::next, and opj_free().

Referenced by destroy_jpipdecoder(), and terminate_dec_server().

void enqueue_mainheader ( msgqueue_param_t msgqueue)
void enqueue_metadata ( Byte8_t  meta_id,
msgqueue_param_t msgqueue 
)
void enqueue_precinct ( int  seq_id,
int  tile_id,
int  comp_id,
int  layers,
msgqueue_param_t msgqueue 
)
void enqueue_tile ( Byte4_t  tile_id,
int  level,
msgqueue_param_t msgqueue 
)
void enqueue_tileheader ( int  tile_id,
msgqueue_param_t msgqueue 
)
msgqueue_param_t* gene_msgqueue ( OPJ_BOOL  stateless,
cachemodel_param_t cachemodel 
)

generate message queue

Parameters
[in]statelessif this is a stateless message queue
[in]cachemodelcachemodel pointer
Returns
generated message queue pointer

References msgqueue_param::cachemodel, msgqueue_param::first, msgqueue_param::last, opj_malloc(), and msgqueue_param::stateless.

Referenced by gene_JPIPstream(), init_dec_server(), and init_jpipdecoder().

void parse_JPIPstream ( Byte_t JPIPstream,
Byte8_t  streamlen,
OPJ_OFF_T  offset,
msgqueue_param_t msgqueue 
)

parse JPT- JPP- stream to message queue

Parameters
[in]JPIPstreamJPT- JPP- stream data pointer
[in]streamlenJPIPstream length
[in]offsetoffset of the stream from the whole beginning
[in,out]msgqueueadding message queue pointer

References message_param::aux, message_param::bin_offset, message_param::class_id, message_param::csn, msgqueue_param::first, message_param::in_class_id, msgqueue_param::last, message_param::last_byte, message_param::length, message_param::next, OPJ_FALSE, opj_malloc(), OPJ_TRUE, parse_bin_id_vbas(), parse_metadata(), parse_vbas(), message_param::phld, and message_param::res_offset.

Referenced by decode_jpip(), and handle_JPIPstreamMSG().

void parse_metamsg ( msgqueue_param_t msgqueue,
Byte_t stream,
Byte8_t  streamlen,
metadatalist_param_t metadatalist 
)

parse JPT- JPP- stream to message queue

Parameters
[in]msgqueuereference message queue pointer
[in]streamstream data pointer
[in]streamlenstream length
[in]metadatalistadding metadata list pointer

References message_param::class_id, msgqueue_param::first, gene_metadata(), message_param::in_class_id, insert_metadata_into_list(), METADATA_MSG, message_param::next, parse_metadata(), parse_phld(), and message_param::res_offset.

Referenced by decode_jpip(), and handle_JPIPstreamMSG().

void print_msgqueue ( msgqueue_param_t msgqueue)
void recons_stream_from_msgqueue ( msgqueue_param_t msgqueue,
int  tmpfd 
)