cleanup.c

Code for handling interrupted transfers. [詳細]

ソースコードを見る。

関数
void	close_all (void)
	Close all open sockets and files, allowing a (somewhat) graceful shutdown() of socket connections.
void	_exit_cleanup (int code, const char *file, int line)
	Eventually calls exit(), passing code, therefore does not return.
void	cleanup_disable (void)
void	cleanup_set (char *fnametmp, char *fname, struct file_struct *file, int fd_r, int fd_w)
void	cleanup_set_pid (pid_t pid)
変数
int	io_error
int	keep_partial
int	log_got_error
char *	partial_dir
static struct sigaction	sigact
int	cleanup_got_literal = 0
	Set to True once literal data has been sent across the link for the current file.
static char *	cleanup_fname
static char *	cleanup_new_fname
static struct file_struct *	cleanup_file
static int	cleanup_fd_r
static int	cleanup_fd_w
static pid_t	cleanup_pid = 0
pid_t	cleanup_child_pid = -1

---

説明

Code for handling interrupted transfers.

Depending on the --partial option, we may either delete the temporary file, or go ahead and overwrite the destination. This second behaviour only occurs if we've sent literal data and therefore hopefully made progress on the transfer.

cleanup.c で定義されています。

---

関数

void close_all

(

void

)

Close all open sockets and files, allowing a (somewhat) graceful shutdown() of socket connections.

This eliminates the abortive TCP RST sent by a Winsock-based system when the close() occurs.

cleanup.c の 38 行で定義されています。

参照先 do_fstat()・is_a_socket().

参照元 _exit_cleanup()・sigusr2_handler()・start_accept_loop().

{
#ifdef SHUTDOWN_ALL_SOCKETS
        int max_fd;
        int fd;
        int ret;
        STRUCT_STAT st;

        max_fd = sysconf(_SC_OPEN_MAX) - 1;
        for (fd = max_fd; fd >= 0; fd--) {
                if ((ret = do_fstat(fd, &st)) == 0) {
                        if (is_a_socket(fd))
                                ret = shutdown(fd, 2);
                        ret = close(fd);
                }
        }
#endif
}

void _exit_cleanup	(	int	code,
		const char *	file,
		int	line
	)

Eventually calls exit(), passing code, therefore does not return.

引数:

code

one of the RERR_* codes from errcode.h.

cleanup.c の 90 行で定義されています。

参照先 cleanup_child_pid・cleanup_fd_r・cleanup_fd_w・cleanup_file・cleanup_fname・cleanup_got_literal・cleanup_new_fname・cleanup_pid・close_all()・do_unlink()・FINFO・finish_transfer()・flush_write_file()・handle_partial_dir()・io_error・io_flush()・keep_partial・kill_all()・log_exit()・log_got_error・partial_dir・rprintf()・verbose・wait_process().

{
        int ocode = code;
        static int inside_cleanup = 0;

        if (inside_cleanup > 10) {
                /* prevent the occasional infinite recursion */
                return;
        }
        inside_cleanup++;

        SIGACTION(SIGUSR1, SIG_IGN);
        SIGACTION(SIGUSR2, SIG_IGN);

        if (verbose > 3) {
                rprintf(FINFO,"_exit_cleanup(code=%d, file=%s, line=%d): entered\n",
                        code, file, line);
        }

        if (cleanup_child_pid != -1) {
                int status;
                if (wait_process(cleanup_child_pid, &status, WNOHANG)
                 == cleanup_child_pid) {
                        status = WEXITSTATUS(status);
                        if (status > code)
                                code = status;
                }
        }

        if (cleanup_got_literal && cleanup_fname && keep_partial
            && handle_partial_dir(cleanup_new_fname, PDIR_CREATE)) {
                char *fname = cleanup_fname;
                cleanup_fname = NULL;
                if (cleanup_fd_r != -1)
                        close(cleanup_fd_r);
                if (cleanup_fd_w != -1) {
                        flush_write_file(cleanup_fd_w);
                        close(cleanup_fd_w);
                }
                finish_transfer(cleanup_new_fname, fname, NULL,
                                cleanup_file, 0, !partial_dir);
        }
        io_flush(FULL_FLUSH);
        if (cleanup_fname)
                do_unlink(cleanup_fname);
        if (code)
                kill_all(SIGUSR1);
        if (cleanup_pid && cleanup_pid == getpid()) {
                char *pidf = lp_pid_file();
                if (pidf && *pidf)
                        unlink(lp_pid_file());
        }

        if (code == 0) {
                if (io_error & IOERR_DEL_LIMIT)
                        code = RERR_DEL_LIMIT;
                if (io_error & IOERR_VANISHED)
                        code = RERR_VANISHED;
                if (io_error & IOERR_GENERAL || log_got_error)
                        code = RERR_PARTIAL;
        }

        if (code)
                log_exit(code, file, line);

        if (verbose > 2) {
                rprintf(FINFO,"_exit_cleanup(code=%d, file=%s, line=%d): about to call exit(%d)\n",
                        ocode, file, line, code);
        }

        close_all();
        exit(code);
}

void cleanup_disable

(

void

)

cleanup.c の 164 行で定義されています。

参照先 cleanup_fname・cleanup_got_literal.

参照元 recv_files().

{
        cleanup_fname = NULL;
        cleanup_got_literal = 0;
}

void cleanup_set	(	char *	fnametmp,
		char *	fname,
		struct file_struct *	file,
		int	fd_r,
		int	fd_w
	)

cleanup.c の 171 行で定義されています。

参照先 cleanup_fd_r・cleanup_fd_w・cleanup_file・cleanup_fname・cleanup_new_fname.

参照元 recv_files().

{
        cleanup_fname = fname ? fnametmp : NULL;
        cleanup_new_fname = fname;
        cleanup_file = file;
        cleanup_fd_r = fd_r;
        cleanup_fd_w = fd_w;
}

void cleanup_set_pid

(

pid_t

pid

)

cleanup.c の 181 行で定義されています。

参照先 cleanup_pid.

参照元 daemon_main().

{
        cleanup_pid = pid;
}

---

変数

int io_error

flist.c の 72 行で定義されています。

参照元 _exit_cleanup()・delete_in_dir()・generate_files()・make_file()・recv_file_list()・send_directory()・send_file_list()・send_files()・send_if_directory().

int keep_partial

options.c の 98 行で定義されています。

参照元 _exit_cleanup()・parse_arguments()・recv_files()・server_options().

int log_got_error

log.c の 61 行で定義されています。

参照元 _exit_cleanup()・rwrite()・sigusr2_handler().

char* partial_dir

options.c の 146 行で定義されています。

参照元 _exit_cleanup()・handle_partial_dir()・parse_arguments()・partial_dir_fname()・recv_files()・recv_generator().

struct sigaction sigact [static]

cleanup.c の 30 行で定義されています。

参照元 main()・start_accept_loop()・start_daemon().

int cleanup_got_literal = 0

Set to True once literal data has been sent across the link for the current file.

(????)

Handling the cleanup when a transfer is interrupted is tricky when --partial is selected. We need to ensure that the partial file is kept if any real data has been transferred.

cleanup.c の 75 行で定義されています。

参照元 _exit_cleanup()・cleanup_disable()・receive_data()・recv_files().

char* cleanup_fname [static]

cleanup.c の 77 行で定義されています。

参照元 _exit_cleanup()・cleanup_disable()・cleanup_set().

char* cleanup_new_fname [static]

cleanup.c の 78 行で定義されています。

参照元 _exit_cleanup()・cleanup_set().

struct file_struct* cleanup_file [static]

cleanup.c の 79 行で定義されています。

参照元 _exit_cleanup()・cleanup_set().

int cleanup_fd_r [static]

cleanup.c の 80 行で定義されています。

参照元 _exit_cleanup()・cleanup_set().

int cleanup_fd_w [static]

cleanup.c の 80 行で定義されています。

参照元 _exit_cleanup()・cleanup_set().

pid_t cleanup_pid = 0 [static]

cleanup.c の 81 行で定義されています。

参照元 _exit_cleanup()・cleanup_set_pid().

pid_t cleanup_child_pid = -1

cleanup.c の 83 行で定義されています。

参照元 _exit_cleanup()・client_run().

---