summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
Diffstat (limited to 'seggetd/networkbroker.cpp')
-rw-r--r--seggetd/networkbroker.cpp65
1 files changed, 26 insertions, 39 deletions
diff --git a/seggetd/networkbroker.cpp b/seggetd/networkbroker.cpp
index 36e3d7e..1137017 100644
--- a/seggetd/networkbroker.cpp
+++ b/seggetd/networkbroker.cpp
@@ -46,52 +46,39 @@ void Tnetwork_distfile_broker::init(ulong network_number){
}
void Tnetwork_distfile_broker::local_mirror_failed(uint mirror_num){
- if (phase==E_USE_AS_LOCAL_MIRRORS){
- if (! mirror_fails_vector[mirror_num]){
- mirror_fails_vector[mirror_num]=true;
- failed_mirrors_num++;
- }
- if (failed_mirrors_num>=mirror_fails_vector.size()){
- phase=E_ALL_LOCAL_MIRRORS_FAILED;
- failed_mirrors_num=0;
- // clean the vector, to use it again when we switch to E_PROXY_FETCHER_DOWNLOADED phase
- for (ulong mirr_num=0; mirr_num<mirror_fails_vector.size(); mirr_num++){
- mirror_fails_vector[mirr_num]=false;
+ try{
+ if (phase==E_USE_AS_LOCAL_MIRRORS){
+ if (! mirror_fails_vector[mirror_num]){
+ mirror_fails_vector[mirror_num]=true;
+ failed_mirrors_num++;
+ }
+ if (failed_mirrors_num>=mirror_fails_vector.size()){
+ phase=E_ALL_LOCAL_MIRRORS_FAILED;
+ failed_mirrors_num=0;
+ // clean the vector, to use it again when we switch to E_PROXY_FETCHER_DOWNLOADED phase
+ for (ulong mirr_num=0; mirr_num<mirror_fails_vector.size(); mirr_num++){
+ mirror_fails_vector[mirr_num]=false;
+ }
}
}
+ }catch(...){
+ error_log("Error in networkbroker.cpp: local_mirror_failed()");
}
}
void Tnetwork_distfile_broker::proxy_fetcher_mirror_failed(uint mirror_num){
- if (phase==E_PROXY_FETCHER_DOWNLOADED){
- if (! mirror_fails_vector[mirror_num]){
- mirror_fails_vector[mirror_num]=true;
- failed_mirrors_num++;
- }
- if (failed_mirrors_num>=mirror_fails_vector.size()){
- phase=E_ALL_PROXY_FETCHER_MIRRORS_FAILED;
- failed_mirrors_num=0;
- }
- }
-}
-
-/*
-bool Tnetwork_distfile_broker::some_mirrors_have_NOT_failed_yet(){
try{
- if (failed_mirrors_num<mirror_fails_vector.size()){
- return false;
- }else{
- return true;
+ if (phase==E_PROXY_FETCHER_DOWNLOADED){
+ if (! mirror_fails_vector[mirror_num]){
+ mirror_fails_vector[mirror_num]=true;
+ failed_mirrors_num++;
+ }
+ if (failed_mirrors_num>=mirror_fails_vector.size()){
+ phase=E_ALL_PROXY_FETCHER_MIRRORS_FAILED;
+ failed_mirrors_num=0;
+ }
}
-// for (ulong cur_mirror_num=0; cur_mirror_num<mirror_fails_vector.size();cur_mirror_num++){
-// if (! mirror_fails_vector[cur_mirror_num]){
-// return true;
-// }
-// }
-// return false;
}catch(...){
- error_log("Error in networkbroker.cpp: init()");
- return false;
+ error_log("Error in networkbroker.cpp: proxy_fetcher_mirror_failed()");
}
-}
-*/ \ No newline at end of file
+} \ No newline at end of file