[rsync/rsync.git] / receiver.c

/* 
   Copyright (C) Andrew Tridgell 1996
   Copyright (C) Paul Mackerras 1996
   
   This program is free software; you can redistribute it and/or modify
   it under the terms of the GNU General Public License as published by
   the Free Software Foundation; either version 2 of the License, or
   (at your option) any later version.
   
   This program is distributed in the hope that it will be useful,
   but WITHOUT ANY WARRANTY; without even the implied warranty of
   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
   GNU General Public License for more details.
   
   You should have received a copy of the GNU General Public License
   along with this program; if not, write to the Free Software
   Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
*/

#include "rsync.h"

extern int verbose;
extern int recurse;
extern int delete_mode;
extern int remote_version;
extern int csum_length;
extern struct stats stats;
extern int dry_run;
extern int am_server;
extern int relative_paths;
extern int preserve_hard_links;
extern int cvs_exclude;
extern int io_error;
extern char *tmpdir;
extern char *compare_dest;


static struct delete_list {
	dev_t dev;
	INO_T inode;
} *delete_list;
static int dlist_len, dlist_alloc_len;


/* yuck! This function wouldn't have been necessary if I had the sorting
   algorithm right. Unfortunately fixing the sorting algorithm would introduce
   a backward incompatibility as file list indexes are sent over the link.
*/
static int delete_already_done(struct file_list *flist,int j)
{
	int i;
	STRUCT_STAT st;

	if (link_stat(f_name(flist->files[j]), &st)) return 1;

	for (i=0;i<dlist_len;i++) {
		if (st.st_ino == delete_list[i].inode &&
		    st.st_dev == delete_list[i].dev)
			return 1;
	}

	return 0;
}

static void add_delete_entry(struct file_struct *file)
{
	if (dlist_len == dlist_alloc_len) {
		dlist_alloc_len += 1024;
		delete_list = (struct delete_list *)Realloc(delete_list, sizeof(delete_list[0])*dlist_alloc_len);
		if (!delete_list) out_of_memory("add_delete_entry");
	}

	delete_list[dlist_len].dev = file->dev;
	delete_list[dlist_len].inode = file->inode;
	dlist_len++;

	if (verbose > 3)
		rprintf(FINFO,"added %s to delete list\n", f_name(file));
}

static void delete_one(struct file_struct *f)
{
	if (!S_ISDIR(f->mode)) {
		if (do_unlink(f_name(f)) != 0) {
			rprintf(FERROR,"unlink %s : %s\n",f_name(f),strerror(errno));
		} else if (verbose) {
			rprintf(FINFO,"deleting %s\n",f_name(f));
		}
	} else {    
		if (do_rmdir(f_name(f)) != 0) {
			if (errno != ENOTEMPTY && errno != EEXIST)
				rprintf(FERROR,"rmdir %s : %s\n",f_name(f),strerror(errno));
		} else if (verbose) {
			rprintf(FINFO,"deleting directory %s\n",f_name(f));      
		}
	}
}


/* this deletes any files on the receiving side that are not present
   on the sending side. For version 1.6.4 I have changed the behaviour
   to match more closely what most people seem to expect of this option */
static void delete_files(struct file_list *flist)
{
	struct file_list *local_file_list;
	int i, j;
	char *name;

	if (cvs_exclude)
		add_cvs_excludes();

	if (io_error) {
		rprintf(FINFO,"IO error encountered - skipping file deletion\n");
		return;
	}

	for (j=0;j<flist->count;j++) {
		if (!S_ISDIR(flist->files[j]->mode) || 
		    !(flist->files[j]->flags & FLAG_DELETE)) continue;

		if (remote_version < 19 &&
		    delete_already_done(flist, j)) continue;

		name = strdup(f_name(flist->files[j]));

		if (!(local_file_list = send_file_list(-1,1,&name))) {
			free(name);
			continue;
		}

		if (verbose > 1)
			rprintf(FINFO,"deleting in %s\n", name);

		for (i=local_file_list->count-1;i>=0;i--) {
			if (!local_file_list->files[i]->basename) continue;
			if (remote_version < 19 &&
			    S_ISDIR(local_file_list->files[i]->mode))
				add_delete_entry(local_file_list->files[i]);
			if (-1 == flist_find(flist,local_file_list->files[i])) {
				delete_one(local_file_list->files[i]);
			}    
		}
		flist_free(local_file_list);
		free(name);
	}
}


static int get_tmpname(char *fnametmp, char *fname)
{
	char *f;

	/* open tmp file */
	if (tmpdir) {
		f = strrchr(fname,'/');
		if (f == NULL) 
			f = fname;
		else 
			f++;
		if (strlen(tmpdir)+strlen(f)+10 > MAXPATHLEN) {
			rprintf(FERROR,"filename too long\n");
			return 0;
		}
		slprintf(fnametmp,MAXPATHLEN, "%s/.%s.XXXXXX",tmpdir,f);
		return 1;
	} 

	f = strrchr(fname,'/');

	if (strlen(fname)+9 > MAXPATHLEN) {
		rprintf(FERROR,"filename too long\n");
		return 0;
	}

	if (f) {
		*f = 0;
		slprintf(fnametmp,MAXPATHLEN,"%s/.%s.XXXXXX",
			 fname,f+1);
		*f = '/';
	} else {
		slprintf(fnametmp,MAXPATHLEN,".%s.XXXXXX",fname);
	}

	return 1;
}


static int receive_data(int f_in,struct map_struct *buf,int fd,char *fname,
			OFF_T total_size)
{
	int i,n,remainder,len,count;
	OFF_T offset = 0;
	OFF_T offset2;
	char *data;
	static char file_sum1[MD4_SUM_LENGTH];
	static char file_sum2[MD4_SUM_LENGTH];
	char *map=NULL;
	
	count = read_int(f_in);
	n = read_int(f_in);
	remainder = read_int(f_in);
	
	sum_init();
	
	for (i=recv_token(f_in,&data); i != 0; i=recv_token(f_in,&data)) {

		show_progress(offset, total_size);

		if (i > 0) {
			extern int cleanup_got_literal;

			if (verbose > 3) {
				rprintf(FINFO,"data recv %d at %d\n",
					i,(int)offset);
			}

			stats.literal_data += i;
			cleanup_got_literal = 1;
      
			sum_update(data,i);

			if (fd != -1 && write_file(fd,data,i) != i) {
				rprintf(FERROR,"write failed on %s : %s\n",fname,strerror(errno));
				exit_cleanup(RERR_FILEIO);
			}
			offset += i;
			continue;
		} 

		i = -(i+1);
		offset2 = i*n;
		len = n;
		if (i == count-1 && remainder != 0)
			len = remainder;
		
		stats.matched_data += len;
		
		if (verbose > 3)
			rprintf(FINFO,"chunk[%d] of size %d at %d offset=%d\n",
				i,len,(int)offset2,(int)offset);
		
		map = map_ptr(buf,offset2,len);
		
		see_token(map, len);
		sum_update(map,len);
		
		if (fd != -1 && write_file(fd,map,len) != len) {
			rprintf(FERROR,"write failed on %s : %s\n",
				fname,strerror(errno));
			exit_cleanup(RERR_FILEIO);
		}
		offset += len;
	}

	end_progress();

	if (fd != -1 && offset > 0 && sparse_end(fd) != 0) {
		rprintf(FERROR,"write failed on %s : %s\n",
			fname,strerror(errno));
		exit_cleanup(RERR_FILEIO);
	}

	sum_end(file_sum1);

	if (remote_version >= 14) {
		read_buf(f_in,file_sum2,MD4_SUM_LENGTH);
		if (verbose > 2) {
			rprintf(FINFO,"got file_sum\n");
		}
		if (fd != -1 && 
		    memcmp(file_sum1,file_sum2,MD4_SUM_LENGTH) != 0) {
			return 0;
		}
	}
	return 1;
}


int recv_files(int f_in,struct file_list *flist,char *local_name,int f_gen)
{  
	int fd1,fd2;
	STRUCT_STAT st;
	char *fname;
	char fnametmp[MAXPATHLEN];
	char *fnamecmp;
	char fnamecmpbuf[MAXPATHLEN];
	struct map_struct *buf;
	int i;
	struct file_struct *file;
	int phase=0;
	int recv_ok;
	extern struct stats stats;		
	struct stats initial_stats;

	if (verbose > 2) {
		rprintf(FINFO,"recv_files(%d) starting\n",flist->count);
	}

	if (recurse && delete_mode && !local_name && flist->count>0) {
		delete_files(flist);
	}

	while (1) {      
		cleanup_disable();

		i = read_int(f_in);
		if (i == -1) {
			if (phase==0 && remote_version >= 13) {
				phase++;
				csum_length = SUM_LENGTH;
				if (verbose > 2)
					rprintf(FINFO,"recv_files phase=%d\n",phase);
				write_int(f_gen,-1);
				continue;
			}
			break;
		}

		if (i < 0 || i >= flist->count) {
			rprintf(FERROR,"Invalid file index %d in recv_files (count=%d)\n", 
				i, flist->count);
			exit_cleanup(RERR_PROTOCOL);
		}

		file = flist->files[i];
		fname = f_name(file);

		stats.num_transferred_files++;
		stats.total_transferred_size += file->length;

		if (local_name)
			fname = local_name;

		if (dry_run) {
			if (!am_server) {
				log_transfer(file, fname);
			}
			continue;
		}

		initial_stats = stats;

		if (verbose > 2)
			rprintf(FINFO,"recv_files(%s)\n",fname);

		fnamecmp = fname;

		/* open the file */  
		fd1 = open(fnamecmp,O_RDONLY);

		if ((fd1 == -1) && (compare_dest != NULL)) {
			/* try the file at compare_dest instead */
			slprintf(fnamecmpbuf,MAXPATHLEN,"%s/%s",
						compare_dest,fname);
			fnamecmp = fnamecmpbuf;
			fd1 = open(fnamecmp,O_RDONLY);
		}

		if (fd1 != -1 && do_fstat(fd1,&st) != 0) {
			rprintf(FERROR,"fstat %s : %s\n",fnamecmp,strerror(errno));
			receive_data(f_in,NULL,-1,NULL,file->length);
			close(fd1);
			continue;
		}

		if (fd1 != -1 && !S_ISREG(st.st_mode)) {
			rprintf(FERROR,"%s : not a regular file (recv_files)\n",fnamecmp);
			receive_data(f_in,NULL,-1,NULL,file->length);
			close(fd1);
			continue;
		}

		if (fd1 != -1 && st.st_size > 0) {
			buf = map_file(fd1,st.st_size);
			if (verbose > 2)
				rprintf(FINFO,"recv mapped %s of size %d\n",fnamecmp,(int)st.st_size);
		} else {
			buf = NULL;
		}

		if (!get_tmpname(fnametmp,fname)) {
			if (buf) unmap_file(buf);
			if (fd1 != -1) close(fd1);
			continue;
		}

		/* mktemp is deliberately used here instead of mkstemp.
		   because O_EXCL is used on the open, the race condition
		   is not a problem or a security hole, and we want to
		   control the access permissions on the created file. */
		if (NULL == do_mktemp(fnametmp)) {
			rprintf(FERROR,"mktemp %s failed\n",fnametmp);
			receive_data(f_in,buf,-1,NULL,file->length);
			if (buf) unmap_file(buf);
			if (fd1 != -1) close(fd1);
			continue;
		}

		/* we initially set the perms without the
		   setuid/setgid bits to ensure that there is no race
		   condition. They are then correctly updated after
		   the lchown. Thanks to snabb@epipe.fi for pointing
		   this out */
		fd2 = do_open(fnametmp,O_WRONLY|O_CREAT|O_EXCL,
			      file->mode & ACCESSPERMS);

		if (fd2 == -1 && relative_paths && errno == ENOENT && 
		    create_directory_path(fnametmp) == 0) {
			fd2 = do_open(fnametmp,O_WRONLY|O_CREAT|O_EXCL,
				      file->mode & ACCESSPERMS);
		}
		if (fd2 == -1) {
			rprintf(FERROR,"open %s : %s\n",fnametmp,strerror(errno));
			receive_data(f_in,buf,-1,NULL,file->length);
			if (buf) unmap_file(buf);
			if (fd1 != -1) close(fd1);
			continue;
		}
      
		cleanup_set(fnametmp, fname, file, buf, fd1, fd2);

		if (!am_server) {
			log_transfer(file, fname);
		}

		/* recv file data */
		recv_ok = receive_data(f_in,buf,fd2,fname,file->length);

		log_recv(file, &initial_stats);
		
		if (buf) unmap_file(buf);
		if (fd1 != -1) {
			close(fd1);
		}
		close(fd2);
		
		if (verbose > 2)
			rprintf(FINFO,"renaming %s to %s\n",fnametmp,fname);

		finish_transfer(fname, fnametmp, file);

		cleanup_disable();
				
		if (!recv_ok) {
			if (csum_length == SUM_LENGTH) {
				rprintf(FERROR,"ERROR: file corruption in %s. File changed during transfer?\n",
					fname);
			} else {
				if (verbose > 1)
					rprintf(FINFO,"redoing %s(%d)\n",fname,i);
				write_int(f_gen,i);
			}
		}
	}

	if (preserve_hard_links)
		do_hard_links(flist);

	/* now we need to fix any directory permissions that were 
	   modified during the transfer */
	for (i = 0; i < flist->count; i++) {
		file = flist->files[i];
		if (!file->basename || !S_ISDIR(file->mode)) continue;
		recv_generator(f_name(file),flist,i,-1);
	}

	if (verbose > 2)
		rprintf(FINFO,"recv_files finished\n");
	
	return 0;
}
Commit	Line	Data
2f03f956 AT	1	/*
	2	Copyright (C) Andrew Tridgell 1996
	3	Copyright (C) Paul Mackerras 1996
	4
	5	This program is free software; you can redistribute it and/or modify
	6	it under the terms of the GNU General Public License as published by
	7	the Free Software Foundation; either version 2 of the License, or
	8	(at your option) any later version.
	9
	10	This program is distributed in the hope that it will be useful,
	11	but WITHOUT ANY WARRANTY; without even the implied warranty of
	12	MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	13	GNU General Public License for more details.
	14
	15	You should have received a copy of the GNU General Public License
	16	along with this program; if not, write to the Free Software
	17	Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
	18	*/
	19
	20	#include "rsync.h"
	21
	22	extern int verbose;
	23	extern int recurse;
	24	extern int delete_mode;
	25	extern int remote_version;
	26	extern int csum_length;
	27	extern struct stats stats;
	28	extern int dry_run;
	29	extern int am_server;
	30	extern int relative_paths;
	31	extern int preserve_hard_links;
	32	extern int cvs_exclude;
	33	extern int io_error;
	34	extern char *tmpdir;
375a4556	35	extern char *compare_dest;
2f03f956 AT	36
	37
	38	static struct delete_list {
	39	dev_t dev;
	40	INO_T inode;
	41	} *delete_list;
	42	static int dlist_len, dlist_alloc_len;
	43
	44
	45	/* yuck! This function wouldn't have been necessary if I had the sorting
	46	algorithm right. Unfortunately fixing the sorting algorithm would introduce
	47	a backward incompatibility as file list indexes are sent over the link.
	48	*/
	49	static int delete_already_done(struct file_list *flist,int j)
	50	{
	51	int i;
	52	STRUCT_STAT st;
	53
	54	if (link_stat(f_name(flist->files[j]), &st)) return 1;
	55
	56	for (i=0;i<dlist_len;i++) {
	57	if (st.st_ino == delete_list[i].inode &&
	58	st.st_dev == delete_list[i].dev)
	59	return 1;
	60	}
	61
	62	return 0;
	63	}
	64
	65	static void add_delete_entry(struct file_struct *file)
	66	{
	67	if (dlist_len == dlist_alloc_len) {
	68	dlist_alloc_len += 1024;
	69	delete_list = (struct delete_list )Realloc(delete_list, sizeof(delete_list[0])dlist_alloc_len);
	70	if (!delete_list) out_of_memory("add_delete_entry");
	71	}
	72
	73	delete_list[dlist_len].dev = file->dev;
	74	delete_list[dlist_len].inode = file->inode;
	75	dlist_len++;
	76
	77	if (verbose > 3)
	78	rprintf(FINFO,"added %s to delete list\n", f_name(file));
	79	}
	80
	81	static void delete_one(struct file_struct *f)
	82	{
	83	if (!S_ISDIR(f->mode)) {
	84	if (do_unlink(f_name(f)) != 0) {
	85	rprintf(FERROR,"unlink %s : %s\n",f_name(f),strerror(errno));
	86	} else if (verbose) {
	87	rprintf(FINFO,"deleting %s\n",f_name(f));
	88	}
	89	} else {
	90	if (do_rmdir(f_name(f)) != 0) {
	91	if (errno != ENOTEMPTY && errno != EEXIST)
	92	rprintf(FERROR,"rmdir %s : %s\n",f_name(f),strerror(errno));
	93	} else if (verbose) {
	94	rprintf(FINFO,"deleting directory %s\n",f_name(f));
	95	}
	96	}
	97	}
	98
	99
100
101
102	/* this deletes any files on the receiving side that are not present
103	on the sending side. For version 1.6.4 I have changed the behaviour
104	to match more closely what most people seem to expect of this option */
105	static void delete_files(struct file_list *flist)
106	{
107	struct file_list *local_file_list;
108	int i, j;
109	char *name;
110
111	if (cvs_exclude)
112	add_cvs_excludes();
113
114	if (io_error) {
115	rprintf(FINFO,"IO error encountered - skipping file deletion\n");
116	return;
117	}
118
119	for (j=0;j<flist->count;j++) {
120	if (!S_ISDIR(flist->files[j]->mode) \|\|
121	!(flist->files[j]->flags & FLAG_DELETE)) continue;
122
123	if (remote_version < 19 &&
124	delete_already_done(flist, j)) continue;
125
126	name = strdup(f_name(flist->files[j]));
127
128	if (!(local_file_list = send_file_list(-1,1,&name))) {
129	free(name);
130	continue;
131	}
132
133	if (verbose > 1)
134	rprintf(FINFO,"deleting in %s\n", name);
135
136	for (i=local_file_list->count-1;i>=0;i--) {
137	if (!local_file_list->files[i]->basename) continue;
138	if (remote_version < 19 &&
139	S_ISDIR(local_file_list->files[i]->mode))
140	add_delete_entry(local_file_list->files[i]);
141	if (-1 == flist_find(flist,local_file_list->files[i])) {
142	delete_one(local_file_list->files[i]);
143	}
144	}
145	flist_free(local_file_list);
146	free(name);
147	}
148	}
149
150
151	static int get_tmpname(char fnametmp, char fname)
152	{
153	char *f;
154
155	/* open tmp file */
156	if (tmpdir) {
157	f = strrchr(fname,'/');
158	if (f == NULL)
159	f = fname;
160	else
161	f++;
162	if (strlen(tmpdir)+strlen(f)+10 > MAXPATHLEN) {
163	rprintf(FERROR,"filename too long\n");
164	return 0;
165	}
37f9805d	166	slprintf(fnametmp,MAXPATHLEN, "%s/.%s.XXXXXX",tmpdir,f);
2f03f956 AT	167	return 1;
	168	}
	169
	170	f = strrchr(fname,'/');
	171
	172	if (strlen(fname)+9 > MAXPATHLEN) {
	173	rprintf(FERROR,"filename too long\n");
	174	return 0;
	175	}
	176
	177	if (f) {
	178	*f = 0;
37f9805d	179	slprintf(fnametmp,MAXPATHLEN,"%s/.%s.XXXXXX",
2f03f956 AT	180	fname,f+1);
	181	*f = '/';
	182	} else {
37f9805d	183	slprintf(fnametmp,MAXPATHLEN,".%s.XXXXXX",fname);
2f03f956 AT	184	}
	185
	186	return 1;
	187	}
	188
	189
	190	static int receive_data(int f_in,struct map_struct buf,int fd,char fname,
	191	OFF_T total_size)
	192	{
	193	int i,n,remainder,len,count;
	194	OFF_T offset = 0;
	195	OFF_T offset2;
	196	char *data;
	197	static char file_sum1[MD4_SUM_LENGTH];
	198	static char file_sum2[MD4_SUM_LENGTH];
	199	char *map=NULL;
	200
	201	count = read_int(f_in);
	202	n = read_int(f_in);
	203	remainder = read_int(f_in);
	204
	205	sum_init();
	206
	207	for (i=recv_token(f_in,&data); i != 0; i=recv_token(f_in,&data)) {
	208
	209	show_progress(offset, total_size);
	210
	211	if (i > 0) {
	212	extern int cleanup_got_literal;
	213
	214	if (verbose > 3) {
	215	rprintf(FINFO,"data recv %d at %d\n",
	216	i,(int)offset);
	217	}
	218
	219	stats.literal_data += i;
	220	cleanup_got_literal = 1;
	221
	222	sum_update(data,i);
	223
	224	if (fd != -1 && write_file(fd,data,i) != i) {
	225	rprintf(FERROR,"write failed on %s : %s\n",fname,strerror(errno));
65417579	226	exit_cleanup(RERR_FILEIO);
2f03f956 AT	227	}
	228	offset += i;
	229	continue;
	230	}
	231
	232	i = -(i+1);
	233	offset2 = i*n;
	234	len = n;
	235	if (i == count-1 && remainder != 0)
	236	len = remainder;
	237
	238	stats.matched_data += len;
	239
	240	if (verbose > 3)
	241	rprintf(FINFO,"chunk[%d] of size %d at %d offset=%d\n",
	242	i,len,(int)offset2,(int)offset);
	243
	244	map = map_ptr(buf,offset2,len);
	245
	246	see_token(map, len);
	247	sum_update(map,len);
	248
	249	if (fd != -1 && write_file(fd,map,len) != len) {
	250	rprintf(FERROR,"write failed on %s : %s\n",
	251	fname,strerror(errno));
65417579	252	exit_cleanup(RERR_FILEIO);
2f03f956 AT	253	}
	254	offset += len;
	255	}
	256
	257	end_progress();
	258
	259	if (fd != -1 && offset > 0 && sparse_end(fd) != 0) {
	260	rprintf(FERROR,"write failed on %s : %s\n",
	261	fname,strerror(errno));
65417579	262	exit_cleanup(RERR_FILEIO);
2f03f956 AT	263	}
	264
	265	sum_end(file_sum1);
	266
	267	if (remote_version >= 14) {
	268	read_buf(f_in,file_sum2,MD4_SUM_LENGTH);
	269	if (verbose > 2) {
	270	rprintf(FINFO,"got file_sum\n");
	271	}
	272	if (fd != -1 &&
	273	memcmp(file_sum1,file_sum2,MD4_SUM_LENGTH) != 0) {
	274	return 0;
	275	}
	276	}
	277	return 1;
	278	}
	279
	280
	281
	282	int recv_files(int f_in,struct file_list flist,char local_name,int f_gen)
	283	{
	284	int fd1,fd2;
	285	STRUCT_STAT st;
	286	char *fname;
	287	char fnametmp[MAXPATHLEN];
375a4556 DD	288	char *fnamecmp;
375a4556 DD	289	char fnamecmpbuf[MAXPATHLEN];
2f03f956 AT	290	struct map_struct *buf;
	291	int i;
	292	struct file_struct *file;
	293	int phase=0;
	294	int recv_ok;
1b7c47cb AT	295	extern struct stats stats;
1b7c47cb AT	296	struct stats initial_stats;
11a5a3c7	297
2f03f956 AT	298	if (verbose > 2) {
	299	rprintf(FINFO,"recv_files(%d) starting\n",flist->count);
	300	}
	301
	302	if (recurse && delete_mode && !local_name && flist->count>0) {
	303	delete_files(flist);
	304	}
	305
	306	while (1) {
	307	cleanup_disable();
	308
	309	i = read_int(f_in);
	310	if (i == -1) {
	311	if (phase==0 && remote_version >= 13) {
	312	phase++;
	313	csum_length = SUM_LENGTH;
	314	if (verbose > 2)
	315	rprintf(FINFO,"recv_files phase=%d\n",phase);
	316	write_int(f_gen,-1);
	317	continue;
	318	}
	319	break;
	320	}
	321
	322	if (i < 0 \|\| i >= flist->count) {
	323	rprintf(FERROR,"Invalid file index %d in recv_files (count=%d)\n",
	324	i, flist->count);
65417579	325	exit_cleanup(RERR_PROTOCOL);
2f03f956 AT	326	}
	327
	328	file = flist->files[i];
	329	fname = f_name(file);
	330
	331	stats.num_transferred_files++;
	332	stats.total_transferred_size += file->length;
	333
	334	if (local_name)
	335	fname = local_name;
	336
	337	if (dry_run) {
11a5a3c7 AT	338	if (!am_server) {
	339	log_transfer(file, fname);
	340	}
2f03f956 AT	341	continue;
	342	}
	343
1b7c47cb AT	344	initial_stats = stats;
1b7c47cb AT	345
2f03f956 AT	346	if (verbose > 2)
	347	rprintf(FINFO,"recv_files(%s)\n",fname);
	348
375a4556 DD	349	fnamecmp = fname;
375a4556 DD	350
2f03f956	351	/* open the file */
375a4556 DD	352	fd1 = open(fnamecmp,O_RDONLY);
	353
	354	if ((fd1 == -1) && (compare_dest != NULL)) {
	355	/* try the file at compare_dest instead */
37f9805d	356	slprintf(fnamecmpbuf,MAXPATHLEN,"%s/%s",
375a4556 DD	357	compare_dest,fname);
	358	fnamecmp = fnamecmpbuf;
	359	fd1 = open(fnamecmp,O_RDONLY);
	360	}
2f03f956 AT	361
2f03f956 AT	362	if (fd1 != -1 && do_fstat(fd1,&st) != 0) {
375a4556	363	rprintf(FERROR,"fstat %s : %s\n",fnamecmp,strerror(errno));
2f03f956 AT	364	receive_data(f_in,NULL,-1,NULL,file->length);
	365	close(fd1);
	366	continue;
	367	}
	368
	369	if (fd1 != -1 && !S_ISREG(st.st_mode)) {
375a4556	370	rprintf(FERROR,"%s : not a regular file (recv_files)\n",fnamecmp);
2f03f956 AT	371	receive_data(f_in,NULL,-1,NULL,file->length);
	372	close(fd1);
	373	continue;
	374	}
	375
	376	if (fd1 != -1 && st.st_size > 0) {
	377	buf = map_file(fd1,st.st_size);
	378	if (verbose > 2)
375a4556	379	rprintf(FINFO,"recv mapped %s of size %d\n",fnamecmp,(int)st.st_size);
2f03f956 AT	380	} else {
	381	buf = NULL;
	382	}
	383
	384	if (!get_tmpname(fnametmp,fname)) {
	385	if (buf) unmap_file(buf);
	386	if (fd1 != -1) close(fd1);
	387	continue;
	388	}
	389
d532c0f5 DD	390	/* mktemp is deliberately used here instead of mkstemp.
	391	because O_EXCL is used on the open, the race condition
	392	is not a problem or a security hole, and we want to
	393	control the access permissions on the created file. */
2f03f956 AT	394	if (NULL == do_mktemp(fnametmp)) {
	395	rprintf(FERROR,"mktemp %s failed\n",fnametmp);
	396	receive_data(f_in,buf,-1,NULL,file->length);
	397	if (buf) unmap_file(buf);
	398	if (fd1 != -1) close(fd1);
	399	continue;
	400	}
	401
	402	/* we initially set the perms without the
	403	setuid/setgid bits to ensure that there is no race
	404	condition. They are then correctly updated after
	405	the lchown. Thanks to snabb@epipe.fi for pointing
	406	this out */
	407	fd2 = do_open(fnametmp,O_WRONLY\|O_CREAT\|O_EXCL,
	408	file->mode & ACCESSPERMS);
	409
	410	if (fd2 == -1 && relative_paths && errno == ENOENT &&
	411	create_directory_path(fnametmp) == 0) {
	412	fd2 = do_open(fnametmp,O_WRONLY\|O_CREAT\|O_EXCL,
	413	file->mode & ACCESSPERMS);
	414	}
	415	if (fd2 == -1) {
	416	rprintf(FERROR,"open %s : %s\n",fnametmp,strerror(errno));
	417	receive_data(f_in,buf,-1,NULL,file->length);
	418	if (buf) unmap_file(buf);
	419	if (fd1 != -1) close(fd1);
	420	continue;
	421	}
	422
c6b81a98	423	cleanup_set(fnametmp, fname, file, buf, fd1, fd2);
2f03f956	424
11a5a3c7 AT	425	if (!am_server) {
	426	log_transfer(file, fname);
	427	}
	428
2f03f956 AT	429	/* recv file data */
2f03f956 AT	430	recv_ok = receive_data(f_in,buf,fd2,fname,file->length);
1b7c47cb AT	431
1b7c47cb AT	432	log_recv(file, &initial_stats);
2f03f956 AT	433
	434	if (buf) unmap_file(buf);
	435	if (fd1 != -1) {
	436	close(fd1);
	437	}
	438	close(fd2);
	439
	440	if (verbose > 2)
	441	rprintf(FINFO,"renaming %s to %s\n",fnametmp,fname);
	442
	443	finish_transfer(fname, fnametmp, file);
c6b81a98	444
2f03f956	445	cleanup_disable();
c6b81a98	446
2f03f956 AT	447	if (!recv_ok) {
	448	if (csum_length == SUM_LENGTH) {
	449	rprintf(FERROR,"ERROR: file corruption in %s. File changed during transfer?\n",
	450	fname);
	451	} else {
	452	if (verbose > 1)
	453	rprintf(FINFO,"redoing %s(%d)\n",fname,i);
	454	write_int(f_gen,i);
	455	}
	456	}
	457	}
	458
	459	if (preserve_hard_links)
	460	do_hard_links(flist);
	461
	462	/* now we need to fix any directory permissions that were
	463	modified during the transfer */
	464	for (i = 0; i < flist->count; i++) {
	465	file = flist->files[i];
	466	if (!file->basename \|\| !S_ISDIR(file->mode)) continue;
	467	recv_generator(f_name(file),flist,i,-1);
	468	}
	469
	470	if (verbose > 2)
	471	rprintf(FINFO,"recv_files finished\n");
	472
	473	return 0;
	474	}
	475