comparison src/recpt1.c @ 144:bf96eac4dbb1

Changed to a variable length buffer of splitbuf_t

143:e72dd5e8d53f

    int split_select_finish = TSS_ERROR;

    buf.size = 0;
    buf.data = NULL;
    splitbuf.size = 0;

    if(wfd == -1)
        fileless = TRUE;

    if(use_udp) {

        }


        if(use_splitter) {
            splitbuf.size = 0;

            while(buf.size) {
                /* $BJ,N%BP>](BPID$B$NCj=P(B */
                if(split_select_finish != TSS_SUCCESS) {
                    split_select_finish = split_select(splitter, &buf);

                if(wc < 0) {
                    if(errno == EPIPE)
                        pthread_kill(signal_thread, SIGPIPE);
                }
            }

            break;
        }
    }

144:bf96eac4dbb1

    int split_select_finish = TSS_ERROR;

    buf.size = 0;
    buf.data = NULL;
    splitbuf.size = 0;
    splitbuf.buffer_length = 0;
    splitbuf.buffer = NULL;

    if(wfd == -1)
        fileless = TRUE;

    if(use_udp) {

        }


        if(use_splitter) {
            splitbuf.size = 0;
            if(splitbuf.buffer_length < buf.size && buf.size > 0) {
                splitbuf.buffer = realloc(splitbuf.buffer, buf.size);
                if(NULL == splitbuf.buffer) {
                    fprintf(stderr, "splitbuf.buffer realloc failed\n");
                    use_splitter = FALSE;
                    goto fin;
                }
                splitbuf.buffer_length = buf.size;
            }

            while(buf.size) {
                /* $BJ,N%BP>](BPID$B$NCj=P(B */
                if(split_select_finish != TSS_SUCCESS) {
                    split_select_finish = split_select(splitter, &buf);

                if(wc < 0) {
                    if(errno == EPIPE)
                        pthread_kill(signal_thread, SIGPIPE);
                }
            }
            if(use_splitter) {
                free(splitbuf.buffer);
                splitbuf.buffer = NULL;
                splitbuf.buffer_length = 0;
            }

            break;
        }
    }