comparison src/recpt1.c @ 126:5dcaf3785ebe

fix process terminate problem. add dynamic Content-Length header.

125:e413158cae13

    ARIB_STD_B25_BUFFER *buf;
    int i;
    //fprintf (stderr, "stream_func(): start.\n");

    while(1) {
        // 3.1 tdata->stream_queue $B$+$i(B dequeue $B$9$k(B
        // dequeue $B$7$?%G!<%?$O(B ARIB_STD_B25_BUFFER
        qbuf = stream_dequeue(p_queue);
        /* no entry in the queue */
        if(qbuf == NULL) {

}

void
cleanup(thread_data *tdata)
{
    /* stop recording */
    ioctl(tdata->tfd, STOP_REC, 0);

    /* xxx need mutex? */
    f_exit = TRUE;

    pthread_cond_signal(&tdata->queue->cond_avail);
    pthread_cond_signal(&tdata->queue->cond_used);
}

126:5dcaf3785ebe

    ARIB_STD_B25_BUFFER *buf;
    int i;
    //fprintf (stderr, "stream_func(): start.\n");

    while(1) {
        if(f_exit)
            break;
        // 3.1 tdata->stream_queue $B$+$i(B dequeue $B$9$k(B
        // dequeue $B$7$?%G!<%?$O(B ARIB_STD_B25_BUFFER
        qbuf = stream_dequeue(p_queue);
        /* no entry in the queue */
        if(qbuf == NULL) {

}

void
cleanup(thread_data *tdata)
{
    int use_dlna = TRUE;
    /* stop recording */
    ioctl(tdata->tfd, STOP_REC, 0);

    /* xxx need mutex? */
    f_exit = TRUE;
    if ( use_dlna ) {
        UPnPBreak(0);
    }

    pthread_cond_signal(&tdata->queue->cond_avail);
    pthread_cond_signal(&tdata->queue->cond_used);
}