OpenJPEG
2.2.0
|
#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include "auxtrans_manager.h"
#include <pthread.h>
Data Structures | |
struct | aux_response_param |
Macros | |
#define | FCGI_stdout stdout |
#define | FCGI_stderr stderr |
#define | logstream stderr |
Typedefs | |
typedef struct aux_response_param | aux_response_param_t |
Functions | |
auxtrans_param_t | init_aux_transport (int tcp_auxport, int udp_auxport) |
Initialize auxiliary transport server of JPIP server. More... | |
void | close_aux_transport (auxtrans_param_t auxtrans) |
Close auxiliary transport server of JPIP server. More... | |
aux_response_param_t * | gene_auxresponse (OPJ_BOOL istcp, auxtrans_param_t auxtrans, const char cid[], void *data, OPJ_SIZE_T datalen, OPJ_SIZE_T maxlenPerFrame) |
void | delete_auxresponse (aux_response_param_t **auxresponse) |
void * | aux_streaming (void *arg) |
void | send_responsedata_on_aux (OPJ_BOOL istcp, auxtrans_param_t auxtrans, const char cid[], void *data, OPJ_SIZE_T datalen, OPJ_SIZE_T maxlenPerFrame) |
Send response data on aux transport. More... | |
OPJ_BOOL | identify_cid (SOCKET connected_socket, char refcid[], FILE *fp) |
Identify cid sent from client. More... | |
OPJ_BOOL | recv_ack (SOCKET connected_socket, void *data) |
#define FCGI_stderr stderr |
Referenced by aux_streaming(), and send_responsedata_on_aux().
#define FCGI_stdout stdout |
#define logstream stderr |
typedef struct aux_response_param aux_response_param_t |
void * aux_streaming | ( | void * | arg | ) |
References accept_socket(), aux_response_param::cid, close_socket(), aux_response_param::data, aux_response_param::datalen, delete_auxresponse(), FCGI_stderr, identify_cid(), aux_response_param::listensock, aux_response_param::maxlenPerFrame, opj_free(), opj_malloc(), recv_ack(), and send_stream().
Referenced by send_responsedata_on_aux().
void close_aux_transport | ( | auxtrans_param_t | auxtrans | ) |
Close auxiliary transport server of JPIP server.
auxiliary response parameters
References close_socket(), auxtrans_param::tcplistensock, and auxtrans_param::udplistensock.
void delete_auxresponse | ( | aux_response_param_t ** | auxresponse | ) |
References opj_free().
Referenced by aux_streaming().
aux_response_param_t * gene_auxresponse | ( | OPJ_BOOL | istcp, |
auxtrans_param_t | auxtrans, | ||
const char | cid[], | ||
void * | data, | ||
OPJ_SIZE_T | datalen, | ||
OPJ_SIZE_T | maxlenPerFrame | ||
) |
Identify cid sent from client.
[in] | connected_socket | file descriptor of the connected socket |
[in] | refcid | refenrece channel ID |
[in] | fp | file pointer for log of aux stream |
References OPJ_FALSE, opj_free(), OPJ_TRUE, and receive_string().
Referenced by aux_streaming().
auxtrans_param_t init_aux_transport | ( | int | tcp_auxport, |
int | udp_auxport | ||
) |
Initialize auxiliary transport server of JPIP server.
[in] | tcp_auxport | opening tcp auxiliary port ( 0 not to open, valid No. 49152-65535) |
[in] | udp_auxport | opening udp auxiliary port ( 0 not to open, valid No. 49152-65535) |
References open_listeningsocket(), auxtrans_param::tcpauxport, auxtrans_param::tcplistensock, auxtrans_param::udpauxport, and auxtrans_param::udplistensock.
References OPJ_FALSE, opj_free(), OPJ_TRUE, and receive_stream().
Referenced by aux_streaming().
void send_responsedata_on_aux | ( | OPJ_BOOL | istcp, |
auxtrans_param_t | auxtrans, | ||
const char | cid[], | ||
void * | data, | ||
OPJ_SIZE_T | length, | ||
OPJ_SIZE_T | maxlenPerFrame | ||
) |
Send response data on aux transport.
[in] | istcp | true if tcp, false if udp |
[in] | auxtrans | available transport parameters |
[in] | cid | channel ID |
[in] | data | sending data |
[in] | length | length of data |
[in] | maxlenPerFrame | maximum data length to send per frame |
References aux_streaming(), FCGI_stderr, gene_auxresponse(), and auxtrans_param::tcplistensock.