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...

Defines

#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
typedef struct msgqueue_param msgqueue_param_t
 message queue parameters

Functions

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


Define 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] t tile index
[in] c component index
[in] s sequence number
[in] num_components total number of components
[in] num_tiles total number of tiles
Returns:
precicnt id

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] message address of the deleting message pointer
[in] msgqueue message 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] msgqueue address 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] stateless if this is a stateless message queue
[in] cachemodel cachemodel 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] JPIPstream JPT- JPP- stream data pointer
[in] streamlen JPIPstream length
[in] offset offset of the stream from the whole beginning
[in,out] msgqueue adding 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_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] msgqueue reference message queue pointer
[in] stream stream data pointer
[in] streamlen stream length
[in] metadatalist adding 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(), 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 
)


Generated on Thu Jan 7 21:55:08 2016 for OpenJPEG by  doxygen 1.5.6