diff options
author | Wayne Davison <wayned@samba.org> | 2004-07-15 02:20:08 +0000 |
---|---|---|
committer | Wayne Davison <wayned@samba.org> | 2004-07-15 02:20:08 +0000 |
commit | b9f592fbf50b0dc9e3d1d33b8deb2bf9abad9ef6 (patch) | |
tree | f7bb3ff7a10192bd8e91b29e5fba68da10dd195e /token.c | |
parent | c7b1a56b3d70fb91b20702f169ae1af9b68de8e9 (diff) | |
download | android_external_rsync-b9f592fbf50b0dc9e3d1d33b8deb2bf9abad9ef6.tar.gz android_external_rsync-b9f592fbf50b0dc9e3d1d33b8deb2bf9abad9ef6.tar.bz2 android_external_rsync-b9f592fbf50b0dc9e3d1d33b8deb2bf9abad9ef6.zip |
My modified version of Chris Shoemaker's improved batch-file handling.
Diffstat (limited to 'token.c')
-rw-r--r-- | token.c | 34 |
1 files changed, 0 insertions, 34 deletions
@@ -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 */ |