savetransfer.c

ソースコードを見る。

関数
void	run_program (char **command)
int	main (int argc, char *argv[])
void	set_nonblocking (int fd)
void	set_blocking (int fd)
変数
char	buf [4096]
int	save_data_from_program = 0

---

関数

void run_program

(

char **

command

)

savetransfer.c の 102 行で定義されています。

参照先 errno・save_data_from_program・set_blocking().

参照元 main().

{
    int pipe_fds[2], ret;
    pid_t pid;

    if (pipe(pipe_fds) < 0) {
        fprintf(stderr, "pipe failed: %s\n", strerror(errno));
        exit(1);
    }

    if ((pid = fork()) < 0) {
        fprintf(stderr, "fork failed: %s\n", strerror(errno));
        exit(1);
    }

    if (pid == 0) {
        if (save_data_from_program)
            ret = dup2(pipe_fds[1], STDOUT_FILENO);
        else
            ret = dup2(pipe_fds[0], STDIN_FILENO);
        if (ret < 0) {
            fprintf(stderr, "Failed to dup (in child): %s\n", strerror(errno));
            exit(1);
        }
        close(pipe_fds[0]);
        close(pipe_fds[1]);
        set_blocking(STDIN_FILENO);
        set_blocking(STDOUT_FILENO);
        execvp(command[0], command);
        fprintf(stderr, "Failed to exec %s: %s\n", command[0], strerror(errno));
        exit(1);
    }

    if (save_data_from_program)
        ret = dup2(pipe_fds[0], STDIN_FILENO);
    else
        ret = dup2(pipe_fds[1], STDOUT_FILENO);
    if (ret < 0) {
        fprintf(stderr, "Failed to dup (in parent): %s\n", strerror(errno));
        exit(1);
    }
    close(pipe_fds[0]);
    close(pipe_fds[1]);
}

int main	(	int	argc,
		char *	argv[]
	)

savetransfer.c の 36 行で定義されています。

参照先 buf・errno・run_program()・save_data_from_program・set_blocking()・set_nonblocking().

{
    int fd_file, len;
    struct timeval tv;
    fd_set fds;

    argv++;
    if (--argc && argv[0][0] == '-') {
        if (argv[0][1] == 'o')
            save_data_from_program = 1;
        else if (argv[0][1] == 'i')
            save_data_from_program = 0;
        else {
            fprintf(stderr, "Unknown option: %s\n", argv[0]);
            exit(1);
        }
        argv++;
        argc--;
    }
    if (argc < 2) {
        fprintf(stderr, "Usage: savetransfer [-i|-o] OUTPUT_FILE PROGRAM [ARGS...]\n");
        fprintf(stderr, "-i  Save the input going to PROGRAM to the OUTPUT_FILE\n");
        fprintf(stderr, "-o  Save the output coming from PROGRAM to the OUTPUT_FILE\n");
        exit(1);
    }
    if ((fd_file = open(*argv, O_WRONLY|O_TRUNC|O_CREAT|O_BINARY, 0644)) < 0) {
        fprintf(stderr, "Unable to write to `%s': %s\n", *argv, strerror(errno));
        exit(1);
    }
    set_blocking(fd_file);

    signal(SIGPIPE, SIG_IGN);

    run_program(argv + 1);

#if defined HAVE_SETMODE && O_BINARY
    setmode(STDIN_FILENO, O_BINARY);
    setmode(STDOUT_FILENO, O_BINARY);
#endif
    set_nonblocking(STDIN_FILENO);
    set_blocking(STDOUT_FILENO);

    while (1) {
        FD_ZERO(&fds);
        FD_SET(STDIN_FILENO, &fds);
        tv.tv_sec = TIMEOUT_SECONDS;
        tv.tv_usec = 0;
        if (!select(STDIN_FILENO+1, &fds, NULL, NULL, &tv))
            break;
        if (!FD_ISSET(STDIN_FILENO, &fds))
            break;
        if ((len = read(STDIN_FILENO, buf, sizeof buf)) <= 0)
            break;
        if (write(STDOUT_FILENO, buf, len) != len) {
            fprintf(stderr, "Failed to write data to stdout: %s\n", strerror(errno));
            exit(1);
        }
        if (write(fd_file, buf, len) != len) {
            fprintf(stderr, "Failed to write data to fd_file: %s\n", strerror(errno));
            exit(1);
        }
    }
    return 0;
}

void set_nonblocking

(

int

fd

)

savetransfer.c の 148 行で定義されています。

参照元 client_run()・fd_pair()・main()・set_msg_fd_out()・socketpair_tcp()・start_daemon()・start_server().

{
    int val;

    if ((val = fcntl(fd, F_GETFL, 0)) == -1)
        return;
    if (!(val & NONBLOCK_FLAG)) {
        val |= NONBLOCK_FLAG;
        fcntl(fd, F_SETFL, val);
    }
}

void set_blocking

(

int

fd

)

savetransfer.c の 161 行で定義されています。

参照元 client_run()・main()・piped_child()・rsync_module()・run_program()・socketpair_tcp().

{
    int val;

    if ((val = fcntl(fd, F_GETFL, 0)) < 0)
        return;
    if (val & NONBLOCK_FLAG) {
        val &= ~NONBLOCK_FLAG;
        fcntl(fd, F_SETFL, val);
    }
}

---

変数

char buf[4096]

savetransfer.c の 32 行で定義されています。

参照元 copy_file()・file_checksum()・file_checksum1()・file_checksum2()・generate_hash()・get_checksum1()・hash_search()・human_dnum()・io_printf()・keep_backup()・list_file()・log_formatted()・main()・match_sums()・matched()・mdfour_tail()・parse_merge_name()・parse_size_arg()・pool_stats()・read_msg_fd()・rprintf()・rsync_module()・rsyserr()・run_test()・send_deflated_token()・send_token()・setup_merge_file()・simple_recv_token()・simple_send_token().

int save_data_from_program = 0

savetransfer.c の 33 行で定義されています。

参照元 main()・run_program().

---