RsyncSpaceCheckTask Class Reference

Inheritance diagram for RsyncSpaceCheckTask:

Public Member Functions
	RsyncSpaceCheckTask ()
override void	prepare ()
override void	parse_stdout_line (string out_line)
override void	parse_stderr_line (string err_line)
bool	update_progress_parse_console_output (string line)
Public Member Functions inherited from AsyncTask
signal void	stdout_line_read (string line)
signal void	stderr_line_read (string line)
signal void	task_complete ()
void	write_stdin (string line)
virtual void	execute ()
bool	is_running ()
void	stop (AppStatus status_to_update=AppStatus.CANCELLED)
void	pause (AppStatus status_to_update=AppStatus.PAUSED)
void	resume (AppStatus status_to_update=AppStatus.RUNNING)
void	print_app_status ()

Public Attributes
bool	delete_extra = true
bool	delete_after = false
bool	delete_excluded = false
bool	relative = false
string	exclude_from_file = ""
string	link_from_path = ""
string	source_path = ""
string	dest_path = ""
bool	verbose = true
bool	io_nice = true
bool	dry_run = false
int64	status_line_count = 0
int64	total_size = 0
Public Attributes inherited from AsyncTask
AppStatus	status = AppStatus.NOT_STARTED
GLib.Mutex	status_line_mutex
int	exit_code = 0
GLib.Timer	timer
double	progress = 0.0
double	percent = 0.0
int64	prg_count = 0
int64	prg_count_total = 0

Protected Member Functions
override string	build_script ()
Protected Member Functions inherited from AsyncTask
	AsyncTask ()
string	build_script ()
virtual bool	begin ()
void	parse_stdout_line (string out_line)
void	parse_stderr_line (string err_line)
virtual void	finish_task ()
int	read_exit_code ()

Private Member Functions
void	init_regular_expressions ()

Private Attributes
Regex	sent_bytes_regex

Additional Inherited Members
Protected Attributes inherited from AsyncTask
DataOutputStream	dos_log = null
Pid	child_pid = 0
string	script_file = ""
string	working_dir = ""
Properties inherited from AsyncTask
string	status_line [get, set]
double	elapsed [get]
string	stat_time_elapsed [get]
string???	stat_time_remaining [get]

Detailed Description

Definition at line 31 of file RsyncSpaceCheckTask.vala.

Constructor & Destructor Documentation

RsyncSpaceCheckTask()

RsyncSpaceCheckTask.RsyncSpaceCheckTask ( )

inline

Definition at line 54 of file RsyncSpaceCheckTask.vala.

                                {
        init_regular_expressions();
    }

References init_regular_expressions().

Referenced by Main.get_space_needed_for_rsync_snapshot().

Member Function Documentation

build_script()

override string RsyncSpaceCheckTask.build_script ( )

inlineprotected

Definition at line 78 of file RsyncSpaceCheckTask.vala.

                                             {
        var cmd = "export LC_ALL=C.UTF-8\n";
 
        cmd += "rsync -aii";
 
        cmd += " --recursive";
 
        if (verbose){
            cmd += " --verbose";
        }
        else{
            cmd += " --quiet";
        }
 
        if (delete_extra){
            cmd += " --delete";
        }
 
        if (delete_after){
            cmd += " --delete-after";
        }
 
        cmd += " --force"; // allow deletion of non-empty directories
 
        cmd += " --stats";
 
        cmd += " --sparse";
 
        if (delete_excluded){
            cmd += " --delete-excluded";
        }
 
        cmd += " --dry-run";
 
        if (link_from_path.length > 0){
            if (!link_from_path.has_suffix("/")){
                link_from_path = "%s/".printf(link_from_path);
            }
            
            cmd += " --link-dest='%s'".printf(escape_single_quote(link_from_path));
        }
        
        if (exclude_from_file.length > 0){
            cmd += " --exclude-from='%s'".printf(escape_single_quote(exclude_from_file));
 
            if (delete_extra && delete_excluded){
                cmd += " --delete-excluded";
            }
        }
 
        source_path = remove_trailing_slash(source_path);
        
        dest_path = remove_trailing_slash(dest_path);
        
        cmd += " '%s/'".printf(escape_single_quote(source_path));
 
        cmd += " '%s/'".printf(escape_single_quote(dest_path));
        
        return cmd;
    }

References delete_after, delete_excluded, delete_extra, dest_path, TeeJee.FileSystem.escape_single_quote(), exclude_from_file, link_from_path, TeeJee.FileSystem.remove_trailing_slash(), source_path, and verbose.

init_regular_expressions()

void RsyncSpaceCheckTask.init_regular_expressions ( )

inlineprivate

Definition at line 58 of file RsyncSpaceCheckTask.vala.

                                           {
        if (sent_bytes_regex != null){
            return; // already initialized
        }
 
        try {
            sent_bytes_regex = new Regex("""sent ([0-9,]+)[ \t]+bytes[ \t]+received""");
        }
        catch (Error e) {
            log_error (e.message);
        }
    }

References Error, TeeJee.Logging.log_error(), and sent_bytes_regex.

Referenced by RsyncSpaceCheckTask().

parse_stderr_line()

override void RsyncSpaceCheckTask.parse_stderr_line ( string err_line )

inline

Definition at line 145 of file RsyncSpaceCheckTask.vala.

                                                           {
        update_progress_parse_console_output(err_line);
    }

References AsyncTask.err_line, and update_progress_parse_console_output().

parse_stdout_line()

override void RsyncSpaceCheckTask.parse_stdout_line ( string out_line )

inline

Definition at line 141 of file RsyncSpaceCheckTask.vala.

                                                           {
        update_progress_parse_console_output(out_line);
    }

References AsyncTask.out_line, and update_progress_parse_console_output().

prepare()

override void RsyncSpaceCheckTask.prepare ( )

inlinevirtual

Reimplemented from AsyncTask.

Definition at line 71 of file RsyncSpaceCheckTask.vala.

                                   {
        base.prepare();
 
        total_size = 0;
        status_line_count = 0;
    }

References status_line_count, and total_size.

update_progress_parse_console_output()

bool RsyncSpaceCheckTask.update_progress_parse_console_output ( string line )

inline

Definition at line 149 of file RsyncSpaceCheckTask.vala.

                                                                   {
        if ((line == null) || (line.length == 0)) {
            return true;
        }
 
        status_line_count++;
 
        if (prg_count_total > 0){
            prg_count = status_line_count;
            progress = (prg_count * 1.0) / prg_count_total;
        }
 
        MatchInfo match;
 
        if (sent_bytes_regex.match(line, 0, out match)) {
            total_size = int64.parse(match.fetch(1).replace(",",""));
        }
        else{
            //log_debug("not-matched: %s".printf(line));
        }
 
        return true;
    }

References AsyncTask.prg_count, AsyncTask.prg_count_total, AsyncTask.progress, sent_bytes_regex, status_line_count, and total_size.

Referenced by parse_stderr_line(), and parse_stdout_line().

Member Data Documentation

delete_after

bool RsyncSpaceCheckTask.delete_after = false

Definition at line 35 of file RsyncSpaceCheckTask.vala.

Referenced by build_script().

delete_excluded

bool RsyncSpaceCheckTask.delete_excluded = false

Definition at line 36 of file RsyncSpaceCheckTask.vala.

Referenced by build_script().

delete_extra

bool RsyncSpaceCheckTask.delete_extra = true

Definition at line 34 of file RsyncSpaceCheckTask.vala.

Referenced by build_script().

dest_path

string RsyncSpaceCheckTask.dest_path = ""

Definition at line 42 of file RsyncSpaceCheckTask.vala.

Referenced by build_script().

dry_run

bool RsyncSpaceCheckTask.dry_run = false

Definition at line 45 of file RsyncSpaceCheckTask.vala.

exclude_from_file

string RsyncSpaceCheckTask.exclude_from_file = ""

Definition at line 39 of file RsyncSpaceCheckTask.vala.

Referenced by build_script().

io_nice

bool RsyncSpaceCheckTask.io_nice = true

Definition at line 44 of file RsyncSpaceCheckTask.vala.

link_from_path

string RsyncSpaceCheckTask.link_from_path = ""

Definition at line 40 of file RsyncSpaceCheckTask.vala.

Referenced by build_script().

relative

bool RsyncSpaceCheckTask.relative = false

Definition at line 37 of file RsyncSpaceCheckTask.vala.

sent_bytes_regex

Regex RsyncSpaceCheckTask.sent_bytes_regex

private

Definition at line 48 of file RsyncSpaceCheckTask.vala.

Referenced by init_regular_expressions(), and update_progress_parse_console_output().

source_path

string RsyncSpaceCheckTask.source_path = ""

Definition at line 41 of file RsyncSpaceCheckTask.vala.

Referenced by build_script().

status_line_count

int64 RsyncSpaceCheckTask.status_line_count = 0

Definition at line 51 of file RsyncSpaceCheckTask.vala.

Referenced by prepare(), and update_progress_parse_console_output().

total_size

int64 RsyncSpaceCheckTask.total_size = 0

Definition at line 52 of file RsyncSpaceCheckTask.vala.

Referenced by Main.get_space_needed_for_rsync_snapshot(), prepare(), and update_progress_parse_console_output().

verbose

bool RsyncSpaceCheckTask.verbose = true

Definition at line 43 of file RsyncSpaceCheckTask.vala.

Referenced by build_script().

---

The documentation for this class was generated from the following file:

• BastionGuard/thirdparty/bastionguard-backup/src/Utility/RsyncSpaceCheckTask.vala