rephist.c 97 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822282328242825282628272828282928302831283228332834283528362837283828392840284128422843284428452846284728482849285028512852285328542855285628572858285928602861286228632864286528662867286828692870287128722873287428752876287728782879288028812882288328842885288628872888288928902891289228932894289528962897289828992900290129022903290429052906290729082909291029112912291329142915291629172918291929202921292229232924292529262927292829292930293129322933293429352936293729382939294029412942294329442945294629472948294929502951295229532954295529562957295829592960296129622963296429652966296729682969297029712972297329742975297629772978297929802981298229832984298529862987298829892990299129922993299429952996299729982999300030013002300330043005300630073008300930103011301230133014301530163017301830193020302130223023
  1. /* Copyright (c) 2004-2006, Roger Dingledine, Nick Mathewson.
  2. * Copyright (c) 2007-2012, The Tor Project, Inc. */
  3. /* See LICENSE for licensing information */
  4. /**
  5. * \file rephist.c
  6. * \brief Basic history and "reputation" functionality to remember
  7. * which servers have worked in the past, how much bandwidth we've
  8. * been using, which ports we tend to want, and so on; further,
  9. * exit port statistics, cell statistics, and connection statistics.
  10. **/
  11. #include "or.h"
  12. #include "circuitlist.h"
  13. #include "circuituse.h"
  14. #include "config.h"
  15. #include "networkstatus.h"
  16. #include "nodelist.h"
  17. #include "rephist.h"
  18. #include "router.h"
  19. #include "routerlist.h"
  20. #include "ht.h"
  21. static void bw_arrays_init(void);
  22. static void predicted_ports_init(void);
  23. /** Total number of bytes currently allocated in fields used by rephist.c. */
  24. uint64_t rephist_total_alloc=0;
  25. /** Number of or_history_t objects currently allocated. */
  26. uint32_t rephist_total_num=0;
  27. /** If the total weighted run count of all runs for a router ever falls
  28. * below this amount, the router can be treated as having 0 MTBF. */
  29. #define STABILITY_EPSILON 0.0001
  30. /** Value by which to discount all old intervals for MTBF purposes. This
  31. * is compounded every STABILITY_INTERVAL. */
  32. #define STABILITY_ALPHA 0.95
  33. /** Interval at which to discount all old intervals for MTBF purposes. */
  34. #define STABILITY_INTERVAL (12*60*60)
  35. /* (This combination of ALPHA, INTERVAL, and EPSILON makes it so that an
  36. * interval that just ended counts twice as much as one that ended a week ago,
  37. * 20X as much as one that ended a month ago, and routers that have had no
  38. * uptime data for about half a year will get forgotten.) */
  39. /** History of an OR-\>OR link. */
  40. typedef struct link_history_t {
  41. /** When did we start tracking this list? */
  42. time_t since;
  43. /** When did we most recently note a change to this link */
  44. time_t changed;
  45. /** How many times did extending from OR1 to OR2 succeed? */
  46. unsigned long n_extend_ok;
  47. /** How many times did extending from OR1 to OR2 fail? */
  48. unsigned long n_extend_fail;
  49. } link_history_t;
  50. /** History of an OR. */
  51. typedef struct or_history_t {
  52. /** When did we start tracking this OR? */
  53. time_t since;
  54. /** When did we most recently note a change to this OR? */
  55. time_t changed;
  56. /** How many times did we successfully connect? */
  57. unsigned long n_conn_ok;
  58. /** How many times did we try to connect and fail?*/
  59. unsigned long n_conn_fail;
  60. /** How many seconds have we been connected to this OR before
  61. * 'up_since'? */
  62. unsigned long uptime;
  63. /** How many seconds have we been unable to connect to this OR before
  64. * 'down_since'? */
  65. unsigned long downtime;
  66. /** If nonzero, we have been connected since this time. */
  67. time_t up_since;
  68. /** If nonzero, we have been unable to connect since this time. */
  69. time_t down_since;
  70. /** The address at which we most recently connected to this OR
  71. * successfully. */
  72. tor_addr_t last_reached_addr;
  73. /** The port at which we most recently connected to this OR successfully */
  74. uint16_t last_reached_port;
  75. /* === For MTBF tracking: */
  76. /** Weighted sum total of all times that this router has been online.
  77. */
  78. unsigned long weighted_run_length;
  79. /** If the router is now online (according to stability-checking rules),
  80. * when did it come online? */
  81. time_t start_of_run;
  82. /** Sum of weights for runs in weighted_run_length. */
  83. double total_run_weights;
  84. /* === For fractional uptime tracking: */
  85. time_t start_of_downtime;
  86. unsigned long weighted_uptime;
  87. unsigned long total_weighted_time;
  88. /** Map from hex OR2 identity digest to a link_history_t for the link
  89. * from this OR to OR2. */
  90. digestmap_t *link_history_map;
  91. } or_history_t;
  92. /** When did we last multiply all routers' weighted_run_length and
  93. * total_run_weights by STABILITY_ALPHA? */
  94. static time_t stability_last_downrated = 0;
  95. /** */
  96. static time_t started_tracking_stability = 0;
  97. /** Map from hex OR identity digest to or_history_t. */
  98. static digestmap_t *history_map = NULL;
  99. /** Return the or_history_t for the OR with identity digest <b>id</b>,
  100. * creating it if necessary. */
  101. static or_history_t *
  102. get_or_history(const char* id)
  103. {
  104. or_history_t *hist;
  105. if (tor_digest_is_zero(id))
  106. return NULL;
  107. hist = digestmap_get(history_map, id);
  108. if (!hist) {
  109. hist = tor_malloc_zero(sizeof(or_history_t));
  110. rephist_total_alloc += sizeof(or_history_t);
  111. rephist_total_num++;
  112. hist->link_history_map = digestmap_new();
  113. hist->since = hist->changed = time(NULL);
  114. tor_addr_make_unspec(&hist->last_reached_addr);
  115. digestmap_set(history_map, id, hist);
  116. }
  117. return hist;
  118. }
  119. /** Return the link_history_t for the link from the first named OR to
  120. * the second, creating it if necessary. (ORs are identified by
  121. * identity digest.)
  122. */
  123. static link_history_t *
  124. get_link_history(const char *from_id, const char *to_id)
  125. {
  126. or_history_t *orhist;
  127. link_history_t *lhist;
  128. orhist = get_or_history(from_id);
  129. if (!orhist)
  130. return NULL;
  131. if (tor_digest_is_zero(to_id))
  132. return NULL;
  133. lhist = (link_history_t*) digestmap_get(orhist->link_history_map, to_id);
  134. if (!lhist) {
  135. lhist = tor_malloc_zero(sizeof(link_history_t));
  136. rephist_total_alloc += sizeof(link_history_t);
  137. lhist->since = lhist->changed = time(NULL);
  138. digestmap_set(orhist->link_history_map, to_id, lhist);
  139. }
  140. return lhist;
  141. }
  142. /** Helper: free storage held by a single link history entry. */
  143. static void
  144. free_link_history_(void *val)
  145. {
  146. rephist_total_alloc -= sizeof(link_history_t);
  147. tor_free(val);
  148. }
  149. /** Helper: free storage held by a single OR history entry. */
  150. static void
  151. free_or_history(void *_hist)
  152. {
  153. or_history_t *hist = _hist;
  154. digestmap_free(hist->link_history_map, free_link_history_);
  155. rephist_total_alloc -= sizeof(or_history_t);
  156. rephist_total_num--;
  157. tor_free(hist);
  158. }
  159. /** Update an or_history_t object <b>hist</b> so that its uptime/downtime
  160. * count is up-to-date as of <b>when</b>.
  161. */
  162. static void
  163. update_or_history(or_history_t *hist, time_t when)
  164. {
  165. tor_assert(hist);
  166. if (hist->up_since) {
  167. tor_assert(!hist->down_since);
  168. hist->uptime += (when - hist->up_since);
  169. hist->up_since = when;
  170. } else if (hist->down_since) {
  171. hist->downtime += (when - hist->down_since);
  172. hist->down_since = when;
  173. }
  174. }
  175. /** Initialize the static data structures for tracking history. */
  176. void
  177. rep_hist_init(void)
  178. {
  179. history_map = digestmap_new();
  180. bw_arrays_init();
  181. predicted_ports_init();
  182. }
  183. /** Helper: note that we are no longer connected to the router with history
  184. * <b>hist</b>. If <b>failed</b>, the connection failed; otherwise, it was
  185. * closed correctly. */
  186. static void
  187. mark_or_down(or_history_t *hist, time_t when, int failed)
  188. {
  189. if (hist->up_since) {
  190. hist->uptime += (when - hist->up_since);
  191. hist->up_since = 0;
  192. }
  193. if (failed && !hist->down_since) {
  194. hist->down_since = when;
  195. }
  196. }
  197. /** Helper: note that we are connected to the router with history
  198. * <b>hist</b>. */
  199. static void
  200. mark_or_up(or_history_t *hist, time_t when)
  201. {
  202. if (hist->down_since) {
  203. hist->downtime += (when - hist->down_since);
  204. hist->down_since = 0;
  205. }
  206. if (!hist->up_since) {
  207. hist->up_since = when;
  208. }
  209. }
  210. /** Remember that an attempt to connect to the OR with identity digest
  211. * <b>id</b> failed at <b>when</b>.
  212. */
  213. void
  214. rep_hist_note_connect_failed(const char* id, time_t when)
  215. {
  216. or_history_t *hist;
  217. hist = get_or_history(id);
  218. if (!hist)
  219. return;
  220. ++hist->n_conn_fail;
  221. mark_or_down(hist, when, 1);
  222. hist->changed = when;
  223. }
  224. /** Remember that an attempt to connect to the OR with identity digest
  225. * <b>id</b> succeeded at <b>when</b>.
  226. */
  227. void
  228. rep_hist_note_connect_succeeded(const char* id, time_t when)
  229. {
  230. or_history_t *hist;
  231. hist = get_or_history(id);
  232. if (!hist)
  233. return;
  234. ++hist->n_conn_ok;
  235. mark_or_up(hist, when);
  236. hist->changed = when;
  237. }
  238. /** Remember that we intentionally closed our connection to the OR
  239. * with identity digest <b>id</b> at <b>when</b>.
  240. */
  241. void
  242. rep_hist_note_disconnect(const char* id, time_t when)
  243. {
  244. or_history_t *hist;
  245. hist = get_or_history(id);
  246. if (!hist)
  247. return;
  248. mark_or_down(hist, when, 0);
  249. hist->changed = when;
  250. }
  251. /** Remember that our connection to the OR with identity digest
  252. * <b>id</b> had an error and stopped working at <b>when</b>.
  253. */
  254. void
  255. rep_hist_note_connection_died(const char* id, time_t when)
  256. {
  257. or_history_t *hist;
  258. if (!id) {
  259. /* If conn has no identity, it didn't complete its handshake, or something
  260. * went wrong. Ignore it.
  261. */
  262. return;
  263. }
  264. hist = get_or_history(id);
  265. if (!hist)
  266. return;
  267. mark_or_down(hist, when, 1);
  268. hist->changed = when;
  269. }
  270. /** We have just decided that this router with identity digest <b>id</b> is
  271. * reachable, meaning we will give it a "Running" flag for the next while. */
  272. void
  273. rep_hist_note_router_reachable(const char *id, const tor_addr_t *at_addr,
  274. const uint16_t at_port, time_t when)
  275. {
  276. or_history_t *hist = get_or_history(id);
  277. int was_in_run = 1;
  278. char tbuf[ISO_TIME_LEN+1];
  279. int addr_changed, port_changed;
  280. tor_assert(hist);
  281. tor_assert((!at_addr && !at_port) || (at_addr && at_port));
  282. addr_changed = at_addr &&
  283. tor_addr_compare(at_addr, &hist->last_reached_addr, CMP_EXACT) != 0;
  284. port_changed = at_port && at_port != hist->last_reached_port;
  285. if (!started_tracking_stability)
  286. started_tracking_stability = time(NULL);
  287. if (!hist->start_of_run) {
  288. hist->start_of_run = when;
  289. was_in_run = 0;
  290. }
  291. if (hist->start_of_downtime) {
  292. long down_length;
  293. format_local_iso_time(tbuf, hist->start_of_downtime);
  294. log_info(LD_HIST, "Router %s is now Running; it had been down since %s.",
  295. hex_str(id, DIGEST_LEN), tbuf);
  296. if (was_in_run)
  297. log_info(LD_HIST, " (Paradoxically, it was already Running too.)");
  298. down_length = when - hist->start_of_downtime;
  299. hist->total_weighted_time += down_length;
  300. hist->start_of_downtime = 0;
  301. } else if (addr_changed || port_changed) {
  302. /* If we're reachable, but the address changed, treat this as some
  303. * downtime. */
  304. int penalty = get_options()->TestingTorNetwork ? 240 : 3600;
  305. networkstatus_t *ns;
  306. if ((ns = networkstatus_get_latest_consensus())) {
  307. int fresh_interval = (int)(ns->fresh_until - ns->valid_after);
  308. int live_interval = (int)(ns->valid_until - ns->valid_after);
  309. /* on average, a descriptor addr change takes .5 intervals to make it
  310. * into a consensus, and half a liveness period to make it to
  311. * clients. */
  312. penalty = (int)(fresh_interval + live_interval) / 2;
  313. }
  314. format_local_iso_time(tbuf, hist->start_of_run);
  315. log_info(LD_HIST,"Router %s still seems Running, but its address appears "
  316. "to have changed since the last time it was reachable. I'm "
  317. "going to treat it as having been down for %d seconds",
  318. hex_str(id, DIGEST_LEN), penalty);
  319. rep_hist_note_router_unreachable(id, when-penalty);
  320. rep_hist_note_router_reachable(id, NULL, 0, when);
  321. } else {
  322. format_local_iso_time(tbuf, hist->start_of_run);
  323. if (was_in_run)
  324. log_debug(LD_HIST, "Router %s is still Running; it has been Running "
  325. "since %s", hex_str(id, DIGEST_LEN), tbuf);
  326. else
  327. log_info(LD_HIST,"Router %s is now Running; it was previously untracked",
  328. hex_str(id, DIGEST_LEN));
  329. }
  330. if (at_addr)
  331. tor_addr_copy(&hist->last_reached_addr, at_addr);
  332. if (at_port)
  333. hist->last_reached_port = at_port;
  334. }
  335. /** We have just decided that this router is unreachable, meaning
  336. * we are taking away its "Running" flag. */
  337. void
  338. rep_hist_note_router_unreachable(const char *id, time_t when)
  339. {
  340. or_history_t *hist = get_or_history(id);
  341. char tbuf[ISO_TIME_LEN+1];
  342. int was_running = 0;
  343. if (!started_tracking_stability)
  344. started_tracking_stability = time(NULL);
  345. tor_assert(hist);
  346. if (hist->start_of_run) {
  347. /*XXXX We could treat failed connections differently from failed
  348. * connect attempts. */
  349. long run_length = when - hist->start_of_run;
  350. format_local_iso_time(tbuf, hist->start_of_run);
  351. hist->total_run_weights += 1.0;
  352. hist->start_of_run = 0;
  353. if (run_length < 0) {
  354. unsigned long penalty = -run_length;
  355. #define SUBTRACT_CLAMPED(var, penalty) \
  356. do { (var) = (var) < (penalty) ? 0 : (var) - (penalty); } while (0)
  357. SUBTRACT_CLAMPED(hist->weighted_run_length, penalty);
  358. SUBTRACT_CLAMPED(hist->weighted_uptime, penalty);
  359. } else {
  360. hist->weighted_run_length += run_length;
  361. hist->weighted_uptime += run_length;
  362. hist->total_weighted_time += run_length;
  363. }
  364. was_running = 1;
  365. log_info(LD_HIST, "Router %s is now non-Running: it had previously been "
  366. "Running since %s. Its total weighted uptime is %lu/%lu.",
  367. hex_str(id, DIGEST_LEN), tbuf, hist->weighted_uptime,
  368. hist->total_weighted_time);
  369. }
  370. if (!hist->start_of_downtime) {
  371. hist->start_of_downtime = when;
  372. if (!was_running)
  373. log_info(LD_HIST, "Router %s is now non-Running; it was previously "
  374. "untracked.", hex_str(id, DIGEST_LEN));
  375. } else {
  376. if (!was_running) {
  377. format_local_iso_time(tbuf, hist->start_of_downtime);
  378. log_info(LD_HIST, "Router %s is still non-Running; it has been "
  379. "non-Running since %s.", hex_str(id, DIGEST_LEN), tbuf);
  380. }
  381. }
  382. }
  383. /** Helper: Discount all old MTBF data, if it is time to do so. Return
  384. * the time at which we should next discount MTBF data. */
  385. time_t
  386. rep_hist_downrate_old_runs(time_t now)
  387. {
  388. digestmap_iter_t *orhist_it;
  389. const char *digest1;
  390. or_history_t *hist;
  391. void *hist_p;
  392. double alpha = 1.0;
  393. if (!history_map)
  394. history_map = digestmap_new();
  395. if (!stability_last_downrated)
  396. stability_last_downrated = now;
  397. if (stability_last_downrated + STABILITY_INTERVAL > now)
  398. return stability_last_downrated + STABILITY_INTERVAL;
  399. /* Okay, we should downrate the data. By how much? */
  400. while (stability_last_downrated + STABILITY_INTERVAL < now) {
  401. stability_last_downrated += STABILITY_INTERVAL;
  402. alpha *= STABILITY_ALPHA;
  403. }
  404. log_info(LD_HIST, "Discounting all old stability info by a factor of %f",
  405. alpha);
  406. /* Multiply every w_r_l, t_r_w pair by alpha. */
  407. for (orhist_it = digestmap_iter_init(history_map);
  408. !digestmap_iter_done(orhist_it);
  409. orhist_it = digestmap_iter_next(history_map,orhist_it)) {
  410. digestmap_iter_get(orhist_it, &digest1, &hist_p);
  411. hist = hist_p;
  412. hist->weighted_run_length =
  413. (unsigned long)(hist->weighted_run_length * alpha);
  414. hist->total_run_weights *= alpha;
  415. hist->weighted_uptime = (unsigned long)(hist->weighted_uptime * alpha);
  416. hist->total_weighted_time = (unsigned long)
  417. (hist->total_weighted_time * alpha);
  418. }
  419. return stability_last_downrated + STABILITY_INTERVAL;
  420. }
  421. /** Helper: Return the weighted MTBF of the router with history <b>hist</b>. */
  422. static double
  423. get_stability(or_history_t *hist, time_t when)
  424. {
  425. long total = hist->weighted_run_length;
  426. double total_weights = hist->total_run_weights;
  427. if (hist->start_of_run) {
  428. /* We're currently in a run. Let total and total_weights hold the values
  429. * they would hold if the current run were to end now. */
  430. total += (when-hist->start_of_run);
  431. total_weights += 1.0;
  432. }
  433. if (total_weights < STABILITY_EPSILON) {
  434. /* Round down to zero, and avoid divide-by-zero. */
  435. return 0.0;
  436. }
  437. return total / total_weights;
  438. }
  439. /** Return the total amount of time we've been observing, with each run of
  440. * time downrated by the appropriate factor. */
  441. static long
  442. get_total_weighted_time(or_history_t *hist, time_t when)
  443. {
  444. long total = hist->total_weighted_time;
  445. if (hist->start_of_run) {
  446. total += (when - hist->start_of_run);
  447. } else if (hist->start_of_downtime) {
  448. total += (when - hist->start_of_downtime);
  449. }
  450. return total;
  451. }
  452. /** Helper: Return the weighted percent-of-time-online of the router with
  453. * history <b>hist</b>. */
  454. static double
  455. get_weighted_fractional_uptime(or_history_t *hist, time_t when)
  456. {
  457. long total = hist->total_weighted_time;
  458. long up = hist->weighted_uptime;
  459. if (hist->start_of_run) {
  460. long run_length = (when - hist->start_of_run);
  461. up += run_length;
  462. total += run_length;
  463. } else if (hist->start_of_downtime) {
  464. total += (when - hist->start_of_downtime);
  465. }
  466. if (!total) {
  467. /* Avoid calling anybody's uptime infinity (which should be impossible if
  468. * the code is working), or NaN (which can happen for any router we haven't
  469. * observed up or down yet). */
  470. return 0.0;
  471. }
  472. return ((double) up) / total;
  473. }
  474. /** Return how long the router whose identity digest is <b>id</b> has
  475. * been reachable. Return 0 if the router is unknown or currently deemed
  476. * unreachable. */
  477. long
  478. rep_hist_get_uptime(const char *id, time_t when)
  479. {
  480. or_history_t *hist = get_or_history(id);
  481. if (!hist)
  482. return 0;
  483. if (!hist->start_of_run || when < hist->start_of_run)
  484. return 0;
  485. return when - hist->start_of_run;
  486. }
  487. /** Return an estimated MTBF for the router whose identity digest is
  488. * <b>id</b>. Return 0 if the router is unknown. */
  489. double
  490. rep_hist_get_stability(const char *id, time_t when)
  491. {
  492. or_history_t *hist = get_or_history(id);
  493. if (!hist)
  494. return 0.0;
  495. return get_stability(hist, when);
  496. }
  497. /** Return an estimated percent-of-time-online for the router whose identity
  498. * digest is <b>id</b>. Return 0 if the router is unknown. */
  499. double
  500. rep_hist_get_weighted_fractional_uptime(const char *id, time_t when)
  501. {
  502. or_history_t *hist = get_or_history(id);
  503. if (!hist)
  504. return 0.0;
  505. return get_weighted_fractional_uptime(hist, when);
  506. }
  507. /** Return a number representing how long we've known about the router whose
  508. * digest is <b>id</b>. Return 0 if the router is unknown.
  509. *
  510. * Be careful: this measure increases monotonically as we know the router for
  511. * longer and longer, but it doesn't increase linearly.
  512. */
  513. long
  514. rep_hist_get_weighted_time_known(const char *id, time_t when)
  515. {
  516. or_history_t *hist = get_or_history(id);
  517. if (!hist)
  518. return 0;
  519. return get_total_weighted_time(hist, when);
  520. }
  521. /** Return true if we've been measuring MTBFs for long enough to
  522. * pronounce on Stability. */
  523. int
  524. rep_hist_have_measured_enough_stability(void)
  525. {
  526. /* XXXX023 This doesn't do so well when we change our opinion
  527. * as to whether we're tracking router stability. */
  528. return started_tracking_stability < time(NULL) - 4*60*60;
  529. }
  530. /** Remember that we successfully extended from the OR with identity
  531. * digest <b>from_id</b> to the OR with identity digest
  532. * <b>to_name</b>.
  533. */
  534. void
  535. rep_hist_note_extend_succeeded(const char *from_id, const char *to_id)
  536. {
  537. link_history_t *hist;
  538. /* log_fn(LOG_WARN, "EXTEND SUCCEEDED: %s->%s",from_name,to_name); */
  539. hist = get_link_history(from_id, to_id);
  540. if (!hist)
  541. return;
  542. ++hist->n_extend_ok;
  543. hist->changed = time(NULL);
  544. }
  545. /** Remember that we tried to extend from the OR with identity digest
  546. * <b>from_id</b> to the OR with identity digest <b>to_name</b>, but
  547. * failed.
  548. */
  549. void
  550. rep_hist_note_extend_failed(const char *from_id, const char *to_id)
  551. {
  552. link_history_t *hist;
  553. /* log_fn(LOG_WARN, "EXTEND FAILED: %s->%s",from_name,to_name); */
  554. hist = get_link_history(from_id, to_id);
  555. if (!hist)
  556. return;
  557. ++hist->n_extend_fail;
  558. hist->changed = time(NULL);
  559. }
  560. /** Log all the reliability data we have remembered, with the chosen
  561. * severity.
  562. */
  563. void
  564. rep_hist_dump_stats(time_t now, int severity)
  565. {
  566. digestmap_iter_t *lhist_it;
  567. digestmap_iter_t *orhist_it;
  568. const char *name1, *name2, *digest1, *digest2;
  569. char hexdigest1[HEX_DIGEST_LEN+1];
  570. char hexdigest2[HEX_DIGEST_LEN+1];
  571. or_history_t *or_history;
  572. link_history_t *link_history;
  573. void *or_history_p, *link_history_p;
  574. double uptime;
  575. char buffer[2048];
  576. size_t len;
  577. int ret;
  578. unsigned long upt, downt;
  579. const node_t *node;
  580. rep_history_clean(now - get_options()->RephistTrackTime);
  581. log(severity, LD_HIST, "--------------- Dumping history information:");
  582. for (orhist_it = digestmap_iter_init(history_map);
  583. !digestmap_iter_done(orhist_it);
  584. orhist_it = digestmap_iter_next(history_map,orhist_it)) {
  585. double s;
  586. long stability;
  587. digestmap_iter_get(orhist_it, &digest1, &or_history_p);
  588. or_history = (or_history_t*) or_history_p;
  589. if ((node = node_get_by_id(digest1)) && node_get_nickname(node))
  590. name1 = node_get_nickname(node);
  591. else
  592. name1 = "(unknown)";
  593. base16_encode(hexdigest1, sizeof(hexdigest1), digest1, DIGEST_LEN);
  594. update_or_history(or_history, now);
  595. upt = or_history->uptime;
  596. downt = or_history->downtime;
  597. s = get_stability(or_history, now);
  598. stability = (long)s;
  599. if (upt+downt) {
  600. uptime = ((double)upt) / (upt+downt);
  601. } else {
  602. uptime=1.0;
  603. }
  604. log(severity, LD_HIST,
  605. "OR %s [%s]: %ld/%ld good connections; uptime %ld/%ld sec (%.2f%%); "
  606. "wmtbf %lu:%02lu:%02lu",
  607. name1, hexdigest1,
  608. or_history->n_conn_ok, or_history->n_conn_fail+or_history->n_conn_ok,
  609. upt, upt+downt, uptime*100.0,
  610. stability/3600, (stability/60)%60, stability%60);
  611. if (!digestmap_isempty(or_history->link_history_map)) {
  612. strlcpy(buffer, " Extend attempts: ", sizeof(buffer));
  613. len = strlen(buffer);
  614. for (lhist_it = digestmap_iter_init(or_history->link_history_map);
  615. !digestmap_iter_done(lhist_it);
  616. lhist_it = digestmap_iter_next(or_history->link_history_map,
  617. lhist_it)) {
  618. digestmap_iter_get(lhist_it, &digest2, &link_history_p);
  619. if ((node = node_get_by_id(digest2)) && node_get_nickname(node))
  620. name2 = node_get_nickname(node);
  621. else
  622. name2 = "(unknown)";
  623. link_history = (link_history_t*) link_history_p;
  624. base16_encode(hexdigest2, sizeof(hexdigest2), digest2, DIGEST_LEN);
  625. ret = tor_snprintf(buffer+len, 2048-len, "%s [%s](%ld/%ld); ",
  626. name2,
  627. hexdigest2,
  628. link_history->n_extend_ok,
  629. link_history->n_extend_ok+link_history->n_extend_fail);
  630. if (ret<0)
  631. break;
  632. else
  633. len += ret;
  634. }
  635. log(severity, LD_HIST, "%s", buffer);
  636. }
  637. }
  638. }
  639. /** Remove history info for routers/links that haven't changed since
  640. * <b>before</b>.
  641. */
  642. void
  643. rep_history_clean(time_t before)
  644. {
  645. int authority = authdir_mode(get_options());
  646. or_history_t *or_history;
  647. link_history_t *link_history;
  648. void *or_history_p, *link_history_p;
  649. digestmap_iter_t *orhist_it, *lhist_it;
  650. const char *d1, *d2;
  651. orhist_it = digestmap_iter_init(history_map);
  652. while (!digestmap_iter_done(orhist_it)) {
  653. int remove;
  654. digestmap_iter_get(orhist_it, &d1, &or_history_p);
  655. or_history = or_history_p;
  656. remove = authority ? (or_history->total_run_weights < STABILITY_EPSILON &&
  657. !or_history->start_of_run)
  658. : (or_history->changed < before);
  659. if (remove) {
  660. orhist_it = digestmap_iter_next_rmv(history_map, orhist_it);
  661. free_or_history(or_history);
  662. continue;
  663. }
  664. for (lhist_it = digestmap_iter_init(or_history->link_history_map);
  665. !digestmap_iter_done(lhist_it); ) {
  666. digestmap_iter_get(lhist_it, &d2, &link_history_p);
  667. link_history = link_history_p;
  668. if (link_history->changed < before) {
  669. lhist_it = digestmap_iter_next_rmv(or_history->link_history_map,
  670. lhist_it);
  671. rephist_total_alloc -= sizeof(link_history_t);
  672. tor_free(link_history);
  673. continue;
  674. }
  675. lhist_it = digestmap_iter_next(or_history->link_history_map,lhist_it);
  676. }
  677. orhist_it = digestmap_iter_next(history_map, orhist_it);
  678. }
  679. }
  680. /** Write MTBF data to disk. Return 0 on success, negative on failure.
  681. *
  682. * If <b>missing_means_down</b>, then if we're about to write an entry
  683. * that is still considered up but isn't in our routerlist, consider it
  684. * to be down. */
  685. int
  686. rep_hist_record_mtbf_data(time_t now, int missing_means_down)
  687. {
  688. char time_buf[ISO_TIME_LEN+1];
  689. digestmap_iter_t *orhist_it;
  690. const char *digest;
  691. void *or_history_p;
  692. or_history_t *hist;
  693. open_file_t *open_file = NULL;
  694. FILE *f;
  695. {
  696. char *filename = get_datadir_fname("router-stability");
  697. f = start_writing_to_stdio_file(filename, OPEN_FLAGS_REPLACE|O_TEXT, 0600,
  698. &open_file);
  699. tor_free(filename);
  700. if (!f)
  701. return -1;
  702. }
  703. /* File format is:
  704. * FormatLine *KeywordLine Data
  705. *
  706. * FormatLine = "format 1" NL
  707. * KeywordLine = Keyword SP Arguments NL
  708. * Data = "data" NL *RouterMTBFLine "." NL
  709. * RouterMTBFLine = Fingerprint SP WeightedRunLen SP
  710. * TotalRunWeights [SP S=StartRunTime] NL
  711. */
  712. #define PUT(s) STMT_BEGIN if (fputs((s),f)<0) goto err; STMT_END
  713. #define PRINTF(args) STMT_BEGIN if (fprintf args <0) goto err; STMT_END
  714. PUT("format 2\n");
  715. format_iso_time(time_buf, time(NULL));
  716. PRINTF((f, "stored-at %s\n", time_buf));
  717. if (started_tracking_stability) {
  718. format_iso_time(time_buf, started_tracking_stability);
  719. PRINTF((f, "tracked-since %s\n", time_buf));
  720. }
  721. if (stability_last_downrated) {
  722. format_iso_time(time_buf, stability_last_downrated);
  723. PRINTF((f, "last-downrated %s\n", time_buf));
  724. }
  725. PUT("data\n");
  726. /* XXX Nick: now bridge auths record this for all routers too.
  727. * Should we make them record it only for bridge routers? -RD
  728. * Not for 0.2.0. -NM */
  729. for (orhist_it = digestmap_iter_init(history_map);
  730. !digestmap_iter_done(orhist_it);
  731. orhist_it = digestmap_iter_next(history_map,orhist_it)) {
  732. char dbuf[HEX_DIGEST_LEN+1];
  733. const char *t = NULL;
  734. digestmap_iter_get(orhist_it, &digest, &or_history_p);
  735. hist = (or_history_t*) or_history_p;
  736. base16_encode(dbuf, sizeof(dbuf), digest, DIGEST_LEN);
  737. if (missing_means_down && hist->start_of_run &&
  738. !router_get_by_id_digest(digest)) {
  739. /* We think this relay is running, but it's not listed in our
  740. * routerlist. Somehow it fell out without telling us it went
  741. * down. Complain and also correct it. */
  742. log_info(LD_HIST,
  743. "Relay '%s' is listed as up in rephist, but it's not in "
  744. "our routerlist. Correcting.", dbuf);
  745. rep_hist_note_router_unreachable(digest, now);
  746. }
  747. PRINTF((f, "R %s\n", dbuf));
  748. if (hist->start_of_run > 0) {
  749. format_iso_time(time_buf, hist->start_of_run);
  750. t = time_buf;
  751. }
  752. PRINTF((f, "+MTBF %lu %.5f%s%s\n",
  753. hist->weighted_run_length, hist->total_run_weights,
  754. t ? " S=" : "", t ? t : ""));
  755. t = NULL;
  756. if (hist->start_of_downtime > 0) {
  757. format_iso_time(time_buf, hist->start_of_downtime);
  758. t = time_buf;
  759. }
  760. PRINTF((f, "+WFU %lu %lu%s%s\n",
  761. hist->weighted_uptime, hist->total_weighted_time,
  762. t ? " S=" : "", t ? t : ""));
  763. }
  764. PUT(".\n");
  765. #undef PUT
  766. #undef PRINTF
  767. return finish_writing_to_file(open_file);
  768. err:
  769. abort_writing_to_file(open_file);
  770. return -1;
  771. }
  772. /** Format the current tracked status of the router in <b>hist</b> at time
  773. * <b>now</b> for analysis; return it in a newly allocated string. */
  774. static char *
  775. rep_hist_format_router_status(or_history_t *hist, time_t now)
  776. {
  777. char sor_buf[ISO_TIME_LEN+1];
  778. char sod_buf[ISO_TIME_LEN+1];
  779. double wfu;
  780. double mtbf;
  781. int up = 0, down = 0;
  782. char *cp = NULL;
  783. if (hist->start_of_run) {
  784. format_iso_time(sor_buf, hist->start_of_run);
  785. up = 1;
  786. }
  787. if (hist->start_of_downtime) {
  788. format_iso_time(sod_buf, hist->start_of_downtime);
  789. down = 1;
  790. }
  791. wfu = get_weighted_fractional_uptime(hist, now);
  792. mtbf = get_stability(hist, now);
  793. tor_asprintf(&cp,
  794. "%s%s%s"
  795. "%s%s%s"
  796. "wfu %0.3f\n"
  797. " weighted-time %lu\n"
  798. " weighted-uptime %lu\n"
  799. "mtbf %0.1f\n"
  800. " weighted-run-length %lu\n"
  801. " total-run-weights %f\n",
  802. up?"uptime-started ":"", up?sor_buf:"", up?" UTC\n":"",
  803. down?"downtime-started ":"", down?sod_buf:"", down?" UTC\n":"",
  804. wfu,
  805. hist->total_weighted_time,
  806. hist->weighted_uptime,
  807. mtbf,
  808. hist->weighted_run_length,
  809. hist->total_run_weights
  810. );
  811. return cp;
  812. }
  813. /** The last stability analysis document that we created, or NULL if we never
  814. * have created one. */
  815. static char *last_stability_doc = NULL;
  816. /** The last time we created a stability analysis document, or 0 if we never
  817. * have created one. */
  818. static time_t built_last_stability_doc_at = 0;
  819. /** Shortest allowable time between building two stability documents. */
  820. #define MAX_STABILITY_DOC_BUILD_RATE (3*60)
  821. /** Return a pointer to a NUL-terminated document describing our view of the
  822. * stability of the routers we've been tracking. Return NULL on failure. */
  823. const char *
  824. rep_hist_get_router_stability_doc(time_t now)
  825. {
  826. char *result;
  827. smartlist_t *chunks;
  828. if (built_last_stability_doc_at + MAX_STABILITY_DOC_BUILD_RATE > now)
  829. return last_stability_doc;
  830. if (!history_map)
  831. return NULL;
  832. tor_free(last_stability_doc);
  833. chunks = smartlist_new();
  834. if (rep_hist_have_measured_enough_stability()) {
  835. smartlist_add(chunks, tor_strdup("we-have-enough-measurements\n"));
  836. } else {
  837. smartlist_add(chunks, tor_strdup("we-do-not-have-enough-measurements\n"));
  838. }
  839. DIGESTMAP_FOREACH(history_map, id, or_history_t *, hist) {
  840. const node_t *node;
  841. char dbuf[BASE64_DIGEST_LEN+1];
  842. char *info;
  843. digest_to_base64(dbuf, id);
  844. node = node_get_by_id(id);
  845. if (node) {
  846. char ip[INET_NTOA_BUF_LEN+1];
  847. char tbuf[ISO_TIME_LEN+1];
  848. time_t published = node_get_published_on(node);
  849. node_get_address_string(node,ip,sizeof(ip));
  850. if (published > 0)
  851. format_iso_time(tbuf, published);
  852. else
  853. strlcpy(tbuf, "???", sizeof(tbuf));
  854. smartlist_add_asprintf(chunks,
  855. "router %s %s %s\n"
  856. "published %s\n"
  857. "relevant-flags %s%s%s\n"
  858. "declared-uptime %ld\n",
  859. dbuf, node_get_nickname(node), ip,
  860. tbuf,
  861. node->is_running ? "Running " : "",
  862. node->is_valid ? "Valid " : "",
  863. node->ri && node->ri->is_hibernating ? "Hibernating " : "",
  864. node_get_declared_uptime(node));
  865. } else {
  866. smartlist_add_asprintf(chunks,
  867. "router %s {no descriptor}\n", dbuf);
  868. }
  869. info = rep_hist_format_router_status(hist, now);
  870. if (info)
  871. smartlist_add(chunks, info);
  872. } DIGESTMAP_FOREACH_END;
  873. result = smartlist_join_strings(chunks, "", 0, NULL);
  874. SMARTLIST_FOREACH(chunks, char *, cp, tor_free(cp));
  875. smartlist_free(chunks);
  876. last_stability_doc = result;
  877. built_last_stability_doc_at = time(NULL);
  878. return result;
  879. }
  880. /** Helper: return the first j >= i such that !strcmpstart(sl[j], prefix) and
  881. * such that no line sl[k] with i <= k < j starts with "R ". Return -1 if no
  882. * such line exists. */
  883. static int
  884. find_next_with(smartlist_t *sl, int i, const char *prefix)
  885. {
  886. for ( ; i < smartlist_len(sl); ++i) {
  887. const char *line = smartlist_get(sl, i);
  888. if (!strcmpstart(line, prefix))
  889. return i;
  890. if (!strcmpstart(line, "R "))
  891. return -1;
  892. }
  893. return -1;
  894. }
  895. /** How many bad times has parse_possibly_bad_iso_time() parsed? */
  896. static int n_bogus_times = 0;
  897. /** Parse the ISO-formatted time in <b>s</b> into *<b>time_out</b>, but
  898. * round any pre-1970 date to Jan 1, 1970. */
  899. static int
  900. parse_possibly_bad_iso_time(const char *s, time_t *time_out)
  901. {
  902. int year;
  903. char b[5];
  904. strlcpy(b, s, sizeof(b));
  905. b[4] = '\0';
  906. year = (int)tor_parse_long(b, 10, 0, INT_MAX, NULL, NULL);
  907. if (year < 1970) {
  908. *time_out = 0;
  909. ++n_bogus_times;
  910. return 0;
  911. } else
  912. return parse_iso_time(s, time_out);
  913. }
  914. /** We've read a time <b>t</b> from a file stored at <b>stored_at</b>, which
  915. * says we started measuring at <b>started_measuring</b>. Return a new number
  916. * that's about as much before <b>now</b> as <b>t</b> was before
  917. * <b>stored_at</b>.
  918. */
  919. static INLINE time_t
  920. correct_time(time_t t, time_t now, time_t stored_at, time_t started_measuring)
  921. {
  922. if (t < started_measuring - 24*60*60*365)
  923. return 0;
  924. else if (t < started_measuring)
  925. return started_measuring;
  926. else if (t > stored_at)
  927. return 0;
  928. else {
  929. long run_length = stored_at - t;
  930. t = now - run_length;
  931. if (t < started_measuring)
  932. t = started_measuring;
  933. return t;
  934. }
  935. }
  936. /** Load MTBF data from disk. Returns 0 on success or recoverable error, -1
  937. * on failure. */
  938. int
  939. rep_hist_load_mtbf_data(time_t now)
  940. {
  941. /* XXXX won't handle being called while history is already populated. */
  942. smartlist_t *lines;
  943. const char *line = NULL;
  944. int r=0, i;
  945. time_t last_downrated = 0, stored_at = 0, tracked_since = 0;
  946. time_t latest_possible_start = now;
  947. long format = -1;
  948. {
  949. char *filename = get_datadir_fname("router-stability");
  950. char *d = read_file_to_str(filename, RFTS_IGNORE_MISSING, NULL);
  951. tor_free(filename);
  952. if (!d)
  953. return -1;
  954. lines = smartlist_new();
  955. smartlist_split_string(lines, d, "\n", SPLIT_SKIP_SPACE, 0);
  956. tor_free(d);
  957. }
  958. {
  959. const char *firstline;
  960. if (smartlist_len(lines)>4) {
  961. firstline = smartlist_get(lines, 0);
  962. if (!strcmpstart(firstline, "format "))
  963. format = tor_parse_long(firstline+strlen("format "),
  964. 10, -1, LONG_MAX, NULL, NULL);
  965. }
  966. }
  967. if (format != 1 && format != 2) {
  968. log_warn(LD_HIST,
  969. "Unrecognized format in mtbf history file. Skipping.");
  970. goto err;
  971. }
  972. for (i = 1; i < smartlist_len(lines); ++i) {
  973. line = smartlist_get(lines, i);
  974. if (!strcmp(line, "data"))
  975. break;
  976. if (!strcmpstart(line, "last-downrated ")) {
  977. if (parse_iso_time(line+strlen("last-downrated "), &last_downrated)<0)
  978. log_warn(LD_HIST,"Couldn't parse downrate time in mtbf "
  979. "history file.");
  980. }
  981. if (!strcmpstart(line, "stored-at ")) {
  982. if (parse_iso_time(line+strlen("stored-at "), &stored_at)<0)
  983. log_warn(LD_HIST,"Couldn't parse stored time in mtbf "
  984. "history file.");
  985. }
  986. if (!strcmpstart(line, "tracked-since ")) {
  987. if (parse_iso_time(line+strlen("tracked-since "), &tracked_since)<0)
  988. log_warn(LD_HIST,"Couldn't parse started-tracking time in mtbf "
  989. "history file.");
  990. }
  991. }
  992. if (last_downrated > now)
  993. last_downrated = now;
  994. if (tracked_since > now)
  995. tracked_since = now;
  996. if (!stored_at) {
  997. log_warn(LD_HIST, "No stored time recorded.");
  998. goto err;
  999. }
  1000. if (line && !strcmp(line, "data"))
  1001. ++i;
  1002. n_bogus_times = 0;
  1003. for (; i < smartlist_len(lines); ++i) {
  1004. char digest[DIGEST_LEN];
  1005. char hexbuf[HEX_DIGEST_LEN+1];
  1006. char mtbf_timebuf[ISO_TIME_LEN+1];
  1007. char wfu_timebuf[ISO_TIME_LEN+1];
  1008. time_t start_of_run = 0;
  1009. time_t start_of_downtime = 0;
  1010. int have_mtbf = 0, have_wfu = 0;
  1011. long wrl = 0;
  1012. double trw = 0;
  1013. long wt_uptime = 0, total_wt_time = 0;
  1014. int n;
  1015. or_history_t *hist;
  1016. line = smartlist_get(lines, i);
  1017. if (!strcmp(line, "."))
  1018. break;
  1019. mtbf_timebuf[0] = '\0';
  1020. wfu_timebuf[0] = '\0';
  1021. if (format == 1) {
  1022. n = tor_sscanf(line, "%40s %ld %lf S=%10s %8s",
  1023. hexbuf, &wrl, &trw, mtbf_timebuf, mtbf_timebuf+11);
  1024. if (n != 3 && n != 5) {
  1025. log_warn(LD_HIST, "Couldn't scan line %s", escaped(line));
  1026. continue;
  1027. }
  1028. have_mtbf = 1;
  1029. } else {
  1030. // format == 2.
  1031. int mtbf_idx, wfu_idx;
  1032. if (strcmpstart(line, "R ") || strlen(line) < 2+HEX_DIGEST_LEN)
  1033. continue;
  1034. strlcpy(hexbuf, line+2, sizeof(hexbuf));
  1035. mtbf_idx = find_next_with(lines, i+1, "+MTBF ");
  1036. wfu_idx = find_next_with(lines, i+1, "+WFU ");
  1037. if (mtbf_idx >= 0) {
  1038. const char *mtbfline = smartlist_get(lines, mtbf_idx);
  1039. n = tor_sscanf(mtbfline, "+MTBF %lu %lf S=%10s %8s",
  1040. &wrl, &trw, mtbf_timebuf, mtbf_timebuf+11);
  1041. if (n == 2 || n == 4) {
  1042. have_mtbf = 1;
  1043. } else {
  1044. log_warn(LD_HIST, "Couldn't scan +MTBF line %s",
  1045. escaped(mtbfline));
  1046. }
  1047. }
  1048. if (wfu_idx >= 0) {
  1049. const char *wfuline = smartlist_get(lines, wfu_idx);
  1050. n = tor_sscanf(wfuline, "+WFU %lu %lu S=%10s %8s",
  1051. &wt_uptime, &total_wt_time,
  1052. wfu_timebuf, wfu_timebuf+11);
  1053. if (n == 2 || n == 4) {
  1054. have_wfu = 1;
  1055. } else {
  1056. log_warn(LD_HIST, "Couldn't scan +WFU line %s", escaped(wfuline));
  1057. }
  1058. }
  1059. if (wfu_idx > i)
  1060. i = wfu_idx;
  1061. if (mtbf_idx > i)
  1062. i = mtbf_idx;
  1063. }
  1064. if (base16_decode(digest, DIGEST_LEN, hexbuf, HEX_DIGEST_LEN) < 0) {
  1065. log_warn(LD_HIST, "Couldn't hex string %s", escaped(hexbuf));
  1066. continue;
  1067. }
  1068. hist = get_or_history(digest);
  1069. if (!hist)
  1070. continue;
  1071. if (have_mtbf) {
  1072. if (mtbf_timebuf[0]) {
  1073. mtbf_timebuf[10] = ' ';
  1074. if (parse_possibly_bad_iso_time(mtbf_timebuf, &start_of_run)<0)
  1075. log_warn(LD_HIST, "Couldn't parse time %s",
  1076. escaped(mtbf_timebuf));
  1077. }
  1078. hist->start_of_run = correct_time(start_of_run, now, stored_at,
  1079. tracked_since);
  1080. if (hist->start_of_run < latest_possible_start + wrl)
  1081. latest_possible_start = hist->start_of_run - wrl;
  1082. hist->weighted_run_length = wrl;
  1083. hist->total_run_weights = trw;
  1084. }
  1085. if (have_wfu) {
  1086. if (wfu_timebuf[0]) {
  1087. wfu_timebuf[10] = ' ';
  1088. if (parse_possibly_bad_iso_time(wfu_timebuf, &start_of_downtime)<0)
  1089. log_warn(LD_HIST, "Couldn't parse time %s", escaped(wfu_timebuf));
  1090. }
  1091. }
  1092. hist->start_of_downtime = correct_time(start_of_downtime, now, stored_at,
  1093. tracked_since);
  1094. hist->weighted_uptime = wt_uptime;
  1095. hist->total_weighted_time = total_wt_time;
  1096. }
  1097. if (strcmp(line, "."))
  1098. log_warn(LD_HIST, "Truncated MTBF file.");
  1099. if (tracked_since < 86400*365) /* Recover from insanely early value. */
  1100. tracked_since = latest_possible_start;
  1101. stability_last_downrated = last_downrated;
  1102. started_tracking_stability = tracked_since;
  1103. goto done;
  1104. err:
  1105. r = -1;
  1106. done:
  1107. SMARTLIST_FOREACH(lines, char *, cp, tor_free(cp));
  1108. smartlist_free(lines);
  1109. return r;
  1110. }
  1111. /** For how many seconds do we keep track of individual per-second bandwidth
  1112. * totals? */
  1113. #define NUM_SECS_ROLLING_MEASURE 10
  1114. /** How large are the intervals for which we track and report bandwidth use? */
  1115. /* XXXX Watch out! Before Tor 0.2.2.21-alpha, using any other value here would
  1116. * generate an unparseable state file. */
  1117. #define NUM_SECS_BW_SUM_INTERVAL (15*60)
  1118. /** How far in the past do we remember and publish bandwidth use? */
  1119. #define NUM_SECS_BW_SUM_IS_VALID (24*60*60)
  1120. /** How many bandwidth usage intervals do we remember? (derived) */
  1121. #define NUM_TOTALS (NUM_SECS_BW_SUM_IS_VALID/NUM_SECS_BW_SUM_INTERVAL)
  1122. /** Structure to track bandwidth use, and remember the maxima for a given
  1123. * time period.
  1124. */
  1125. typedef struct bw_array_t {
  1126. /** Observation array: Total number of bytes transferred in each of the last
  1127. * NUM_SECS_ROLLING_MEASURE seconds. This is used as a circular array. */
  1128. uint64_t obs[NUM_SECS_ROLLING_MEASURE];
  1129. int cur_obs_idx; /**< Current position in obs. */
  1130. time_t cur_obs_time; /**< Time represented in obs[cur_obs_idx] */
  1131. uint64_t total_obs; /**< Total for all members of obs except
  1132. * obs[cur_obs_idx] */
  1133. uint64_t max_total; /**< Largest value that total_obs has taken on in the
  1134. * current period. */
  1135. uint64_t total_in_period; /**< Total bytes transferred in the current
  1136. * period. */
  1137. /** When does the next period begin? */
  1138. time_t next_period;
  1139. /** Where in 'maxima' should the maximum bandwidth usage for the current
  1140. * period be stored? */
  1141. int next_max_idx;
  1142. /** How many values in maxima/totals have been set ever? */
  1143. int num_maxes_set;
  1144. /** Circular array of the maximum
  1145. * bandwidth-per-NUM_SECS_ROLLING_MEASURE usage for the last
  1146. * NUM_TOTALS periods */
  1147. uint64_t maxima[NUM_TOTALS];
  1148. /** Circular array of the total bandwidth usage for the last NUM_TOTALS
  1149. * periods */
  1150. uint64_t totals[NUM_TOTALS];
  1151. } bw_array_t;
  1152. /** Shift the current period of b forward by one. */
  1153. static void
  1154. commit_max(bw_array_t *b)
  1155. {
  1156. /* Store total from current period. */
  1157. b->totals[b->next_max_idx] = b->total_in_period;
  1158. /* Store maximum from current period. */
  1159. b->maxima[b->next_max_idx++] = b->max_total;
  1160. /* Advance next_period and next_max_idx */
  1161. b->next_period += NUM_SECS_BW_SUM_INTERVAL;
  1162. if (b->next_max_idx == NUM_TOTALS)
  1163. b->next_max_idx = 0;
  1164. if (b->num_maxes_set < NUM_TOTALS)
  1165. ++b->num_maxes_set;
  1166. /* Reset max_total. */
  1167. b->max_total = 0;
  1168. /* Reset total_in_period. */
  1169. b->total_in_period = 0;
  1170. }
  1171. /** Shift the current observation time of <b>b</b> forward by one second. */
  1172. static INLINE void
  1173. advance_obs(bw_array_t *b)
  1174. {
  1175. int nextidx;
  1176. uint64_t total;
  1177. /* Calculate the total bandwidth for the last NUM_SECS_ROLLING_MEASURE
  1178. * seconds; adjust max_total as needed.*/
  1179. total = b->total_obs + b->obs[b->cur_obs_idx];
  1180. if (total > b->max_total)
  1181. b->max_total = total;
  1182. nextidx = b->cur_obs_idx+1;
  1183. if (nextidx == NUM_SECS_ROLLING_MEASURE)
  1184. nextidx = 0;
  1185. b->total_obs = total - b->obs[nextidx];
  1186. b->obs[nextidx]=0;
  1187. b->cur_obs_idx = nextidx;
  1188. if (++b->cur_obs_time >= b->next_period)
  1189. commit_max(b);
  1190. }
  1191. /** Add <b>n</b> bytes to the number of bytes in <b>b</b> for second
  1192. * <b>when</b>. */
  1193. static INLINE void
  1194. add_obs(bw_array_t *b, time_t when, uint64_t n)
  1195. {
  1196. if (when < b->cur_obs_time)
  1197. return; /* Don't record data in the past. */
  1198. /* If we're currently adding observations for an earlier second than
  1199. * 'when', advance b->cur_obs_time and b->cur_obs_idx by an
  1200. * appropriate number of seconds, and do all the other housekeeping. */
  1201. while (when > b->cur_obs_time) {
  1202. /* Doing this one second at a time is potentially inefficient, if we start
  1203. with a state file that is very old. Fortunately, it doesn't seem to
  1204. show up in profiles, so we can just ignore it for now. */
  1205. advance_obs(b);
  1206. }
  1207. b->obs[b->cur_obs_idx] += n;
  1208. b->total_in_period += n;
  1209. }
  1210. /** Allocate, initialize, and return a new bw_array. */
  1211. static bw_array_t *
  1212. bw_array_new(void)
  1213. {
  1214. bw_array_t *b;
  1215. time_t start;
  1216. b = tor_malloc_zero(sizeof(bw_array_t));
  1217. rephist_total_alloc += sizeof(bw_array_t);
  1218. start = time(NULL);
  1219. b->cur_obs_time = start;
  1220. b->next_period = start + NUM_SECS_BW_SUM_INTERVAL;
  1221. return b;
  1222. }
  1223. /** Recent history of bandwidth observations for read operations. */
  1224. static bw_array_t *read_array = NULL;
  1225. /** Recent history of bandwidth observations for write operations. */
  1226. static bw_array_t *write_array = NULL;
  1227. /** Recent history of bandwidth observations for read operations for the
  1228. directory protocol. */
  1229. static bw_array_t *dir_read_array = NULL;
  1230. /** Recent history of bandwidth observations for write operations for the
  1231. directory protocol. */
  1232. static bw_array_t *dir_write_array = NULL;
  1233. /** Set up [dir-]read_array and [dir-]write_array, freeing them if they
  1234. * already exist. */
  1235. static void
  1236. bw_arrays_init(void)
  1237. {
  1238. tor_free(read_array);
  1239. tor_free(write_array);
  1240. tor_free(dir_read_array);
  1241. tor_free(dir_write_array);
  1242. read_array = bw_array_new();
  1243. write_array = bw_array_new();
  1244. dir_read_array = bw_array_new();
  1245. dir_write_array = bw_array_new();
  1246. }
  1247. /** Remember that we read <b>num_bytes</b> bytes in second <b>when</b>.
  1248. *
  1249. * Add num_bytes to the current running total for <b>when</b>.
  1250. *
  1251. * <b>when</b> can go back to time, but it's safe to ignore calls
  1252. * earlier than the latest <b>when</b> you've heard of.
  1253. */
  1254. void
  1255. rep_hist_note_bytes_written(size_t num_bytes, time_t when)
  1256. {
  1257. /* Maybe a circular array for recent seconds, and step to a new point
  1258. * every time a new second shows up. Or simpler is to just to have
  1259. * a normal array and push down each item every second; it's short.
  1260. */
  1261. /* When a new second has rolled over, compute the sum of the bytes we've
  1262. * seen over when-1 to when-1-NUM_SECS_ROLLING_MEASURE, and stick it
  1263. * somewhere. See rep_hist_bandwidth_assess() below.
  1264. */
  1265. add_obs(write_array, when, num_bytes);
  1266. }
  1267. /** Remember that we wrote <b>num_bytes</b> bytes in second <b>when</b>.
  1268. * (like rep_hist_note_bytes_written() above)
  1269. */
  1270. void
  1271. rep_hist_note_bytes_read(size_t num_bytes, time_t when)
  1272. {
  1273. /* if we're smart, we can make this func and the one above share code */
  1274. add_obs(read_array, when, num_bytes);
  1275. }
  1276. /** Remember that we wrote <b>num_bytes</b> directory bytes in second
  1277. * <b>when</b>. (like rep_hist_note_bytes_written() above)
  1278. */
  1279. void
  1280. rep_hist_note_dir_bytes_written(size_t num_bytes, time_t when)
  1281. {
  1282. add_obs(dir_write_array, when, num_bytes);
  1283. }
  1284. /** Remember that we read <b>num_bytes</b> directory bytes in second
  1285. * <b>when</b>. (like rep_hist_note_bytes_written() above)
  1286. */
  1287. void
  1288. rep_hist_note_dir_bytes_read(size_t num_bytes, time_t when)
  1289. {
  1290. add_obs(dir_read_array, when, num_bytes);
  1291. }
  1292. /** Helper: Return the largest value in b->maxima. (This is equal to the
  1293. * most bandwidth used in any NUM_SECS_ROLLING_MEASURE period for the last
  1294. * NUM_SECS_BW_SUM_IS_VALID seconds.)
  1295. */
  1296. static uint64_t
  1297. find_largest_max(bw_array_t *b)
  1298. {
  1299. int i;
  1300. uint64_t max;
  1301. max=0;
  1302. for (i=0; i<NUM_TOTALS; ++i) {
  1303. if (b->maxima[i]>max)
  1304. max = b->maxima[i];
  1305. }
  1306. return max;
  1307. }
  1308. /** Find the largest sums in the past NUM_SECS_BW_SUM_IS_VALID (roughly)
  1309. * seconds. Find one sum for reading and one for writing. They don't have
  1310. * to be at the same time.
  1311. *
  1312. * Return the smaller of these sums, divided by NUM_SECS_ROLLING_MEASURE.
  1313. */
  1314. int
  1315. rep_hist_bandwidth_assess(void)
  1316. {
  1317. uint64_t w,r;
  1318. r = find_largest_max(read_array);
  1319. w = find_largest_max(write_array);
  1320. if (r>w)
  1321. return (int)(U64_TO_DBL(w)/NUM_SECS_ROLLING_MEASURE);
  1322. else
  1323. return (int)(U64_TO_DBL(r)/NUM_SECS_ROLLING_MEASURE);
  1324. }
  1325. /** Print the bandwidth history of b (either [dir-]read_array or
  1326. * [dir-]write_array) into the buffer pointed to by buf. The format is
  1327. * simply comma separated numbers, from oldest to newest.
  1328. *
  1329. * It returns the number of bytes written.
  1330. */
  1331. static size_t
  1332. rep_hist_fill_bandwidth_history(char *buf, size_t len, const bw_array_t *b)
  1333. {
  1334. char *cp = buf;
  1335. int i, n;
  1336. const or_options_t *options = get_options();
  1337. uint64_t cutoff;
  1338. if (b->num_maxes_set <= b->next_max_idx) {
  1339. /* We haven't been through the circular array yet; time starts at i=0.*/
  1340. i = 0;
  1341. } else {
  1342. /* We've been around the array at least once. The next i to be
  1343. overwritten is the oldest. */
  1344. i = b->next_max_idx;
  1345. }
  1346. if (options->RelayBandwidthRate) {
  1347. /* We don't want to report that we used more bandwidth than the max we're
  1348. * willing to relay; otherwise everybody will know how much traffic
  1349. * we used ourself. */
  1350. cutoff = options->RelayBandwidthRate * NUM_SECS_BW_SUM_INTERVAL;
  1351. } else {
  1352. cutoff = UINT64_MAX;
  1353. }
  1354. for (n=0; n<b->num_maxes_set; ++n,++i) {
  1355. uint64_t total;
  1356. if (i >= NUM_TOTALS)
  1357. i -= NUM_TOTALS;
  1358. tor_assert(i < NUM_TOTALS);
  1359. /* Round the bandwidth used down to the nearest 1k. */
  1360. total = b->totals[i] & ~0x3ff;
  1361. if (total > cutoff)
  1362. total = cutoff;
  1363. if (n==(b->num_maxes_set-1))
  1364. tor_snprintf(cp, len-(cp-buf), U64_FORMAT, U64_PRINTF_ARG(total));
  1365. else
  1366. tor_snprintf(cp, len-(cp-buf), U64_FORMAT",", U64_PRINTF_ARG(total));
  1367. cp += strlen(cp);
  1368. }
  1369. return cp-buf;
  1370. }
  1371. /** Allocate and return lines for representing this server's bandwidth
  1372. * history in its descriptor. We publish these lines in our extra-info
  1373. * descriptor.
  1374. */
  1375. char *
  1376. rep_hist_get_bandwidth_lines(void)
  1377. {
  1378. char *buf, *cp;
  1379. char t[ISO_TIME_LEN+1];
  1380. int r;
  1381. bw_array_t *b = NULL;
  1382. const char *desc = NULL;
  1383. size_t len;
  1384. /* [dirreq-](read|write)-history yyyy-mm-dd HH:MM:SS (n s) n,n,n... */
  1385. /* The n,n,n part above. Largest representation of a uint64_t is 20 chars
  1386. * long, plus the comma. */
  1387. #define MAX_HIST_VALUE_LEN 21*NUM_TOTALS
  1388. len = (67+MAX_HIST_VALUE_LEN)*4;
  1389. buf = tor_malloc_zero(len);
  1390. cp = buf;
  1391. for (r=0;r<4;++r) {
  1392. char tmp[MAX_HIST_VALUE_LEN];
  1393. size_t slen;
  1394. switch (r) {
  1395. case 0:
  1396. b = write_array;
  1397. desc = "write-history";
  1398. break;
  1399. case 1:
  1400. b = read_array;
  1401. desc = "read-history";
  1402. break;
  1403. case 2:
  1404. b = dir_write_array;
  1405. desc = "dirreq-write-history";
  1406. break;
  1407. case 3:
  1408. b = dir_read_array;
  1409. desc = "dirreq-read-history";
  1410. break;
  1411. }
  1412. tor_assert(b);
  1413. slen = rep_hist_fill_bandwidth_history(tmp, MAX_HIST_VALUE_LEN, b);
  1414. /* If we don't have anything to write, skip to the next entry. */
  1415. if (slen == 0)
  1416. continue;
  1417. format_iso_time(t, b->next_period-NUM_SECS_BW_SUM_INTERVAL);
  1418. tor_snprintf(cp, len-(cp-buf), "%s %s (%d s) ",
  1419. desc, t, NUM_SECS_BW_SUM_INTERVAL);
  1420. cp += strlen(cp);
  1421. strlcat(cp, tmp, len-(cp-buf));
  1422. cp += slen;
  1423. strlcat(cp, "\n", len-(cp-buf));
  1424. ++cp;
  1425. }
  1426. return buf;
  1427. }
  1428. /** Write a single bw_array_t into the Values, Ends, Interval, and Maximum
  1429. * entries of an or_state_t. Done before writing out a new state file. */
  1430. static void
  1431. rep_hist_update_bwhist_state_section(or_state_t *state,
  1432. const bw_array_t *b,
  1433. smartlist_t **s_values,
  1434. smartlist_t **s_maxima,
  1435. time_t *s_begins,
  1436. int *s_interval)
  1437. {
  1438. int i,j;
  1439. uint64_t maxval;
  1440. if (*s_values) {
  1441. SMARTLIST_FOREACH(*s_values, char *, val, tor_free(val));
  1442. smartlist_free(*s_values);
  1443. }
  1444. if (*s_maxima) {
  1445. SMARTLIST_FOREACH(*s_maxima, char *, val, tor_free(val));
  1446. smartlist_free(*s_maxima);
  1447. }
  1448. if (! server_mode(get_options())) {
  1449. /* Clients don't need to store bandwidth history persistently;
  1450. * force these values to the defaults. */
  1451. /* FFFF we should pull the default out of config.c's state table,
  1452. * so we don't have two defaults. */
  1453. if (*s_begins != 0 || *s_interval != 900) {
  1454. time_t now = time(NULL);
  1455. time_t save_at = get_options()->AvoidDiskWrites ? now+3600 : now+600;
  1456. or_state_mark_dirty(state, save_at);
  1457. }
  1458. *s_begins = 0;
  1459. *s_interval = 900;
  1460. *s_values = smartlist_new();
  1461. *s_maxima = smartlist_new();
  1462. return;
  1463. }
  1464. *s_begins = b->next_period;
  1465. *s_interval = NUM_SECS_BW_SUM_INTERVAL;
  1466. *s_values = smartlist_new();
  1467. *s_maxima = smartlist_new();
  1468. /* Set i to first position in circular array */
  1469. i = (b->num_maxes_set <= b->next_max_idx) ? 0 : b->next_max_idx;
  1470. for (j=0; j < b->num_maxes_set; ++j,++i) {
  1471. if (i >= NUM_TOTALS)
  1472. i = 0;
  1473. smartlist_add_asprintf(*s_values, U64_FORMAT,
  1474. U64_PRINTF_ARG(b->totals[i] & ~0x3ff));
  1475. maxval = b->maxima[i] / NUM_SECS_ROLLING_MEASURE;
  1476. smartlist_add_asprintf(*s_maxima, U64_FORMAT,
  1477. U64_PRINTF_ARG(maxval & ~0x3ff));
  1478. }
  1479. smartlist_add_asprintf(*s_values, U64_FORMAT,
  1480. U64_PRINTF_ARG(b->total_in_period & ~0x3ff));
  1481. maxval = b->max_total / NUM_SECS_ROLLING_MEASURE;
  1482. smartlist_add_asprintf(*s_maxima, U64_FORMAT,
  1483. U64_PRINTF_ARG(maxval & ~0x3ff));
  1484. }
  1485. /** Update <b>state</b> with the newest bandwidth history. Done before
  1486. * writing out a new state file. */
  1487. void
  1488. rep_hist_update_state(or_state_t *state)
  1489. {
  1490. #define UPDATE(arrname,st) \
  1491. rep_hist_update_bwhist_state_section(state,\
  1492. (arrname),\
  1493. &state->BWHistory ## st ## Values, \
  1494. &state->BWHistory ## st ## Maxima, \
  1495. &state->BWHistory ## st ## Ends, \
  1496. &state->BWHistory ## st ## Interval)
  1497. UPDATE(write_array, Write);
  1498. UPDATE(read_array, Read);
  1499. UPDATE(dir_write_array, DirWrite);
  1500. UPDATE(dir_read_array, DirRead);
  1501. if (server_mode(get_options())) {
  1502. or_state_mark_dirty(state, time(NULL)+(2*3600));
  1503. }
  1504. #undef UPDATE
  1505. }
  1506. /** Load a single bw_array_t from its Values, Ends, Maxima, and Interval
  1507. * entries in an or_state_t. Done while reading the state file. */
  1508. static int
  1509. rep_hist_load_bwhist_state_section(bw_array_t *b,
  1510. const smartlist_t *s_values,
  1511. const smartlist_t *s_maxima,
  1512. const time_t s_begins,
  1513. const int s_interval)
  1514. {
  1515. time_t now = time(NULL);
  1516. int retval = 0;
  1517. time_t start;
  1518. uint64_t v, mv;
  1519. int i,ok,ok_m;
  1520. int have_maxima = s_maxima && s_values &&
  1521. (smartlist_len(s_values) == smartlist_len(s_maxima));
  1522. if (s_values && s_begins >= now - NUM_SECS_BW_SUM_INTERVAL*NUM_TOTALS) {
  1523. start = s_begins - s_interval*(smartlist_len(s_values));
  1524. if (start > now)
  1525. return 0;
  1526. b->cur_obs_time = start;
  1527. b->next_period = start + NUM_SECS_BW_SUM_INTERVAL;
  1528. SMARTLIST_FOREACH_BEGIN(s_values, const char *, cp) {
  1529. const char *maxstr = NULL;
  1530. v = tor_parse_uint64(cp, 10, 0, UINT64_MAX, &ok, NULL);
  1531. if (have_maxima) {
  1532. maxstr = smartlist_get(s_maxima, cp_sl_idx);
  1533. mv = tor_parse_uint64(maxstr, 10, 0, UINT64_MAX, &ok_m, NULL);
  1534. mv *= NUM_SECS_ROLLING_MEASURE;
  1535. } else {
  1536. /* No maxima known; guess average rate to be conservative. */
  1537. mv = (v / s_interval) * NUM_SECS_ROLLING_MEASURE;
  1538. }
  1539. if (!ok) {
  1540. retval = -1;
  1541. log_notice(LD_HIST, "Could not parse value '%s' into a number.'",cp);
  1542. }
  1543. if (maxstr && !ok_m) {
  1544. retval = -1;
  1545. log_notice(LD_HIST, "Could not parse maximum '%s' into a number.'",
  1546. maxstr);
  1547. }
  1548. if (start < now) {
  1549. time_t cur_start = start;
  1550. time_t actual_interval_len = s_interval;
  1551. uint64_t cur_val = 0;
  1552. /* Calculate the average per second. This is the best we can do
  1553. * because our state file doesn't have per-second resolution. */
  1554. if (start + s_interval > now)
  1555. actual_interval_len = now - start;
  1556. cur_val = v / actual_interval_len;
  1557. /* This is potentially inefficient, but since we don't do it very
  1558. * often it should be ok. */
  1559. while (cur_start < start + actual_interval_len) {
  1560. add_obs(b, cur_start, cur_val);
  1561. ++cur_start;
  1562. }
  1563. b->max_total = mv;
  1564. /* This will result in some fairly choppy history if s_interval
  1565. * is not the same as NUM_SECS_BW_SUM_INTERVAL. XXXX */
  1566. start += actual_interval_len;
  1567. }
  1568. } SMARTLIST_FOREACH_END(cp);
  1569. }
  1570. /* Clean up maxima and observed */
  1571. for (i=0; i<NUM_SECS_ROLLING_MEASURE; ++i) {
  1572. b->obs[i] = 0;
  1573. }
  1574. b->total_obs = 0;
  1575. return retval;
  1576. }
  1577. /** Set bandwidth history from the state file we just loaded. */
  1578. int
  1579. rep_hist_load_state(or_state_t *state, char **err)
  1580. {
  1581. int all_ok = 1;
  1582. /* Assert they already have been malloced */
  1583. tor_assert(read_array && write_array);
  1584. tor_assert(dir_read_array && dir_write_array);
  1585. #define LOAD(arrname,st) \
  1586. if (rep_hist_load_bwhist_state_section( \
  1587. (arrname), \
  1588. state->BWHistory ## st ## Values, \
  1589. state->BWHistory ## st ## Maxima, \
  1590. state->BWHistory ## st ## Ends, \
  1591. state->BWHistory ## st ## Interval)<0) \
  1592. all_ok = 0
  1593. LOAD(write_array, Write);
  1594. LOAD(read_array, Read);
  1595. LOAD(dir_write_array, DirWrite);
  1596. LOAD(dir_read_array, DirRead);
  1597. #undef LOAD
  1598. if (!all_ok) {
  1599. *err = tor_strdup("Parsing of bandwidth history values failed");
  1600. /* and create fresh arrays */
  1601. bw_arrays_init();
  1602. return -1;
  1603. }
  1604. return 0;
  1605. }
  1606. /*********************************************************************/
  1607. /** A single predicted port: used to remember which ports we've made
  1608. * connections to, so that we can try to keep making circuits that can handle
  1609. * those ports. */
  1610. typedef struct predicted_port_t {
  1611. /** The port we connected to */
  1612. uint16_t port;
  1613. /** The time at which we last used it */
  1614. time_t time;
  1615. } predicted_port_t;
  1616. /** A list of port numbers that have been used recently. */
  1617. static smartlist_t *predicted_ports_list=NULL;
  1618. /** We just got an application request for a connection with
  1619. * port <b>port</b>. Remember it for the future, so we can keep
  1620. * some circuits open that will exit to this port.
  1621. */
  1622. static void
  1623. add_predicted_port(time_t now, uint16_t port)
  1624. {
  1625. predicted_port_t *pp = tor_malloc(sizeof(predicted_port_t));
  1626. pp->port = port;
  1627. pp->time = now;
  1628. rephist_total_alloc += sizeof(*pp);
  1629. smartlist_add(predicted_ports_list, pp);
  1630. }
  1631. /** Initialize whatever memory and structs are needed for predicting
  1632. * which ports will be used. Also seed it with port 80, so we'll build
  1633. * circuits on start-up.
  1634. */
  1635. static void
  1636. predicted_ports_init(void)
  1637. {
  1638. predicted_ports_list = smartlist_new();
  1639. add_predicted_port(time(NULL), 80); /* add one to kickstart us */
  1640. }
  1641. /** Free whatever memory is needed for predicting which ports will
  1642. * be used.
  1643. */
  1644. static void
  1645. predicted_ports_free(void)
  1646. {
  1647. rephist_total_alloc -=
  1648. smartlist_len(predicted_ports_list)*sizeof(predicted_port_t);
  1649. SMARTLIST_FOREACH(predicted_ports_list, predicted_port_t *,
  1650. pp, tor_free(pp));
  1651. smartlist_free(predicted_ports_list);
  1652. }
  1653. /** Remember that <b>port</b> has been asked for as of time <b>now</b>.
  1654. * This is used for predicting what sorts of streams we'll make in the
  1655. * future and making exit circuits to anticipate that.
  1656. */
  1657. void
  1658. rep_hist_note_used_port(time_t now, uint16_t port)
  1659. {
  1660. tor_assert(predicted_ports_list);
  1661. if (!port) /* record nothing */
  1662. return;
  1663. SMARTLIST_FOREACH_BEGIN(predicted_ports_list, predicted_port_t *, pp) {
  1664. if (pp->port == port) {
  1665. pp->time = now;
  1666. return;
  1667. }
  1668. } SMARTLIST_FOREACH_END(pp);
  1669. /* it's not there yet; we need to add it */
  1670. add_predicted_port(now, port);
  1671. }
  1672. /** For this long after we've seen a request for a given port, assume that
  1673. * we'll want to make connections to the same port in the future. */
  1674. #define PREDICTED_CIRCS_RELEVANCE_TIME (60*60)
  1675. /** Return a newly allocated pointer to a list of uint16_t * for ports that
  1676. * are likely to be asked for in the near future.
  1677. */
  1678. smartlist_t *
  1679. rep_hist_get_predicted_ports(time_t now)
  1680. {
  1681. smartlist_t *out = smartlist_new();
  1682. tor_assert(predicted_ports_list);
  1683. /* clean out obsolete entries */
  1684. SMARTLIST_FOREACH_BEGIN(predicted_ports_list, predicted_port_t *, pp) {
  1685. if (pp->time + PREDICTED_CIRCS_RELEVANCE_TIME < now) {
  1686. log_debug(LD_CIRC, "Expiring predicted port %d", pp->port);
  1687. rephist_total_alloc -= sizeof(predicted_port_t);
  1688. tor_free(pp);
  1689. SMARTLIST_DEL_CURRENT(predicted_ports_list, pp);
  1690. } else {
  1691. smartlist_add(out, tor_memdup(&pp->port, sizeof(uint16_t)));
  1692. }
  1693. } SMARTLIST_FOREACH_END(pp);
  1694. return out;
  1695. }
  1696. /**
  1697. * Take a list of uint16_t *, and remove every port in the list from the
  1698. * current list of predicted ports.
  1699. */
  1700. void
  1701. rep_hist_remove_predicted_ports(const smartlist_t *rmv_ports)
  1702. {
  1703. /* Let's do this on O(N), not O(N^2). */
  1704. bitarray_t *remove_ports = bitarray_init_zero(UINT16_MAX);
  1705. SMARTLIST_FOREACH(rmv_ports, const uint16_t *, p,
  1706. bitarray_set(remove_ports, *p));
  1707. SMARTLIST_FOREACH_BEGIN(predicted_ports_list, predicted_port_t *, pp) {
  1708. if (bitarray_is_set(remove_ports, pp->port)) {
  1709. tor_free(pp);
  1710. SMARTLIST_DEL_CURRENT(predicted_ports_list, pp);
  1711. }
  1712. } SMARTLIST_FOREACH_END(pp);
  1713. bitarray_free(remove_ports);
  1714. }
  1715. /** The user asked us to do a resolve. Rather than keeping track of
  1716. * timings and such of resolves, we fake it for now by treating
  1717. * it the same way as a connection to port 80. This way we will continue
  1718. * to have circuits lying around if the user only uses Tor for resolves.
  1719. */
  1720. void
  1721. rep_hist_note_used_resolve(time_t now)
  1722. {
  1723. rep_hist_note_used_port(now, 80);
  1724. }
  1725. /** The last time at which we needed an internal circ. */
  1726. static time_t predicted_internal_time = 0;
  1727. /** The last time we needed an internal circ with good uptime. */
  1728. static time_t predicted_internal_uptime_time = 0;
  1729. /** The last time we needed an internal circ with good capacity. */
  1730. static time_t predicted_internal_capacity_time = 0;
  1731. /** Remember that we used an internal circ at time <b>now</b>. */
  1732. void
  1733. rep_hist_note_used_internal(time_t now, int need_uptime, int need_capacity)
  1734. {
  1735. predicted_internal_time = now;
  1736. if (need_uptime)
  1737. predicted_internal_uptime_time = now;
  1738. if (need_capacity)
  1739. predicted_internal_capacity_time = now;
  1740. }
  1741. /** Return 1 if we've used an internal circ recently; else return 0. */
  1742. int
  1743. rep_hist_get_predicted_internal(time_t now, int *need_uptime,
  1744. int *need_capacity)
  1745. {
  1746. if (!predicted_internal_time) { /* initialize it */
  1747. predicted_internal_time = now;
  1748. predicted_internal_uptime_time = now;
  1749. predicted_internal_capacity_time = now;
  1750. }
  1751. if (predicted_internal_time + PREDICTED_CIRCS_RELEVANCE_TIME < now)
  1752. return 0; /* too long ago */
  1753. if (predicted_internal_uptime_time + PREDICTED_CIRCS_RELEVANCE_TIME >= now)
  1754. *need_uptime = 1;
  1755. // Always predict that we need capacity.
  1756. *need_capacity = 1;
  1757. return 1;
  1758. }
  1759. /** Any ports used lately? These are pre-seeded if we just started
  1760. * up or if we're running a hidden service. */
  1761. int
  1762. any_predicted_circuits(time_t now)
  1763. {
  1764. return smartlist_len(predicted_ports_list) ||
  1765. predicted_internal_time + PREDICTED_CIRCS_RELEVANCE_TIME >= now;
  1766. }
  1767. /** Return 1 if we have no need for circuits currently, else return 0. */
  1768. int
  1769. rep_hist_circbuilding_dormant(time_t now)
  1770. {
  1771. if (any_predicted_circuits(now))
  1772. return 0;
  1773. /* see if we'll still need to build testing circuits */
  1774. if (server_mode(get_options()) &&
  1775. (!check_whether_orport_reachable() || !circuit_enough_testing_circs()))
  1776. return 0;
  1777. if (!check_whether_dirport_reachable())
  1778. return 0;
  1779. return 1;
  1780. }
  1781. /** Structure to track how many times we've done each public key operation. */
  1782. static struct {
  1783. /** How many directory objects have we signed? */
  1784. unsigned long n_signed_dir_objs;
  1785. /** How many routerdescs have we signed? */
  1786. unsigned long n_signed_routerdescs;
  1787. /** How many directory objects have we verified? */
  1788. unsigned long n_verified_dir_objs;
  1789. /** How many routerdescs have we verified */
  1790. unsigned long n_verified_routerdescs;
  1791. /** How many onionskins have we encrypted to build circuits? */
  1792. unsigned long n_onionskins_encrypted;
  1793. /** How many onionskins have we decrypted to do circuit build requests? */
  1794. unsigned long n_onionskins_decrypted;
  1795. /** How many times have we done the TLS handshake as a client? */
  1796. unsigned long n_tls_client_handshakes;
  1797. /** How many times have we done the TLS handshake as a server? */
  1798. unsigned long n_tls_server_handshakes;
  1799. /** How many PK operations have we done as a hidden service client? */
  1800. unsigned long n_rend_client_ops;
  1801. /** How many PK operations have we done as a hidden service midpoint? */
  1802. unsigned long n_rend_mid_ops;
  1803. /** How many PK operations have we done as a hidden service provider? */
  1804. unsigned long n_rend_server_ops;
  1805. } pk_op_counts = {0,0,0,0,0,0,0,0,0,0,0};
  1806. /** Increment the count of the number of times we've done <b>operation</b>. */
  1807. void
  1808. note_crypto_pk_op(pk_op_t operation)
  1809. {
  1810. switch (operation)
  1811. {
  1812. case SIGN_DIR:
  1813. pk_op_counts.n_signed_dir_objs++;
  1814. break;
  1815. case SIGN_RTR:
  1816. pk_op_counts.n_signed_routerdescs++;
  1817. break;
  1818. case VERIFY_DIR:
  1819. pk_op_counts.n_verified_dir_objs++;
  1820. break;
  1821. case VERIFY_RTR:
  1822. pk_op_counts.n_verified_routerdescs++;
  1823. break;
  1824. case ENC_ONIONSKIN:
  1825. pk_op_counts.n_onionskins_encrypted++;
  1826. break;
  1827. case DEC_ONIONSKIN:
  1828. pk_op_counts.n_onionskins_decrypted++;
  1829. break;
  1830. case TLS_HANDSHAKE_C:
  1831. pk_op_counts.n_tls_client_handshakes++;
  1832. break;
  1833. case TLS_HANDSHAKE_S:
  1834. pk_op_counts.n_tls_server_handshakes++;
  1835. break;
  1836. case REND_CLIENT:
  1837. pk_op_counts.n_rend_client_ops++;
  1838. break;
  1839. case REND_MID:
  1840. pk_op_counts.n_rend_mid_ops++;
  1841. break;
  1842. case REND_SERVER:
  1843. pk_op_counts.n_rend_server_ops++;
  1844. break;
  1845. default:
  1846. log_warn(LD_BUG, "Unknown pk operation %d", operation);
  1847. }
  1848. }
  1849. /** Log the number of times we've done each public/private-key operation. */
  1850. void
  1851. dump_pk_ops(int severity)
  1852. {
  1853. log(severity, LD_HIST,
  1854. "PK operations: %lu directory objects signed, "
  1855. "%lu directory objects verified, "
  1856. "%lu routerdescs signed, "
  1857. "%lu routerdescs verified, "
  1858. "%lu onionskins encrypted, "
  1859. "%lu onionskins decrypted, "
  1860. "%lu client-side TLS handshakes, "
  1861. "%lu server-side TLS handshakes, "
  1862. "%lu rendezvous client operations, "
  1863. "%lu rendezvous middle operations, "
  1864. "%lu rendezvous server operations.",
  1865. pk_op_counts.n_signed_dir_objs,
  1866. pk_op_counts.n_verified_dir_objs,
  1867. pk_op_counts.n_signed_routerdescs,
  1868. pk_op_counts.n_verified_routerdescs,
  1869. pk_op_counts.n_onionskins_encrypted,
  1870. pk_op_counts.n_onionskins_decrypted,
  1871. pk_op_counts.n_tls_client_handshakes,
  1872. pk_op_counts.n_tls_server_handshakes,
  1873. pk_op_counts.n_rend_client_ops,
  1874. pk_op_counts.n_rend_mid_ops,
  1875. pk_op_counts.n_rend_server_ops);
  1876. }
  1877. /*** Exit port statistics ***/
  1878. /* Some constants */
  1879. /** To what multiple should byte numbers be rounded up? */
  1880. #define EXIT_STATS_ROUND_UP_BYTES 1024
  1881. /** To what multiple should stream counts be rounded up? */
  1882. #define EXIT_STATS_ROUND_UP_STREAMS 4
  1883. /** Number of TCP ports */
  1884. #define EXIT_STATS_NUM_PORTS 65536
  1885. /** Top n ports that will be included in exit stats. */
  1886. #define EXIT_STATS_TOP_N_PORTS 10
  1887. /* The following data structures are arrays and no fancy smartlists or maps,
  1888. * so that all write operations can be done in constant time. This comes at
  1889. * the price of some memory (1.25 MB) and linear complexity when writing
  1890. * stats for measuring relays. */
  1891. /** Number of bytes read in current period by exit port */
  1892. static uint64_t *exit_bytes_read = NULL;
  1893. /** Number of bytes written in current period by exit port */
  1894. static uint64_t *exit_bytes_written = NULL;
  1895. /** Number of streams opened in current period by exit port */
  1896. static uint32_t *exit_streams = NULL;
  1897. /** Start time of exit stats or 0 if we're not collecting exit stats. */
  1898. static time_t start_of_exit_stats_interval;
  1899. /** Initialize exit port stats. */
  1900. void
  1901. rep_hist_exit_stats_init(time_t now)
  1902. {
  1903. start_of_exit_stats_interval = now;
  1904. exit_bytes_read = tor_malloc_zero(EXIT_STATS_NUM_PORTS *
  1905. sizeof(uint64_t));
  1906. exit_bytes_written = tor_malloc_zero(EXIT_STATS_NUM_PORTS *
  1907. sizeof(uint64_t));
  1908. exit_streams = tor_malloc_zero(EXIT_STATS_NUM_PORTS *
  1909. sizeof(uint32_t));
  1910. }
  1911. /** Reset counters for exit port statistics. */
  1912. void
  1913. rep_hist_reset_exit_stats(time_t now)
  1914. {
  1915. start_of_exit_stats_interval = now;
  1916. memset(exit_bytes_read, 0, EXIT_STATS_NUM_PORTS * sizeof(uint64_t));
  1917. memset(exit_bytes_written, 0, EXIT_STATS_NUM_PORTS * sizeof(uint64_t));
  1918. memset(exit_streams, 0, EXIT_STATS_NUM_PORTS * sizeof(uint32_t));
  1919. }
  1920. /** Stop collecting exit port stats in a way that we can re-start doing
  1921. * so in rep_hist_exit_stats_init(). */
  1922. void
  1923. rep_hist_exit_stats_term(void)
  1924. {
  1925. start_of_exit_stats_interval = 0;
  1926. tor_free(exit_bytes_read);
  1927. tor_free(exit_bytes_written);
  1928. tor_free(exit_streams);
  1929. }
  1930. /** Helper for qsort: compare two ints. Does not handle overflow properly,
  1931. * but works fine for sorting an array of port numbers, which is what we use
  1932. * it for. */
  1933. static int
  1934. compare_int_(const void *x, const void *y)
  1935. {
  1936. return (*(int*)x - *(int*)y);
  1937. }
  1938. /** Return a newly allocated string containing the exit port statistics
  1939. * until <b>now</b>, or NULL if we're not collecting exit stats. Caller
  1940. * must ensure start_of_exit_stats_interval is in the past. */
  1941. char *
  1942. rep_hist_format_exit_stats(time_t now)
  1943. {
  1944. int i, j, top_elements = 0, cur_min_idx = 0, cur_port;
  1945. uint64_t top_bytes[EXIT_STATS_TOP_N_PORTS];
  1946. int top_ports[EXIT_STATS_TOP_N_PORTS];
  1947. uint64_t cur_bytes = 0, other_read = 0, other_written = 0,
  1948. total_read = 0, total_written = 0;
  1949. uint32_t total_streams = 0, other_streams = 0;
  1950. smartlist_t *written_strings, *read_strings, *streams_strings;
  1951. char *written_string, *read_string, *streams_string;
  1952. char t[ISO_TIME_LEN+1];
  1953. char *result;
  1954. if (!start_of_exit_stats_interval)
  1955. return NULL; /* Not initialized. */
  1956. tor_assert(now >= start_of_exit_stats_interval);
  1957. /* Go through all ports to find the n ports that saw most written and
  1958. * read bytes.
  1959. *
  1960. * Invariant: at the end of the loop for iteration i,
  1961. * total_read is the sum of all exit_bytes_read[0..i]
  1962. * total_written is the sum of all exit_bytes_written[0..i]
  1963. * total_stream is the sum of all exit_streams[0..i]
  1964. *
  1965. * top_elements = MAX(EXIT_STATS_TOP_N_PORTS,
  1966. * #{j | 0 <= j <= i && volume(i) > 0})
  1967. *
  1968. * For all 0 <= j < top_elements,
  1969. * top_bytes[j] > 0
  1970. * 0 <= top_ports[j] <= 65535
  1971. * top_bytes[j] = volume(top_ports[j])
  1972. *
  1973. * There is no j in 0..i and k in 0..top_elements such that:
  1974. * volume(j) > top_bytes[k] AND j is not in top_ports[0..top_elements]
  1975. *
  1976. * There is no j!=cur_min_idx in 0..top_elements such that:
  1977. * top_bytes[j] < top_bytes[cur_min_idx]
  1978. *
  1979. * where volume(x) == exit_bytes_read[x]+exit_bytes_written[x]
  1980. *
  1981. * Worst case: O(EXIT_STATS_NUM_PORTS * EXIT_STATS_TOP_N_PORTS)
  1982. */
  1983. for (i = 1; i < EXIT_STATS_NUM_PORTS; i++) {
  1984. total_read += exit_bytes_read[i];
  1985. total_written += exit_bytes_written[i];
  1986. total_streams += exit_streams[i];
  1987. cur_bytes = exit_bytes_read[i] + exit_bytes_written[i];
  1988. if (cur_bytes == 0) {
  1989. continue;
  1990. }
  1991. if (top_elements < EXIT_STATS_TOP_N_PORTS) {
  1992. top_bytes[top_elements] = cur_bytes;
  1993. top_ports[top_elements++] = i;
  1994. } else if (cur_bytes > top_bytes[cur_min_idx]) {
  1995. top_bytes[cur_min_idx] = cur_bytes;
  1996. top_ports[cur_min_idx] = i;
  1997. } else {
  1998. continue;
  1999. }
  2000. cur_min_idx = 0;
  2001. for (j = 1; j < top_elements; j++) {
  2002. if (top_bytes[j] < top_bytes[cur_min_idx]) {
  2003. cur_min_idx = j;
  2004. }
  2005. }
  2006. }
  2007. /* Add observations of top ports to smartlists. */
  2008. written_strings = smartlist_new();
  2009. read_strings = smartlist_new();
  2010. streams_strings = smartlist_new();
  2011. other_read = total_read;
  2012. other_written = total_written;
  2013. other_streams = total_streams;
  2014. /* Sort the ports; this puts them out of sync with top_bytes, but we
  2015. * won't be using top_bytes again anyway */
  2016. qsort(top_ports, top_elements, sizeof(int), compare_int_);
  2017. for (j = 0; j < top_elements; j++) {
  2018. cur_port = top_ports[j];
  2019. if (exit_bytes_written[cur_port] > 0) {
  2020. uint64_t num = round_uint64_to_next_multiple_of(
  2021. exit_bytes_written[cur_port],
  2022. EXIT_STATS_ROUND_UP_BYTES);
  2023. num /= 1024;
  2024. smartlist_add_asprintf(written_strings, "%d="U64_FORMAT,
  2025. cur_port, U64_PRINTF_ARG(num));
  2026. other_written -= exit_bytes_written[cur_port];
  2027. }
  2028. if (exit_bytes_read[cur_port] > 0) {
  2029. uint64_t num = round_uint64_to_next_multiple_of(
  2030. exit_bytes_read[cur_port],
  2031. EXIT_STATS_ROUND_UP_BYTES);
  2032. num /= 1024;
  2033. smartlist_add_asprintf(read_strings, "%d="U64_FORMAT,
  2034. cur_port, U64_PRINTF_ARG(num));
  2035. other_read -= exit_bytes_read[cur_port];
  2036. }
  2037. if (exit_streams[cur_port] > 0) {
  2038. uint32_t num = round_uint32_to_next_multiple_of(
  2039. exit_streams[cur_port],
  2040. EXIT_STATS_ROUND_UP_STREAMS);
  2041. smartlist_add_asprintf(streams_strings, "%d=%u", cur_port, num);
  2042. other_streams -= exit_streams[cur_port];
  2043. }
  2044. }
  2045. /* Add observations of other ports in a single element. */
  2046. other_written = round_uint64_to_next_multiple_of(other_written,
  2047. EXIT_STATS_ROUND_UP_BYTES);
  2048. other_written /= 1024;
  2049. smartlist_add_asprintf(written_strings, "other="U64_FORMAT,
  2050. U64_PRINTF_ARG(other_written));
  2051. other_read = round_uint64_to_next_multiple_of(other_read,
  2052. EXIT_STATS_ROUND_UP_BYTES);
  2053. other_read /= 1024;
  2054. smartlist_add_asprintf(read_strings, "other="U64_FORMAT,
  2055. U64_PRINTF_ARG(other_read));
  2056. other_streams = round_uint32_to_next_multiple_of(other_streams,
  2057. EXIT_STATS_ROUND_UP_STREAMS);
  2058. smartlist_add_asprintf(streams_strings, "other=%u", other_streams);
  2059. /* Join all observations in single strings. */
  2060. written_string = smartlist_join_strings(written_strings, ",", 0, NULL);
  2061. read_string = smartlist_join_strings(read_strings, ",", 0, NULL);
  2062. streams_string = smartlist_join_strings(streams_strings, ",", 0, NULL);
  2063. SMARTLIST_FOREACH(written_strings, char *, cp, tor_free(cp));
  2064. SMARTLIST_FOREACH(read_strings, char *, cp, tor_free(cp));
  2065. SMARTLIST_FOREACH(streams_strings, char *, cp, tor_free(cp));
  2066. smartlist_free(written_strings);
  2067. smartlist_free(read_strings);
  2068. smartlist_free(streams_strings);
  2069. /* Put everything together. */
  2070. format_iso_time(t, now);
  2071. tor_asprintf(&result, "exit-stats-end %s (%d s)\n"
  2072. "exit-kibibytes-written %s\n"
  2073. "exit-kibibytes-read %s\n"
  2074. "exit-streams-opened %s\n",
  2075. t, (unsigned) (now - start_of_exit_stats_interval),
  2076. written_string,
  2077. read_string,
  2078. streams_string);
  2079. tor_free(written_string);
  2080. tor_free(read_string);
  2081. tor_free(streams_string);
  2082. return result;
  2083. }
  2084. /** If 24 hours have passed since the beginning of the current exit port
  2085. * stats period, write exit stats to $DATADIR/stats/exit-stats (possibly
  2086. * overwriting an existing file) and reset counters. Return when we would
  2087. * next want to write exit stats or 0 if we never want to write. */
  2088. time_t
  2089. rep_hist_exit_stats_write(time_t now)
  2090. {
  2091. char *statsdir = NULL, *filename = NULL, *str = NULL;
  2092. if (!start_of_exit_stats_interval)
  2093. return 0; /* Not initialized. */
  2094. if (start_of_exit_stats_interval + WRITE_STATS_INTERVAL > now)
  2095. goto done; /* Not ready to write. */
  2096. log_info(LD_HIST, "Writing exit port statistics to disk.");
  2097. /* Generate history string. */
  2098. str = rep_hist_format_exit_stats(now);
  2099. /* Reset counters. */
  2100. rep_hist_reset_exit_stats(now);
  2101. /* Try to write to disk. */
  2102. statsdir = get_datadir_fname("stats");
  2103. if (check_private_dir(statsdir, CPD_CREATE, get_options()->User) < 0) {
  2104. log_warn(LD_HIST, "Unable to create stats/ directory!");
  2105. goto done;
  2106. }
  2107. filename = get_datadir_fname2("stats", "exit-stats");
  2108. if (write_str_to_file(filename, str, 0) < 0)
  2109. log_warn(LD_HIST, "Unable to write exit port statistics to disk!");
  2110. done:
  2111. tor_free(str);
  2112. tor_free(statsdir);
  2113. tor_free(filename);
  2114. return start_of_exit_stats_interval + WRITE_STATS_INTERVAL;
  2115. }
  2116. /** Note that we wrote <b>num_written</b> bytes and read <b>num_read</b>
  2117. * bytes to/from an exit connection to <b>port</b>. */
  2118. void
  2119. rep_hist_note_exit_bytes(uint16_t port, size_t num_written,
  2120. size_t num_read)
  2121. {
  2122. if (!start_of_exit_stats_interval)
  2123. return; /* Not initialized. */
  2124. exit_bytes_written[port] += num_written;
  2125. exit_bytes_read[port] += num_read;
  2126. log_debug(LD_HIST, "Written %lu bytes and read %lu bytes to/from an "
  2127. "exit connection to port %d.",
  2128. (unsigned long)num_written, (unsigned long)num_read, port);
  2129. }
  2130. /** Note that we opened an exit stream to <b>port</b>. */
  2131. void
  2132. rep_hist_note_exit_stream_opened(uint16_t port)
  2133. {
  2134. if (!start_of_exit_stats_interval)
  2135. return; /* Not initialized. */
  2136. exit_streams[port]++;
  2137. log_debug(LD_HIST, "Opened exit stream to port %d", port);
  2138. }
  2139. /*** cell statistics ***/
  2140. /** Start of the current buffer stats interval or 0 if we're not
  2141. * collecting buffer statistics. */
  2142. static time_t start_of_buffer_stats_interval;
  2143. /** Initialize buffer stats. */
  2144. void
  2145. rep_hist_buffer_stats_init(time_t now)
  2146. {
  2147. start_of_buffer_stats_interval = now;
  2148. }
  2149. /** Statistics from a single circuit. Collected when the circuit closes, or
  2150. * when we flush statistics to disk. */
  2151. typedef struct circ_buffer_stats_t {
  2152. /** Average number of cells in the circuit's queue */
  2153. double mean_num_cells_in_queue;
  2154. /** Average time a cell waits in the queue. */
  2155. double mean_time_cells_in_queue;
  2156. /** Total number of cells sent over this circuit */
  2157. uint32_t processed_cells;
  2158. } circ_buffer_stats_t;
  2159. /** List of circ_buffer_stats_t. */
  2160. static smartlist_t *circuits_for_buffer_stats = NULL;
  2161. /** Remember cell statistics <b>mean_num_cells_in_queue</b>,
  2162. * <b>mean_time_cells_in_queue</b>, and <b>processed_cells</b> of a
  2163. * circuit. */
  2164. void
  2165. rep_hist_add_buffer_stats(double mean_num_cells_in_queue,
  2166. double mean_time_cells_in_queue, uint32_t processed_cells)
  2167. {
  2168. circ_buffer_stats_t *stat;
  2169. if (!start_of_buffer_stats_interval)
  2170. return; /* Not initialized. */
  2171. stat = tor_malloc_zero(sizeof(circ_buffer_stats_t));
  2172. stat->mean_num_cells_in_queue = mean_num_cells_in_queue;
  2173. stat->mean_time_cells_in_queue = mean_time_cells_in_queue;
  2174. stat->processed_cells = processed_cells;
  2175. if (!circuits_for_buffer_stats)
  2176. circuits_for_buffer_stats = smartlist_new();
  2177. smartlist_add(circuits_for_buffer_stats, stat);
  2178. }
  2179. /** Remember cell statistics for circuit <b>circ</b> at time
  2180. * <b>end_of_interval</b> and reset cell counters in case the circuit
  2181. * remains open in the next measurement interval. */
  2182. void
  2183. rep_hist_buffer_stats_add_circ(circuit_t *circ, time_t end_of_interval)
  2184. {
  2185. time_t start_of_interval;
  2186. int interval_length;
  2187. or_circuit_t *orcirc;
  2188. double mean_num_cells_in_queue, mean_time_cells_in_queue;
  2189. uint32_t processed_cells;
  2190. if (CIRCUIT_IS_ORIGIN(circ))
  2191. return;
  2192. orcirc = TO_OR_CIRCUIT(circ);
  2193. if (!orcirc->processed_cells)
  2194. return;
  2195. start_of_interval = (circ->timestamp_created.tv_sec >
  2196. start_of_buffer_stats_interval) ?
  2197. circ->timestamp_created.tv_sec :
  2198. start_of_buffer_stats_interval;
  2199. interval_length = (int) (end_of_interval - start_of_interval);
  2200. if (interval_length <= 0)
  2201. return;
  2202. processed_cells = orcirc->processed_cells;
  2203. /* 1000.0 for s -> ms; 2.0 because of app-ward and exit-ward queues */
  2204. mean_num_cells_in_queue = (double) orcirc->total_cell_waiting_time /
  2205. (double) interval_length / 1000.0 / 2.0;
  2206. mean_time_cells_in_queue =
  2207. (double) orcirc->total_cell_waiting_time /
  2208. (double) orcirc->processed_cells;
  2209. orcirc->total_cell_waiting_time = 0;
  2210. orcirc->processed_cells = 0;
  2211. rep_hist_add_buffer_stats(mean_num_cells_in_queue,
  2212. mean_time_cells_in_queue,
  2213. processed_cells);
  2214. }
  2215. /** Sorting helper: return -1, 1, or 0 based on comparison of two
  2216. * circ_buffer_stats_t */
  2217. static int
  2218. buffer_stats_compare_entries_(const void **_a, const void **_b)
  2219. {
  2220. const circ_buffer_stats_t *a = *_a, *b = *_b;
  2221. if (a->processed_cells < b->processed_cells)
  2222. return 1;
  2223. else if (a->processed_cells > b->processed_cells)
  2224. return -1;
  2225. else
  2226. return 0;
  2227. }
  2228. /** Stop collecting cell stats in a way that we can re-start doing so in
  2229. * rep_hist_buffer_stats_init(). */
  2230. void
  2231. rep_hist_buffer_stats_term(void)
  2232. {
  2233. rep_hist_reset_buffer_stats(0);
  2234. }
  2235. /** Clear history of circuit statistics and set the measurement interval
  2236. * start to <b>now</b>. */
  2237. void
  2238. rep_hist_reset_buffer_stats(time_t now)
  2239. {
  2240. if (!circuits_for_buffer_stats)
  2241. circuits_for_buffer_stats = smartlist_new();
  2242. SMARTLIST_FOREACH(circuits_for_buffer_stats, circ_buffer_stats_t *,
  2243. stat, tor_free(stat));
  2244. smartlist_clear(circuits_for_buffer_stats);
  2245. start_of_buffer_stats_interval = now;
  2246. }
  2247. /** Return a newly allocated string containing the buffer statistics until
  2248. * <b>now</b>, or NULL if we're not collecting buffer stats. Caller must
  2249. * ensure start_of_buffer_stats_interval is in the past. */
  2250. char *
  2251. rep_hist_format_buffer_stats(time_t now)
  2252. {
  2253. #define SHARES 10
  2254. uint64_t processed_cells[SHARES];
  2255. uint32_t circs_in_share[SHARES];
  2256. int number_of_circuits, i;
  2257. double queued_cells[SHARES], time_in_queue[SHARES];
  2258. smartlist_t *processed_cells_strings, *queued_cells_strings,
  2259. *time_in_queue_strings;
  2260. char *processed_cells_string, *queued_cells_string,
  2261. *time_in_queue_string;
  2262. char t[ISO_TIME_LEN+1];
  2263. char *result;
  2264. if (!start_of_buffer_stats_interval)
  2265. return NULL; /* Not initialized. */
  2266. tor_assert(now >= start_of_buffer_stats_interval);
  2267. /* Calculate deciles if we saw at least one circuit. */
  2268. memset(processed_cells, 0, SHARES * sizeof(uint64_t));
  2269. memset(circs_in_share, 0, SHARES * sizeof(uint32_t));
  2270. memset(queued_cells, 0, SHARES * sizeof(double));
  2271. memset(time_in_queue, 0, SHARES * sizeof(double));
  2272. if (!circuits_for_buffer_stats)
  2273. circuits_for_buffer_stats = smartlist_new();
  2274. number_of_circuits = smartlist_len(circuits_for_buffer_stats);
  2275. if (number_of_circuits > 0) {
  2276. smartlist_sort(circuits_for_buffer_stats,
  2277. buffer_stats_compare_entries_);
  2278. i = 0;
  2279. SMARTLIST_FOREACH_BEGIN(circuits_for_buffer_stats,
  2280. circ_buffer_stats_t *, stat)
  2281. {
  2282. int share = i++ * SHARES / number_of_circuits;
  2283. processed_cells[share] += stat->processed_cells;
  2284. queued_cells[share] += stat->mean_num_cells_in_queue;
  2285. time_in_queue[share] += stat->mean_time_cells_in_queue;
  2286. circs_in_share[share]++;
  2287. }
  2288. SMARTLIST_FOREACH_END(stat);
  2289. }
  2290. /* Write deciles to strings. */
  2291. processed_cells_strings = smartlist_new();
  2292. queued_cells_strings = smartlist_new();
  2293. time_in_queue_strings = smartlist_new();
  2294. for (i = 0; i < SHARES; i++) {
  2295. smartlist_add_asprintf(processed_cells_strings,
  2296. U64_FORMAT, !circs_in_share[i] ? 0 :
  2297. U64_PRINTF_ARG(processed_cells[i] /
  2298. circs_in_share[i]));
  2299. }
  2300. for (i = 0; i < SHARES; i++) {
  2301. smartlist_add_asprintf(queued_cells_strings, "%.2f",
  2302. circs_in_share[i] == 0 ? 0.0 :
  2303. queued_cells[i] / (double) circs_in_share[i]);
  2304. }
  2305. for (i = 0; i < SHARES; i++) {
  2306. smartlist_add_asprintf(time_in_queue_strings, "%.0f",
  2307. circs_in_share[i] == 0 ? 0.0 :
  2308. time_in_queue[i] / (double) circs_in_share[i]);
  2309. }
  2310. /* Join all observations in single strings. */
  2311. processed_cells_string = smartlist_join_strings(processed_cells_strings,
  2312. ",", 0, NULL);
  2313. queued_cells_string = smartlist_join_strings(queued_cells_strings,
  2314. ",", 0, NULL);
  2315. time_in_queue_string = smartlist_join_strings(time_in_queue_strings,
  2316. ",", 0, NULL);
  2317. SMARTLIST_FOREACH(processed_cells_strings, char *, cp, tor_free(cp));
  2318. SMARTLIST_FOREACH(queued_cells_strings, char *, cp, tor_free(cp));
  2319. SMARTLIST_FOREACH(time_in_queue_strings, char *, cp, tor_free(cp));
  2320. smartlist_free(processed_cells_strings);
  2321. smartlist_free(queued_cells_strings);
  2322. smartlist_free(time_in_queue_strings);
  2323. /* Put everything together. */
  2324. format_iso_time(t, now);
  2325. tor_asprintf(&result, "cell-stats-end %s (%d s)\n"
  2326. "cell-processed-cells %s\n"
  2327. "cell-queued-cells %s\n"
  2328. "cell-time-in-queue %s\n"
  2329. "cell-circuits-per-decile %d\n",
  2330. t, (unsigned) (now - start_of_buffer_stats_interval),
  2331. processed_cells_string,
  2332. queued_cells_string,
  2333. time_in_queue_string,
  2334. (number_of_circuits + SHARES - 1) / SHARES);
  2335. tor_free(processed_cells_string);
  2336. tor_free(queued_cells_string);
  2337. tor_free(time_in_queue_string);
  2338. return result;
  2339. #undef SHARES
  2340. }
  2341. /** If 24 hours have passed since the beginning of the current buffer
  2342. * stats period, write buffer stats to $DATADIR/stats/buffer-stats
  2343. * (possibly overwriting an existing file) and reset counters. Return
  2344. * when we would next want to write buffer stats or 0 if we never want to
  2345. * write. */
  2346. time_t
  2347. rep_hist_buffer_stats_write(time_t now)
  2348. {
  2349. circuit_t *circ;
  2350. char *statsdir = NULL, *filename = NULL, *str = NULL;
  2351. if (!start_of_buffer_stats_interval)
  2352. return 0; /* Not initialized. */
  2353. if (start_of_buffer_stats_interval + WRITE_STATS_INTERVAL > now)
  2354. goto done; /* Not ready to write */
  2355. /* Add open circuits to the history. */
  2356. for (circ = circuit_get_global_list_(); circ; circ = circ->next) {
  2357. rep_hist_buffer_stats_add_circ(circ, now);
  2358. }
  2359. /* Generate history string. */
  2360. str = rep_hist_format_buffer_stats(now);
  2361. /* Reset both buffer history and counters of open circuits. */
  2362. rep_hist_reset_buffer_stats(now);
  2363. /* Try to write to disk. */
  2364. statsdir = get_datadir_fname("stats");
  2365. if (check_private_dir(statsdir, CPD_CREATE, get_options()->User) < 0) {
  2366. log_warn(LD_HIST, "Unable to create stats/ directory!");
  2367. goto done;
  2368. }
  2369. filename = get_datadir_fname2("stats", "buffer-stats");
  2370. if (write_str_to_file(filename, str, 0) < 0)
  2371. log_warn(LD_HIST, "Unable to write buffer stats to disk!");
  2372. done:
  2373. tor_free(str);
  2374. tor_free(filename);
  2375. tor_free(statsdir);
  2376. return start_of_buffer_stats_interval + WRITE_STATS_INTERVAL;
  2377. }
  2378. /*** Descriptor serving statistics ***/
  2379. /** Digestmap to track which descriptors were downloaded this stats
  2380. * collection interval. It maps descriptor digest to pointers to 1,
  2381. * effectively turning this into a list. */
  2382. static digestmap_t *served_descs = NULL;
  2383. /** Number of how many descriptors were downloaded in total during this
  2384. * interval. */
  2385. static unsigned long total_descriptor_downloads;
  2386. /** Start time of served descs stats or 0 if we're not collecting those. */
  2387. static time_t start_of_served_descs_stats_interval;
  2388. /** Initialize descriptor stats. */
  2389. void
  2390. rep_hist_desc_stats_init(time_t now)
  2391. {
  2392. if (served_descs) {
  2393. log_warn(LD_BUG, "Called rep_hist_desc_stats_init() when desc stats were "
  2394. "already initialized. This is probably harmless.");
  2395. return; // Already initialized
  2396. }
  2397. served_descs = digestmap_new();
  2398. total_descriptor_downloads = 0;
  2399. start_of_served_descs_stats_interval = now;
  2400. }
  2401. /** Reset served descs stats to empty, starting a new interval <b>now</b>. */
  2402. static void
  2403. rep_hist_reset_desc_stats(time_t now)
  2404. {
  2405. rep_hist_desc_stats_term();
  2406. rep_hist_desc_stats_init(now);
  2407. }
  2408. /** Stop collecting served descs stats, so that rep_hist_desc_stats_init() is
  2409. * safe to be called again. */
  2410. void
  2411. rep_hist_desc_stats_term(void)
  2412. {
  2413. digestmap_free(served_descs, NULL);
  2414. served_descs = NULL;
  2415. start_of_served_descs_stats_interval = 0;
  2416. total_descriptor_downloads = 0;
  2417. }
  2418. /** Helper for rep_hist_desc_stats_write(). Return a newly allocated string
  2419. * containing the served desc statistics until now, or NULL if we're not
  2420. * collecting served desc stats. Caller must ensure that now is not before
  2421. * start_of_served_descs_stats_interval. */
  2422. static char *
  2423. rep_hist_format_desc_stats(time_t now)
  2424. {
  2425. char t[ISO_TIME_LEN+1];
  2426. char *result;
  2427. digestmap_iter_t *iter;
  2428. const char *key;
  2429. void *val;
  2430. unsigned size;
  2431. int *vals, max = 0, q3 = 0, md = 0, q1 = 0, min = 0;
  2432. int n = 0;
  2433. if (!start_of_served_descs_stats_interval)
  2434. return NULL;
  2435. size = digestmap_size(served_descs);
  2436. if (size > 0) {
  2437. vals = tor_malloc(size * sizeof(int));
  2438. for (iter = digestmap_iter_init(served_descs);
  2439. !digestmap_iter_done(iter);
  2440. iter = digestmap_iter_next(served_descs, iter)) {
  2441. uintptr_t count;
  2442. digestmap_iter_get(iter, &key, &val);
  2443. count = (uintptr_t)val;
  2444. vals[n++] = (int)count;
  2445. (void)key;
  2446. }
  2447. max = find_nth_int(vals, size, size-1);
  2448. q3 = find_nth_int(vals, size, (3*size-1)/4);
  2449. md = find_nth_int(vals, size, (size-1)/2);
  2450. q1 = find_nth_int(vals, size, (size-1)/4);
  2451. min = find_nth_int(vals, size, 0);
  2452. tor_free(vals);
  2453. }
  2454. format_iso_time(t, now);
  2455. tor_asprintf(&result,
  2456. "served-descs-stats-end %s (%d s) total=%lu unique=%u "
  2457. "max=%d q3=%d md=%d q1=%d min=%d\n",
  2458. t,
  2459. (unsigned) (now - start_of_served_descs_stats_interval),
  2460. total_descriptor_downloads,
  2461. size, max, q3, md, q1, min);
  2462. return result;
  2463. }
  2464. /** If WRITE_STATS_INTERVAL seconds have passed since the beginning of
  2465. * the current served desc stats interval, write the stats to
  2466. * $DATADIR/stats/served-desc-stats (possibly appending to an existing file)
  2467. * and reset the state for the next interval. Return when we would next want
  2468. * to write served desc stats or 0 if we won't want to write. */
  2469. time_t
  2470. rep_hist_desc_stats_write(time_t now)
  2471. {
  2472. char *statsdir = NULL, *filename = NULL, *str = NULL;
  2473. if (!start_of_served_descs_stats_interval)
  2474. return 0; /* We're not collecting stats. */
  2475. if (start_of_served_descs_stats_interval + WRITE_STATS_INTERVAL > now)
  2476. return start_of_served_descs_stats_interval + WRITE_STATS_INTERVAL;
  2477. str = rep_hist_format_desc_stats(now);
  2478. tor_assert(str != NULL);
  2479. statsdir = get_datadir_fname("stats");
  2480. if (check_private_dir(statsdir, CPD_CREATE, get_options()->User) < 0) {
  2481. log_warn(LD_HIST, "Unable to create stats/ directory!");
  2482. goto done;
  2483. }
  2484. filename = get_datadir_fname2("stats", "served-desc-stats");
  2485. if (append_bytes_to_file(filename, str, strlen(str), 0) < 0)
  2486. log_warn(LD_HIST, "Unable to write served descs statistics to disk!");
  2487. rep_hist_reset_desc_stats(now);
  2488. done:
  2489. tor_free(statsdir);
  2490. tor_free(filename);
  2491. tor_free(str);
  2492. return start_of_served_descs_stats_interval + WRITE_STATS_INTERVAL;
  2493. }
  2494. /* DOCDOC rep_hist_note_desc_served */
  2495. void
  2496. rep_hist_note_desc_served(const char * desc)
  2497. {
  2498. void *val;
  2499. uintptr_t count;
  2500. if (!served_descs)
  2501. return; // We're not collecting stats
  2502. val = digestmap_get(served_descs, desc);
  2503. count = (uintptr_t)val;
  2504. if (count != INT_MAX)
  2505. ++count;
  2506. digestmap_set(served_descs, desc, (void*)count);
  2507. total_descriptor_downloads++;
  2508. }
  2509. /*** Connection statistics ***/
  2510. /** Start of the current connection stats interval or 0 if we're not
  2511. * collecting connection statistics. */
  2512. static time_t start_of_conn_stats_interval;
  2513. /** Initialize connection stats. */
  2514. void
  2515. rep_hist_conn_stats_init(time_t now)
  2516. {
  2517. start_of_conn_stats_interval = now;
  2518. }
  2519. /* Count connections that we read and wrote less than these many bytes
  2520. * from/to as below threshold. */
  2521. #define BIDI_THRESHOLD 20480
  2522. /* Count connections that we read or wrote at least this factor as many
  2523. * bytes from/to than we wrote or read to/from as mostly reading or
  2524. * writing. */
  2525. #define BIDI_FACTOR 10
  2526. /* Interval length in seconds for considering read and written bytes for
  2527. * connection stats. */
  2528. #define BIDI_INTERVAL 10
  2529. /** Start of next BIDI_INTERVAL second interval. */
  2530. static time_t bidi_next_interval = 0;
  2531. /** Number of connections that we read and wrote less than BIDI_THRESHOLD
  2532. * bytes from/to in BIDI_INTERVAL seconds. */
  2533. static uint32_t below_threshold = 0;
  2534. /** Number of connections that we read at least BIDI_FACTOR times more
  2535. * bytes from than we wrote to in BIDI_INTERVAL seconds. */
  2536. static uint32_t mostly_read = 0;
  2537. /** Number of connections that we wrote at least BIDI_FACTOR times more
  2538. * bytes to than we read from in BIDI_INTERVAL seconds. */
  2539. static uint32_t mostly_written = 0;
  2540. /** Number of connections that we read and wrote at least BIDI_THRESHOLD
  2541. * bytes from/to, but not BIDI_FACTOR times more in either direction in
  2542. * BIDI_INTERVAL seconds. */
  2543. static uint32_t both_read_and_written = 0;
  2544. /** Entry in a map from connection ID to the number of read and written
  2545. * bytes on this connection in a BIDI_INTERVAL second interval. */
  2546. typedef struct bidi_map_entry_t {
  2547. HT_ENTRY(bidi_map_entry_t) node;
  2548. uint64_t conn_id; /**< Connection ID */
  2549. size_t read; /**< Number of read bytes */
  2550. size_t written; /**< Number of written bytes */
  2551. } bidi_map_entry_t;
  2552. /** Map of OR connections together with the number of read and written
  2553. * bytes in the current BIDI_INTERVAL second interval. */
  2554. static HT_HEAD(bidimap, bidi_map_entry_t) bidi_map =
  2555. HT_INITIALIZER();
  2556. static int
  2557. bidi_map_ent_eq(const bidi_map_entry_t *a, const bidi_map_entry_t *b)
  2558. {
  2559. return a->conn_id == b->conn_id;
  2560. }
  2561. /* DOCDOC bidi_map_ent_hash */
  2562. static unsigned
  2563. bidi_map_ent_hash(const bidi_map_entry_t *entry)
  2564. {
  2565. return (unsigned) entry->conn_id;
  2566. }
  2567. HT_PROTOTYPE(bidimap, bidi_map_entry_t, node, bidi_map_ent_hash,
  2568. bidi_map_ent_eq);
  2569. HT_GENERATE(bidimap, bidi_map_entry_t, node, bidi_map_ent_hash,
  2570. bidi_map_ent_eq, 0.6, malloc, realloc, free);
  2571. /* DOCDOC bidi_map_free */
  2572. static void
  2573. bidi_map_free(void)
  2574. {
  2575. bidi_map_entry_t **ptr, **next, *ent;
  2576. for (ptr = HT_START(bidimap, &bidi_map); ptr; ptr = next) {
  2577. ent = *ptr;
  2578. next = HT_NEXT_RMV(bidimap, &bidi_map, ptr);
  2579. tor_free(ent);
  2580. }
  2581. HT_CLEAR(bidimap, &bidi_map);
  2582. }
  2583. /** Reset counters for conn statistics. */
  2584. void
  2585. rep_hist_reset_conn_stats(time_t now)
  2586. {
  2587. start_of_conn_stats_interval = now;
  2588. below_threshold = 0;
  2589. mostly_read = 0;
  2590. mostly_written = 0;
  2591. both_read_and_written = 0;
  2592. bidi_map_free();
  2593. }
  2594. /** Stop collecting connection stats in a way that we can re-start doing
  2595. * so in rep_hist_conn_stats_init(). */
  2596. void
  2597. rep_hist_conn_stats_term(void)
  2598. {
  2599. rep_hist_reset_conn_stats(0);
  2600. }
  2601. /** We read <b>num_read</b> bytes and wrote <b>num_written</b> from/to OR
  2602. * connection <b>conn_id</b> in second <b>when</b>. If this is the first
  2603. * observation in a new interval, sum up the last observations. Add bytes
  2604. * for this connection. */
  2605. void
  2606. rep_hist_note_or_conn_bytes(uint64_t conn_id, size_t num_read,
  2607. size_t num_written, time_t when)
  2608. {
  2609. if (!start_of_conn_stats_interval)
  2610. return;
  2611. /* Initialize */
  2612. if (bidi_next_interval == 0)
  2613. bidi_next_interval = when + BIDI_INTERVAL;
  2614. /* Sum up last period's statistics */
  2615. if (when >= bidi_next_interval) {
  2616. bidi_map_entry_t **ptr, **next, *ent;
  2617. for (ptr = HT_START(bidimap, &bidi_map); ptr; ptr = next) {
  2618. ent = *ptr;
  2619. if (ent->read + ent->written < BIDI_THRESHOLD)
  2620. below_threshold++;
  2621. else if (ent->read >= ent->written * BIDI_FACTOR)
  2622. mostly_read++;
  2623. else if (ent->written >= ent->read * BIDI_FACTOR)
  2624. mostly_written++;
  2625. else
  2626. both_read_and_written++;
  2627. next = HT_NEXT_RMV(bidimap, &bidi_map, ptr);
  2628. tor_free(ent);
  2629. }
  2630. while (when >= bidi_next_interval)
  2631. bidi_next_interval += BIDI_INTERVAL;
  2632. log_info(LD_GENERAL, "%d below threshold, %d mostly read, "
  2633. "%d mostly written, %d both read and written.",
  2634. below_threshold, mostly_read, mostly_written,
  2635. both_read_and_written);
  2636. }
  2637. /* Add this connection's bytes. */
  2638. if (num_read > 0 || num_written > 0) {
  2639. bidi_map_entry_t *entry, lookup;
  2640. lookup.conn_id = conn_id;
  2641. entry = HT_FIND(bidimap, &bidi_map, &lookup);
  2642. if (entry) {
  2643. entry->written += num_written;
  2644. entry->read += num_read;
  2645. } else {
  2646. entry = tor_malloc_zero(sizeof(bidi_map_entry_t));
  2647. entry->conn_id = conn_id;
  2648. entry->written = num_written;
  2649. entry->read = num_read;
  2650. HT_INSERT(bidimap, &bidi_map, entry);
  2651. }
  2652. }
  2653. }
  2654. /** Return a newly allocated string containing the connection statistics
  2655. * until <b>now</b>, or NULL if we're not collecting conn stats. Caller must
  2656. * ensure start_of_conn_stats_interval is in the past. */
  2657. char *
  2658. rep_hist_format_conn_stats(time_t now)
  2659. {
  2660. char *result, written[ISO_TIME_LEN+1];
  2661. if (!start_of_conn_stats_interval)
  2662. return NULL; /* Not initialized. */
  2663. tor_assert(now >= start_of_conn_stats_interval);
  2664. format_iso_time(written, now);
  2665. tor_asprintf(&result, "conn-bi-direct %s (%d s) %d,%d,%d,%d\n",
  2666. written,
  2667. (unsigned) (now - start_of_conn_stats_interval),
  2668. below_threshold,
  2669. mostly_read,
  2670. mostly_written,
  2671. both_read_and_written);
  2672. return result;
  2673. }
  2674. /** If 24 hours have passed since the beginning of the current conn stats
  2675. * period, write conn stats to $DATADIR/stats/conn-stats (possibly
  2676. * overwriting an existing file) and reset counters. Return when we would
  2677. * next want to write conn stats or 0 if we never want to write. */
  2678. time_t
  2679. rep_hist_conn_stats_write(time_t now)
  2680. {
  2681. char *statsdir = NULL, *filename = NULL, *str = NULL;
  2682. if (!start_of_conn_stats_interval)
  2683. return 0; /* Not initialized. */
  2684. if (start_of_conn_stats_interval + WRITE_STATS_INTERVAL > now)
  2685. goto done; /* Not ready to write */
  2686. /* Generate history string. */
  2687. str = rep_hist_format_conn_stats(now);
  2688. /* Reset counters. */
  2689. rep_hist_reset_conn_stats(now);
  2690. /* Try to write to disk. */
  2691. statsdir = get_datadir_fname("stats");
  2692. if (check_private_dir(statsdir, CPD_CREATE, get_options()->User) < 0) {
  2693. log_warn(LD_HIST, "Unable to create stats/ directory!");
  2694. goto done;
  2695. }
  2696. filename = get_datadir_fname2("stats", "conn-stats");
  2697. if (write_str_to_file(filename, str, 0) < 0)
  2698. log_warn(LD_HIST, "Unable to write conn stats to disk!");
  2699. done:
  2700. tor_free(str);
  2701. tor_free(filename);
  2702. tor_free(statsdir);
  2703. return start_of_conn_stats_interval + WRITE_STATS_INTERVAL;
  2704. }
  2705. /** Free all storage held by the OR/link history caches, by the
  2706. * bandwidth history arrays, by the port history, or by statistics . */
  2707. void
  2708. rep_hist_free_all(void)
  2709. {
  2710. digestmap_free(history_map, free_or_history);
  2711. tor_free(read_array);
  2712. tor_free(write_array);
  2713. tor_free(last_stability_doc);
  2714. tor_free(exit_bytes_read);
  2715. tor_free(exit_bytes_written);
  2716. tor_free(exit_streams);
  2717. built_last_stability_doc_at = 0;
  2718. predicted_ports_free();
  2719. bidi_map_free();
  2720. if (circuits_for_buffer_stats) {
  2721. SMARTLIST_FOREACH(circuits_for_buffer_stats, circ_buffer_stats_t *, s,
  2722. tor_free(s));
  2723. smartlist_free(circuits_for_buffer_stats);
  2724. circuits_for_buffer_stats = NULL;
  2725. }
  2726. rep_hist_desc_stats_term();
  2727. total_descriptor_downloads = 0;
  2728. }