- Changed the xattr namespaces check to filter out system xattrs
[rsync-patches.git] / xattrs.diff
index 78691061c7667376659421c8e4035e3ccdf3acf0..ae25d2c81c6074e3b3ddf5b10f6d00abd215f194 100644 (file)
@@ -1,14 +1,22 @@
-Depends-On-Patch: acls.diff
+This patch adds basic support for extended attributes.  It works, but there
+are some things that still needs to be improved (see TODO list below).
 
-After applying this patch, run these commands for a successful build:
+To use this patch, run these commands for a successful build:
 
+    patch -p1 <patches/acls.diff
+    patch -p1 <patches/xattrs.diff
     ./prepare-source
     ./configure --enable-acl-support --enable-xattr-support
     make
 
+Alternately, if you don't want ACL support, configure it this way:
+
+    ./configure --enable-xattr-support
+
 TODO:
 
- - This patch needs to be rewritten to more efficiently handle large xattrs.
+ - This patch needs to more efficiently handle large xattrs, especially when
+   they're unchanged.
 
  - Extraneous xattr values need to be removed from files that are not being
    recreated.
@@ -38,15 +46,15 @@ TODO:
  popt_OBJS=popt/findme.o  popt/popt.o  popt/poptconfig.o \
 --- old/acls.c
 +++ new/acls.c
-@@ -29,6 +29,7 @@ extern int am_root;
- extern int dry_run;
+@@ -30,6 +30,7 @@ extern int read_only;
+ extern int list_only;
  extern int orig_umask;
  extern int preserve_acls;
 +extern int preserve_xattrs;
  extern unsigned int file_struct_len;
  
  /* === ACL structures === */
-@@ -740,6 +741,10 @@ void receive_acl(struct file_struct *fil
+@@ -741,6 +742,10 @@ void receive_acl(struct file_struct *fil
        type = SMB_ACL_TYPE_ACCESS;
        racl_list = &access_acl_list;
        ndx_ptr = (char*)file + file_struct_len;
@@ -57,7 +65,7 @@ TODO:
        do {
                char tag = read_byte(f);
                int ndx;
-@@ -799,6 +804,10 @@ void cache_acl(struct file_struct *file,
+@@ -800,6 +805,10 @@ void cache_acl(struct file_struct *file,
        racl = sxp->acc_acl;
        racl_list = &access_acl_list;
        ndx_ptr = (char*)file + file_struct_len;
@@ -68,7 +76,7 @@ TODO:
        do {
                if (!racl)
                        ndx = -1;
-@@ -914,6 +923,10 @@ int set_acl(const char *fname, const str
+@@ -920,6 +929,10 @@ int set_acl(const char *fname, const str
  
        type = SMB_ACL_TYPE_ACCESS;
        ndx_ptr = (char*)file + file_struct_len;
@@ -137,12 +145,13 @@ TODO:
        if ((am_root && preserve_devices && IS_DEVICE(file->mode))
 --- old/configure.in
 +++ new/configure.in
-@@ -856,6 +856,35 @@ samba_cv_HAVE_ACL_GET_PERM_NP=yes,samba_
+@@ -856,6 +856,40 @@ samba_cv_HAVE_ACL_GET_PERM_NP=yes,samba_
    AC_MSG_RESULT(no)
  )
  
 +AC_CHECK_HEADERS(attr/xattr.h)
 +AC_CHECK_HEADERS(sys/xattr.h)
++AC_CHECK_HEADERS(sys/extattr.h)
 +AC_MSG_CHECKING(whether to support extended attributes)
 +AC_ARG_ENABLE(xattr-support,
 +AC_HELP_STRING([--enable-xattr-support], [Include extended attribute support (default=no)]),
@@ -157,6 +166,10 @@ TODO:
 +            AC_MSG_RESULT(Using OS X xattrs)
 +            AC_DEFINE(HAVE_OSX_XATTRS, 1, [True if you have Mac OS X xattrs])
 +            ;;
++      freebsd*)
++            AC_MSG_RESULT(Using FreeBSD extattrs)
++            AC_DEFINE(HAVE_FREEBSD_XATTRS, 1, [True if you have FreeBSD xattrs])
++            ;;
 +      *)
 +            AC_MSG_RESULT(Xattrs requested but not Linux or OS X.  Good luck...)
 +            ;;
@@ -164,10 +177,10 @@ TODO:
 +      ;;
 +  *)
 +      AC_MSG_RESULT(no)
-+      AC_DEFINE(HAVE_NA_XATTRS, 1, [True if you don't have extended attributes])
++      AC_DEFINE(HAVE_NO_XATTRS, 1, [True if you don't have extended attributes])
 +  esac ],
 +  AC_MSG_RESULT(no)
-+  AC_DEFINE(HAVE_NO_XATTRL, 1, [True if you don't have extended attributes])
++  AC_DEFINE(HAVE_NO_XATTRS, 1, [True if you don't have extended attributes])
 +)
 +
  AC_CONFIG_FILES([Makefile lib/dummy zlib/dummy popt/dummy shconfig])
@@ -275,7 +288,7 @@ TODO:
  }
 --- old/lib/sysxattr.c
 +++ new/lib/sysxattr.c
-@@ -0,0 +1,71 @@
+@@ -0,0 +1,136 @@
 +/*
 + * Extended attribute support for rsync.
 + *
@@ -300,6 +313,8 @@ TODO:
 +#include "rsync.h"
 +#include "sysxattr.h"
 +
++#ifdef SUPPORT_XATTRS
++
 +#if defined HAVE_LINUX_XATTRS
 +
 +ssize_t sys_lgetxattr(const char *path, const char *name, void *value, size_t size)
@@ -307,9 +322,14 @@ TODO:
 +      return lgetxattr(path, name, value, size);
 +}
 +
-+int sys_lsetxattr(const char *path, const char *name, const void *value, size_t size, int flags)
++ssize_t sys_fgetxattr(int filedes, const char *name, void *value, size_t size)
 +{
-+      return lsetxattr(path, name, value, size, flags);
++      return fgetxattr(filedes, name, value, size);
++}
++
++int sys_lsetxattr(const char *path, const char *name, const void *value, size_t size)
++{
++      return lsetxattr(path, name, value, size, 0);
 +}
 +
 +int sys_lremovexattr(const char *path, const char *name)
@@ -329,9 +349,14 @@ TODO:
 +      return getxattr(path, name, value, size, 0, XATTR_NOFOLLOW);
 +}
 +
-+int sys_lsetxattr(const char *path, const char *name, const void *value, size_t size, int flags)
++ssize_t sys_fgetxattr(int filedes, const char *name, void *value, size_t size)
 +{
-+      return setxattr(path, name, value, size, 0, XATTR_NOFOLLOW | flags);
++      return fgetxattr(filedes, name, value, size, 0, 0);
++}
++
++int sys_lsetxattr(const char *path, const char *name, const void *value, size_t size)
++{
++      return setxattr(path, name, value, size, 0, XATTR_NOFOLLOW);
 +}
 +
 +int sys_lremovexattr(const char *path, const char *name)
@@ -344,21 +369,74 @@ TODO:
 +      return listxattr(path, list, size, XATTR_NOFOLLOW);
 +}
 +
++#elif HAVE_FREEBSD_XATTRS
++
++ssize_t sys_lgetxattr(const char *path, const char *name, void *value, size_t size)
++{
++      return extattr_get_link(path, EXTATTR_NAMESPACE_USER, name, value, size);
++}
++
++ssize_t sys_fgetxattr(int filedes, const char *name, void *value, size_t size)
++{
++      return extattr_get_fd(filedes, EXTATTR_NAMESPACE_USER, name, value, size);
++}
++
++int sys_lsetxattr(const char *path, const char *name, const void *value, size_t size)
++{
++      return extattr_set_link(path, EXTATTR_NAMESPACE_USER, name, value, size);
++}
++
++int sys_lremovexattr(const char *path, const char *name)
++{
++      return extattr_delete_link(path, EXTATTR_NAMESPACE_USER, name);
++}
++
++ssize_t sys_llistxattr(const char *path, char *list, size_t size)
++{
++      unsigned char keylen;
++      ssize_t off, len = extattr_list_link(path, EXTATTR_NAMESPACE_USER, list, size);
++
++      if (len <= 0 || (size_t)len > size)
++              return len;
++
++      /* FreeBSD puts a single-byte length before each string, with no '\0'
++       * terminator.  We need to change this into a series of null-terminted
++       * strings.  Since the size is the same, we can simply transform the
++       * output in place. */
++      for (off = 0; off < len; ) {
++              keylen = ((unsigned char*)list)[off];
++              if (off + keylen >= len) {
++                      /* Should be impossible, but kernel bugs happen! */
++                      errno = EINVAL;
++                      return -1;
++              }
++              memmove(list+off, list+off+1, keylen);
++              off += keylen;
++              list[off++] = '\0';
++      }
++
++      return len;
++}
++
 +#else
 +
-+#endif /* No xattrs */
++#error You need to create xattr compatibility functions.
++
++#endif
++
++#endif /* SUPPORT_XATTRS */
 --- old/lib/sysxattr.h
 +++ new/lib/sysxattr.h
-@@ -0,0 +1,25 @@
+@@ -0,0 +1,26 @@
 +#ifdef SUPPORT_XATTRS
++
 +#if defined HAVE_ATTR_XATTR_H
 +#include <attr/xattr.h>
 +#elif defined HAVE_SYS_XATTR_H
 +#include <sys/xattr.h>
++#elif defined HAVE_SYS_EXTATTR_H
++#include <sys/extattr.h>
 +#endif
-+#endif
-+
-+#if defined HAVE_LINUX_XATTRS || defined HAVE_OSX_XATTRS
 +
 +/* Linux 2.4 does not define this as a distinct errno value: */
 +#ifndef ENOATTR
@@ -366,13 +444,14 @@ TODO:
 +#endif
 +
 +ssize_t sys_lgetxattr(const char *path, const char *name, void *value, size_t size);
-+int sys_lsetxattr(const char *path, const char *name, const void *value, size_t size, int flags);
++ssize_t sys_fgetxattr(int filedes, const char *name, void *value, size_t size);
++int sys_lsetxattr(const char *path, const char *name, const void *value, size_t size);
 +int sys_lremovexattr(const char *path, const char *name);
 +ssize_t sys_llistxattr(const char *path, char *list, size_t size);
 +
 +#else
 +
-+/* No xattrs */
++/* No xattrs available */
 +
 +#endif
 --- old/options.c
@@ -404,19 +483,18 @@ TODO:
  #ifdef SUPPORT_LINKS
        links = "";
  #endif
-@@ -234,9 +238,9 @@ static void print_rsync_version(enum log
-       rprintf(f, "Copyright (C) 1996-2006 by Andrew Tridgell, Wayne Davison, and others.\n");
-       rprintf(f, "<http://rsync.samba.org/>\n");
-       rprintf(f, "Capabilities: %d-bit files, %ssocketpairs, "
--              "%shard links, %sACLs, %ssymlinks, batchfiles,\n",
-+              "%shard links, %sACLs, %sxattrs, %ssymlinks, batchfiles,\n",
-               (int) (sizeof (OFF_T) * 8),
--              got_socketpair, hardlinks, acls, links);
-+              got_socketpair, hardlinks, acls, xattrs, links);
+@@ -236,8 +240,8 @@ static void print_rsync_version(enum log
+       rprintf(f, "Capabilities: %d-bit files, %ssocketpairs, %shard links, %ssymlinks,\n",
+               (int) (sizeof (OFF_T) * 8), got_socketpair, hardlinks, links);
+-      rprintf(f, "              batchfiles, %sinplace, %sIPv6, %sACLs,\n",
+-              have_inplace, ipv6, acls);
++      rprintf(f, "              batchfiles, %sinplace, %sIPv6, %sACLs, %sxattrs,\n",
++              have_inplace, ipv6, acls, xattrs);
  
        /* Note that this field may not have type ino_t.  It depends
         * on the complicated interaction between largefile feature
-@@ -290,7 +294,7 @@ void usage(enum logcode F)
+@@ -289,7 +293,7 @@ void usage(enum logcode F)
    rprintf(F," -q, --quiet                 suppress non-error messages\n");
    rprintf(F,"     --no-motd               suppress daemon-mode MOTD (see manpage caveat)\n");
    rprintf(F," -c, --checksum              skip based on checksum, not mod-time & size\n");
@@ -425,7 +503,7 @@ TODO:
    rprintf(F,"     --no-OPTION             turn off an implied OPTION (e.g. --no-D)\n");
    rprintf(F," -r, --recursive             recurse into directories\n");
    rprintf(F," -R, --relative              use relative path names\n");
-@@ -315,6 +319,9 @@ void usage(enum logcode F)
+@@ -314,6 +318,9 @@ void usage(enum logcode F)
  #ifdef SUPPORT_ACLS
    rprintf(F," -A, --acls                  preserve ACLs (implies --perms)\n");
  #endif
@@ -435,7 +513,7 @@ TODO:
    rprintf(F," -o, --owner                 preserve owner (super-user only)\n");
    rprintf(F," -g, --group                 preserve group\n");
    rprintf(F,"     --devices               preserve device files (super-user only)\n");
-@@ -437,6 +444,9 @@ static struct poptOption long_options[] 
+@@ -436,6 +443,9 @@ static struct poptOption long_options[] 
    {"acls",            'A', POPT_ARG_NONE,   0, 'A', 0, 0 },
    {"no-acls",          0,  POPT_ARG_VAL,    &preserve_acls, 0, 0, 0 },
    {"no-A",             0,  POPT_ARG_VAL,    &preserve_acls, 0, 0, 0 },
@@ -445,7 +523,7 @@ TODO:
    {"times",           't', POPT_ARG_VAL,    &preserve_times, 1, 0, 0 },
    {"no-times",         0,  POPT_ARG_VAL,    &preserve_times, 0, 0, 0 },
    {"no-t",             0,  POPT_ARG_VAL,    &preserve_times, 0, 0, 0 },
-@@ -1118,6 +1128,17 @@ int parse_arguments(int *argc, const cha
+@@ -1117,6 +1127,17 @@ int parse_arguments(int *argc, const cha
                        return 0;
  #endif
  
@@ -459,11 +537,11 @@ TODO:
 +                               "extended attributes are not supported on this %s\n",
 +                               am_server ? "server" : "client");
 +                      return 0;
-+#endif /* SUPPORT_XATTRS */
++#endif
  
                default:
                        /* A large opt value means that set_refuse_options()
-@@ -1564,6 +1585,10 @@ void server_options(char **args,int *arg
+@@ -1563,6 +1584,10 @@ void server_options(char **args,int *arg
        if (preserve_acls)
                argstr[x++] = 'A';
  #endif
@@ -484,31 +562,31 @@ TODO:
  extern int preserve_perms;
  extern int preserve_executability;
  extern int preserve_times;
-@@ -229,6 +230,10 @@ int set_file_attrs(char *fname, struct f
-       if (preserve_acls && set_acl(fname, file, sxp) == 0)
-               updated = 1;
- #endif
+@@ -218,6 +219,10 @@ int set_file_attrs(char *fname, struct f
+       if (daemon_chmod_modes && !S_ISLNK(new_mode))
+               new_mode = tweak_mode(new_mode, daemon_chmod_modes);
 +#ifdef SUPPORT_XATTRS
 +      if (preserve_xattrs && set_xattr(fname, file, sxp) == 0)
 +              updated = 1;
 +#endif
- #ifdef HAVE_CHMOD
-       if ((sxp->st.st_mode & CHMOD_BITS) != (new_mode & CHMOD_BITS)) {
+ #ifdef SUPPORT_ACLS
+       /* It's OK to call set_acl() now, even for a dir, as the generator
+        * will enable owner-writability using chmod, if necessary.
 --- old/rsync.h
 +++ new/rsync.h
-@@ -501,6 +501,10 @@ struct idev {
+@@ -500,6 +500,10 @@ struct idev {
  #define ACLS_NEED_MASK 1
  #endif
  
-+#if defined HAVE_LINUX_XATTRS || defined HAVE_OSX_XATTRS
++#ifndef HAVE_NO_XATTRS
 +#define SUPPORT_XATTRS 1
 +#endif
 +
  #define GID_NONE ((gid_t)-1)
  
  #define HL_CHECK_MASTER       0
-@@ -695,6 +699,9 @@ typedef struct {
+@@ -694,6 +698,9 @@ typedef struct {
      struct rsync_acl *acc_acl; /* access ACL */
      struct rsync_acl *def_acl; /* default ACL */
  #endif
@@ -551,7 +629,7 @@ TODO:
  transfer.  The resulting value is treated as though it was the permissions
 --- old/xattr.c
 +++ new/xattr.c
-@@ -0,0 +1,368 @@
+@@ -0,0 +1,406 @@
 +/*
 + * Extended Attribute support for rsync.
 + * Written by Jay Fenlason, vaguely based on the ACLs patch.
@@ -580,16 +658,29 @@ TODO:
 +#ifdef SUPPORT_XATTRS
 +
 +extern int dry_run;
++extern int am_root;
++extern int read_only;
++extern int list_only;
 +extern unsigned int file_struct_len;
 +
 +#define RSYNC_XAL_INITIAL 5
 +#define RSYNC_XAL_LIST_INITIAL 100
 +
++#define USER_PREFIX "user."
++#define UPRE_LEN ((int)sizeof USER_PREFIX - 1)
++#define SYSTEM_PREFIX "system."
++#define SPRE_LEN ((int)sizeof SYSTEM_PREFIX - 1)
++
++#ifdef HAVE_LINUX_XATTRS
++#define RPRE_LEN 0
++#else
++#define RSYNC_PREFIX "rsync."
++#define RPRE_LEN ((int)sizeof RSYNC_PREFIX - 1)
++#endif
++
 +typedef struct {
-+      char *name;
-+      char *datum;
-+      size_t name_len;
-+      size_t datum_len;
++      char *datum, *name;
++      size_t datum_len, name_len;
 +} rsync_xa;
 +
 +static size_t namebuf_len = 0;
@@ -598,11 +689,6 @@ TODO:
 +static item_list empty_xattr = EMPTY_ITEM_LIST;
 +static item_list rsync_xal_l = EMPTY_ITEM_LIST;
 +
-+#ifdef HAVE_OSX_XATTRS
-+static char unique_prefix[] = "user.0S%."; /* OSX */
-+static int upre_len = sizeof unique_prefix - 1;
-+#endif
-+
 +/* ------------------------------------------------------------------------- */
 +
 +static void rsync_xal_free(item_list *xalp)
@@ -611,8 +697,8 @@ TODO:
 +      rsync_xa *rxas = xalp->items;
 +
 +      for (i = 0; i < xalp->count; i++) {
-+              free(rxas[i].name);
-+              /* free(rxas[i].value); */
++              free(rxas[i].datum);
++              /*free(rxas[i].name);*/
 +      }
 +      xalp->count = 0;
 +}
@@ -633,12 +719,8 @@ TODO:
 +
 +static int rsync_xal_get(const char *fname, item_list *xalp)
 +{
-+      ssize_t name_size;
-+      ssize_t datum_size;
-+      ssize_t left;
-+      char *name;
-+      size_t len;
-+      char *ptr;
++      ssize_t list_len, name_len, datum_len;
++      char *name, *ptr;
 +
 +      if (!namebuf) {
 +              namebuf_len = 1024;
@@ -648,27 +730,27 @@ TODO:
 +      }
 +
 +      /* The length returned includes all the '\0' terminators. */
-+      name_size = sys_llistxattr(fname, namebuf, namebuf_len);
-+      if (name_size > (ssize_t)namebuf_len) {
-+              name_size = -1;
++      list_len = sys_llistxattr(fname, namebuf, namebuf_len);
++      if (list_len > (ssize_t)namebuf_len) {
++              list_len = -1;
 +              errno = ERANGE;
 +      }
-+      if (name_size < 0) {
++      if (list_len < 0) {
 +              if (errno == ENOTSUP)
 +                      return 0;
 +              if (errno == ERANGE) {
-+                      name_size = sys_llistxattr(fname, NULL, 0);
-+                      if (name_size < 0) {
++                      list_len = sys_llistxattr(fname, NULL, 0);
++                      if (list_len < 0) {
 +                              rsyserr(FERROR, errno, "%s: rsync_xal_get: llistxattr",
 +                                      fname);
 +                              return -1;
 +                      }
-+                      namebuf = realloc_array(namebuf, char, name_size + 1024);
++                      namebuf = realloc_array(namebuf, char, list_len + 1024);
 +                      if (!namebuf)
 +                              out_of_memory("rsync_xal_get");
-+                      namebuf_len = name_size + 1024;
-+                      name_size = sys_llistxattr(fname, namebuf, namebuf_len);
-+                      if (name_size < 0) {
++                      namebuf_len = list_len + 1024;
++                      list_len = sys_llistxattr(fname, namebuf, namebuf_len);
++                      if (list_len < 0) {
 +                              rsyserr(FERROR, errno,
 +                                  "%s: rsync_xal_get: re-llistxattr failed",
 +                                  fname);
@@ -681,14 +763,20 @@ TODO:
 +                      return -1;
 +              }
 +      }
-+      if (name_size == 0)
-+              return 0;
-+      for (left = name_size, name = namebuf; left > 0 ; left -= len, name += len) {
-+              rsync_xa *rxas = EXPAND_ITEM_LIST(xalp, rsync_xa, RSYNC_XAL_INITIAL);
-+
-+              len = strlen(name) + 1;
-+              datum_size = sys_lgetxattr(fname, name, NULL, 0);
-+              if (datum_size < 0) {
++
++      for (name = namebuf; list_len > 0 ; list_len -= name_len, name += name_len) {
++              rsync_xa *rxas;
++
++              name_len = strlen(name) + 1;
++
++#ifdef HAVE_LINUX_XATTRS
++              /* We don't send the system namespace. */
++              if (strncmp(name, SYSTEM_PREFIX, SPRE_LEN) == 0)
++                      continue;
++#endif
++
++              datum_len = sys_lgetxattr(fname, name, NULL, 0);
++              if (datum_len < 0) {
 +                      if (errno == ENOTSUP)
 +                              return -1;
 +                      rsyserr(FERROR, errno,
@@ -696,18 +784,13 @@ TODO:
 +                          fname, name);
 +                      return -1;
 +              }
-+              ptr = new_array(char, len + datum_size);
++              ptr = new_array(char, name_len + datum_len);
 +              if (!ptr)
 +                      out_of_memory("rsync_xal_get");
-+              memcpy(ptr, name, len);
-+              rxas->name_len = len;
-+              rxas->name = ptr;
-+              rxas->datum_len = datum_size;
-+              rxas->datum = ptr + len;
-+              if (datum_size) {
-+                      ssize_t size = sys_lgetxattr(fname, name, rxas->datum, datum_size);
-+                      if (size != datum_size) {
-+                              if (size < 0) {
++              if (datum_len) {
++                      ssize_t len = sys_lgetxattr(fname, name, ptr, datum_len);
++                      if (len != datum_len) {
++                              if (len < 0) {
 +                                      rsyserr(FERROR, errno,
 +                                          "rsync_xal_get: lgetxattr(%s,%s)"
 +                                          " failed", fname, name);
@@ -716,11 +799,18 @@ TODO:
 +                                          "rsync_xal_get: lgetxattr(%s,%s)"
 +                                          " returned %ld instead of %ld\n",
 +                                          fname, name,
-+                                          (long)size, (long)datum_size);
++                                          (long)len, (long)datum_len);
 +                              }
++                              free(ptr);
 +                              return -1;
 +                      }
 +              }
++              rxas = EXPAND_ITEM_LIST(xalp, rsync_xa, RSYNC_XAL_INITIAL);
++              rxas->name = ptr + datum_len;
++              memcpy(rxas->name, name, name_len);
++              rxas->name_len = name_len;
++              rxas->datum_len = datum_len;
++              rxas->datum = ptr;
 +      }
 +      if (xalp->count > 1)
 +              qsort(xalp->items, xalp->count, sizeof (rsync_xa), rsync_xal_compare_names);
@@ -794,19 +884,24 @@ TODO:
 +              write_byte(f, 'X');
 +              write_int(f, count);
 +              for (rxa = sxp->xattr->items; count--; rxa++) {
-+#ifdef HAVE_OSX_XATTRS
-+                      if (strncmp(rxa->name, "user.", 5) != 0
-+                       && strncmp(rxa->name, "system.", 7) != 0) {
-+                              write_int(f, rxa->name_len + upre_len);
++#ifdef HAVE_LINUX_XATTRS
++                      write_int(f, rxa->name_len);
++                      write_int(f, rxa->datum_len);
++                      write_buf(f, rxa->name, rxa->name_len);
++#else
++                      /* We strip the rsync prefix from disguised namespaces
++                       * and put everything else in the user namespace. */
++                      if (strncmp(rxa->name, RSYNC_PREFIX, RPRE_LEN) == 0) {
++                              write_int(f, rxa->name_len - RPRE_LEN);
 +                              write_int(f, rxa->datum_len);
-+                              write_buf(f, unique_prefix, upre_len);
-+                      } else
-+#endif
-+                      {
-+                              write_int(f, rxa->name_len);
++                              write_buf(f, rxa->name + RPRE_LEN, rxa->name_len - RPRE_LEN);
++                      } else {
++                              write_int(f, rxa->name_len + UPRE_LEN);
 +                              write_int(f, rxa->datum_len);
++                              write_buf(f, USER_PREFIX, UPRE_LEN);
++                              write_buf(f, rxa->name, rxa->name_len);
 +                      }
-+                      write_buf(f, rxa->name, rxa->name_len);
++#endif
 +                      write_buf(f, rxa->datum, rxa->datum_len);
 +              }
 +              rsync_xal_store(sxp->xattr); /* adds item to rsync_xal_l */
@@ -820,35 +915,51 @@ TODO:
 +void receive_xattr(struct file_struct *file, int f)
 +{
 +      static item_list temp_xattr = EMPTY_ITEM_LIST;
-+      int tag = read_byte(f);
 +      char *ndx_ptr = (char*)file + file_struct_len;
-+      int ndx;
++      int ndx, tag = read_byte(f);
 +
 +      if (tag == 'X') {
 +              int i, count = read_int(f);
 +              for (i = 0; i < count; i++) {
-+                      char *ptr;
++                      char *ptr, *name;
 +                      rsync_xa *rxa;
 +                      size_t name_len = read_int(f);
 +                      size_t datum_len = read_int(f);
 +                      if (name_len + datum_len < name_len)
 +                              out_of_memory("receive_xattr"); /* overflow */
-+                      rxa = EXPAND_ITEM_LIST(&temp_xattr, rsync_xa, count);
-+                      ptr = new_array(char, name_len + datum_len);
++#ifndef HAVE_LINUX_XATTRS
++                      if (name_len + datum_len + RPRE_LEN < RPRE_LEN)
++                              out_of_memory("receive_xattr"); /* overflow */
++#endif
++                      ptr = new_array(char, name_len + datum_len + RPRE_LEN);
 +                      if (!ptr)
 +                              out_of_memory("receive_xattr");
-+                      read_buf(f, ptr, name_len);
-+                      read_buf(f, ptr + name_len, datum_len);
-+                      rxa->name_len = name_len;
-+                      rxa->datum_len = datum_len;
-+                      rxa->name = ptr;
-+                      rxa->datum = ptr + name_len;
-+#ifdef HAVE_OSX_XATTRS
-+                      if (strncmp(rxa->name, unique_prefix, upre_len) == 0) {
-+                              rxa->name_len -= upre_len;
-+                              memmove(rxa->name, rxa->name + upre_len, rxa->name_len);
++                      name = ptr + datum_len + RPRE_LEN;
++                      read_buf(f, name, name_len);
++                      read_buf(f, ptr, datum_len);
++#ifdef HAVE_LINUX_XATTRS
++                      /* Non-root can only save the user namespace. */
++                      if (!am_root && strncmp(name, USER_PREFIX, UPRE_LEN) != 0) {
++                              free(ptr);
++                              continue;
++                      }
++#else
++                      /* This OS only has a user namespace, so we either
++                       * strip the user prefix, or we put a non-user
++                       * namespace inside our rsync hierarchy. */
++                      if (strncmp(name, USER_PREFIX, UPRE_LEN) == 0) {
++                              name += UPRE_LEN;
++                              name_len -= UPRE_LEN;
++                      } else {
++                              name -= RPRE_LEN;
++                              memcpy(name, RSYNC_PREFIX, RPRE_LEN);
 +                      }
 +#endif
++                      rxa = EXPAND_ITEM_LIST(&temp_xattr, rsync_xa, count);
++                      rxa->name = name;
++                      rxa->name_len = name_len;
++                      rxa->datum = ptr;
++                      rxa->datum_len = datum_len;
 +              }
 +              ndx = rsync_xal_l.count; /* pre-incremented count */
 +              rsync_xal_store(&temp_xattr); /* adds item to rsync_xal_l */
@@ -895,7 +1006,7 @@ TODO:
 +      int ret = 0;
 +
 +      for (i = 0; i < xalp->count; i++) {
-+              int status = sys_lsetxattr(fname, rxas[i].name, rxas[i].datum, rxas[i].datum_len, 0);
++              int status = sys_lsetxattr(fname, rxas[i].name, rxas[i].datum, rxas[i].datum_len);
 +              if (status < 0) {
 +                      rsyserr(FERROR, errno, "%s: rsync_xal_set: lsetxattr %s failed",
 +                              fname, rxas[i].name);
@@ -915,6 +1026,11 @@ TODO:
 +      if (dry_run)
 +              return 1; /* FIXME: --dry-run needs to compute this value */
 +
++      if (read_only || list_only) {
++              errno = EROFS;
++              return -1;
++      }
++
 +      ndx = IVAL(ndx_ptr, 0);
 +      return rsync_xal_set(fname, lst + ndx); /* TODO:  This needs to return 1 if no xattrs changed! */
 +}