view src/recpt1.h @ 185:7a0f498af035 default tip

Fix a race condition.

/* -*- tab-width: 4; indent-tabs-mode: nil -*- */
#ifndef _RECPT1_H_
#define _RECPT1_H_
#include <sys/types.h>
#include <netdb.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include "decoder.h"
#include "tssplitter_lite.h"

#define HAVE_LIBARIB25 1
#define NUM_BSDEV       16
#define NUM_ISDB_T_DEV  16
#define CHTYPE_SATELLITE    0        /* satellite digital */
#define CHTYPE_GROUND       1        /* terrestrial digital */
#define MAX_QUEUE           8192
#define MAX_READ_SIZE       (188 * 87) /* 188*87=16356 splitterが188アライメントを期待しているのでこの数字とする*/
#define WRITE_SIZE          (1024 * 1024 * 2)
#define TRUE                1
#define FALSE               0
#define STREAM_MAX (16)
#define CHANNEL_MAX (256)


/* type definitions */
typedef int boolean;

typedef struct _BUFSZ {
    int size;
    u_char buffer[MAX_READ_SIZE];
} BUFSZ;

typedef struct _QUEUE_T {
    unsigned int in;        // 次に入れるインデックス
    unsigned int out;        // 次に出すインデックス
    unsigned int size;        // キューのサイズ
    unsigned int num_avail;    // 満タンになると 0 になる
    unsigned int num_used;    // 空っぽになると 0 になる
    pthread_mutex_t mutex;
    pthread_cond_t cond_avail;    // データが満タンのときに待つための cond
    pthread_cond_t cond_used;    // データが空のときに待つための cond
    BUFSZ *buffer[1];    // バッファポインタ
} QUEUE_T;

typedef struct _STREAM_QUEUE_T {
    unsigned int in;        // 次に入れるインデックス
    unsigned int out;        // 次に出すインデックス
    unsigned int size;        // キューのサイズ
    unsigned int num_avail;    // 満タンになると 0 になる
    unsigned int num_used;    // 空っぽになると 0 になる
    pthread_mutex_t mutex;
    pthread_cond_t cond_avail;    // データが満タンのときに待つための cond
    pthread_cond_t cond_used;    // データが空のときに待つための cond
    ARIB_STD_B25_BUFFER   *buffer[1];    // バッファポインタ
} STREAM_QUEUE_T;

typedef struct _ISDB_T_FREQ_CONV_TABLE {
    int set_freq;    // 実際にioctl()を行う値
    int type;        // チャンネルタイプ
    int add_freq;    // 追加する周波数(BS/CSの場合はスロット番号)
    char *parm_freq;    // パラメータで受ける値
} ISDB_T_FREQ_CONV_TABLE;

typedef struct sock_data {
    int sfd;    /* socket fd */
    struct sockaddr_in addr;
} sock_data;

typedef struct _session {
    int id;
    int is_valid;
    QUEUE_T *p_queue;
} session;

typedef struct _streamer {
    pthread_mutex_t mutex;   //open、close、(recpt1からの)write
    int stream_nr;
    size_t total_byte; // 送信BYTE数
    struct timespec start; // 開始時刻
    session *stream_session[STREAM_MAX]; //NULL止めの配列
} streamer;

typedef struct thread_data {
    QUEUE_T *queue;
    QUEUE_T *stream_queue;
    decoder *decoder;
    decoder_options *dopt;
    char ch[16];   /* channel is one of the following. Number, C00, BS0_0, CS0 */
    int lnb;    /* LNB voltage */
    int tfd;    /* tuner fd */
    int wfd;    /* output file fd */
    char *device_name; /* "/dev/ptXvideoY" */
    ISDB_T_FREQ_CONV_TABLE *table;
    sock_data *sock_data;
    pthread_t signal_thread;
    int recsec;
    time_t start_time;
    boolean indefinite;
    int msqid;
    splitter *splitter;
    streamer *streamer;
    char sid_list[256];
    pthread_mutex_t splitter_mutex;
} thread_data;

struct channel_info {
    int   id;
    char *sid;
    char *tp;
    char *name;
};

struct channel_info_list {
    int                  nr_channel;
    struct channel_info *channel_info[CHANNEL_MAX];
};

QUEUE_T *create_queue(size_t size);
BUFSZ *dequeue(QUEUE_T *p_queue);
ARIB_STD_B25_BUFFER *stream_dequeue(STREAM_QUEUE_T *p_queue);
void destroy_queue(QUEUE_T *p_queue);
void destroy_stream_queue(STREAM_QUEUE_T *p_queue);

#endif