1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
/*
* Copyright (C) 2010 Robin H.Johnson, Ovechko Kostyantyn <fastinetserver@gmail.com>.
*
* Project: IDFetch.
* Developer: Ovechko Kostyantyn Olexandrovich (Kharkiv State Technical University of Construction and Architecture, Ukraine).
* Mentor: Robin H. Johnson (Gentoo Linux: Developer, Trustee & Infrastructure Lead).
* Mentoring organization: Gentoo Linux.
* Sponsored by GSOC 2010.
*
* This file is part of Segget.
*
* Segget is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2.1 of the License, or (at your option) any later version.
*
* Segget is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with Segget; if not, write to the Free Software
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
*/
#include "mirror.h"
map<string,Tmirror *> mirror_list;
string strip_mirror_name(string path){
try{
string mirror_name;
mirror_name=path.substr(0,path.find("/",(path.find("://",0)+3)));
return mirror_name;
}catch(...){
error_log("Error in mirror.cpp: strip_mirror_name()");
return "";
}
}
string convert_to_coral_cdn_url(string url_address){
try{
string protocol, after_protocol;
if (split("://",url_address, protocol, after_protocol)){
error_log("Can't convert url:"+url_address+"to CoralCDN url");
return "";
}
if (protocol!="http") return "";
string site_name_and_port, path;
if (split("/",after_protocol,site_name_and_port,path)){
error_log("Can't convert url:"+url_address+"to CoralCDN url");
return "";
}
string site_name,site_port;
string new_coral_cdn_url;
if (split(":",site_name_and_port,site_name,site_port)){
string site_name=site_name_and_port;
new_coral_cdn_url=protocol+"://"+site_name+".nyud.net/"+path;
}else{;
new_coral_cdn_url=protocol+"://"+site_name+"."+site_port+".nyud.net/"+path;
}
return new_coral_cdn_url;
}catch(...){
error_log("Error in mirror.cpp: convert_to_coral_cdn_url()");
}
return "";
}
double Tmirror::mirror_on_the_wall(){
try{
double criterion=honesty*1000000000*dld_time/dld_size;
honesty=honesty*100/(100+settings.benchmark_oblivion);
return criterion;
}catch(...){
error_log("Error in mirror.cpp: mirror_on_the_wall()");
return 0;
}
}
void Tmirror::start(){
try{
if (!dld_time)
dld_time=1;
active_num++;
honesty=1;
}catch(...){
error_log("Error in mirror.cpp: start()");
}
}
void Tmirror::stop(ulong time, uint size){
try{
dld_time+=time/1000;
dld_size+=size;
honesty=1;
debug("Connnection to Mirror stopped: Time spent:"+toString(time)+"--- Size downloaded:"+toString(size));
active_num--;
}catch(...){
error_log("Error in mirror.cpp: stop()");
}
}
Tmirror* find_mirror(string mirror_url){
try{
map<string,Tmirror*>::const_iterator mirror_iterator = mirror_list.find(mirror_url);
if (mirror_iterator==mirror_list.end()){
Tmirror * Pnew_mirror=new Tmirror;
debug("Cant find mirror:"+mirror_url+" - creating new record");
mirror_list[mirror_url]=Pnew_mirror;
return Pnew_mirror;
}
else{
debug("Found mirror:"+mirror_url);
debug("==================>>");
debug(" time:"+toString((uint)mirror_iterator->second->dld_time));
debug(" size:"+toString(mirror_iterator->second->dld_size));
debug(" honesty:"+toString((uint)mirror_iterator->second->honesty));
debug(" criterion:"+toString((uint)mirror_iterator->second->mirror_on_the_wall()));
return mirror_iterator->second;
}
}catch(...){
error_log("Error in mirror.cpp: find_mirror()");
return 0;
}
}
|
GitWeb