#include "common.h"
#include "main.h"
#include "error.h"
#include "fileutils.h"
#include "malloc.h"
#include "cluster.h"
#include "sync.h"
#include "glibex.h"
#include "control.h"
#include "indexes.h"
#include "privileged.h"
#include "rules.h"
#include <stdio.h>
#include <dlfcn.h>

Include dependency graph for sync.c:

Data Structures
struct	trylocked_arg

struct	sync_dump_arg

Macros
#define	SEQID_WINDOW (((unsigned int)~0)>>1)

#define	SEQID_EQ(a, b) ((a)==(b))

#define	SEQID_GE(a, b) ((a)-(b) < SEQID_WINDOW)

#define	SEQID_LE(a, b) ((b)-(a) < SEQID_WINDOW)

#define	SEQID_GT(a, b) ((!SEQID_EQ(a, b)) && (SEQID_GE(a, b)))

#define	SEQID_LT(a, b) ((!SEQID_EQ(a, b)) && (SEQID_LE(a, b)))

#define	SHOULD_THREAD(ctx_p) ((ctx_p->flags[THREADING] != PM_OFF) && (ctx_p->flags[THREADING] != PM_SAFE \|\| ctx_p->iteration_num))

#define	SYNC_EXEC_ARGV(...) sync_exec_argv(__VA_ARGS__)

#define	debug_argv_dump(level, argv)

#define	_sync_exec_getargv(argv, firstarg, COPYARG)

#define	SYNC_LOOP_IDLE

#define	SYNC_LOOP_CONTINUE_UNLOCK

Enumerations
enum	dump_dirfd_obj { DUMP_DIRFD_ROOT = 0, DUMP_DIRFD_QUEUE, DUMP_DIRFD_THREAD, DUMP_DIRFD_MAX }

enum	dump_ltype { DUMP_LTYPE_INCLUDE, DUMP_LTYPE_EXCLUDE, DUMP_LTYPE_EVINFO }

Functions
static unsigned int	sync_seqid ()

static void	setenv_iteration (uint32_t iteration_num)

static void	finish_iteration (ctx_t *ctx_p)

gpointer	eidup (gpointer ei_gp)

static void	evinfo_merge (ctx_t ctx_p, eventinfo_t evinfo_dst, eventinfo_t *evinfo_src)

static int	_exitcode_process (ctx_t *ctx_p, int exitcode)

int	exitcode_process (ctx_t *ctx_p, int exitcode)

threadsinfo_t *	thread_info ()

int	exec_argv (char *argv, int child_pid)

static void	so_call_sync_finished (int n, api_eventinfo_t *ei)

static int	so_call_sync (ctx_t ctx_p, indexes_t indexes_p, int n, api_eventinfo_t *ei)

static int	so_call_rsync_finished (ctx_t ctx_p, const char inclistfile, const char *exclistfile)

static int	so_call_rsync (ctx_t ctx_p, indexes_t indexes_p, const char inclistfile, const char exclistfile)

static void	argv_dump (int debug_level, char **argv)

char *	sync_path_rel2abs (ctx_t ctx_p, const char path_rel, ssize_t path_rel_len, size_t path_abs_len_p, char path_abs_oldptr)

char *	sync_path_abs2rel (ctx_t ctx_p, const char path_abs, ssize_t path_abs_len, size_t path_rel_len_p, char path_rel_oldptr)

pid_t	clsyncapi_fork (ctx_t *ctx_p)
	clsync's wrapper for function "fork()". Should be used instead of "fork()" directly, to notify clsync about child's pid. More...

int	sync_exec_argv (ctx_t ctx_p, indexes_t indexes_p, thread_callbackfunct_t callback, thread_callbackfunct_arg_t callback_arg_p, char *argv)

static int	sync_queuesync (const char fpath_rel, eventinfo_t evinfo, ctx_t ctx_p, indexes_t indexes_p, queue_id_t queue_id)

static void	evinfo_initialevmask (ctx_t ctx_p, eventinfo_t evinfo_p, int isdir)

static void	api_evinfo_initialevmask (ctx_t ctx_p, api_eventinfo_t evinfo_p, int isdir)

int	sync_dosync (const char fpath, uint32_t evmask, ctx_t ctx_p, indexes_t *indexes_p)

int	sync_initialsync_walk (ctx_t ctx_p, const char dirpath, indexes_t *indexes_p, queue_id_t queue_id, initsync_t initsync)

const char *	sync_parameter_get (const char variable_name, void _dosync_arg_p)

static char **	sync_customargv (ctx_t ctx_p, struct dosync_arg dosync_arg_p, synchandler_args_t *args_p)

static void	argv_free (char **argv)

static int	sync_initialsync_finish (ctx_t *ctx_p, initsync_t initsync, int ret)

int	sync_initialsync (const char path, ctx_t ctx_p, indexes_t *indexes_p, initsync_t initsync)

int	sync_notify_mark (ctx_t ctx_p, const char accpath, const char path, size_t pathlen, indexes_t indexes_p)

int	sync_mark_walk (ctx_t ctx_p, const char dirpath, indexes_t *indexes_p)

int	sync_notify_init (ctx_t *ctx_p)

static int	sync_dosync_exec (ctx_t ctx_p, indexes_t indexes_p, const char evmask_str, const char fpath)

int	fileischanged (ctx_t ctx_p, indexes_t indexes_p, const char path_rel, stat64_t lst_p, int is_deleted)

static int	sync_indexes_fpath2ei_addfixed (ctx_t ctx_p, indexes_t indexes_p, const char fpath, eventinfo_t evinfo)

int	sync_prequeue_loadmark (int monitored, ctx_t ctx_p, indexes_t indexes_p, const char path_full, const char path_rel, stat64_t lst_p, eventobjtype_t objtype_old, eventobjtype_t objtype_new, uint32_t event_mask, int event_wd, mode_t st_mode, off_t st_size, char path_buf_p, size_t path_buf_len_p, eventinfo_t *evinfo)

void	_sync_idle_dosync_collectedexcludes (gpointer fpath_gp, gpointer flags_gp, gpointer arg_gp)

eventinfo_t *	ht_fpath_isincluded (GHashTable ht, const char const fpath)

int	_sync_islocked (threadinfo_t threadinfo_p, void _fpath)

static int	sync_islocked (const char *const fpath)

void	_sync_idle_dosync_collectedevents (gpointer fpath_gp, gpointer evinfo_gp, gpointer arg_gp)

gboolean	sync_trylocked (gpointer fpath_gp, gpointer evinfo_gp, gpointer arg_gp)

int	sync_idle_dosync_collectedevents_cleanup (ctx_t ctx_p, thread_callbackfunct_arg_t arg_p)

void	sync_queuesync_wrapper (gpointer fpath_gp, gpointer evinfo_gp, gpointer arg_gp)

int	sync_prequeue_unload (ctx_t ctx_p, indexes_t indexes_p)

int	sync_idle_dosync_collectedevents_aggrqueue (queue_id_t queue_id, ctx_t ctx_p, indexes_t indexes_p, struct dosync_arg *dosync_arg)

int	sync_idle_dosync_collectedevents_uniqfname (ctx_t ctx_p, char fpath, char *name)

int	sync_idle_dosync_collectedevents_listcreate (struct dosync_arg dosync_arg_p, char name)

void	rsync_escape_cleanup ()

const char *	rsync_escape (const char *path)

static int	rsync_outline (FILE outf, char outline, eventinfo_flags_t flags)

gboolean	rsync_aggrout (gpointer outline_gp, gpointer flags_gp, gpointer arg_gp)

static int	rsync_listpush (indexes_t indexes_p, const char fpath, size_t fpath_len, eventinfo_flags_t flags, unsigned int *linescount_p)

gboolean	sync_idle_dosync_collectedevents_rsync_exclistpush (gpointer fpath_gp, gpointer flags_gp, gpointer arg_gp)

int	sync_idle_dosync_collectedevents_commitpart (struct dosync_arg *dosync_arg_p)

void	sync_inclist_rotate (ctx_t ctx_p, struct dosync_arg dosync_arg_p)

void	sync_idle_dosync_collectedevents_listpush (gpointer fpath_gp, gpointer evinfo_gp, gpointer arg_gp)

int	sync_idle_dosync_collectedevents (ctx_t ctx_p, indexes_t indexes_p)

int	apievinfo2rsynclist (indexes_t indexes_p, FILE listfile, int n, api_eventinfo_t *apievinfo)
	Writes the list to list-file for "--include-from" option of rsync using array of api_eventinfo_t. More...

int	sync_idle (ctx_t ctx_p, indexes_t indexes_p)

int	notify_wait (ctx_t ctx_p, indexes_t indexes_p)

void	hook_preexit (ctx_t *ctx_p)

int	sync_loop (ctx_t ctx_p, indexes_t indexes_p)

void	sync_sig_int (int signal)

int	sync_tryforcecycle (ctx_t *ctx_p, pthread_t pthread_parent)

int	sync_switch_state (ctx_t *ctx_p, pthread_t pthread_parent, int newstate)

void	sync_dump_liststep (gpointer fpath_gp, gpointer evinfo_gp, gpointer arg_gp)

int	sync_dump_thread (threadinfo_t threadinfo_p, void _arg)

int	sync_dump (ctx_t ctx_p, const char const dir_path)

void	sync_sigchld ()

int	sync_sighandler (sighandler_arg_t *sighandler_arg_p)

int	sync_term (int exitcode)

__extension__ int	sync_run (ctx_t *ctx_p)

Variables
pthread_t	pthread_sighandler

static unsigned int	_sync_seqid_value = 0

volatile state_t *	state_p = NULL

volatile int	exitcode = 0

size_t	rsync_escape_result_size = 0

char *	rsync_escape_result = NULL

int *	sync_sighandler_exitcode_p = NULL

Macro Definition Documentation

◆ _sync_exec_getargv

#define _sync_exec_getargv	(	argv,
		firstarg,
		COPYARG
	)

Value:

        {\
        va_list arglist;\
        va_start(arglist, firstarg);\
        \
        int i = 0;\
        do {\
            char *arg;\
            if(i >= MAXARGUMENTS) {\
                error("Too many arguments (%i >= %i).", i, MAXARGUMENTS);\
                return ENOMEM;\
            }\
            arg = (char *)va_arg(arglist, const char *const);\
            argv[i] = arg!=NULL ? COPYARG : NULL;\
        } while(argv[i++] != NULL);\
        va_end(arglist);\
    }

Definition at line 971 of file sync.c.

◆ debug_argv_dump

#define debug_argv_dump	(	level,
		argv
	)

Value:

if (unlikely(ctx_p->flags[DEBUG] >= level))\

argv_dump(level, argv)

Definition at line 952 of file sync.c.

◆ SEQID_EQ

#define SEQID_EQ	(	a,
		b
	)	((a)==(b))

Definition at line 65 of file sync.c.

◆ SEQID_GE

#define SEQID_GE	(	a,
		b
	)	((a)-(b) < SEQID_WINDOW)

Definition at line 66 of file sync.c.

◆ SEQID_GT

#define SEQID_GT	(	a,
		b
	)	((!SEQID_EQ(a, b)) && (SEQID_GE(a, b)))

Definition at line 68 of file sync.c.

◆ SEQID_LE

#define SEQID_LE	(	a,
		b
	)	((b)-(a) < SEQID_WINDOW)

Definition at line 67 of file sync.c.

◆ SEQID_LT

#define SEQID_LT	(	a,
		b
	)	((!SEQID_EQ(a, b)) && (SEQID_LE(a, b)))

Definition at line 69 of file sync.c.

◆ SEQID_WINDOW

#define SEQID_WINDOW (((unsigned int)~0)>>1)

Definition at line 64 of file sync.c.

◆ SHOULD_THREAD

#define SHOULD_THREAD ( ctx_p ) ((ctx_p->flags[THREADING] != PM_OFF) && (ctx_p->flags[THREADING] != PM_SAFE || ctx_p->iteration_num))

Definition at line 548 of file sync.c.

◆ SYNC_EXEC_ARGV

#define SYNC_EXEC_ARGV ( ... ) sync_exec_argv(__VA_ARGS__)

Definition at line 949 of file sync.c.

◆ SYNC_LOOP_CONTINUE_UNLOCK

#define SYNC_LOOP_CONTINUE_UNLOCK

Value:

        {\
        pthread_cond_broadcast(&threadsinfo_p->cond[PTHREAD_MUTEX_STATE]);\
        debug(4, "pthread_mutex_unlock()");\
        pthread_mutex_unlock(&threadsinfo_p->mutex[PTHREAD_MUTEX_STATE]);\
        continue;\
    }

Definition at line 3358 of file sync.c.

◆ SYNC_LOOP_IDLE

#define SYNC_LOOP_IDLE

Value:

        {\
        int ret;\
        if((ret=sync_idle(ctx_p, indexes_p))) {\
            error("got error while sync_idle().");\
            return ret;\
        }\
    }

Definition at line 3350 of file sync.c.

Enumeration Type Documentation

◆ dump_dirfd_obj

enum dump_dirfd_obj

Enumerator
DUMP_DIRFD_ROOT
DUMP_DIRFD_QUEUE
DUMP_DIRFD_THREAD
DUMP_DIRFD_MAX

Definition at line 3681 of file sync.c.

◆ dump_ltype

enum dump_ltype

Enumerator
DUMP_LTYPE_INCLUDE
DUMP_LTYPE_EXCLUDE
DUMP_LTYPE_EVINFO

Definition at line 3689 of file sync.c.

Function Documentation

◆ _exitcode_process()

static int _exitcode_process	(	ctx_t *	ctx_p,
		int	exitcode
	)

inlinestatic

Definition at line 164 of file sync.c.

Here is the caller graph for this function:

◆ _sync_idle_dosync_collectedevents()

void _sync_idle_dosync_collectedevents	(	gpointer	fpath_gp,
		gpointer	evinfo_gp,
		gpointer	arg_gp
	)

Definition at line 2427 of file sync.c.

◆ _sync_idle_dosync_collectedexcludes()

void _sync_idle_dosync_collectedexcludes	(	gpointer	fpath_gp,
		gpointer	flags_gp,
		gpointer	arg_gp
	)

Definition at line 2347 of file sync.c.

◆ _sync_islocked()

int _sync_islocked	(	threadinfo_t *	threadinfo_p,
		void *	_fpath
	)

Definition at line 2404 of file sync.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ api_evinfo_initialevmask()

static void api_evinfo_initialevmask	(	ctx_t *	ctx_p,
		api_eventinfo_t *	evinfo_p,
		int	isdir
	)

inlinestatic

Definition at line 1338 of file sync.c.

Here is the call graph for this function:

◆ apievinfo2rsynclist()

int apievinfo2rsynclist	(	struct indexes *	indexes_p,
		FILE *	listfile,
		int	n,
		api_eventinfo_t *	apievinfo
	)

Writes the list to list-file for "--include-from" option of rsync using array of api_eventinfo_t.

Parameters

[in]	indexes_p	Pointer to "indexes"
[in]	listfile	File identifier to write to
[in]	n	Number of records in apievinfo
[in]	apievinfo	Pointer to api_eventinfo_t records

Return values

zero	Successful
non-zero	If got error while deleting the message. The error-code is placed into returned value.

Definition at line 3171 of file sync.c.

◆ argv_dump()

static void argv_dump	(	int	debug_level,
		char **	argv
	)

inlinestatic

Definition at line 956 of file sync.c.

◆ argv_free()

static void argv_free ( char ** argv )

static

Definition at line 1639 of file sync.c.

◆ clsyncapi_fork()

pid_t clsyncapi_fork ( struct ctx * ctx_p )

clsync's wrapper for function "fork()". Should be used instead of "fork()" directly, to notify clsync about child's pid.

Parameters

[in] ctx_p Pointer to "ctx"

Return values

-1	If error (see "man 2 fork", added error code "ECANCELED" if too many children)
0	If child
pid	Pid of child of parent. (see "man 2 fork")

Definition at line 1060 of file sync.c.

◆ eidup()

gpointer eidup ( gpointer ei_gp )

Definition at line 100 of file sync.c.

◆ evinfo_initialevmask()

static void evinfo_initialevmask	(	ctx_t *	ctx_p,
		eventinfo_t *	evinfo_p,
		int	isdir
	)

inlinestatic

Definition at line 1291 of file sync.c.

Here is the caller graph for this function:

◆ evinfo_merge()

static void evinfo_merge	(	ctx_t *	ctx_p,
		eventinfo_t *	evinfo_dst,
		eventinfo_t *	evinfo_src
	)

inlinestatic

Definition at line 108 of file sync.c.

◆ exec_argv()

int exec_argv	(	char **	argv,
		int *	child_pid
	)

Definition at line 550 of file sync.c.

Here is the caller graph for this function:

◆ exitcode_process()

int exitcode_process	(	ctx_t *	ctx_p,
		int	exitcode
	)

Definition at line 177 of file sync.c.

Here is the call graph for this function:

◆ fileischanged()

int fileischanged	(	ctx_t *	ctx_p,
		indexes_t *	indexes_p,
		const char *	path_rel,
		stat64_t *	lst_p,
		int	is_deleted
	)

Definition at line 2083 of file sync.c.

◆ finish_iteration()

static void finish_iteration ( ctx_t * ctx_p )

inlinestatic

Definition at line 84 of file sync.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ hook_preexit()

void hook_preexit ( ctx_t * ctx_p )

Definition at line 3365 of file sync.c.

Here is the call graph for this function:

◆ ht_fpath_isincluded()

eventinfo_t* ht_fpath_isincluded	(	GHashTable *	ht,
		const char *const	fpath
	)

Definition at line 2357 of file sync.c.

Here is the caller graph for this function:

◆ notify_wait()

int notify_wait	(	ctx_t *	ctx_p,
		indexes_t *	indexes_p
	)

Definition at line 3246 of file sync.c.

◆ rsync_aggrout()

gboolean rsync_aggrout	(	gpointer	outline_gp,
		gpointer	flags_gp,
		gpointer	arg_gp
	)

Definition at line 2755 of file sync.c.

Here is the call graph for this function:

◆ rsync_escape()

const char* rsync_escape ( const char * path )

Definition at line 2681 of file sync.c.

Here is the caller graph for this function:

◆ rsync_escape_cleanup()

void rsync_escape_cleanup ( )

Definition at line 2675 of file sync.c.

Here is the caller graph for this function:

◆ rsync_listpush()

static int rsync_listpush	(	indexes_t *	indexes_p,
		const char *	fpath,
		size_t	fpath_len,
		eventinfo_flags_t	flags,
		unsigned int *	linescount_p
	)

inlinestatic

Definition at line 2772 of file sync.c.

◆ rsync_outline()

static int rsync_outline	(	FILE *	outf,
		char *	outline,
		eventinfo_flags_t	flags
	)

inlinestatic

Definition at line 2734 of file sync.c.

Here is the caller graph for this function:

◆ setenv_iteration()

static void setenv_iteration ( uint32_t iteration_num )

inlinestatic

Definition at line 76 of file sync.c.

Here is the caller graph for this function:

◆ so_call_rsync()

static int so_call_rsync	(	ctx_t *	ctx_p,
		indexes_t *	indexes_p,
		const char *	inclistfile,
		const char *	exclistfile
	)

inlinestatic

Definition at line 858 of file sync.c.

◆ so_call_rsync_finished()

static int so_call_rsync_finished	(	ctx_t *	ctx_p,
		const char *	inclistfile,
		const char *	exclistfile
	)

inlinestatic

Definition at line 781 of file sync.c.

◆ so_call_sync()

static int so_call_sync	(	ctx_t *	ctx_p,
		indexes_t *	indexes_p,
		int	n,
		api_eventinfo_t *	ei
	)

inlinestatic

Definition at line 701 of file sync.c.

◆ so_call_sync_finished()

static void so_call_sync_finished	(	int	n,
		api_eventinfo_t *	ei
	)

inlinestatic

Definition at line 633 of file sync.c.

◆ sync_customargv()

static char** sync_customargv	(	ctx_t *	ctx_p,
		struct dosync_arg *	dosync_arg_p,
		synchandler_args_t *	args_p
	)

static

Definition at line 1569 of file sync.c.

◆ sync_dosync()

int sync_dosync	(	const char *	fpath,
		uint32_t	evmask,
		ctx_t *	ctx_p,
		indexes_t *	indexes_p
	)

Definition at line 2064 of file sync.c.

◆ sync_dosync_exec()

static int sync_dosync_exec	(	ctx_t *	ctx_p,
		indexes_t *	indexes_p,
		const char *	evmask_str,
		const char *	fpath
	)

inlinestatic

Definition at line 2035 of file sync.c.

◆ sync_dump()

int sync_dump	(	ctx_t *	ctx_p,
		const char *const	dir_path
	)

Definition at line 3773 of file sync.c.

Here is the caller graph for this function:

◆ sync_dump_liststep()

void sync_dump_liststep	(	gpointer	fpath_gp,
		gpointer	evinfo_gp,
		gpointer	arg_gp
	)

Definition at line 3702 of file sync.c.

Here is the caller graph for this function:

◆ sync_dump_thread()

int sync_dump_thread	(	threadinfo_t *	threadinfo_p,
		void *	_arg
	)

Definition at line 3738 of file sync.c.

Here is the call graph for this function:

◆ sync_exec_argv()

int sync_exec_argv	(	ctx_t *	ctx_p,
		indexes_t *	indexes_p,
		thread_callbackfunct_t	callback,
		thread_callbackfunct_arg_t *	callback_arg_p,
		char **	argv
	)

Definition at line 1087 of file sync.c.

◆ sync_idle()

int sync_idle	(	ctx_t *	ctx_p,
		indexes_t *	indexes_p
	)

Definition at line 3196 of file sync.c.

◆ sync_idle_dosync_collectedevents()

int sync_idle_dosync_collectedevents	(	ctx_t *	ctx_p,
		indexes_t *	indexes_p
	)

Definition at line 3055 of file sync.c.

◆ sync_idle_dosync_collectedevents_aggrqueue()

int sync_idle_dosync_collectedevents_aggrqueue	(	queue_id_t	queue_id,
		ctx_t *	ctx_p,
		indexes_t *	indexes_p,
		struct dosync_arg *	dosync_arg
	)

Definition at line 2575 of file sync.c.

◆ sync_idle_dosync_collectedevents_cleanup()

int sync_idle_dosync_collectedevents_cleanup	(	ctx_t *	ctx_p,
		thread_callbackfunct_arg_t *	arg_p
	)

Definition at line 2529 of file sync.c.

◆ sync_idle_dosync_collectedevents_commitpart()

int sync_idle_dosync_collectedevents_commitpart ( struct dosync_arg * dosync_arg_p )

Definition at line 2852 of file sync.c.

Here is the caller graph for this function:

◆ sync_idle_dosync_collectedevents_listcreate()

int sync_idle_dosync_collectedevents_listcreate	(	struct dosync_arg *	dosync_arg_p,
		char *	name
	)

Definition at line 2647 of file sync.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ sync_idle_dosync_collectedevents_listpush()

void sync_idle_dosync_collectedevents_listpush	(	gpointer	fpath_gp,
		gpointer	evinfo_gp,
		gpointer	arg_gp
	)

Definition at line 2973 of file sync.c.

◆ sync_idle_dosync_collectedevents_rsync_exclistpush()

gboolean sync_idle_dosync_collectedevents_rsync_exclistpush	(	gpointer	fpath_gp,
		gpointer	flags_gp,
		gpointer	arg_gp
	)

Definition at line 2819 of file sync.c.

Here is the call graph for this function:

◆ sync_idle_dosync_collectedevents_uniqfname()

int sync_idle_dosync_collectedevents_uniqfname	(	ctx_t *	ctx_p,
		char *	fpath,
		char *	name
	)

Definition at line 2626 of file sync.c.

Here is the caller graph for this function:

◆ sync_inclist_rotate()

void sync_inclist_rotate	(	ctx_t *	ctx_p,
		struct dosync_arg *	dosync_arg_p
	)

Definition at line 2930 of file sync.c.

Here is the call graph for this function:

◆ sync_indexes_fpath2ei_addfixed()

static int sync_indexes_fpath2ei_addfixed	(	ctx_t *	ctx_p,
		indexes_t *	indexes_p,
		const char *	fpath,
		eventinfo_t *	evinfo
	)

inlinestatic

Definition at line 2120 of file sync.c.

◆ sync_initialsync()

int sync_initialsync	(	const char *	path,
		ctx_t *	ctx_p,
		indexes_t *	indexes_p,
		initsync_t	initsync
	)

Definition at line 1671 of file sync.c.

◆ sync_initialsync_finish()

static int sync_initialsync_finish	(	ctx_t *	ctx_p,
		initsync_t	initsync,
		int	ret
	)

inlinestatic

Definition at line 1664 of file sync.c.

Here is the call graph for this function:

◆ sync_initialsync_walk()

int sync_initialsync_walk	(	ctx_t *	ctx_p,
		const char *	dirpath,
		indexes_t *	indexes_p,
		queue_id_t	queue_id,
		initsync_t	initsync
	)

Definition at line 1347 of file sync.c.

◆ sync_islocked()

static int sync_islocked ( const char *const fpath )

inlinestatic

Definition at line 2416 of file sync.c.

Here is the call graph for this function:

◆ sync_loop()

int sync_loop	(	ctx_t *	ctx_p,
		indexes_t *	indexes_p
	)

Definition at line 3379 of file sync.c.

Here is the caller graph for this function:

◆ sync_mark_walk()

int sync_mark_walk	(	ctx_t *	ctx_p,
		const char *	dirpath,
		indexes_t *	indexes_p
	)

Definition at line 1828 of file sync.c.

Here is the caller graph for this function:

◆ sync_notify_init()

int sync_notify_init ( ctx_t * ctx_p )

Definition at line 1953 of file sync.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ sync_notify_mark()

int sync_notify_mark	(	ctx_t *	ctx_p,
		const char *	accpath,
		const char *	path,
		size_t	pathlen,
		indexes_t *	indexes_p
	)

Definition at line 1787 of file sync.c.

◆ sync_parameter_get()

const char* sync_parameter_get	(	const char *	variable_name,
		void *	_dosync_arg_p
	)

Definition at line 1548 of file sync.c.

Here is the caller graph for this function:

◆ sync_path_abs2rel()

char* sync_path_abs2rel	(	ctx_t *	ctx_p,
		const char *	path_abs,
		ssize_t	path_abs_len,
		size_t *	path_rel_len_p,
		char *	path_rel_oldptr
	)

Definition at line 1018 of file sync.c.

◆ sync_path_rel2abs()

char* sync_path_rel2abs	(	ctx_t *	ctx_p,
		const char *	path_rel,
		ssize_t	path_rel_len,
		size_t *	path_abs_len_p,
		char *	path_abs_oldptr
	)

Definition at line 988 of file sync.c.

◆ sync_prequeue_loadmark()

int sync_prequeue_loadmark	(	int	monitored,
		ctx_t *	ctx_p,
		indexes_t *	indexes_p,
		const char *	path_full,
		const char *	path_rel,
		stat64_t *	lst_p,
		eventobjtype_t	objtype_old,
		eventobjtype_t	objtype_new,
		uint32_t	event_mask,
		int	event_wd,
		mode_t	st_mode,
		off_t	st_size,
		char **	path_buf_p,
		size_t *	path_buf_len_p,
		eventinfo_t *	evinfo
	)

Definition at line 2143 of file sync.c.

◆ sync_prequeue_unload()

int sync_prequeue_unload	(	ctx_t *	ctx_p,
		indexes_t *	indexes_p
	)

Definition at line 2564 of file sync.c.

◆ sync_queuesync()

static int sync_queuesync	(	const char *	fpath_rel,
		eventinfo_t *	evinfo,
		ctx_t *	ctx_p,
		indexes_t *	indexes_p,
		queue_id_t	queue_id
	)

static

Definition at line 1251 of file sync.c.

◆ sync_queuesync_wrapper()

void sync_queuesync_wrapper	(	gpointer	fpath_gp,
		gpointer	evinfo_gp,
		gpointer	arg_gp
	)

Definition at line 2554 of file sync.c.

◆ sync_run()

__extension__ int sync_run ( ctx_t * ctx_p )

Definition at line 3998 of file sync.c.

Here is the call graph for this function:

◆ sync_seqid()

static unsigned int sync_seqid ( )

inlinestatic

Definition at line 71 of file sync.c.

◆ sync_sig_int()

void sync_sig_int ( int signal )

Definition at line 3548 of file sync.c.

Here is the caller graph for this function:

◆ sync_sigchld()

void sync_sigchld ( )

Definition at line 3866 of file sync.c.

Here is the caller graph for this function:

◆ sync_sighandler()

int sync_sighandler ( sighandler_arg_t * sighandler_arg_p )

Definition at line 3874 of file sync.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ sync_switch_state()

int sync_switch_state	(	ctx_t *	ctx_p,
		pthread_t	pthread_parent,
		int	newstate
	)

Definition at line 3597 of file sync.c.

Here is the call graph for this function:

Here is the caller graph for this function:

◆ sync_term()

int sync_term ( int exitcode )

Definition at line 3991 of file sync.c.

Here is the caller graph for this function:

◆ sync_tryforcecycle()

int sync_tryforcecycle	(	ctx_t *	ctx_p,
		pthread_t	pthread_parent
	)

Definition at line 3557 of file sync.c.

Here is the caller graph for this function:

◆ sync_trylocked()

gboolean sync_trylocked	(	gpointer	fpath_gp,
		gpointer	evinfo_gp,
		gpointer	arg_gp
	)

Definition at line 2504 of file sync.c.

◆ thread_info()

threadsinfo_t* thread_info ( )

Definition at line 190 of file sync.c.

Here is the caller graph for this function:

Variable Documentation

◆ _sync_seqid_value

unsigned int _sync_seqid_value = 0

static

Definition at line 70 of file sync.c.

◆ exitcode

volatile int exitcode = 0

Definition at line 547 of file sync.c.

◆ pthread_sighandler

pthread_t pthread_sighandler

Definition at line 59 of file sync.c.

◆ rsync_escape_result

char* rsync_escape_result = NULL

Definition at line 2673 of file sync.c.

◆ rsync_escape_result_size

size_t rsync_escape_result_size = 0

Definition at line 2672 of file sync.c.

◆ state_p

volatile state_t* state_p = NULL

Definition at line 546 of file sync.c.

◆ sync_sighandler_exitcode_p

int* sync_sighandler_exitcode_p = NULL

Definition at line 3873 of file sync.c.

Data Structures

Macros

Enumerations

Functions

Variables

Macro Definition Documentation

◆ _sync_exec_getargv

◆ debug_argv_dump

◆ SEQID_EQ

◆ SEQID_GE

◆ SEQID_GT

◆ SEQID_LE

◆ SEQID_LT

◆ SEQID_WINDOW

◆ SHOULD_THREAD

◆ SYNC_EXEC_ARGV

◆ SYNC_LOOP_CONTINUE_UNLOCK

◆ SYNC_LOOP_IDLE

Enumeration Type Documentation

◆ dump_dirfd_obj

◆ dump_ltype

Function Documentation

◆ _exitcode_process()

◆ _sync_idle_dosync_collectedevents()

◆ _sync_idle_dosync_collectedexcludes()

◆ _sync_islocked()

◆ api_evinfo_initialevmask()

◆ apievinfo2rsynclist()

◆ argv_dump()

◆ argv_free()

◆ clsyncapi_fork()

◆ eidup()

◆ evinfo_initialevmask()

◆ evinfo_merge()

◆ exec_argv()

◆ exitcode_process()

◆ fileischanged()

◆ finish_iteration()

◆ hook_preexit()

◆ ht_fpath_isincluded()

◆ notify_wait()

◆ rsync_aggrout()

◆ rsync_escape()

◆ rsync_escape_cleanup()

◆ rsync_listpush()

◆ rsync_outline()

◆ setenv_iteration()

◆ so_call_rsync()

◆ so_call_rsync_finished()

◆ so_call_sync()

◆ so_call_sync_finished()

◆ sync_customargv()

◆ sync_dosync()

◆ sync_dosync_exec()

◆ sync_dump()

◆ sync_dump_liststep()

◆ sync_dump_thread()

◆ sync_exec_argv()

◆ sync_idle()

◆ sync_idle_dosync_collectedevents()

◆ sync_idle_dosync_collectedevents_aggrqueue()

◆ sync_idle_dosync_collectedevents_cleanup()

◆ sync_idle_dosync_collectedevents_commitpart()

◆ sync_idle_dosync_collectedevents_listcreate()

◆ sync_idle_dosync_collectedevents_listpush()

◆ sync_idle_dosync_collectedevents_rsync_exclistpush()

◆ sync_idle_dosync_collectedevents_uniqfname()

◆ sync_inclist_rotate()

◆ sync_indexes_fpath2ei_addfixed()

◆ sync_initialsync()

◆ sync_initialsync_finish()

◆ sync_initialsync_walk()

◆ sync_islocked()

◆ sync_loop()

◆ sync_mark_walk()

◆ sync_notify_init()

◆ sync_notify_mark()

◆ sync_parameter_get()

◆ sync_path_abs2rel()

◆ sync_path_rel2abs()