Improvments by Matt for the --progress option, including updating
[rsync/rsync.git] / rsync.c
1 /*
2  * Routines common to more than one of the rsync processes.
3  *
4  * Copyright (C) 1996 Andrew Tridgell
5  * Copyright (C) 1996 Paul Mackerras
6  * Copyright (C) 2003, 2004, 2005, 2006 Wayne Davison
7  *
8  * This program is free software; you can redistribute it and/or modify
9  * it under the terms of the GNU General Public License as published by
10  * the Free Software Foundation; either version 2 of the License, or
11  * (at your option) any later version.
12  *
13  * This program is distributed in the hope that it will be useful,
14  * but WITHOUT ANY WARRANTY; without even the implied warranty of
15  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
16  * GNU General Public License for more details.
17  *
18  * You should have received a copy of the GNU General Public License along
19  * with this program; if not, write to the Free Software Foundation, Inc.,
20  * 51 Franklin Street - Fifth Floor, Boston, MA 02110-1301, USA.
21  */
22
23 #include "rsync.h"
24 #if defined HAVE_ICONV_OPEN && defined HAVE_ICONV_H
25 #include <iconv.h>
26 #endif
27 #if defined HAVE_LIBCHARSET_H && defined HAVE_LOCALE_CHARSET
28 #include <libcharset.h>
29 #elif defined HAVE_LANGINFO_H && defined HAVE_NL_LANGINFO
30 #include <langinfo.h>
31 #endif
32
33 extern int verbose;
34 extern int dry_run;
35 extern int preserve_perms;
36 extern int preserve_executability;
37 extern int preserve_times;
38 extern int omit_dir_times;
39 extern int am_root;
40 extern int am_server;
41 extern int am_sender;
42 extern int am_generator;
43 extern int am_starting_up;
44 extern int allow_8bit_chars;
45 extern int preserve_uid;
46 extern int preserve_gid;
47 extern int inplace;
48 extern int keep_dirlinks;
49 extern int make_backups;
50 extern mode_t orig_umask;
51 extern struct stats stats;
52 extern struct chmod_mode_struct *daemon_chmod_modes;
53
54 #if defined HAVE_ICONV_OPEN && defined HAVE_ICONV_H
55 iconv_t ic_chck = (iconv_t)-1;
56
57 static const char *default_charset(void)
58 {
59 #if defined HAVE_LIBCHARSET_H && defined HAVE_LOCALE_CHARSET
60         return locale_charset();
61 #elif defined HAVE_LANGINFO_H && defined HAVE_NL_LANGINFO
62         return nl_langinfo(CODESET);
63 #else
64         return ""; /* Works with (at the very least) gnu iconv... */
65 #endif
66 }
67
68 void setup_iconv()
69 {
70         if (!am_server && !allow_8bit_chars) {
71                 const char *defset = default_charset();
72
73                 /* It's OK if this fails... */
74                 ic_chck = iconv_open(defset, defset);
75
76                 if (verbose > 3) {
77                         if (ic_chck == (iconv_t)-1) {
78                                 rprintf(FINFO,
79                                         "note: iconv_open(\"%s\", \"%s\") failed (%d)"
80                                         " -- using isprint() instead of iconv().\n",
81                                         defset, defset, errno);
82                         } else {
83                                 rprintf(FINFO,
84                                         "note: iconv_open(\"%s\", \"%s\") succeeded.\n",
85                                         defset, defset);
86                         }
87                 }
88         }
89 }
90 #endif
91
92 /*
93   free a sums struct
94   */
95 void free_sums(struct sum_struct *s)
96 {
97         if (s->sums) free(s->sums);
98         free(s);
99 }
100
101 /* This is only called when we aren't preserving permissions.  Figure out what
102  * the permissions should be and return them merged back into the mode. */
103 mode_t dest_mode(mode_t flist_mode, mode_t cur_mode, int exists)
104 {
105         /* If the file already exists, we'll return the local permissions,
106          * possibly tweaked by the --executability option. */
107         if (exists) {
108                 if (preserve_executability && S_ISREG(flist_mode)) {
109                         /* If the source file is executable, grant execute
110                          * rights to everyone who can read, but ONLY if the
111                          * file isn't already executable. */
112                         if (!(flist_mode & 0111))
113                                 cur_mode &= ~0111;
114                         else if (!(cur_mode & 0111))
115                                 cur_mode |= (cur_mode & 0444) >> 2;
116                 }
117         } else
118                 cur_mode = flist_mode & ACCESSPERMS & ~orig_umask;
119         if (daemon_chmod_modes && !S_ISLNK(flist_mode))
120                 cur_mode = tweak_mode(cur_mode, daemon_chmod_modes);
121         return (flist_mode & ~CHMOD_BITS) | (cur_mode & CHMOD_BITS);
122 }
123
124 int set_file_attrs(char *fname, struct file_struct *file, STRUCT_STAT *st,
125                    int flags)
126 {
127         int updated = 0;
128         STRUCT_STAT st2;
129         int change_uid, change_gid;
130
131         if (!st) {
132                 if (dry_run)
133                         return 1;
134                 if (link_stat(fname, &st2, 0) < 0) {
135                         rsyserr(FERROR, errno, "stat %s failed",
136                                 full_fname(fname));
137                         return 0;
138                 }
139                 st = &st2;
140                 if (!preserve_perms && S_ISDIR(file->mode)
141                  && st->st_mode & S_ISGID) {
142                         /* We just created this directory and its setgid
143                          * bit is on, so make sure it stays on. */
144                         file->mode |= S_ISGID;
145                 }
146         }
147
148         if (!preserve_times || (S_ISDIR(st->st_mode) && omit_dir_times))
149                 flags |= ATTRS_SKIP_MTIME;
150         if (!(flags & ATTRS_SKIP_MTIME)
151             && cmp_time(st->st_mtime, file->modtime) != 0) {
152                 int ret = set_modtime(fname, file->modtime, st->st_mode);
153                 if (ret < 0) {
154                         rsyserr(FERROR, errno, "failed to set times on %s",
155                                 full_fname(fname));
156                         return 0;
157                 }
158                 if (ret == 0) /* ret == 1 if symlink could not be set */
159                         updated = 1;
160         }
161
162         change_uid = am_root && preserve_uid && st->st_uid != file->uid;
163         change_gid = preserve_gid && file->gid != GID_NONE
164                 && st->st_gid != file->gid;
165 #if !defined HAVE_LCHOWN && !defined CHOWN_MODIFIES_SYMLINK
166         if (S_ISLNK(st->st_mode))
167                 ;
168         else
169 #endif
170         if (change_uid || change_gid) {
171                 if (verbose > 2) {
172                         if (change_uid) {
173                                 rprintf(FINFO,
174                                         "set uid of %s from %ld to %ld\n",
175                                         fname,
176                                         (long)st->st_uid, (long)file->uid);
177                         }
178                         if (change_gid) {
179                                 rprintf(FINFO,
180                                         "set gid of %s from %ld to %ld\n",
181                                         fname,
182                                         (long)st->st_gid, (long)file->gid);
183                         }
184                 }
185                 if (do_lchown(fname,
186                     change_uid ? file->uid : st->st_uid,
187                     change_gid ? file->gid : st->st_gid) != 0) {
188                         /* shouldn't have attempted to change uid or gid
189                          * unless have the privilege */
190                         rsyserr(FERROR, errno, "%s %s failed",
191                             change_uid ? "chown" : "chgrp",
192                             full_fname(fname));
193                         return 0;
194                 }
195                 /* a lchown had been done - we have to re-stat if the
196                  * destination had the setuid or setgid bits set due
197                  * to the side effect of the chown call */
198                 if (st->st_mode & (S_ISUID | S_ISGID)) {
199                         link_stat(fname, st,
200                                   keep_dirlinks && S_ISDIR(st->st_mode));
201                 }
202                 updated = 1;
203         }
204
205 #ifdef HAVE_CHMOD
206         if ((st->st_mode & CHMOD_BITS) != (file->mode & CHMOD_BITS)) {
207                 int ret = do_chmod(fname, file->mode);
208                 if (ret < 0) {
209                         rsyserr(FERROR, errno,
210                                 "failed to set permissions on %s",
211                                 full_fname(fname));
212                         return 0;
213                 }
214                 if (ret == 0) /* ret == 1 if symlink could not be set */
215                         updated = 1;
216         }
217 #endif
218
219         if (verbose > 1 && flags & ATTRS_REPORT) {
220                 if (updated)
221                         rprintf(FCLIENT, "%s\n", fname);
222                 else
223                         rprintf(FCLIENT, "%s is uptodate\n", fname);
224         }
225         return updated;
226 }
227
228 RETSIGTYPE sig_int(UNUSED(int val))
229 {
230         /* KLUGE: if the user hits Ctrl-C while ssh is prompting
231          * for a password, then our cleanup's sending of a SIGUSR1
232          * signal to all our children may kill ssh before it has a
233          * chance to restore the tty settings (i.e. turn echo back
234          * on).  By sleeping for a short time, ssh gets a bigger
235          * chance to do the right thing.  If child processes are
236          * not ssh waiting for a password, then this tiny delay
237          * shouldn't hurt anything. */
238         msleep(400);
239         exit_cleanup(RERR_SIGNAL);
240 }
241
242 /* Finish off a file transfer: renaming the file and setting the file's
243  * attributes (e.g. permissions, ownership, etc.).  If partialptr is not
244  * NULL and the robust_rename() call is forced to copy the temp file, we
245  * stage the file into the partial-dir and then rename it into place. */
246 void finish_transfer(char *fname, char *fnametmp, char *partialptr,
247                      struct file_struct *file, int ok_to_set_time,
248                      int overwriting_basis)
249 {
250         int ret;
251
252         if (inplace) {
253                 if (verbose > 2)
254                         rprintf(FINFO, "finishing %s\n", fname);
255                 fnametmp = fname;
256                 goto do_set_file_attrs;
257         }
258
259         if (make_backups && overwriting_basis && !make_backup(fname))
260                 return;
261
262         /* Change permissions before putting the file into place. */
263         set_file_attrs(fnametmp, file, NULL,
264                        ok_to_set_time ? 0 : ATTRS_SKIP_MTIME);
265
266         /* move tmp file over real file */
267         if (verbose > 2)
268                 rprintf(FINFO, "renaming %s to %s\n", fnametmp, fname);
269         ret = robust_rename(fnametmp, fname, partialptr,
270                             file->mode & INITACCESSPERMS);
271         if (ret < 0) {
272                 rsyserr(FERROR, errno, "%s %s -> \"%s\"",
273                         ret == -2 ? "copy" : "rename",
274                         full_fname(fnametmp), fname);
275                 do_unlink(fnametmp);
276                 return;
277         }
278         if (ret == 0) {
279                 /* The file was moved into place (not copied), so it's done. */
280                 return;
281         }
282         /* The file was copied, so tweak the perms of the copied file.  If it
283          * was copied to partialptr, move it into its final destination. */
284         fnametmp = partialptr ? partialptr : fname;
285
286   do_set_file_attrs:
287         set_file_attrs(fnametmp, file, NULL,
288                        ok_to_set_time ? 0 : ATTRS_SKIP_MTIME);
289
290         if (partialptr) {
291                 if (do_rename(fnametmp, fname) < 0) {
292                         rsyserr(FERROR, errno, "rename %s -> \"%s\"",
293                                 full_fname(fnametmp), fname);
294                 } else
295                         handle_partial_dir(partialptr, PDIR_DELETE);
296         }
297 }
298
299 const char *who_am_i(void)
300 {
301         if (am_starting_up)
302                 return am_server ? "server" : "client";
303         return am_sender ? "sender" : am_generator ? "generator" : "receiver";
304 }