Updated to fix a couple compile errors and to apply cleanly.
[rsync-patches.git] / slp.diff
index 6a7a37c506bf3f6b2770b10f5862c17ce685a8f7..e46fbdce932a915aa7ea082650f1b791c212eba9 100644 (file)
--- a/slp.diff
+++ b/slp.diff
@@ -10,8 +10,10 @@ To use this patch, run these commands for a successful build:
 TODO: the configure changes should abort if the user requests --enable-slp
 and we can't honor that request.
 
---- old/Makefile.in
-+++ new/Makefile.in
+based-on: a59a7b242393699fedeb4f66911e3fc9b4fadd73
+diff --git a/Makefile.in b/Makefile.in
+--- a/Makefile.in
++++ b/Makefile.in
 @@ -13,6 +13,8 @@ CFLAGS=@CFLAGS@
  CPPFLAGS=@CPPFLAGS@
  EXEEXT=@EXEEXT@
@@ -21,7 +23,7 @@ and we can't honor that request.
  
  INSTALLCMD=@INSTALL@
  INSTALLMAN=@INSTALL@
-@@ -36,7 +38,7 @@ OBJS1=flist.o rsync.o generator.o receiv
+@@ -38,7 +40,7 @@ OBJS1=flist.o rsync.o generator.o receiver.o cleanup.o sender.o exclude.o \
  OBJS2=options.o io.o compat.o hlink.o token.o uidlist.o socket.o hashtable.o \
        fileio.o batch.o clientname.o chmod.o acls.o xattrs.o
  OBJS3=progress.o pipe.o
@@ -30,7 +32,7 @@ and we can't honor that request.
  popt_OBJS=popt/findme.o  popt/popt.o  popt/poptconfig.o \
        popt/popthelp.o popt/poptparse.o
  OBJS=$(OBJS1) $(OBJS2) $(OBJS3) $(DAEMON_OBJ) $(LIBOBJ) $(ZLIBOBJ) @BUILD_POPT@
-@@ -72,7 +74,7 @@ install-strip:
+@@ -74,7 +76,7 @@ install-strip:
        $(MAKE) INSTALL_STRIP='-s' install
  
  rsync$(EXEEXT): $(OBJS)
@@ -38,10 +40,11 @@ and we can't honor that request.
 +      $(CC) $(CFLAGS) $(LDFLAGS) -o $@ $(OBJS) $(LIBS) $(LIBSLP)
  
  $(OBJS): $(HEADERS)
---- old/clientserver.c
-+++ new/clientserver.c
-@@ -876,6 +876,13 @@ int daemon_main(void)
+ $(CHECK_OBJS): $(HEADERS)
+diff --git a/clientserver.c b/clientserver.c
+--- a/clientserver.c
++++ b/clientserver.c
+@@ -1202,6 +1202,13 @@ int daemon_main(void)
         * address too.  In fact, why not just do inet_ntop on the
         * local address??? */
  
@@ -52,12 +55,13 @@ and we can't honor that request.
 +      }
 +#endif
 +
-       if (((pid_file = lp_pid_file()) != NULL) && (*pid_file != '\0')) {
-               char pidbuf[16];
-               int fd;
---- old/configure.in
-+++ new/configure.in
-@@ -641,6 +641,29 @@ if test $rsync_cv_can_hardlink_special =
+       start_accept_loop(rsync_port, start_daemon);
+       return -1;
+ }
+diff --git a/configure.ac b/configure.ac
+--- a/configure.ac
++++ b/configure.ac
+@@ -723,6 +723,29 @@ if test $rsync_cv_can_hardlink_special = yes; then
      AC_DEFINE(CAN_HARDLINK_SPECIAL, 1, [Define to 1 if link() can hard-link special files.])
  fi
  
@@ -87,41 +91,43 @@ and we can't honor that request.
  AC_CACHE_CHECK([for working socketpair],rsync_cv_HAVE_SOCKETPAIR,[
  AC_TRY_RUN([
  #include <sys/types.h>
---- old/loadparm.c
-+++ new/loadparm.c
-@@ -110,6 +110,9 @@ typedef struct
-       char *socket_options;
+diff --git a/loadparm.c b/loadparm.c
+--- a/loadparm.c
++++ b/loadparm.c
+@@ -99,6 +99,9 @@ typedef struct {
  
+       int listen_backlog;
        int rsync_port;
 +#ifdef HAVE_LIBSLP
 +      int slp_refresh;
 +#endif
- } global;
+ } global_vars;
  
- static global Globals;
-@@ -295,6 +298,9 @@ static struct parm_struct parm_table[] =
-  {"motd file",         P_STRING, P_GLOBAL,&Globals.motd_file,          NULL,0},
-  {"pid file",          P_STRING, P_GLOBAL,&Globals.pid_file,           NULL,0},
-  {"port",              P_INTEGER,P_GLOBAL,&Globals.rsync_port,         NULL,0},
+ /* This structure describes a single section.  Their order must match the
+@@ -317,6 +320,9 @@ static struct parm_struct parm_table[] =
+  {"motd file",         P_STRING, P_GLOBAL,&Vars.g.motd_file,           NULL,0},
+  {"pid file",          P_STRING, P_GLOBAL,&Vars.g.pid_file,            NULL,0},
+  {"port",              P_INTEGER,P_GLOBAL,&Vars.g.rsync_port,          NULL,0},
 +#ifdef HAVE_LIBSLP
-+ {"slp refresh",       P_INTEGER,P_GLOBAL,&Globals.slp_refresh,        NULL,0},
++ {"slp refresh",       P_INTEGER,P_GLOBAL,&Vars.g.slp_refresh,         NULL,0},
 +#endif
-  {"socket options",    P_STRING, P_GLOBAL,&Globals.socket_options,     NULL,0},
+  {"socket options",    P_STRING, P_GLOBAL,&Vars.g.socket_options,      NULL,0},
  
-  {"auth users",        P_STRING, P_LOCAL, &sDefault.auth_users,        NULL,0},
-@@ -386,6 +392,9 @@ FN_GLOBAL_STRING(lp_pid_file, &Globals.p
- FN_GLOBAL_STRING(lp_socket_options, &Globals.socket_options)
+  {"auth users",        P_STRING, P_LOCAL, &Vars.l.auth_users,          NULL,0},
+@@ -450,6 +456,9 @@ FN_GLOBAL_STRING(lp_socket_options, &Vars.g.socket_options)
  
- FN_GLOBAL_INTEGER(lp_rsync_port, &Globals.rsync_port)
+ FN_GLOBAL_INTEGER(lp_listen_backlog, &Vars.g.listen_backlog)
+ FN_GLOBAL_INTEGER(lp_rsync_port, &Vars.g.rsync_port)
 +#ifdef HAVE_LIBSLP
-+FN_GLOBAL_INTEGER(lp_slp_refresh, &Globals.slp_refresh)
++FN_GLOBAL_INTEGER(lp_slp_refresh, &Vars.g.slp_refresh)
 +#endif
  
  FN_LOCAL_STRING(lp_auth_users, auth_users)
- FN_LOCAL_STRING(lp_comment, comment)
---- old/main.c
-+++ new/main.c
-@@ -1099,6 +1099,18 @@ static int start_client(int argc, char *
+ FN_LOCAL_STRING(lp_charset, charset)
+diff --git a/main.c b/main.c
+--- a/main.c
++++ b/main.c
+@@ -1243,6 +1243,18 @@ static int start_client(int argc, char *argv[])
  
        if (!read_batch) { /* for read_batch, NO source is specified */
                char *path = check_for_hostspec(argv[0], &shell_machine, &rsync_port);
@@ -138,11 +144,12 @@ and we can't honor that request.
 +              }
 +
                if (path) { /* source is remote */
-                       char *dummy1;
-                       int dummy2;
---- old/options.c
-+++ new/options.c
-@@ -220,6 +220,7 @@ static void print_rsync_version(enum log
+                       char *dummy_host;
+                       int dummy_port = 0;
+diff --git a/options.c b/options.c
+--- a/options.c
++++ b/options.c
+@@ -570,6 +570,7 @@ static void print_rsync_version(enum logcode f)
        char const *links = "no ";
        char const *iconv = "no ";
        char const *ipv6 = "no ";
@@ -150,9 +157,9 @@ and we can't honor that request.
        STRUCT_STAT *dumstat;
  
  #if SUBPROTOCOL_VERSION != 0
-@@ -249,6 +250,9 @@ static void print_rsync_version(enum log
- #ifdef ICONV_OPTION
-       iconv = "";
+@@ -606,6 +607,9 @@ static void print_rsync_version(enum logcode f)
+ #ifdef CAN_SET_SYMLINK_TIMES
+       symtimes = "";
  #endif
 +#if HAVE_LIBSLP
 +      slp = "";
@@ -160,32 +167,35 @@ and we can't honor that request.
  
        rprintf(f, "%s  version %s  protocol version %d%s\n",
                RSYNC_NAME, RSYNC_VERSION, PROTOCOL_VERSION, subprotocol);
-@@ -262,8 +266,8 @@ static void print_rsync_version(enum log
+@@ -619,8 +623,8 @@ static void print_rsync_version(enum logcode f)
                (int)(sizeof (int64) * 8));
        rprintf(f, "    %ssocketpairs, %shardlinks, %ssymlinks, %sIPv6, batchfiles, %sinplace,\n",
                got_socketpair, hardlinks, links, ipv6, have_inplace);
--      rprintf(f, "    %sappend, %sACLs, %sxattrs, %siconv\n",
--              have_inplace, acls, xattrs, iconv);
-+      rprintf(f, "    %sappend, %sACLs, %sxattrs, %siconv, %sSLP\n",
-+              have_inplace, acls, xattrs, iconv, slp);
+-      rprintf(f, "    %sappend, %sACLs, %sxattrs, %siconv, %ssymtimes, %sprealloc\n",
+-              have_inplace, acls, xattrs, iconv, symtimes, prealloc);
++      rprintf(f, "    %sappend, %sACLs, %sxattrs, %siconv, %ssymtimes, %sprealloc, %sSLP\n",
++              have_inplace, acls, xattrs, iconv, symtimes, prealloc, slp);
  
  #ifdef MAINTAINER_MODE
        rprintf(f, "Panic Action: \"%s\"\n", get_panic_action());
---- old/rsync.h
-+++ new/rsync.h
-@@ -182,6 +182,9 @@
+diff --git a/rsync.h b/rsync.h
+--- a/rsync.h
++++ b/rsync.h
+@@ -204,6 +204,10 @@
  #define SIGNIFICANT_ITEM_FLAGS (~(\
        ITEM_BASIS_TYPE_FOLLOWS | ITEM_XNAME_FOLLOWS | ITEM_LOCAL_CHANGE))
  
 +/* this is the minimum we'll use, irrespective of config setting */
 +/* definately don't set to less than about 30 seconds */
 +#define SLP_MIN_TIMEOUT 120
- /* Log-message categories.  Only FERROR and FINFO get sent over the socket,
-  * but FLOG and FSOCKERR can be sent over the receiver -> generator pipe.
---- old/rsync.yo
-+++ new/rsync.yo
-@@ -145,7 +145,12 @@ particular rsync daemon by leaving off t
++
+ #define CFN_KEEP_DOT_DIRS (1<<0)
+ #define CFN_KEEP_TRAILING_SLASH (1<<1)
+ #define CFN_DROP_TRAILING_DOT_DIR (1<<2)
+diff --git a/rsync.yo b/rsync.yo
+--- a/rsync.yo
++++ b/rsync.yo
+@@ -148,7 +148,12 @@ particular rsync daemon by leaving off the module name:
  
  quote(tt(rsync somehost.mydomain.com::))
  
@@ -199,21 +209,24 @@ and we can't honor that request.
  
  manpagesection(ADVANCED USAGE)
  
---- old/rsyncd.conf
-+++ new/rsyncd.conf
+diff --git a/rsyncd.conf b/rsyncd.conf
+new file mode 100644
+--- /dev/null
++++ b/rsyncd.conf
 @@ -0,0 +1,3 @@
 +
 +slp refresh = 300
 +
---- old/rsyncd.conf.yo
-+++ new/rsyncd.conf.yo
-@@ -103,6 +103,15 @@ details on some of the options you may b
- special socket options are set.  These settings are superseded by the
- bf(--sockopts) command-line option.
+diff --git a/rsyncd.conf.yo b/rsyncd.conf.yo
+--- a/rsyncd.conf.yo
++++ b/rsyncd.conf.yo
+@@ -123,6 +123,15 @@ via the bf(--sockopts) command-line option.
+ dit(bf(listen backlog)) You can override the default backlog value when the
+ daemon listens for connections.  It defaults to 5.
  
-+dit(bf(slp refresh)) This option is used to determine how long service
++dit(bf(slp refresh)) This parameter is used to determine how long service
 +advertisements are valid (measured in seconds), and is only applicable if
-+you have Service Location Protocol support compiled in. If this option is
++you have Service Location Protocol support compiled in. If this is
 +not set or is set to zero, then service advertisements never time out. If
 +this is set to less than 120 seconds, then 120 seconds is used. If it is
 +set to more than 65535, then 65535 is used (which is a limitation of SLP).
@@ -222,18 +235,19 @@ and we can't honor that request.
 +
  enddit()
  
-@@ -564,6 +573,7 @@ use chroot = no
+ manpagesection(MODULE PARAMETERS)
+@@ -842,6 +851,7 @@ use chroot = yes
  max connections = 4
  syslog facility = local5
  pid file = /var/run/rsyncd.pid
 +slp refresh = 3600
  
  [ftp]
-         path = /var/ftp/pub
---- old/socket.c
-+++ new/socket.c
-@@ -501,6 +501,16 @@ void start_accept_loop(int port, int (*f
+         path = /var/ftp/./pub
+diff --git a/socket.c b/socket.c
+--- a/socket.c
++++ b/socket.c
+@@ -533,6 +533,16 @@ void start_accept_loop(int port, int (*fn)(int, int))
  {
        fd_set deffds;
        int *sp, maxfd, i;
@@ -250,7 +264,7 @@ and we can't honor that request.
  
  #ifdef HAVE_SIGACTION
        sigact.sa_flags = SA_NOCLDSTOP;
-@@ -529,14 +539,25 @@ void start_accept_loop(int port, int (*f
+@@ -561,14 +571,25 @@ void start_accept_loop(int port, int (*fn)(int, int))
                        maxfd = sp[i];
        }
  
@@ -276,29 +290,30 @@ and we can't honor that request.
  
                /* close log file before the potentially very long select so
                 * file can be trimmed by another process instead of growing
-@@ -548,8 +569,18 @@ void start_accept_loop(int port, int (*f
- #else
+@@ -581,7 +602,18 @@ void start_accept_loop(int port, int (*fn)(int, int))
                fds = deffds;
  #endif
--
--              if (select(maxfd + 1, &fds, NULL, NULL, NULL) != 1)
+-              if (select(maxfd + 1, &fds, NULL, NULL, NULL) < 1)
 +#ifdef HAVE_LIBSLP
 +              sel_ret = select(maxfd + 1, &fds, NULL, NULL,
 +                               slp_timeout ? &slp_tv : NULL);
 +              if (sel_ret == 0 && slp_timeout && time(NULL) > next_slp_refresh) {
-+                  rprintf(FINFO, "Service registration expired, refreshing it\n");
-+                  register_services();
-+                  next_slp_refresh = time(NULL) + slp_timeout;
++                      rprintf(FINFO, "Service registration expired, refreshing it\n");
++                      register_services();
++                      next_slp_refresh = time(NULL) + slp_timeout;
 +              }
 +#else
 +              sel_ret = select(maxfd + 1, &fds, NULL, NULL, NULL);
 +#endif
-+              if (sel_ret != 1)
++              if (sel_ret < 1)
                        continue;
  
                for (i = 0, fd = -1; sp[i] >= 0; i++) {
---- old/srvloc.c
-+++ new/srvloc.c
+diff --git a/srvloc.c b/srvloc.c
+new file mode 100644
+--- /dev/null
++++ b/srvloc.c
 @@ -0,0 +1,103 @@
 +/* -*- c-file-style: "linux"; -*-
 +
@@ -403,8 +418,10 @@ and we can't honor that request.
 +
 +      return 0;
 +}
---- old/srvreg.c
-+++ new/srvreg.c
+diff --git a/srvreg.c b/srvreg.c
+new file mode 100644
+--- /dev/null
++++ b/srvreg.c
 @@ -0,0 +1,128 @@
 +/* -*- c-file-style: "linux"; -*-
 +