[Top][All Lists]
[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Mldonkey-commits] Changes to mldonkey/src/daemon/common/commonHasher.ml
From: |
mldonkey-commits |
Subject: |
[Mldonkey-commits] Changes to mldonkey/src/daemon/common/commonHasher.ml |
Date: |
Fri, 22 Jul 2005 10:32:19 -0400 |
Index: mldonkey/src/daemon/common/commonHasher.ml
diff -u mldonkey/src/daemon/common/commonHasher.ml:1.5
mldonkey/src/daemon/common/commonHasher.ml:1.6
--- mldonkey/src/daemon/common/commonHasher.ml:1.5 Tue Jun 28 23:17:07 2005
+++ mldonkey/src/daemon/common/commonHasher.ml Fri Jul 22 14:32:12 2005
@@ -34,10 +34,10 @@
let (fifo : string job Fifo.t) = Fifo.create ()
let current_job = ref None
-
+
external job_done : 'a job -> bool = "ml_job_done"
external job_start : 'a job -> Unix.file_descr -> unit = "ml_job_start"
-
+
let _ =
BasicSocket.add_infinite_timer 0.1 (fun _ ->
(* lprintf "test job\n"; *)
@@ -47,22 +47,21 @@
| Some (job, fd) ->
(* lprintf "job done\n"; *)
if job_done job then begin
- if !verbose_md4 then begin
- lprintf "Job finished\n";
- end;
+ if !verbose_md4 then
+ lprintf_nl "[cHa] Job finished";
current_job := None;
Unix.close fd;
- (try job.job_handler job with e ->
- lprintf "exception %s in job_handler\n"
- (Printexc2.to_string e);
+ (try job.job_handler job with e ->
+ lprintf_nl "[cHa] exception %s in job_handler"
+ (Printexc2.to_string e);
);
raise Not_found
end
with _ ->
- let job = try Fifo.take fifo
-
- with e ->
+ let job = try Fifo.take fifo
+
+ with e ->
(* lprintf "No waiting job\n"; *)
raise e
in
@@ -71,23 +70,22 @@
let fd = Unix.openfile job.job_name [Unix.O_RDONLY] 0o444 in
current_job := Some (job, fd);
if !verbose_md4 then begin
- lprintf "Starting job %s %Ld %Ld %s\n" job.job_name
+ lprintf_nl "[cHa] Starting job %s %Ld %Ld %s" job.job_name
job.job_begin job.job_len
(match job.job_method with
MD5 -> "MD5"
| TIGER -> "TIGER"
| SHA1 -> "SHA1"
- | MD4 -> "MD4");
+ | MD4 -> "MD4");
end;
job_start job fd;
- if !verbose_md4 then begin
- lprintf "Job started\n";
- end
+ if !verbose_md4 then
+ lprintf_nl "[cHa] Job started"
with e ->
- lprintf "Exception %s in starting job\n"
- (Printexc2.to_string e);
+ lprintf_nl "[cHa] Exception %s in starting job"
+ (Printexc2.to_string e);
)
-
+
let compute_md4 name begin_pos len f =
let job = {
job_name = name;
@@ -99,7 +97,7 @@
job_error = false;
} in
Fifo.put fifo (Obj.magic job)
-
+
let compute_sha1 name begin_pos len f =
let job = {
job_name = name;
@@ -111,7 +109,7 @@
job_error = false;
} in
Fifo.put fifo (Obj.magic job)
-
+
let compute_md5 name begin_pos len f =
let job = {
job_name = name;
@@ -123,7 +121,7 @@
job_error = false;
} in
Fifo.put fifo (Obj.magic job)
-
+
let compute_tiger name begin_pos len f =
let job = {
job_name = name;
@@ -135,4 +133,3 @@
job_error = false;
} in
Fifo.put fifo (Obj.magic job)
-
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- [Mldonkey-commits] Changes to mldonkey/src/daemon/common/commonHasher.ml,
mldonkey-commits <=