-#ifdef HAVE_MKNOD
- if (preserve_devices && IS_DEVICE(flist->files[i].mode)) {
- if (statret != 0 ||
- st.st_mode != flist->files[i].mode ||
- st.st_rdev != flist->files[i].dev) {
- if (!dry_run) unlink(fname);
- if (verbose > 2)
- fprintf(stderr,"mknod(%s,0%o,0x%x)\n",
- fname,(int)flist->files[i].mode,(int)flist->files[i].dev);
- if (!dry_run &&
- mknod(fname,flist->files[i].mode,flist->files[i].dev) != 0) {
- fprintf(stderr,"mknod %s : %s\n",fname,strerror(errno));
- } else {
- set_perms(fname,&flist->files[i],NULL,0);
- if (verbose)
- fprintf(am_server?stderr:stdout,"%s\n",fname);
- }
- } else {
- set_perms(fname,&flist->files[i],&st,1);
- }
- return;
- }
-#endif
-
- if (!S_ISREG(flist->files[i].mode)) {
- fprintf(stderr,"skipping non-regular file %s\n",fname);
- return;
- }
-
- if (statret == -1) {
- if (errno == ENOENT) {
- write_int(f_out,i);
- if (!dry_run) send_sums(NULL,f_out);
- } else {
- if (verbose > 1)
- fprintf(stderr,"recv_generator failed to open %s\n",fname);
- }
- return;
- }
-
- if (!S_ISREG(st.st_mode)) {
- fprintf(stderr,"%s : not a regular file\n",fname);
- return;
- }
-
- if (update_only && st.st_mtime >= flist->files[i].modtime) {
- if (verbose > 1)
- fprintf(stderr,"%s is newer\n",fname);
- return;
- }
-
- if (always_checksum && S_ISREG(st.st_mode)) {
- file_checksum(fname,sum,st.st_size);
- }
-
- if (st.st_size == flist->files[i].length &&
- ((!ignore_times && st.st_mtime == flist->files[i].modtime) ||
- (always_checksum && S_ISREG(st.st_mode) &&
- memcmp(sum,flist->files[i].sum,SUM_LENGTH) == 0))) {
- set_perms(fname,&flist->files[i],&st,1);
- return;
- }
-
- if (dry_run) {
- write_int(f_out,i);
- return;
- }
-
- /* open the file */
- fd = open(fname,O_RDONLY);
-
- if (fd == -1) {
- fprintf(stderr,"failed to open %s : %s\n",fname,strerror(errno));
- return;
- }
-
- if (st.st_size > 0) {
- buf = map_file(fd,st.st_size);
- } else {
- buf = NULL;
- }
-
- if (verbose > 3)
- fprintf(stderr,"mapped %s of size %d\n",fname,(int)st.st_size);
-
- s = generate_sums(buf,st.st_size,block_size);
-
- write_int(f_out,i);
- send_sums(s,f_out);
- write_flush(f_out);
-
- close(fd);
- unmap_file(buf,st.st_size);
-
- free_sums(s);
-}
-
-
-
-static void receive_data(int f_in,char *buf,int fd,char *fname)
-{
- int i,n,remainder,len,count;
- off_t offset = 0;
- off_t offset2;
-
- count = read_int(f_in);
- n = read_int(f_in);
- remainder = read_int(f_in);
-
- for (i=read_int(f_in); i != 0; i=read_int(f_in)) {
- if (i > 0) {
- if (verbose > 3)
- fprintf(stderr,"data recv %d at %d\n",i,(int)offset);
-
- if (read_write(f_in,fd,i) != i) {
- fprintf(stderr,"write failed on %s : %s\n",fname,strerror(errno));
- exit(1);
- }
- offset += i;
- } else {
- i = -(i+1);
- offset2 = i*n;
- len = n;
- if (i == count-1 && remainder != 0)
- len = remainder;
-
- if (verbose > 3)
- fprintf(stderr,"chunk[%d] of size %d at %d offset=%d\n",
- i,len,(int)offset2,(int)offset);
-
- if (write(fd,map_ptr(buf,offset2,len),len) != len) {
- fprintf(stderr,"write failed on %s : %s\n",fname,strerror(errno));
- exit(1);
- }
- offset += len;
- }
- }
-}
-
-
-static void delete_one(struct file_struct *f)
-{
- if (!S_ISDIR(f->mode)) {
- if (!dry_run && unlink(f->name) != 0) {
- fprintf(stderr,"unlink %s : %s\n",f->name,strerror(errno));
- } else if (verbose) {
- fprintf(stderr,"deleting %s\n",f->name);
- }
- } else {
- if (!dry_run && rmdir(f->name) != 0) {
- if (errno != ENOTEMPTY)
- fprintf(stderr,"rmdir %s : %s\n",f->name,strerror(errno));
- } else if (verbose) {
- fprintf(stderr,"deleting directory %s\n",f->name);
- }
- }
-}
-
-
-static void delete_files(struct file_list *flist)
-{
- struct file_list *local_file_list;
- char *dot=".";
- int i;
-
- if (cvs_exclude)
- add_cvs_excludes();
-
- if (!(local_file_list = send_file_list(-1,recurse,1,&dot)))
- return;
-
- for (i=local_file_list->count;i>=0;i--) {
- if (!local_file_list->files[i].name) continue;
- if (-1 == flist_find(flist,&local_file_list->files[i])) {
- delete_one(&local_file_list->files[i]);
- }
- }