303 |
(* Global tables *) |
(* Global tables *) |
304 |
(* *) |
(* *) |
305 |
(*************************************************************************) |
(*************************************************************************) |
306 |
|
|
307 |
let sources_by_uid = HS.create 13557 |
let sources_by_uid = HS.create 13557 |
308 |
let sources_by_num = H.create 13557 |
let sources_by_num = H.create 13557 |
309 |
|
|
310 |
let file_sources_managers = ref [] |
let file_sources_managers = ref [] |
311 |
|
|
312 |
let connecting_sources = Fifo.create () |
let connecting_sources = Fifo.create () |
313 |
|
|
314 |
let next_direct_sources = Fifo.create () |
let next_direct_sources = Fifo.create () |
315 |
let next_indirect_sources = ref [] |
let next_indirect_sources = ref [] |
316 |
|
|
317 |
|
|
318 |
let active_queue q = |
let active_queue q = |
319 |
q >= connected_sources_queue && q <= busy_sources_queue |
q >= connected_sources_queue && q <= busy_sources_queue |
320 |
|
|
321 |
(*************************************************************************) |
(*************************************************************************) |
1446 |
if file_state (file.manager_file ()) = FileDownloading then |
if file_state (file.manager_file ()) = FileDownloading then |
1447 |
let r = find_request s file in |
let r = find_request s file in |
1448 |
if r.request_time + !!min_reask_delay <= last_time () then |
if r.request_time + !!min_reask_delay <= last_time () then |
1449 |
|
|
1450 |
(* There is really no need to query a not found source again |
(* There is really no need to query a not found source again |
1451 |
for the file ... not even after an hour! *) |
for the file ... not even after an hour! *) |
1452 |
if r.request_score > not_found_score then |
if r.request_score > not_found_score then |