comparison src/recpt1.c @ 127:5a380559a61e

modify calclate bitrate mechanism.

126:5dcaf3785ebe

    thread_data *data = (thread_data *)p;
    STREAM_QUEUE_T *p_queue = data->stream_queue;
    ARIB_STD_B25_BUFFER *qbuf = NULL;
    ARIB_STD_B25_BUFFER *buf;
    int i;
    //fprintf (stderr, "stream_func(): start.\n");

    while(1) {
        if(f_exit)
            break;

        /* no entry in the queue */
        if(qbuf == NULL) {
            //fprintf (stderr, "stream_func(): dequeue() return NULL pointer. streaming abort.\n");
            continue;
        }
        // クリティカルセクション長いのなんとかしたいなぁ…
        // ToDo: memcpy とかクリティカルセクションの外に出す
        // 3.2 tdata->streamer->mutex を lock
        //fprintf (stderr, "stream_func(): mutex lock try.\n");
        pthread_mutex_lock(&data->streamer->mutex);

127:5a380559a61e

    thread_data *data = (thread_data *)p;
    STREAM_QUEUE_T *p_queue = data->stream_queue;
    ARIB_STD_B25_BUFFER *qbuf = NULL;
    ARIB_STD_B25_BUFFER *buf;
    int i;
    clock_gettime(CLOCK_REALTIME, &data->streamer->start);
    data->streamer->total_byte = 0;
    //fprintf (stderr, "stream_func(): start.\n");

    while(1) {
        if(f_exit)
            break;

        /* no entry in the queue */
        if(qbuf == NULL) {
            //fprintf (stderr, "stream_func(): dequeue() return NULL pointer. streaming abort.\n");
            continue;
        }
        data->streamer->total_byte += qbuf->size;
        // クリティカルセクション長いのなんとかしたいなぁ…
        // ToDo: memcpy とかクリティカルセクションの外に出す
        // 3.2 tdata->streamer->mutex を lock
        //fprintf (stderr, "stream_func(): mutex lock try.\n");
        pthread_mutex_lock(&data->streamer->mutex);