145 |
Unix2.really_write fd b.buf b.pos b.len; |
Unix2.really_write fd b.buf b.pos b.len; |
146 |
end; *) |
end; *) |
147 |
(* lprintf "DIFF %d/%d" nread b.len; lprint_newline ();*) |
(* lprintf "DIFF %d/%d" nread b.len; lprint_newline ();*) |
148 |
c.client_pos <- Int64.add c.client_pos (Int64.of_int b.len); |
c.client_pos <- c.client_pos ++ (Int64.of_int b.len); |
149 |
(* |
(* |
150 |
lprintf "NEW SOURCE POS %s" (Int64.to_string c.source_pos); |
lprintf "NEW SOURCE POS %s" (Int64.to_string c.source_pos); |
151 |
lprint_newline (); |
lprint_newline (); |
153 |
TcpBufferedSocket.buf_used b b.len; |
TcpBufferedSocket.buf_used b b.len; |
154 |
(* if c.client_pos > file_downloaded file then begin |
(* if c.client_pos > file_downloaded file then begin |
155 |
add_file_downloaded file.file_file |
add_file_downloaded file.file_file |
156 |
(Int64.sub c.client_pos (file_downloaded file)) |
(c.client_pos -- (file_downloaded file)) |
157 |
end; *) |
end; *) |
158 |
if file_downloaded file = file_size file then |
if file_downloaded file = file_size file then |
159 |
|
|