comparison recpt1/recpt1.c @ 28:97c820e30737

limit write length at once so that udp/stdout works well.

27:763cf84d2dc7

#include "pt1_ioctl.h"

#include "recpt1.h"
#include "decoder.h"

/* globals */
int f_exit = FALSE;

/* type definitions */
typedef struct sock_data {

        sfd = data->sock_data->sfd;
        addr = &data->sock_data->addr;
    }

    while(1) {
        ssize_t wc;
        qbuf = dequeue(p_queue);
        /* no entry in the queue */
        if(qbuf == NULL) {
            break;
        }

        sbuf.size = qbuf->size;

        buf = sbuf; /* default */

        if(use_b25) {
            /* write data to output file*/
            code = b25_decode(dec, &sbuf, &dbuf);
            if(code < 0)
                fprintf(stderr, "b25_decode failed\n");
            else
                buf = dbuf;
        }

        if(!fileless) {
            wc = write(wfd, buf.data, buf.size);
            if(wc < 0) {
                if(errno == EPIPE)
                    pthread_kill(signal_thread, SIGPIPE);
                else
                    pthread_kill(signal_thread, SIGUSR2);
            }
        }

        if(use_udp && sfd != -1) {
            sendto(sfd, buf.data, buf.size, 0,
                   (struct sockaddr *)addr, sizeof(*addr));
        }

        free(qbuf);

        /* normal exit */

                        pthread_kill(signal_thread, SIGUSR2);
                }
            }

            if(use_udp && sfd != -1) {
                sendto(sfd, buf.data, buf.size, 0,
                       (struct sockaddr *)addr, sizeof(*addr));
            }

            break;
        }
    }

                perror("gethostbyname");
                return 1;
            }
            ia.s_addr = *(in_addr_t*) (hoste->h_addr_list[0]);
        }
        sockdata->addr.sin_family = AF_INET;
        sockdata->addr.sin_port = htons (port_to);
        sockdata->addr.sin_addr.s_addr = ia.s_addr;
        if((sockdata->sfd = socket(PF_INET, SOCK_DGRAM, 0)) < 0) {
            perror("socket");
            return 1;
        }
    }

    /* setup tuner */

28:97c820e30737

#include "pt1_ioctl.h"

#include "recpt1.h"
#include "decoder.h"

/* maximum write length at once */
#define SIZE_CHANK 1316

/* globals */
int f_exit = FALSE;

/* type definitions */
typedef struct sock_data {

        sfd = data->sock_data->sfd;
        addr = &data->sock_data->addr;
    }

    while(1) {
        ssize_t wc = 0;
        qbuf = dequeue(p_queue);
        /* no entry in the queue */
        if(qbuf == NULL) {
            break;
        }

        sbuf.size = qbuf->size;

        buf = sbuf; /* default */

        if(use_b25) {
            code = b25_decode(dec, &sbuf, &dbuf);
            if(code < 0)
                fprintf(stderr, "b25_decode failed\n");
            else
                buf = dbuf;
        }

        if(!fileless) {
            /* write data to output file */
            int size_remain = buf.size;
            int offset = 0;
            while(size_remain > 0) {
                int ws = size_remain < SIZE_CHANK ? size_remain : SIZE_CHANK;
                wc = write(wfd, buf.data + offset, ws);
                if(wc < 0) {
                    if(errno == EPIPE)
                        pthread_kill(signal_thread, SIGPIPE);
                    else
                        pthread_kill(signal_thread, SIGUSR2);
                    break;
                }
                size_remain -= wc;
                offset += wc;
            }
        }

        if(use_udp && sfd != -1) {
            /* write data to socket */
            int size_remain = buf.size;
            int offset = 0;
            while(size_remain > 0) {
                int ws = size_remain < SIZE_CHANK ? size_remain : SIZE_CHANK;
                wc = write(sfd, buf.data + offset, ws);
                if(wc < 0) {
                    if(errno == EPIPE)
                        pthread_kill(signal_thread, SIGPIPE);
                    break;
                }
                size_remain -= wc;
                offset += wc;
            }
        }

        free(qbuf);

        /* normal exit */

                        pthread_kill(signal_thread, SIGUSR2);
                }
            }

            if(use_udp && sfd != -1) {
                wc = write(sfd, buf.data, buf.size);
                if(wc < 0) {
                    if(errno == EPIPE)
                        pthread_kill(signal_thread, SIGPIPE);
                }
            }

            break;
        }
    }

                perror("gethostbyname");
                return 1;
            }
            ia.s_addr = *(in_addr_t*) (hoste->h_addr_list[0]);
        }
        if((sockdata->sfd = socket(PF_INET, SOCK_DGRAM, 0)) < 0) {
            perror("socket");
            return 1;
        }

        sockdata->addr.sin_family = AF_INET;
        sockdata->addr.sin_port = htons (port_to);
        sockdata->addr.sin_addr.s_addr = ia.s_addr;

        if(connect(sockdata->sfd, (struct sockaddr *)&sockdata->addr,
                   sizeof(sockdata->addr)) < 0) {
            perror("connect");
            return 1;
        }
    }

    /* setup tuner */