summaryrefslogtreecommitdiff
path: root/token.c
diff options
context:
space:
mode:
authorWayne Davison <wayned@samba.org>2004-07-15 02:20:08 +0000
committerWayne Davison <wayned@samba.org>2004-07-15 02:20:08 +0000
commitb9f592fbf50b0dc9e3d1d33b8deb2bf9abad9ef6 (patch)
treef7bb3ff7a10192bd8e91b29e5fba68da10dd195e /token.c
parentc7b1a56b3d70fb91b20702f169ae1af9b68de8e9 (diff)
downloadrsync-b9f592fbf50b0dc9e3d1d33b8deb2bf9abad9ef6.tar.gz
rsync-b9f592fbf50b0dc9e3d1d33b8deb2bf9abad9ef6.tar.bz2
rsync-b9f592fbf50b0dc9e3d1d33b8deb2bf9abad9ef6.zip
My modified version of Chris Shoemaker's improved batch-file handling.
Diffstat (limited to 'token.c')
-rw-r--r--token.c34
1 files changed, 0 insertions, 34 deletions
diff --git a/token.c b/token.c
index 707512ef..c7e898ce 100644
--- a/token.c
+++ b/token.c
@@ -22,7 +22,6 @@
extern int do_compression;
extern int module_id;
-extern int write_batch;
static int compression_level = Z_DEFAULT_COMPRESSION;
@@ -97,28 +96,18 @@ static int simple_recv_token(int f,char **data)
static void simple_send_token(int f,int token,
struct map_struct *buf,OFF_T offset,int n)
{
- int hold_int;
-
if (n > 0) {
int l = 0;
while (l < n) {
int n1 = MIN(CHUNK_SIZE,n-l);
write_int(f,n1);
write_buf(f,map_ptr(buf,offset+l,n1),n1);
- if (write_batch) {
- write_batch_delta_file( (char *) &n1, sizeof(int) );
- write_batch_delta_file(map_ptr(buf,offset+l,n1),n1);
- }
l += n1;
}
}
/* a -2 token means to send data only and no token */
if (token != -2) {
write_int(f,-(token+1));
- if (write_batch) {
- hold_int = -(token+1);
- write_batch_delta_file( (char *) &hold_int, sizeof(int) );
- }
}
}
@@ -165,7 +154,6 @@ send_deflated_token(int f, int token,
{
int n, r;
static int init_done, flush_pending;
- char temp_byte;
if (last_token == -1) {
/* initialization */
@@ -198,28 +186,13 @@ send_deflated_token(int f, int token,
n = last_token - run_start;
if (r >= 0 && r <= 63) {
write_byte(f, (n==0? TOKEN_REL: TOKENRUN_REL) + r);
- if (write_batch) {
- temp_byte = (char)( (n==0? TOKEN_REL: TOKENRUN_REL) + r);
- write_batch_delta_file(&temp_byte,sizeof(char));
- }
} else {
write_byte(f, (n==0? TOKEN_LONG: TOKENRUN_LONG));
write_int(f, run_start);
- if (write_batch) {
- temp_byte = (char)(n==0? TOKEN_LONG: TOKENRUN_LONG);
- write_batch_delta_file(&temp_byte,sizeof(char));
- write_batch_delta_file((char *)&run_start,sizeof(run_start));
- }
}
if (n != 0) {
write_byte(f, n);
write_byte(f, n >> 8);
- if (write_batch) {
- temp_byte = (char)n;
- write_batch_delta_file(&temp_byte,sizeof(char));
- temp_byte = (char)(n >> 8);
- write_batch_delta_file(&temp_byte,sizeof(char));
- }
}
last_run_end = last_token;
run_start = token;
@@ -278,8 +251,6 @@ send_deflated_token(int f, int token,
obuf[0] = DEFLATED_DATA + (n >> 8);
obuf[1] = n;
write_buf(f, obuf, n+2);
- if (write_batch)
- write_batch_delta_file(obuf,n+2);
}
}
} while (nb != 0 || tx_strm.avail_out == 0);
@@ -289,11 +260,6 @@ send_deflated_token(int f, int token,
if (token == -1) {
/* end of file - clean up */
write_byte(f, END_FLAG);
- if (write_batch) {
- temp_byte = END_FLAG;
- write_batch_delta_file(&temp_byte,sizeof(char));
- }
-
} else if (token != -2) {
/* add the data in the current block to the compressor's
history and hash table */