Call delete_in_dir(NULL, NULL, NULL) in do_delete_pass().

[rsync/rsync.git] / token.c

diff --git a/token.c b/token.c
index 8ba32b9..3286a13 100644 (file)
--- a/token.c
+++ b/token.c
@@ -22,8 +22,9 @@
 
 extern int do_compression;
 extern int module_id;
+extern int def_compress_level;
 
-static int compression_level = Z_DEFAULT_COMPRESSION;
+static int compression_level;
 
 /* determine the compression level based on a wildcard filename list */
 void set_compression(char *fname)
@@ -34,7 +35,7 @@ void set_compression(char *fname)
        if (!do_compression)
                return;
 
-       compression_level = Z_DEFAULT_COMPRESSION;
+       compression_level = def_compress_level;
        dont = lp_dont_compress(module_id);
 
        if (!dont || !*dont)
@@ -67,7 +68,7 @@ void set_compression(char *fname)
 /* non-compressing recv token */
 static int32 simple_recv_token(int f, char **data)
 {
-       static int residue;
+       static int32 residue;
        static char *buf;
        int32 n;
 
@@ -93,7 +94,7 @@ static int32 simple_recv_token(int f, char **data)
 
 
 /* non-compressing send token */
-static void simple_send_token(int f, int token, struct map_struct *buf,
+static void simple_send_token(int f, int32 token, struct map_struct *buf,
                              OFF_T offset, int32 n)
 {
        if (n > 0) {
@@ -128,9 +129,9 @@ static void simple_send_token(int f, int token, struct map_struct *buf,
 #define AVAIL_OUT_SIZE(avail_in_size) ((avail_in_size)*1001/1000+16)
 
 /* For coding runs of tokens */
-static int last_token = -1;
-static int run_start;
-static int last_run_end;
+static int32 last_token = -1;
+static int32 run_start;
+static int32 last_run_end;
 
 /* Deflation state */
 static z_stream tx_strm;
@@ -148,7 +149,7 @@ static char *obuf;
 
 /* Send a deflated token */
 static void
-send_deflated_token(int f, int token, struct map_struct *buf, OFF_T offset,
+send_deflated_token(int f, int32 token, struct map_struct *buf, OFF_T offset,
                    int32 nb, int32 toklen)
 {
        int32 n, r;
@@ -260,18 +261,24 @@ send_deflated_token(int f, int token, struct map_struct *buf, OFF_T offset,
                /* end of file - clean up */
                write_byte(f, END_FLAG);
        } else if (token != -2) {
-               /* add the data in the current block to the compressor's
-                  history and hash table */
-               tx_strm.next_in = (Bytef *) map_ptr(buf, offset, toklen);
-               tx_strm.avail_in = toklen;
-               tx_strm.next_out = (Bytef *) obuf;
-               tx_strm.avail_out = AVAIL_OUT_SIZE(CHUNK_SIZE);
-               r = deflate(&tx_strm, Z_INSERT_ONLY);
-               if (r != Z_OK || tx_strm.avail_in != 0) {
-                       rprintf(FERROR, "deflate on token returned %d (%d bytes left)\n",
-                               r, tx_strm.avail_in);
-                       exit_cleanup(RERR_STREAMIO);
-               }
+               /* Add the data in the current block to the compressor's
+                * history and hash table. */
+               do {
+                       /* Break up long sections in the same way that
+                        * see_deflate_token() does. */
+                       int32 n1 = toklen > 0xffff ? 0xffff : toklen;
+                       toklen -= n1;
+                       tx_strm.next_in = (Bytef *)map_ptr(buf, offset, n1);
+                       tx_strm.avail_in = n1;
+                       tx_strm.next_out = (Bytef *) obuf;
+                       tx_strm.avail_out = AVAIL_OUT_SIZE(CHUNK_SIZE);
+                       r = deflate(&tx_strm, Z_INSERT_ONLY);
+                       if (r != Z_OK || tx_strm.avail_in != 0) {
+                               rprintf(FERROR, "deflate on token returned %d (%d bytes left)\n",
+                                       r, tx_strm.avail_in);
+                               exit_cleanup(RERR_STREAMIO);
+                       }
+               } while (toklen > 0);
        }
 }
 
@@ -292,9 +299,9 @@ static int32 rx_run;
 static int32 recv_deflated_token(int f, char **data)
 {
        static int init_done;
-       static int saved_flag;
-       int r, flag;
-       int32 n;
+       static int32 saved_flag;
+       int32 n, flag;
+       int r;
 
        for (;;) {
                switch (recv_state) {
@@ -423,7 +430,8 @@ static int32 recv_deflated_token(int f, char **data)
  */
 static void see_deflate_token(char *buf, int32 len)
 {
-       int r, blklen;
+       int r;
+       int32 blklen;
        unsigned char hdr[5];
 
        rx_strm.avail_in = 0;
@@ -464,7 +472,7 @@ static void see_deflate_token(char *buf, int32 len)
  * If token == -1 then we have reached EOF
  * If n == 0 then don't send a buffer
  */
-void send_token(int f, int token, struct map_struct *buf, OFF_T offset,
+void send_token(int f, int32 token, struct map_struct *buf, OFF_T offset,
                int32 n, int32 toklen)
 {
        if (!do_compression)