rephist.c 96 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935293629372938293929402941294229432944294529462947294829492950295129522953295429552956295729582959296029612962296329642965296629672968296929702971297229732974297529762977297829792980298129822983298429852986298729882989299029912992299329942995299629972998299930003001300230033004300530063007300830093010301130123013301430153016
  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. /* XXXX022 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 %.5lf%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.3lf\n"
  797. " weighted-time %lu\n"
  798. " weighted-uptime %lu\n"
  799. "mtbf %0.1lf\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 = 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 = 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 = 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. /* opt [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 = (smartlist_len(s_values) == smartlist_len(s_maxima));
  1521. if (s_values && s_begins >= now - NUM_SECS_BW_SUM_INTERVAL*NUM_TOTALS) {
  1522. start = s_begins - s_interval*(smartlist_len(s_values));
  1523. if (start > now)
  1524. return 0;
  1525. b->cur_obs_time = start;
  1526. b->next_period = start + NUM_SECS_BW_SUM_INTERVAL;
  1527. SMARTLIST_FOREACH_BEGIN(s_values, const char *, cp) {
  1528. const char *maxstr = NULL;
  1529. v = tor_parse_uint64(cp, 10, 0, UINT64_MAX, &ok, NULL);
  1530. if (have_maxima) {
  1531. maxstr = smartlist_get(s_maxima, cp_sl_idx);
  1532. mv = tor_parse_uint64(maxstr, 10, 0, UINT64_MAX, &ok_m, NULL);
  1533. mv *= NUM_SECS_ROLLING_MEASURE;
  1534. } else {
  1535. /* No maxima known; guess average rate to be conservative. */
  1536. mv = (v / s_interval) * NUM_SECS_ROLLING_MEASURE;
  1537. }
  1538. if (!ok) {
  1539. retval = -1;
  1540. log_notice(LD_HIST, "Could not parse value '%s' into a number.'",cp);
  1541. }
  1542. if (maxstr && !ok_m) {
  1543. retval = -1;
  1544. log_notice(LD_HIST, "Could not parse maximum '%s' into a number.'",
  1545. maxstr);
  1546. }
  1547. if (start < now) {
  1548. time_t cur_start = start;
  1549. time_t actual_interval_len = s_interval;
  1550. uint64_t cur_val = 0;
  1551. /* Calculate the average per second. This is the best we can do
  1552. * because our state file doesn't have per-second resolution. */
  1553. if (start + s_interval > now)
  1554. actual_interval_len = now - start;
  1555. cur_val = v / actual_interval_len;
  1556. /* This is potentially inefficient, but since we don't do it very
  1557. * often it should be ok. */
  1558. while (cur_start < start + actual_interval_len) {
  1559. add_obs(b, cur_start, cur_val);
  1560. ++cur_start;
  1561. }
  1562. b->max_total = mv;
  1563. /* This will result in some fairly choppy history if s_interval
  1564. * is not the same as NUM_SECS_BW_SUM_INTERVAL. XXXX */
  1565. start += actual_interval_len;
  1566. }
  1567. } SMARTLIST_FOREACH_END(cp);
  1568. }
  1569. /* Clean up maxima and observed */
  1570. for (i=0; i<NUM_SECS_ROLLING_MEASURE; ++i) {
  1571. b->obs[i] = 0;
  1572. }
  1573. b->total_obs = 0;
  1574. return retval;
  1575. }
  1576. /** Set bandwidth history from the state file we just loaded. */
  1577. int
  1578. rep_hist_load_state(or_state_t *state, char **err)
  1579. {
  1580. int all_ok = 1;
  1581. /* Assert they already have been malloced */
  1582. tor_assert(read_array && write_array);
  1583. tor_assert(dir_read_array && dir_write_array);
  1584. #define LOAD(arrname,st) \
  1585. if (rep_hist_load_bwhist_state_section( \
  1586. (arrname), \
  1587. state->BWHistory ## st ## Values, \
  1588. state->BWHistory ## st ## Maxima, \
  1589. state->BWHistory ## st ## Ends, \
  1590. state->BWHistory ## st ## Interval)<0) \
  1591. all_ok = 0
  1592. LOAD(write_array, Write);
  1593. LOAD(read_array, Read);
  1594. LOAD(dir_write_array, DirWrite);
  1595. LOAD(dir_read_array, DirRead);
  1596. #undef LOAD
  1597. if (!all_ok) {
  1598. *err = tor_strdup("Parsing of bandwidth history values failed");
  1599. /* and create fresh arrays */
  1600. bw_arrays_init();
  1601. return -1;
  1602. }
  1603. return 0;
  1604. }
  1605. /*********************************************************************/
  1606. /* DOCDOC predicted_port_t */
  1607. typedef struct predicted_port_t {
  1608. uint16_t port;
  1609. time_t time;
  1610. } predicted_port_t;
  1611. /** A list of port numbers that have been used recently. */
  1612. static smartlist_t *predicted_ports_list=NULL;
  1613. /** We just got an application request for a connection with
  1614. * port <b>port</b>. Remember it for the future, so we can keep
  1615. * some circuits open that will exit to this port.
  1616. */
  1617. static void
  1618. add_predicted_port(time_t now, uint16_t port)
  1619. {
  1620. predicted_port_t *pp = tor_malloc(sizeof(predicted_port_t));
  1621. pp->port = port;
  1622. pp->time = now;
  1623. rephist_total_alloc += sizeof(*pp);
  1624. smartlist_add(predicted_ports_list, pp);
  1625. }
  1626. /** Initialize whatever memory and structs are needed for predicting
  1627. * which ports will be used. Also seed it with port 80, so we'll build
  1628. * circuits on start-up.
  1629. */
  1630. static void
  1631. predicted_ports_init(void)
  1632. {
  1633. predicted_ports_list = smartlist_new();
  1634. add_predicted_port(time(NULL), 80); /* add one to kickstart us */
  1635. }
  1636. /** Free whatever memory is needed for predicting which ports will
  1637. * be used.
  1638. */
  1639. static void
  1640. predicted_ports_free(void)
  1641. {
  1642. rephist_total_alloc -=
  1643. smartlist_len(predicted_ports_list)*sizeof(predicted_port_t);
  1644. SMARTLIST_FOREACH(predicted_ports_list, predicted_port_t *,
  1645. pp, tor_free(pp));
  1646. smartlist_free(predicted_ports_list);
  1647. }
  1648. /** Remember that <b>port</b> has been asked for as of time <b>now</b>.
  1649. * This is used for predicting what sorts of streams we'll make in the
  1650. * future and making exit circuits to anticipate that.
  1651. */
  1652. void
  1653. rep_hist_note_used_port(time_t now, uint16_t port)
  1654. {
  1655. tor_assert(predicted_ports_list);
  1656. if (!port) /* record nothing */
  1657. return;
  1658. SMARTLIST_FOREACH_BEGIN(predicted_ports_list, predicted_port_t *, pp) {
  1659. if (pp->port == port) {
  1660. pp->time = now;
  1661. return;
  1662. }
  1663. } SMARTLIST_FOREACH_END(pp);
  1664. /* it's not there yet; we need to add it */
  1665. add_predicted_port(now, port);
  1666. }
  1667. /** For this long after we've seen a request for a given port, assume that
  1668. * we'll want to make connections to the same port in the future. */
  1669. #define PREDICTED_CIRCS_RELEVANCE_TIME (60*60)
  1670. /** Return a newly allocated pointer to a list of uint16_t * for ports that
  1671. * are likely to be asked for in the near future.
  1672. */
  1673. smartlist_t *
  1674. rep_hist_get_predicted_ports(time_t now)
  1675. {
  1676. smartlist_t *out = smartlist_new();
  1677. tor_assert(predicted_ports_list);
  1678. /* clean out obsolete entries */
  1679. SMARTLIST_FOREACH_BEGIN(predicted_ports_list, predicted_port_t *, pp) {
  1680. if (pp->time + PREDICTED_CIRCS_RELEVANCE_TIME < now) {
  1681. log_debug(LD_CIRC, "Expiring predicted port %d", pp->port);
  1682. rephist_total_alloc -= sizeof(predicted_port_t);
  1683. tor_free(pp);
  1684. SMARTLIST_DEL_CURRENT(predicted_ports_list, pp);
  1685. } else {
  1686. smartlist_add(out, tor_memdup(&pp->port, sizeof(uint16_t)));
  1687. }
  1688. } SMARTLIST_FOREACH_END(pp);
  1689. return out;
  1690. }
  1691. /**
  1692. * Take a list of uint16_t *, and remove every port in the list from the
  1693. * current list of predicted ports.
  1694. */
  1695. void
  1696. rep_hist_remove_predicted_ports(const smartlist_t *rmv_ports)
  1697. {
  1698. /* Let's do this on O(N), not O(N^2). */
  1699. bitarray_t *remove_ports = bitarray_init_zero(UINT16_MAX);
  1700. SMARTLIST_FOREACH(rmv_ports, const uint16_t *, p,
  1701. bitarray_set(remove_ports, *p));
  1702. SMARTLIST_FOREACH_BEGIN(predicted_ports_list, predicted_port_t *, pp) {
  1703. if (bitarray_is_set(remove_ports, pp->port)) {
  1704. tor_free(pp);
  1705. SMARTLIST_DEL_CURRENT(predicted_ports_list, pp);
  1706. }
  1707. } SMARTLIST_FOREACH_END(pp);
  1708. bitarray_free(remove_ports);
  1709. }
  1710. /** The user asked us to do a resolve. Rather than keeping track of
  1711. * timings and such of resolves, we fake it for now by treating
  1712. * it the same way as a connection to port 80. This way we will continue
  1713. * to have circuits lying around if the user only uses Tor for resolves.
  1714. */
  1715. void
  1716. rep_hist_note_used_resolve(time_t now)
  1717. {
  1718. rep_hist_note_used_port(now, 80);
  1719. }
  1720. /** The last time at which we needed an internal circ. */
  1721. static time_t predicted_internal_time = 0;
  1722. /** The last time we needed an internal circ with good uptime. */
  1723. static time_t predicted_internal_uptime_time = 0;
  1724. /** The last time we needed an internal circ with good capacity. */
  1725. static time_t predicted_internal_capacity_time = 0;
  1726. /** Remember that we used an internal circ at time <b>now</b>. */
  1727. void
  1728. rep_hist_note_used_internal(time_t now, int need_uptime, int need_capacity)
  1729. {
  1730. predicted_internal_time = now;
  1731. if (need_uptime)
  1732. predicted_internal_uptime_time = now;
  1733. if (need_capacity)
  1734. predicted_internal_capacity_time = now;
  1735. }
  1736. /** Return 1 if we've used an internal circ recently; else return 0. */
  1737. int
  1738. rep_hist_get_predicted_internal(time_t now, int *need_uptime,
  1739. int *need_capacity)
  1740. {
  1741. if (!predicted_internal_time) { /* initialize it */
  1742. predicted_internal_time = now;
  1743. predicted_internal_uptime_time = now;
  1744. predicted_internal_capacity_time = now;
  1745. }
  1746. if (predicted_internal_time + PREDICTED_CIRCS_RELEVANCE_TIME < now)
  1747. return 0; /* too long ago */
  1748. if (predicted_internal_uptime_time + PREDICTED_CIRCS_RELEVANCE_TIME >= now)
  1749. *need_uptime = 1;
  1750. // Always predict that we need capacity.
  1751. *need_capacity = 1;
  1752. return 1;
  1753. }
  1754. /** Any ports used lately? These are pre-seeded if we just started
  1755. * up or if we're running a hidden service. */
  1756. int
  1757. any_predicted_circuits(time_t now)
  1758. {
  1759. return smartlist_len(predicted_ports_list) ||
  1760. predicted_internal_time + PREDICTED_CIRCS_RELEVANCE_TIME >= now;
  1761. }
  1762. /** Return 1 if we have no need for circuits currently, else return 0. */
  1763. int
  1764. rep_hist_circbuilding_dormant(time_t now)
  1765. {
  1766. if (any_predicted_circuits(now))
  1767. return 0;
  1768. /* see if we'll still need to build testing circuits */
  1769. if (server_mode(get_options()) &&
  1770. (!check_whether_orport_reachable() || !circuit_enough_testing_circs()))
  1771. return 0;
  1772. if (!check_whether_dirport_reachable())
  1773. return 0;
  1774. return 1;
  1775. }
  1776. /** Structure to track how many times we've done each public key operation. */
  1777. static struct {
  1778. /** How many directory objects have we signed? */
  1779. unsigned long n_signed_dir_objs;
  1780. /** How many routerdescs have we signed? */
  1781. unsigned long n_signed_routerdescs;
  1782. /** How many directory objects have we verified? */
  1783. unsigned long n_verified_dir_objs;
  1784. /** How many routerdescs have we verified */
  1785. unsigned long n_verified_routerdescs;
  1786. /** How many onionskins have we encrypted to build circuits? */
  1787. unsigned long n_onionskins_encrypted;
  1788. /** How many onionskins have we decrypted to do circuit build requests? */
  1789. unsigned long n_onionskins_decrypted;
  1790. /** How many times have we done the TLS handshake as a client? */
  1791. unsigned long n_tls_client_handshakes;
  1792. /** How many times have we done the TLS handshake as a server? */
  1793. unsigned long n_tls_server_handshakes;
  1794. /** How many PK operations have we done as a hidden service client? */
  1795. unsigned long n_rend_client_ops;
  1796. /** How many PK operations have we done as a hidden service midpoint? */
  1797. unsigned long n_rend_mid_ops;
  1798. /** How many PK operations have we done as a hidden service provider? */
  1799. unsigned long n_rend_server_ops;
  1800. } pk_op_counts = {0,0,0,0,0,0,0,0,0,0,0};
  1801. /** Increment the count of the number of times we've done <b>operation</b>. */
  1802. void
  1803. note_crypto_pk_op(pk_op_t operation)
  1804. {
  1805. switch (operation)
  1806. {
  1807. case SIGN_DIR:
  1808. pk_op_counts.n_signed_dir_objs++;
  1809. break;
  1810. case SIGN_RTR:
  1811. pk_op_counts.n_signed_routerdescs++;
  1812. break;
  1813. case VERIFY_DIR:
  1814. pk_op_counts.n_verified_dir_objs++;
  1815. break;
  1816. case VERIFY_RTR:
  1817. pk_op_counts.n_verified_routerdescs++;
  1818. break;
  1819. case ENC_ONIONSKIN:
  1820. pk_op_counts.n_onionskins_encrypted++;
  1821. break;
  1822. case DEC_ONIONSKIN:
  1823. pk_op_counts.n_onionskins_decrypted++;
  1824. break;
  1825. case TLS_HANDSHAKE_C:
  1826. pk_op_counts.n_tls_client_handshakes++;
  1827. break;
  1828. case TLS_HANDSHAKE_S:
  1829. pk_op_counts.n_tls_server_handshakes++;
  1830. break;
  1831. case REND_CLIENT:
  1832. pk_op_counts.n_rend_client_ops++;
  1833. break;
  1834. case REND_MID:
  1835. pk_op_counts.n_rend_mid_ops++;
  1836. break;
  1837. case REND_SERVER:
  1838. pk_op_counts.n_rend_server_ops++;
  1839. break;
  1840. default:
  1841. log_warn(LD_BUG, "Unknown pk operation %d", operation);
  1842. }
  1843. }
  1844. /** Log the number of times we've done each public/private-key operation. */
  1845. void
  1846. dump_pk_ops(int severity)
  1847. {
  1848. log(severity, LD_HIST,
  1849. "PK operations: %lu directory objects signed, "
  1850. "%lu directory objects verified, "
  1851. "%lu routerdescs signed, "
  1852. "%lu routerdescs verified, "
  1853. "%lu onionskins encrypted, "
  1854. "%lu onionskins decrypted, "
  1855. "%lu client-side TLS handshakes, "
  1856. "%lu server-side TLS handshakes, "
  1857. "%lu rendezvous client operations, "
  1858. "%lu rendezvous middle operations, "
  1859. "%lu rendezvous server operations.",
  1860. pk_op_counts.n_signed_dir_objs,
  1861. pk_op_counts.n_verified_dir_objs,
  1862. pk_op_counts.n_signed_routerdescs,
  1863. pk_op_counts.n_verified_routerdescs,
  1864. pk_op_counts.n_onionskins_encrypted,
  1865. pk_op_counts.n_onionskins_decrypted,
  1866. pk_op_counts.n_tls_client_handshakes,
  1867. pk_op_counts.n_tls_server_handshakes,
  1868. pk_op_counts.n_rend_client_ops,
  1869. pk_op_counts.n_rend_mid_ops,
  1870. pk_op_counts.n_rend_server_ops);
  1871. }
  1872. /*** Exit port statistics ***/
  1873. /* Some constants */
  1874. /** To what multiple should byte numbers be rounded up? */
  1875. #define EXIT_STATS_ROUND_UP_BYTES 1024
  1876. /** To what multiple should stream counts be rounded up? */
  1877. #define EXIT_STATS_ROUND_UP_STREAMS 4
  1878. /** Number of TCP ports */
  1879. #define EXIT_STATS_NUM_PORTS 65536
  1880. /** Top n ports that will be included in exit stats. */
  1881. #define EXIT_STATS_TOP_N_PORTS 10
  1882. /* The following data structures are arrays and no fancy smartlists or maps,
  1883. * so that all write operations can be done in constant time. This comes at
  1884. * the price of some memory (1.25 MB) and linear complexity when writing
  1885. * stats for measuring relays. */
  1886. /** Number of bytes read in current period by exit port */
  1887. static uint64_t *exit_bytes_read = NULL;
  1888. /** Number of bytes written in current period by exit port */
  1889. static uint64_t *exit_bytes_written = NULL;
  1890. /** Number of streams opened in current period by exit port */
  1891. static uint32_t *exit_streams = NULL;
  1892. /** Start time of exit stats or 0 if we're not collecting exit stats. */
  1893. static time_t start_of_exit_stats_interval;
  1894. /** Initialize exit port stats. */
  1895. void
  1896. rep_hist_exit_stats_init(time_t now)
  1897. {
  1898. start_of_exit_stats_interval = now;
  1899. exit_bytes_read = tor_malloc_zero(EXIT_STATS_NUM_PORTS *
  1900. sizeof(uint64_t));
  1901. exit_bytes_written = tor_malloc_zero(EXIT_STATS_NUM_PORTS *
  1902. sizeof(uint64_t));
  1903. exit_streams = tor_malloc_zero(EXIT_STATS_NUM_PORTS *
  1904. sizeof(uint32_t));
  1905. }
  1906. /** Reset counters for exit port statistics. */
  1907. void
  1908. rep_hist_reset_exit_stats(time_t now)
  1909. {
  1910. start_of_exit_stats_interval = now;
  1911. memset(exit_bytes_read, 0, EXIT_STATS_NUM_PORTS * sizeof(uint64_t));
  1912. memset(exit_bytes_written, 0, EXIT_STATS_NUM_PORTS * sizeof(uint64_t));
  1913. memset(exit_streams, 0, EXIT_STATS_NUM_PORTS * sizeof(uint32_t));
  1914. }
  1915. /** Stop collecting exit port stats in a way that we can re-start doing
  1916. * so in rep_hist_exit_stats_init(). */
  1917. void
  1918. rep_hist_exit_stats_term(void)
  1919. {
  1920. start_of_exit_stats_interval = 0;
  1921. tor_free(exit_bytes_read);
  1922. tor_free(exit_bytes_written);
  1923. tor_free(exit_streams);
  1924. }
  1925. /** Helper for qsort: compare two ints. Does not handle overflow properly,
  1926. * but works fine for sorting an array of port numbers, which is what we use
  1927. * it for. */
  1928. static int
  1929. _compare_int(const void *x, const void *y)
  1930. {
  1931. return (*(int*)x - *(int*)y);
  1932. }
  1933. /** Return a newly allocated string containing the exit port statistics
  1934. * until <b>now</b>, or NULL if we're not collecting exit stats. Caller
  1935. * must ensure start_of_exit_stats_interval is in the past. */
  1936. char *
  1937. rep_hist_format_exit_stats(time_t now)
  1938. {
  1939. int i, j, top_elements = 0, cur_min_idx = 0, cur_port;
  1940. uint64_t top_bytes[EXIT_STATS_TOP_N_PORTS];
  1941. int top_ports[EXIT_STATS_TOP_N_PORTS];
  1942. uint64_t cur_bytes = 0, other_read = 0, other_written = 0,
  1943. total_read = 0, total_written = 0;
  1944. uint32_t total_streams = 0, other_streams = 0;
  1945. smartlist_t *written_strings, *read_strings, *streams_strings;
  1946. char *written_string, *read_string, *streams_string;
  1947. char t[ISO_TIME_LEN+1];
  1948. char *result;
  1949. if (!start_of_exit_stats_interval)
  1950. return NULL; /* Not initialized. */
  1951. tor_assert(now >= start_of_exit_stats_interval);
  1952. /* Go through all ports to find the n ports that saw most written and
  1953. * read bytes.
  1954. *
  1955. * Invariant: at the end of the loop for iteration i,
  1956. * total_read is the sum of all exit_bytes_read[0..i]
  1957. * total_written is the sum of all exit_bytes_written[0..i]
  1958. * total_stream is the sum of all exit_streams[0..i]
  1959. *
  1960. * top_elements = MAX(EXIT_STATS_TOP_N_PORTS,
  1961. * #{j | 0 <= j <= i && volume(i) > 0})
  1962. *
  1963. * For all 0 <= j < top_elements,
  1964. * top_bytes[j] > 0
  1965. * 0 <= top_ports[j] <= 65535
  1966. * top_bytes[j] = volume(top_ports[j])
  1967. *
  1968. * There is no j in 0..i and k in 0..top_elements such that:
  1969. * volume(j) > top_bytes[k] AND j is not in top_ports[0..top_elements]
  1970. *
  1971. * There is no j!=cur_min_idx in 0..top_elements such that:
  1972. * top_bytes[j] < top_bytes[cur_min_idx]
  1973. *
  1974. * where volume(x) == exit_bytes_read[x]+exit_bytes_written[x]
  1975. *
  1976. * Worst case: O(EXIT_STATS_NUM_PORTS * EXIT_STATS_TOP_N_PORTS)
  1977. */
  1978. for (i = 1; i < EXIT_STATS_NUM_PORTS; i++) {
  1979. total_read += exit_bytes_read[i];
  1980. total_written += exit_bytes_written[i];
  1981. total_streams += exit_streams[i];
  1982. cur_bytes = exit_bytes_read[i] + exit_bytes_written[i];
  1983. if (cur_bytes == 0) {
  1984. continue;
  1985. }
  1986. if (top_elements < EXIT_STATS_TOP_N_PORTS) {
  1987. top_bytes[top_elements] = cur_bytes;
  1988. top_ports[top_elements++] = i;
  1989. } else if (cur_bytes > top_bytes[cur_min_idx]) {
  1990. top_bytes[cur_min_idx] = cur_bytes;
  1991. top_ports[cur_min_idx] = i;
  1992. } else {
  1993. continue;
  1994. }
  1995. cur_min_idx = 0;
  1996. for (j = 1; j < top_elements; j++) {
  1997. if (top_bytes[j] < top_bytes[cur_min_idx]) {
  1998. cur_min_idx = j;
  1999. }
  2000. }
  2001. }
  2002. /* Add observations of top ports to smartlists. */
  2003. written_strings = smartlist_new();
  2004. read_strings = smartlist_new();
  2005. streams_strings = smartlist_new();
  2006. other_read = total_read;
  2007. other_written = total_written;
  2008. other_streams = total_streams;
  2009. /* Sort the ports; this puts them out of sync with top_bytes, but we
  2010. * won't be using top_bytes again anyway */
  2011. qsort(top_ports, top_elements, sizeof(int), _compare_int);
  2012. for (j = 0; j < top_elements; j++) {
  2013. cur_port = top_ports[j];
  2014. if (exit_bytes_written[cur_port] > 0) {
  2015. uint64_t num = round_uint64_to_next_multiple_of(
  2016. exit_bytes_written[cur_port],
  2017. EXIT_STATS_ROUND_UP_BYTES);
  2018. num /= 1024;
  2019. smartlist_add_asprintf(written_strings, "%d="U64_FORMAT,
  2020. cur_port, U64_PRINTF_ARG(num));
  2021. other_written -= exit_bytes_written[cur_port];
  2022. }
  2023. if (exit_bytes_read[cur_port] > 0) {
  2024. uint64_t num = round_uint64_to_next_multiple_of(
  2025. exit_bytes_read[cur_port],
  2026. EXIT_STATS_ROUND_UP_BYTES);
  2027. num /= 1024;
  2028. smartlist_add_asprintf(read_strings, "%d="U64_FORMAT,
  2029. cur_port, U64_PRINTF_ARG(num));
  2030. other_read -= exit_bytes_read[cur_port];
  2031. }
  2032. if (exit_streams[cur_port] > 0) {
  2033. uint32_t num = round_uint32_to_next_multiple_of(
  2034. exit_streams[cur_port],
  2035. EXIT_STATS_ROUND_UP_STREAMS);
  2036. smartlist_add_asprintf(streams_strings, "%d=%u", cur_port, num);
  2037. other_streams -= exit_streams[cur_port];
  2038. }
  2039. }
  2040. /* Add observations of other ports in a single element. */
  2041. other_written = round_uint64_to_next_multiple_of(other_written,
  2042. EXIT_STATS_ROUND_UP_BYTES);
  2043. other_written /= 1024;
  2044. smartlist_add_asprintf(written_strings, "other="U64_FORMAT,
  2045. U64_PRINTF_ARG(other_written));
  2046. other_read = round_uint64_to_next_multiple_of(other_read,
  2047. EXIT_STATS_ROUND_UP_BYTES);
  2048. other_read /= 1024;
  2049. smartlist_add_asprintf(read_strings, "other="U64_FORMAT,
  2050. U64_PRINTF_ARG(other_read));
  2051. other_streams = round_uint32_to_next_multiple_of(other_streams,
  2052. EXIT_STATS_ROUND_UP_STREAMS);
  2053. smartlist_add_asprintf(streams_strings, "other=%u", other_streams);
  2054. /* Join all observations in single strings. */
  2055. written_string = smartlist_join_strings(written_strings, ",", 0, NULL);
  2056. read_string = smartlist_join_strings(read_strings, ",", 0, NULL);
  2057. streams_string = smartlist_join_strings(streams_strings, ",", 0, NULL);
  2058. SMARTLIST_FOREACH(written_strings, char *, cp, tor_free(cp));
  2059. SMARTLIST_FOREACH(read_strings, char *, cp, tor_free(cp));
  2060. SMARTLIST_FOREACH(streams_strings, char *, cp, tor_free(cp));
  2061. smartlist_free(written_strings);
  2062. smartlist_free(read_strings);
  2063. smartlist_free(streams_strings);
  2064. /* Put everything together. */
  2065. format_iso_time(t, now);
  2066. tor_asprintf(&result, "exit-stats-end %s (%d s)\n"
  2067. "exit-kibibytes-written %s\n"
  2068. "exit-kibibytes-read %s\n"
  2069. "exit-streams-opened %s\n",
  2070. t, (unsigned) (now - start_of_exit_stats_interval),
  2071. written_string,
  2072. read_string,
  2073. streams_string);
  2074. tor_free(written_string);
  2075. tor_free(read_string);
  2076. tor_free(streams_string);
  2077. return result;
  2078. }
  2079. /** If 24 hours have passed since the beginning of the current exit port
  2080. * stats period, write exit stats to $DATADIR/stats/exit-stats (possibly
  2081. * overwriting an existing file) and reset counters. Return when we would
  2082. * next want to write exit stats or 0 if we never want to write. */
  2083. time_t
  2084. rep_hist_exit_stats_write(time_t now)
  2085. {
  2086. char *statsdir = NULL, *filename = NULL, *str = NULL;
  2087. if (!start_of_exit_stats_interval)
  2088. return 0; /* Not initialized. */
  2089. if (start_of_exit_stats_interval + WRITE_STATS_INTERVAL > now)
  2090. goto done; /* Not ready to write. */
  2091. log_info(LD_HIST, "Writing exit port statistics to disk.");
  2092. /* Generate history string. */
  2093. str = rep_hist_format_exit_stats(now);
  2094. /* Reset counters. */
  2095. rep_hist_reset_exit_stats(now);
  2096. /* Try to write to disk. */
  2097. statsdir = get_datadir_fname("stats");
  2098. if (check_private_dir(statsdir, CPD_CREATE, get_options()->User) < 0) {
  2099. log_warn(LD_HIST, "Unable to create stats/ directory!");
  2100. goto done;
  2101. }
  2102. filename = get_datadir_fname2("stats", "exit-stats");
  2103. if (write_str_to_file(filename, str, 0) < 0)
  2104. log_warn(LD_HIST, "Unable to write exit port statistics to disk!");
  2105. done:
  2106. tor_free(str);
  2107. tor_free(statsdir);
  2108. tor_free(filename);
  2109. return start_of_exit_stats_interval + WRITE_STATS_INTERVAL;
  2110. }
  2111. /** Note that we wrote <b>num_written</b> bytes and read <b>num_read</b>
  2112. * bytes to/from an exit connection to <b>port</b>. */
  2113. void
  2114. rep_hist_note_exit_bytes(uint16_t port, size_t num_written,
  2115. size_t num_read)
  2116. {
  2117. if (!start_of_exit_stats_interval)
  2118. return; /* Not initialized. */
  2119. exit_bytes_written[port] += num_written;
  2120. exit_bytes_read[port] += num_read;
  2121. log_debug(LD_HIST, "Written %lu bytes and read %lu bytes to/from an "
  2122. "exit connection to port %d.",
  2123. (unsigned long)num_written, (unsigned long)num_read, port);
  2124. }
  2125. /** Note that we opened an exit stream to <b>port</b>. */
  2126. void
  2127. rep_hist_note_exit_stream_opened(uint16_t port)
  2128. {
  2129. if (!start_of_exit_stats_interval)
  2130. return; /* Not initialized. */
  2131. exit_streams[port]++;
  2132. log_debug(LD_HIST, "Opened exit stream to port %d", port);
  2133. }
  2134. /*** cell statistics ***/
  2135. /** Start of the current buffer stats interval or 0 if we're not
  2136. * collecting buffer statistics. */
  2137. static time_t start_of_buffer_stats_interval;
  2138. /** Initialize buffer stats. */
  2139. void
  2140. rep_hist_buffer_stats_init(time_t now)
  2141. {
  2142. start_of_buffer_stats_interval = now;
  2143. }
  2144. /** Statistics from a single circuit. Collected when the circuit closes, or
  2145. * when we flush statistics to disk. */
  2146. typedef struct circ_buffer_stats_t {
  2147. /** Average number of cells in the circuit's queue */
  2148. double mean_num_cells_in_queue;
  2149. /** Average time a cell waits in the queue. */
  2150. double mean_time_cells_in_queue;
  2151. /** Total number of cells sent over this circuit */
  2152. uint32_t processed_cells;
  2153. } circ_buffer_stats_t;
  2154. /** List of circ_buffer_stats_t. */
  2155. static smartlist_t *circuits_for_buffer_stats = NULL;
  2156. /** Remember cell statistics <b>mean_num_cells_in_queue</b>,
  2157. * <b>mean_time_cells_in_queue</b>, and <b>processed_cells</b> of a
  2158. * circuit. */
  2159. void
  2160. rep_hist_add_buffer_stats(double mean_num_cells_in_queue,
  2161. double mean_time_cells_in_queue, uint32_t processed_cells)
  2162. {
  2163. circ_buffer_stats_t *stat;
  2164. if (!start_of_buffer_stats_interval)
  2165. return; /* Not initialized. */
  2166. stat = tor_malloc_zero(sizeof(circ_buffer_stats_t));
  2167. stat->mean_num_cells_in_queue = mean_num_cells_in_queue;
  2168. stat->mean_time_cells_in_queue = mean_time_cells_in_queue;
  2169. stat->processed_cells = processed_cells;
  2170. if (!circuits_for_buffer_stats)
  2171. circuits_for_buffer_stats = smartlist_new();
  2172. smartlist_add(circuits_for_buffer_stats, stat);
  2173. }
  2174. /** Remember cell statistics for circuit <b>circ</b> at time
  2175. * <b>end_of_interval</b> and reset cell counters in case the circuit
  2176. * remains open in the next measurement interval. */
  2177. void
  2178. rep_hist_buffer_stats_add_circ(circuit_t *circ, time_t end_of_interval)
  2179. {
  2180. time_t start_of_interval;
  2181. int interval_length;
  2182. or_circuit_t *orcirc;
  2183. double mean_num_cells_in_queue, mean_time_cells_in_queue;
  2184. uint32_t processed_cells;
  2185. if (CIRCUIT_IS_ORIGIN(circ))
  2186. return;
  2187. orcirc = TO_OR_CIRCUIT(circ);
  2188. if (!orcirc->processed_cells)
  2189. return;
  2190. start_of_interval = (circ->timestamp_created.tv_sec >
  2191. start_of_buffer_stats_interval) ?
  2192. circ->timestamp_created.tv_sec :
  2193. start_of_buffer_stats_interval;
  2194. interval_length = (int) (end_of_interval - start_of_interval);
  2195. if (interval_length <= 0)
  2196. return;
  2197. processed_cells = orcirc->processed_cells;
  2198. /* 1000.0 for s -> ms; 2.0 because of app-ward and exit-ward queues */
  2199. mean_num_cells_in_queue = (double) orcirc->total_cell_waiting_time /
  2200. (double) interval_length / 1000.0 / 2.0;
  2201. mean_time_cells_in_queue =
  2202. (double) orcirc->total_cell_waiting_time /
  2203. (double) orcirc->processed_cells;
  2204. orcirc->total_cell_waiting_time = 0;
  2205. orcirc->processed_cells = 0;
  2206. rep_hist_add_buffer_stats(mean_num_cells_in_queue,
  2207. mean_time_cells_in_queue,
  2208. processed_cells);
  2209. }
  2210. /** Sorting helper: return -1, 1, or 0 based on comparison of two
  2211. * circ_buffer_stats_t */
  2212. static int
  2213. _buffer_stats_compare_entries(const void **_a, const void **_b)
  2214. {
  2215. const circ_buffer_stats_t *a = *_a, *b = *_b;
  2216. if (a->processed_cells < b->processed_cells)
  2217. return 1;
  2218. else if (a->processed_cells > b->processed_cells)
  2219. return -1;
  2220. else
  2221. return 0;
  2222. }
  2223. /** Stop collecting cell stats in a way that we can re-start doing so in
  2224. * rep_hist_buffer_stats_init(). */
  2225. void
  2226. rep_hist_buffer_stats_term(void)
  2227. {
  2228. rep_hist_reset_buffer_stats(0);
  2229. }
  2230. /** Clear history of circuit statistics and set the measurement interval
  2231. * start to <b>now</b>. */
  2232. void
  2233. rep_hist_reset_buffer_stats(time_t now)
  2234. {
  2235. if (!circuits_for_buffer_stats)
  2236. circuits_for_buffer_stats = smartlist_new();
  2237. SMARTLIST_FOREACH(circuits_for_buffer_stats, circ_buffer_stats_t *,
  2238. stat, tor_free(stat));
  2239. smartlist_clear(circuits_for_buffer_stats);
  2240. start_of_buffer_stats_interval = now;
  2241. }
  2242. /** Return a newly allocated string containing the buffer statistics until
  2243. * <b>now</b>, or NULL if we're not collecting buffer stats. Caller must
  2244. * ensure start_of_buffer_stats_interval is in the past. */
  2245. char *
  2246. rep_hist_format_buffer_stats(time_t now)
  2247. {
  2248. #define SHARES 10
  2249. int processed_cells[SHARES], circs_in_share[SHARES],
  2250. number_of_circuits, i;
  2251. double queued_cells[SHARES], time_in_queue[SHARES];
  2252. smartlist_t *processed_cells_strings, *queued_cells_strings,
  2253. *time_in_queue_strings;
  2254. char *processed_cells_string, *queued_cells_string,
  2255. *time_in_queue_string;
  2256. char t[ISO_TIME_LEN+1];
  2257. char *result;
  2258. if (!start_of_buffer_stats_interval)
  2259. return NULL; /* Not initialized. */
  2260. tor_assert(now >= start_of_buffer_stats_interval);
  2261. /* Calculate deciles if we saw at least one circuit. */
  2262. memset(processed_cells, 0, SHARES * sizeof(int));
  2263. memset(circs_in_share, 0, SHARES * sizeof(int));
  2264. memset(queued_cells, 0, SHARES * sizeof(double));
  2265. memset(time_in_queue, 0, SHARES * sizeof(double));
  2266. if (!circuits_for_buffer_stats)
  2267. circuits_for_buffer_stats = smartlist_new();
  2268. number_of_circuits = smartlist_len(circuits_for_buffer_stats);
  2269. if (number_of_circuits > 0) {
  2270. smartlist_sort(circuits_for_buffer_stats,
  2271. _buffer_stats_compare_entries);
  2272. i = 0;
  2273. SMARTLIST_FOREACH_BEGIN(circuits_for_buffer_stats,
  2274. circ_buffer_stats_t *, stat)
  2275. {
  2276. int share = i++ * SHARES / number_of_circuits;
  2277. processed_cells[share] += stat->processed_cells;
  2278. queued_cells[share] += stat->mean_num_cells_in_queue;
  2279. time_in_queue[share] += stat->mean_time_cells_in_queue;
  2280. circs_in_share[share]++;
  2281. }
  2282. SMARTLIST_FOREACH_END(stat);
  2283. }
  2284. /* Write deciles to strings. */
  2285. processed_cells_strings = smartlist_new();
  2286. queued_cells_strings = smartlist_new();
  2287. time_in_queue_strings = smartlist_new();
  2288. for (i = 0; i < SHARES; i++) {
  2289. smartlist_add_asprintf(processed_cells_strings,
  2290. "%d", !circs_in_share[i] ? 0 :
  2291. processed_cells[i] / circs_in_share[i]);
  2292. }
  2293. for (i = 0; i < SHARES; i++) {
  2294. smartlist_add_asprintf(queued_cells_strings, "%.2f",
  2295. circs_in_share[i] == 0 ? 0.0 :
  2296. queued_cells[i] / (double) circs_in_share[i]);
  2297. }
  2298. for (i = 0; i < SHARES; i++) {
  2299. smartlist_add_asprintf(time_in_queue_strings, "%.0f",
  2300. circs_in_share[i] == 0 ? 0.0 :
  2301. time_in_queue[i] / (double) circs_in_share[i]);
  2302. }
  2303. /* Join all observations in single strings. */
  2304. processed_cells_string = smartlist_join_strings(processed_cells_strings,
  2305. ",", 0, NULL);
  2306. queued_cells_string = smartlist_join_strings(queued_cells_strings,
  2307. ",", 0, NULL);
  2308. time_in_queue_string = smartlist_join_strings(time_in_queue_strings,
  2309. ",", 0, NULL);
  2310. SMARTLIST_FOREACH(processed_cells_strings, char *, cp, tor_free(cp));
  2311. SMARTLIST_FOREACH(queued_cells_strings, char *, cp, tor_free(cp));
  2312. SMARTLIST_FOREACH(time_in_queue_strings, char *, cp, tor_free(cp));
  2313. smartlist_free(processed_cells_strings);
  2314. smartlist_free(queued_cells_strings);
  2315. smartlist_free(time_in_queue_strings);
  2316. /* Put everything together. */
  2317. format_iso_time(t, now);
  2318. tor_asprintf(&result, "cell-stats-end %s (%d s)\n"
  2319. "cell-processed-cells %s\n"
  2320. "cell-queued-cells %s\n"
  2321. "cell-time-in-queue %s\n"
  2322. "cell-circuits-per-decile %d\n",
  2323. t, (unsigned) (now - start_of_buffer_stats_interval),
  2324. processed_cells_string,
  2325. queued_cells_string,
  2326. time_in_queue_string,
  2327. (number_of_circuits + SHARES - 1) / SHARES);
  2328. tor_free(processed_cells_string);
  2329. tor_free(queued_cells_string);
  2330. tor_free(time_in_queue_string);
  2331. return result;
  2332. #undef SHARES
  2333. }
  2334. /** If 24 hours have passed since the beginning of the current buffer
  2335. * stats period, write buffer stats to $DATADIR/stats/buffer-stats
  2336. * (possibly overwriting an existing file) and reset counters. Return
  2337. * when we would next want to write buffer stats or 0 if we never want to
  2338. * write. */
  2339. time_t
  2340. rep_hist_buffer_stats_write(time_t now)
  2341. {
  2342. circuit_t *circ;
  2343. char *statsdir = NULL, *filename = NULL, *str = NULL;
  2344. if (!start_of_buffer_stats_interval)
  2345. return 0; /* Not initialized. */
  2346. if (start_of_buffer_stats_interval + WRITE_STATS_INTERVAL > now)
  2347. goto done; /* Not ready to write */
  2348. /* Add open circuits to the history. */
  2349. for (circ = _circuit_get_global_list(); circ; circ = circ->next) {
  2350. rep_hist_buffer_stats_add_circ(circ, now);
  2351. }
  2352. /* Generate history string. */
  2353. str = rep_hist_format_buffer_stats(now);
  2354. /* Reset both buffer history and counters of open circuits. */
  2355. rep_hist_reset_buffer_stats(now);
  2356. /* Try to write to disk. */
  2357. statsdir = get_datadir_fname("stats");
  2358. if (check_private_dir(statsdir, CPD_CREATE, get_options()->User) < 0) {
  2359. log_warn(LD_HIST, "Unable to create stats/ directory!");
  2360. goto done;
  2361. }
  2362. filename = get_datadir_fname2("stats", "buffer-stats");
  2363. if (write_str_to_file(filename, str, 0) < 0)
  2364. log_warn(LD_HIST, "Unable to write buffer stats to disk!");
  2365. done:
  2366. tor_free(str);
  2367. tor_free(filename);
  2368. tor_free(statsdir);
  2369. return start_of_buffer_stats_interval + WRITE_STATS_INTERVAL;
  2370. }
  2371. /*** Descriptor serving statistics ***/
  2372. /** Digestmap to track which descriptors were downloaded this stats
  2373. * collection interval. It maps descriptor digest to pointers to 1,
  2374. * effectively turning this into a list. */
  2375. static digestmap_t *served_descs = NULL;
  2376. /** Number of how many descriptors were downloaded in total during this
  2377. * interval. */
  2378. static unsigned long total_descriptor_downloads;
  2379. /** Start time of served descs stats or 0 if we're not collecting those. */
  2380. static time_t start_of_served_descs_stats_interval;
  2381. /** Initialize descriptor stats. */
  2382. void
  2383. rep_hist_desc_stats_init(time_t now)
  2384. {
  2385. if (served_descs) {
  2386. log_warn(LD_BUG, "Called rep_hist_desc_stats_init() when desc stats were "
  2387. "already initialized. This is probably harmless.");
  2388. return; // Already initialized
  2389. }
  2390. served_descs = digestmap_new();
  2391. total_descriptor_downloads = 0;
  2392. start_of_served_descs_stats_interval = now;
  2393. }
  2394. /** Reset served descs stats to empty, starting a new interval <b>now</b>. */
  2395. static void
  2396. rep_hist_reset_desc_stats(time_t now)
  2397. {
  2398. rep_hist_desc_stats_term();
  2399. rep_hist_desc_stats_init(now);
  2400. }
  2401. /** Stop collecting served descs stats, so that rep_hist_desc_stats_init() is
  2402. * safe to be called again. */
  2403. void
  2404. rep_hist_desc_stats_term(void)
  2405. {
  2406. digestmap_free(served_descs, NULL);
  2407. served_descs = NULL;
  2408. start_of_served_descs_stats_interval = 0;
  2409. total_descriptor_downloads = 0;
  2410. }
  2411. /** Helper for rep_hist_desc_stats_write(). Return a newly allocated string
  2412. * containing the served desc statistics until now, or NULL if we're not
  2413. * collecting served desc stats. Caller must ensure that now is not before
  2414. * start_of_served_descs_stats_interval. */
  2415. static char *
  2416. rep_hist_format_desc_stats(time_t now)
  2417. {
  2418. char t[ISO_TIME_LEN+1];
  2419. char *result;
  2420. digestmap_iter_t *iter;
  2421. const char *key;
  2422. void *val;
  2423. unsigned size;
  2424. int *vals, max = 0, q3 = 0, md = 0, q1 = 0, min = 0;
  2425. int n = 0;
  2426. if (!start_of_served_descs_stats_interval)
  2427. return NULL;
  2428. size = digestmap_size(served_descs);
  2429. if (size > 0) {
  2430. vals = tor_malloc(size * sizeof(int));
  2431. for (iter = digestmap_iter_init(served_descs);
  2432. !digestmap_iter_done(iter);
  2433. iter = digestmap_iter_next(served_descs, iter)) {
  2434. uintptr_t count;
  2435. digestmap_iter_get(iter, &key, &val);
  2436. count = (uintptr_t)val;
  2437. vals[n++] = (int)count;
  2438. (void)key;
  2439. }
  2440. max = find_nth_int(vals, size, size-1);
  2441. q3 = find_nth_int(vals, size, (3*size-1)/4);
  2442. md = find_nth_int(vals, size, (size-1)/2);
  2443. q1 = find_nth_int(vals, size, (size-1)/4);
  2444. min = find_nth_int(vals, size, 0);
  2445. tor_free(vals);
  2446. }
  2447. format_iso_time(t, now);
  2448. tor_asprintf(&result,
  2449. "served-descs-stats-end %s (%d s) total=%lu unique=%u "
  2450. "max=%d q3=%d md=%d q1=%d min=%d\n",
  2451. t,
  2452. (unsigned) (now - start_of_served_descs_stats_interval),
  2453. total_descriptor_downloads,
  2454. size, max, q3, md, q1, min);
  2455. return result;
  2456. }
  2457. /** If WRITE_STATS_INTERVAL seconds have passed since the beginning of
  2458. * the current served desc stats interval, write the stats to
  2459. * $DATADIR/stats/served-desc-stats (possibly appending to an existing file)
  2460. * and reset the state for the next interval. Return when we would next want
  2461. * to write served desc stats or 0 if we won't want to write. */
  2462. time_t
  2463. rep_hist_desc_stats_write(time_t now)
  2464. {
  2465. char *statsdir = NULL, *filename = NULL, *str = NULL;
  2466. if (!start_of_served_descs_stats_interval)
  2467. return 0; /* We're not collecting stats. */
  2468. if (start_of_served_descs_stats_interval + WRITE_STATS_INTERVAL > now)
  2469. return start_of_served_descs_stats_interval + WRITE_STATS_INTERVAL;
  2470. str = rep_hist_format_desc_stats(now);
  2471. tor_assert(str != NULL);
  2472. statsdir = get_datadir_fname("stats");
  2473. if (check_private_dir(statsdir, CPD_CREATE, get_options()->User) < 0) {
  2474. log_warn(LD_HIST, "Unable to create stats/ directory!");
  2475. goto done;
  2476. }
  2477. filename = get_datadir_fname2("stats", "served-desc-stats");
  2478. if (append_bytes_to_file(filename, str, strlen(str), 0) < 0)
  2479. log_warn(LD_HIST, "Unable to write served descs statistics to disk!");
  2480. rep_hist_reset_desc_stats(now);
  2481. done:
  2482. tor_free(statsdir);
  2483. tor_free(filename);
  2484. tor_free(str);
  2485. return start_of_served_descs_stats_interval + WRITE_STATS_INTERVAL;
  2486. }
  2487. /* DOCDOC rep_hist_note_desc_served */
  2488. void
  2489. rep_hist_note_desc_served(const char * desc)
  2490. {
  2491. void *val;
  2492. uintptr_t count;
  2493. if (!served_descs)
  2494. return; // We're not collecting stats
  2495. val = digestmap_get(served_descs, desc);
  2496. count = (uintptr_t)val;
  2497. if (count != INT_MAX)
  2498. ++count;
  2499. digestmap_set(served_descs, desc, (void*)count);
  2500. total_descriptor_downloads++;
  2501. }
  2502. /*** Connection statistics ***/
  2503. /** Start of the current connection stats interval or 0 if we're not
  2504. * collecting connection statistics. */
  2505. static time_t start_of_conn_stats_interval;
  2506. /** Initialize connection stats. */
  2507. void
  2508. rep_hist_conn_stats_init(time_t now)
  2509. {
  2510. start_of_conn_stats_interval = now;
  2511. }
  2512. /* Count connections that we read and wrote less than these many bytes
  2513. * from/to as below threshold. */
  2514. #define BIDI_THRESHOLD 20480
  2515. /* Count connections that we read or wrote at least this factor as many
  2516. * bytes from/to than we wrote or read to/from as mostly reading or
  2517. * writing. */
  2518. #define BIDI_FACTOR 10
  2519. /* Interval length in seconds for considering read and written bytes for
  2520. * connection stats. */
  2521. #define BIDI_INTERVAL 10
  2522. /** Start of next BIDI_INTERVAL second interval. */
  2523. static time_t bidi_next_interval = 0;
  2524. /** Number of connections that we read and wrote less than BIDI_THRESHOLD
  2525. * bytes from/to in BIDI_INTERVAL seconds. */
  2526. static uint32_t below_threshold = 0;
  2527. /** Number of connections that we read at least BIDI_FACTOR times more
  2528. * bytes from than we wrote to in BIDI_INTERVAL seconds. */
  2529. static uint32_t mostly_read = 0;
  2530. /** Number of connections that we wrote at least BIDI_FACTOR times more
  2531. * bytes to than we read from in BIDI_INTERVAL seconds. */
  2532. static uint32_t mostly_written = 0;
  2533. /** Number of connections that we read and wrote at least BIDI_THRESHOLD
  2534. * bytes from/to, but not BIDI_FACTOR times more in either direction in
  2535. * BIDI_INTERVAL seconds. */
  2536. static uint32_t both_read_and_written = 0;
  2537. /** Entry in a map from connection ID to the number of read and written
  2538. * bytes on this connection in a BIDI_INTERVAL second interval. */
  2539. typedef struct bidi_map_entry_t {
  2540. HT_ENTRY(bidi_map_entry_t) node;
  2541. uint64_t conn_id; /**< Connection ID */
  2542. size_t read; /**< Number of read bytes */
  2543. size_t written; /**< Number of written bytes */
  2544. } bidi_map_entry_t;
  2545. /** Map of OR connections together with the number of read and written
  2546. * bytes in the current BIDI_INTERVAL second interval. */
  2547. static HT_HEAD(bidimap, bidi_map_entry_t) bidi_map =
  2548. HT_INITIALIZER();
  2549. static int
  2550. bidi_map_ent_eq(const bidi_map_entry_t *a, const bidi_map_entry_t *b)
  2551. {
  2552. return a->conn_id == b->conn_id;
  2553. }
  2554. /* DOCDOC bidi_map_ent_hash */
  2555. static unsigned
  2556. bidi_map_ent_hash(const bidi_map_entry_t *entry)
  2557. {
  2558. return (unsigned) entry->conn_id;
  2559. }
  2560. HT_PROTOTYPE(bidimap, bidi_map_entry_t, node, bidi_map_ent_hash,
  2561. bidi_map_ent_eq);
  2562. HT_GENERATE(bidimap, bidi_map_entry_t, node, bidi_map_ent_hash,
  2563. bidi_map_ent_eq, 0.6, malloc, realloc, free);
  2564. /* DOCDOC bidi_map_free */
  2565. static void
  2566. bidi_map_free(void)
  2567. {
  2568. bidi_map_entry_t **ptr, **next, *ent;
  2569. for (ptr = HT_START(bidimap, &bidi_map); ptr; ptr = next) {
  2570. ent = *ptr;
  2571. next = HT_NEXT_RMV(bidimap, &bidi_map, ptr);
  2572. tor_free(ent);
  2573. }
  2574. HT_CLEAR(bidimap, &bidi_map);
  2575. }
  2576. /** Reset counters for conn statistics. */
  2577. void
  2578. rep_hist_reset_conn_stats(time_t now)
  2579. {
  2580. start_of_conn_stats_interval = now;
  2581. below_threshold = 0;
  2582. mostly_read = 0;
  2583. mostly_written = 0;
  2584. both_read_and_written = 0;
  2585. bidi_map_free();
  2586. }
  2587. /** Stop collecting connection stats in a way that we can re-start doing
  2588. * so in rep_hist_conn_stats_init(). */
  2589. void
  2590. rep_hist_conn_stats_term(void)
  2591. {
  2592. rep_hist_reset_conn_stats(0);
  2593. }
  2594. /** We read <b>num_read</b> bytes and wrote <b>num_written</b> from/to OR
  2595. * connection <b>conn_id</b> in second <b>when</b>. If this is the first
  2596. * observation in a new interval, sum up the last observations. Add bytes
  2597. * for this connection. */
  2598. void
  2599. rep_hist_note_or_conn_bytes(uint64_t conn_id, size_t num_read,
  2600. size_t num_written, time_t when)
  2601. {
  2602. if (!start_of_conn_stats_interval)
  2603. return;
  2604. /* Initialize */
  2605. if (bidi_next_interval == 0)
  2606. bidi_next_interval = when + BIDI_INTERVAL;
  2607. /* Sum up last period's statistics */
  2608. if (when >= bidi_next_interval) {
  2609. bidi_map_entry_t **ptr, **next, *ent;
  2610. for (ptr = HT_START(bidimap, &bidi_map); ptr; ptr = next) {
  2611. ent = *ptr;
  2612. if (ent->read + ent->written < BIDI_THRESHOLD)
  2613. below_threshold++;
  2614. else if (ent->read >= ent->written * BIDI_FACTOR)
  2615. mostly_read++;
  2616. else if (ent->written >= ent->read * BIDI_FACTOR)
  2617. mostly_written++;
  2618. else
  2619. both_read_and_written++;
  2620. next = HT_NEXT_RMV(bidimap, &bidi_map, ptr);
  2621. tor_free(ent);
  2622. }
  2623. while (when >= bidi_next_interval)
  2624. bidi_next_interval += BIDI_INTERVAL;
  2625. log_info(LD_GENERAL, "%d below threshold, %d mostly read, "
  2626. "%d mostly written, %d both read and written.",
  2627. below_threshold, mostly_read, mostly_written,
  2628. both_read_and_written);
  2629. }
  2630. /* Add this connection's bytes. */
  2631. if (num_read > 0 || num_written > 0) {
  2632. bidi_map_entry_t *entry, lookup;
  2633. lookup.conn_id = conn_id;
  2634. entry = HT_FIND(bidimap, &bidi_map, &lookup);
  2635. if (entry) {
  2636. entry->written += num_written;
  2637. entry->read += num_read;
  2638. } else {
  2639. entry = tor_malloc_zero(sizeof(bidi_map_entry_t));
  2640. entry->conn_id = conn_id;
  2641. entry->written = num_written;
  2642. entry->read = num_read;
  2643. HT_INSERT(bidimap, &bidi_map, entry);
  2644. }
  2645. }
  2646. }
  2647. /** Return a newly allocated string containing the connection statistics
  2648. * until <b>now</b>, or NULL if we're not collecting conn stats. Caller must
  2649. * ensure start_of_conn_stats_interval is in the past. */
  2650. char *
  2651. rep_hist_format_conn_stats(time_t now)
  2652. {
  2653. char *result, written[ISO_TIME_LEN+1];
  2654. if (!start_of_conn_stats_interval)
  2655. return NULL; /* Not initialized. */
  2656. tor_assert(now >= start_of_conn_stats_interval);
  2657. format_iso_time(written, now);
  2658. tor_asprintf(&result, "conn-bi-direct %s (%d s) %d,%d,%d,%d\n",
  2659. written,
  2660. (unsigned) (now - start_of_conn_stats_interval),
  2661. below_threshold,
  2662. mostly_read,
  2663. mostly_written,
  2664. both_read_and_written);
  2665. return result;
  2666. }
  2667. /** If 24 hours have passed since the beginning of the current conn stats
  2668. * period, write conn stats to $DATADIR/stats/conn-stats (possibly
  2669. * overwriting an existing file) and reset counters. Return when we would
  2670. * next want to write conn stats or 0 if we never want to write. */
  2671. time_t
  2672. rep_hist_conn_stats_write(time_t now)
  2673. {
  2674. char *statsdir = NULL, *filename = NULL, *str = NULL;
  2675. if (!start_of_conn_stats_interval)
  2676. return 0; /* Not initialized. */
  2677. if (start_of_conn_stats_interval + WRITE_STATS_INTERVAL > now)
  2678. goto done; /* Not ready to write */
  2679. /* Generate history string. */
  2680. str = rep_hist_format_conn_stats(now);
  2681. /* Reset counters. */
  2682. rep_hist_reset_conn_stats(now);
  2683. /* Try to write to disk. */
  2684. statsdir = get_datadir_fname("stats");
  2685. if (check_private_dir(statsdir, CPD_CREATE, get_options()->User) < 0) {
  2686. log_warn(LD_HIST, "Unable to create stats/ directory!");
  2687. goto done;
  2688. }
  2689. filename = get_datadir_fname2("stats", "conn-stats");
  2690. if (write_str_to_file(filename, str, 0) < 0)
  2691. log_warn(LD_HIST, "Unable to write conn stats to disk!");
  2692. done:
  2693. tor_free(str);
  2694. tor_free(filename);
  2695. tor_free(statsdir);
  2696. return start_of_conn_stats_interval + WRITE_STATS_INTERVAL;
  2697. }
  2698. /** Free all storage held by the OR/link history caches, by the
  2699. * bandwidth history arrays, by the port history, or by statistics . */
  2700. void
  2701. rep_hist_free_all(void)
  2702. {
  2703. digestmap_free(history_map, free_or_history);
  2704. tor_free(read_array);
  2705. tor_free(write_array);
  2706. tor_free(last_stability_doc);
  2707. tor_free(exit_bytes_read);
  2708. tor_free(exit_bytes_written);
  2709. tor_free(exit_streams);
  2710. built_last_stability_doc_at = 0;
  2711. predicted_ports_free();
  2712. bidi_map_free();
  2713. if (circuits_for_buffer_stats) {
  2714. SMARTLIST_FOREACH(circuits_for_buffer_stats, circ_buffer_stats_t *, s,
  2715. tor_free(s));
  2716. smartlist_free(circuits_for_buffer_stats);
  2717. circuits_for_buffer_stats = NULL;
  2718. }
  2719. rep_hist_desc_stats_term();
  2720. total_descriptor_downloads = 0;
  2721. }