nodelist.c 69 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169
  1. /* Copyright (c) 2001 Matej Pfajfar.
  2. * Copyright (c) 2001-2004, Roger Dingledine.
  3. * Copyright (c) 2004-2006, Roger Dingledine, Nick Mathewson.
  4. * Copyright (c) 2007-2017, The Tor Project, Inc. */
  5. /* See LICENSE for licensing information */
  6. /**
  7. * \file nodelist.c
  8. *
  9. * \brief Structures and functions for tracking what we know about the routers
  10. * on the Tor network, and correlating information from networkstatus,
  11. * routerinfo, and microdescs.
  12. *
  13. * The key structure here is node_t: that's the canonical way to refer
  14. * to a Tor relay that we might want to build a circuit through. Every
  15. * node_t has either a routerinfo_t, or a routerstatus_t from the current
  16. * networkstatus consensus. If it has a routerstatus_t, it will also
  17. * need to have a microdesc_t before you can use it for circuits.
  18. *
  19. * The nodelist_t is a global singleton that maps identities to node_t
  20. * objects. Access them with the node_get_*() functions. The nodelist_t
  21. * is maintained by calls throughout the codebase
  22. *
  23. * Generally, other code should not have to reach inside a node_t to
  24. * see what information it has. Instead, you should call one of the
  25. * many accessor functions that works on a generic node_t. If there
  26. * isn't one that does what you need, it's better to make such a function,
  27. * and then use it.
  28. *
  29. * For historical reasons, some of the functions that select a node_t
  30. * from the list of all usable node_t objects are in the routerlist.c
  31. * module, since they originally selected a routerinfo_t. (TODO: They
  32. * should move!)
  33. *
  34. * (TODO: Perhaps someday we should abstract the remaining ways of
  35. * talking about a relay to also be node_t instances. Those would be
  36. * routerstatus_t as used for directory requests, and dir_server_t as
  37. * used for authorities and fallback directories.)
  38. */
  39. #include "or.h"
  40. #include "address.h"
  41. #include "config.h"
  42. #include "control.h"
  43. #include "dirserv.h"
  44. #include "entrynodes.h"
  45. #include "geoip.h"
  46. #include "hs_common.h"
  47. #include "main.h"
  48. #include "microdesc.h"
  49. #include "networkstatus.h"
  50. #include "nodelist.h"
  51. #include "policies.h"
  52. #include "protover.h"
  53. #include "rendservice.h"
  54. #include "router.h"
  55. #include "routerlist.h"
  56. #include "routerparse.h"
  57. #include "routerset.h"
  58. #include "torcert.h"
  59. #include <string.h>
  60. static void nodelist_drop_node(node_t *node, int remove_from_ht);
  61. static void node_free(node_t *node);
  62. /** count_usable_descriptors counts descriptors with these flag(s)
  63. */
  64. typedef enum {
  65. /* All descriptors regardless of flags */
  66. USABLE_DESCRIPTOR_ALL = 0,
  67. /* Only descriptors with the Exit flag */
  68. USABLE_DESCRIPTOR_EXIT_ONLY = 1
  69. } usable_descriptor_t;
  70. static void count_usable_descriptors(int *num_present,
  71. int *num_usable,
  72. smartlist_t *descs_out,
  73. const networkstatus_t *consensus,
  74. time_t now,
  75. routerset_t *in_set,
  76. usable_descriptor_t exit_only);
  77. static void update_router_have_minimum_dir_info(void);
  78. static double get_frac_paths_needed_for_circs(const or_options_t *options,
  79. const networkstatus_t *ns);
  80. /** A nodelist_t holds a node_t object for every router we're "willing to use
  81. * for something". Specifically, it should hold a node_t for every node that
  82. * is currently in the routerlist, or currently in the consensus we're using.
  83. */
  84. typedef struct nodelist_t {
  85. /* A list of all the nodes. */
  86. smartlist_t *nodes;
  87. /* Hash table to map from node ID digest to node. */
  88. HT_HEAD(nodelist_map, node_t) nodes_by_id;
  89. } nodelist_t;
  90. static inline unsigned int
  91. node_id_hash(const node_t *node)
  92. {
  93. return (unsigned) siphash24g(node->identity, DIGEST_LEN);
  94. }
  95. static inline unsigned int
  96. node_id_eq(const node_t *node1, const node_t *node2)
  97. {
  98. return tor_memeq(node1->identity, node2->identity, DIGEST_LEN);
  99. }
  100. HT_PROTOTYPE(nodelist_map, node_t, ht_ent, node_id_hash, node_id_eq)
  101. HT_GENERATE2(nodelist_map, node_t, ht_ent, node_id_hash, node_id_eq,
  102. 0.6, tor_reallocarray_, tor_free_)
  103. /** The global nodelist. */
  104. static nodelist_t *the_nodelist=NULL;
  105. /** Create an empty nodelist if we haven't done so already. */
  106. static void
  107. init_nodelist(void)
  108. {
  109. if (PREDICT_UNLIKELY(the_nodelist == NULL)) {
  110. the_nodelist = tor_malloc_zero(sizeof(nodelist_t));
  111. HT_INIT(nodelist_map, &the_nodelist->nodes_by_id);
  112. the_nodelist->nodes = smartlist_new();
  113. }
  114. }
  115. /** As node_get_by_id, but returns a non-const pointer */
  116. node_t *
  117. node_get_mutable_by_id(const char *identity_digest)
  118. {
  119. node_t search, *node;
  120. if (PREDICT_UNLIKELY(the_nodelist == NULL))
  121. return NULL;
  122. memcpy(&search.identity, identity_digest, DIGEST_LEN);
  123. node = HT_FIND(nodelist_map, &the_nodelist->nodes_by_id, &search);
  124. return node;
  125. }
  126. /** Return the node_t whose identity is <b>identity_digest</b>, or NULL
  127. * if no such node exists. */
  128. MOCK_IMPL(const node_t *,
  129. node_get_by_id,(const char *identity_digest))
  130. {
  131. return node_get_mutable_by_id(identity_digest);
  132. }
  133. /** Internal: return the node_t whose identity_digest is
  134. * <b>identity_digest</b>. If none exists, create a new one, add it to the
  135. * nodelist, and return it.
  136. *
  137. * Requires that the nodelist be initialized.
  138. */
  139. static node_t *
  140. node_get_or_create(const char *identity_digest)
  141. {
  142. node_t *node;
  143. if ((node = node_get_mutable_by_id(identity_digest)))
  144. return node;
  145. node = tor_malloc_zero(sizeof(node_t));
  146. memcpy(node->identity, identity_digest, DIGEST_LEN);
  147. HT_INSERT(nodelist_map, &the_nodelist->nodes_by_id, node);
  148. smartlist_add(the_nodelist->nodes, node);
  149. node->nodelist_idx = smartlist_len(the_nodelist->nodes) - 1;
  150. node->hsdir_index = tor_malloc_zero(sizeof(hsdir_index_t));
  151. node->country = -1;
  152. return node;
  153. }
  154. /* For a given <b>node</b> for the consensus <b>ns</b>, set the hsdir index
  155. * for the node, both current and next if possible. This can only fails if the
  156. * node_t ed25519 identity key can't be found which would be a bug. */
  157. static void
  158. node_set_hsdir_index(node_t *node, const networkstatus_t *ns)
  159. {
  160. time_t now = time(NULL);
  161. const ed25519_public_key_t *node_identity_pk;
  162. uint8_t *next_hsdir_index_srv = NULL, *current_hsdir_index_srv = NULL;
  163. uint64_t next_time_period_num, current_time_period_num;
  164. tor_assert(node);
  165. tor_assert(ns);
  166. node_identity_pk = node_get_ed25519_id(node);
  167. if (node_identity_pk == NULL) {
  168. log_debug(LD_GENERAL, "ed25519 identity public key not found when "
  169. "trying to build the hsdir indexes for node %s",
  170. node_describe(node));
  171. goto done;
  172. }
  173. /* Get the current and next time period number, we might use them both. */
  174. current_time_period_num = hs_get_time_period_num(now);
  175. next_time_period_num = hs_get_next_time_period_num(now);
  176. if (hs_overlap_mode_is_active(ns, now)) {
  177. /* We are in overlap mode, this means that our consensus has just cycled
  178. * from current SRV to previous SRV so for the _next_ upcoming time
  179. * period, we have to use the current SRV and use the previous SRV for the
  180. * current time period. If the current or previous SRV can't be found, the
  181. * disaster one is returned. */
  182. next_hsdir_index_srv = hs_get_current_srv(next_time_period_num);
  183. /* The following can be confusing so again, in overlap mode, we use our
  184. * previous SRV for our _current_ hsdir index. */
  185. current_hsdir_index_srv = hs_get_previous_srv(current_time_period_num);
  186. } else {
  187. /* If NOT in overlap mode, we only need to compute the current hsdir index
  188. * for the ongoing time period and thus the current SRV. If it can't be
  189. * found, the disaster one is returned. */
  190. current_hsdir_index_srv = hs_get_current_srv(current_time_period_num);
  191. }
  192. /* Build the current hsdir index. */
  193. hs_build_hsdir_index(node_identity_pk, current_hsdir_index_srv,
  194. current_time_period_num, node->hsdir_index->current);
  195. if (next_hsdir_index_srv) {
  196. /* Build the next hsdir index if we have a next SRV that we can use. */
  197. hs_build_hsdir_index(node_identity_pk, next_hsdir_index_srv,
  198. next_time_period_num, node->hsdir_index->next);
  199. } else {
  200. memset(node->hsdir_index->next, 0, sizeof(node->hsdir_index->next));
  201. }
  202. done:
  203. tor_free(current_hsdir_index_srv);
  204. tor_free(next_hsdir_index_srv);
  205. return;
  206. }
  207. /** Called when a node's address changes. */
  208. static void
  209. node_addrs_changed(node_t *node)
  210. {
  211. node->last_reachable = node->last_reachable6 = 0;
  212. node->country = -1;
  213. }
  214. /** Add <b>ri</b> to an appropriate node in the nodelist. If we replace an
  215. * old routerinfo, and <b>ri_old_out</b> is not NULL, set *<b>ri_old_out</b>
  216. * to the previous routerinfo.
  217. */
  218. node_t *
  219. nodelist_set_routerinfo(routerinfo_t *ri, routerinfo_t **ri_old_out)
  220. {
  221. node_t *node;
  222. const char *id_digest;
  223. int had_router = 0;
  224. tor_assert(ri);
  225. init_nodelist();
  226. id_digest = ri->cache_info.identity_digest;
  227. node = node_get_or_create(id_digest);
  228. if (node->ri) {
  229. if (!routers_have_same_or_addrs(node->ri, ri)) {
  230. node_addrs_changed(node);
  231. }
  232. had_router = 1;
  233. if (ri_old_out)
  234. *ri_old_out = node->ri;
  235. } else {
  236. if (ri_old_out)
  237. *ri_old_out = NULL;
  238. }
  239. node->ri = ri;
  240. if (node->country == -1)
  241. node_set_country(node);
  242. if (authdir_mode(get_options()) && !had_router) {
  243. const char *discard=NULL;
  244. uint32_t status = dirserv_router_get_status(ri, &discard, LOG_INFO);
  245. dirserv_set_node_flags_from_authoritative_status(node, status);
  246. }
  247. /* Setting the HSDir index requires the ed25519 identity key which can
  248. * only be found either in the ri or md. This is why this is called here.
  249. * Only nodes supporting HSDir=2 protocol version needs this index. */
  250. if (node->rs && node->rs->supports_v3_hsdir) {
  251. node_set_hsdir_index(node,
  252. networkstatus_get_latest_consensus());
  253. }
  254. return node;
  255. }
  256. /** Set the appropriate node_t to use <b>md</b> as its microdescriptor.
  257. *
  258. * Called when a new microdesc has arrived and the usable consensus flavor
  259. * is "microdesc".
  260. **/
  261. node_t *
  262. nodelist_add_microdesc(microdesc_t *md)
  263. {
  264. networkstatus_t *ns =
  265. networkstatus_get_latest_consensus_by_flavor(FLAV_MICRODESC);
  266. const routerstatus_t *rs;
  267. node_t *node;
  268. if (ns == NULL)
  269. return NULL;
  270. init_nodelist();
  271. /* Microdescriptors don't carry an identity digest, so we need to figure
  272. * it out by looking up the routerstatus. */
  273. rs = router_get_consensus_status_by_descriptor_digest(ns, md->digest);
  274. if (rs == NULL)
  275. return NULL;
  276. node = node_get_mutable_by_id(rs->identity_digest);
  277. if (node) {
  278. if (node->md)
  279. node->md->held_by_nodes--;
  280. node->md = md;
  281. md->held_by_nodes++;
  282. /* Setting the HSDir index requires the ed25519 identity key which can
  283. * only be found either in the ri or md. This is why this is called here.
  284. * Only nodes supporting HSDir=2 protocol version needs this index. */
  285. if (rs->supports_v3_hsdir) {
  286. node_set_hsdir_index(node, ns);
  287. }
  288. }
  289. return node;
  290. }
  291. /** Tell the nodelist that the current usable consensus is <b>ns</b>.
  292. * This makes the nodelist change all of the routerstatus entries for
  293. * the nodes, drop nodes that no longer have enough info to get used,
  294. * and grab microdescriptors into nodes as appropriate.
  295. */
  296. void
  297. nodelist_set_consensus(networkstatus_t *ns)
  298. {
  299. const or_options_t *options = get_options();
  300. int authdir = authdir_mode_v3(options);
  301. init_nodelist();
  302. if (ns->flavor == FLAV_MICRODESC)
  303. (void) get_microdesc_cache(); /* Make sure it exists first. */
  304. SMARTLIST_FOREACH(the_nodelist->nodes, node_t *, node,
  305. node->rs = NULL);
  306. SMARTLIST_FOREACH_BEGIN(ns->routerstatus_list, routerstatus_t *, rs) {
  307. node_t *node = node_get_or_create(rs->identity_digest);
  308. node->rs = rs;
  309. if (ns->flavor == FLAV_MICRODESC) {
  310. if (node->md == NULL ||
  311. tor_memneq(node->md->digest,rs->descriptor_digest,DIGEST256_LEN)) {
  312. if (node->md)
  313. node->md->held_by_nodes--;
  314. node->md = microdesc_cache_lookup_by_digest256(NULL,
  315. rs->descriptor_digest);
  316. if (node->md)
  317. node->md->held_by_nodes++;
  318. }
  319. }
  320. if (rs->supports_v3_hsdir) {
  321. node_set_hsdir_index(node, ns);
  322. }
  323. node_set_country(node);
  324. /* If we're not an authdir, believe others. */
  325. if (!authdir) {
  326. node->is_valid = rs->is_valid;
  327. node->is_running = rs->is_flagged_running;
  328. node->is_fast = rs->is_fast;
  329. node->is_stable = rs->is_stable;
  330. node->is_possible_guard = rs->is_possible_guard;
  331. node->is_exit = rs->is_exit;
  332. node->is_bad_exit = rs->is_bad_exit;
  333. node->is_hs_dir = rs->is_hs_dir;
  334. node->ipv6_preferred = 0;
  335. if (fascist_firewall_prefer_ipv6_orport(options) &&
  336. (tor_addr_is_null(&rs->ipv6_addr) == 0 ||
  337. (node->md && tor_addr_is_null(&node->md->ipv6_addr) == 0)))
  338. node->ipv6_preferred = 1;
  339. }
  340. } SMARTLIST_FOREACH_END(rs);
  341. nodelist_purge();
  342. if (! authdir) {
  343. SMARTLIST_FOREACH_BEGIN(the_nodelist->nodes, node_t *, node) {
  344. /* We have no routerstatus for this router. Clear flags so we can skip
  345. * it, maybe.*/
  346. if (!node->rs) {
  347. tor_assert(node->ri); /* if it had only an md, or nothing, purge
  348. * would have removed it. */
  349. if (node->ri->purpose == ROUTER_PURPOSE_GENERAL) {
  350. /* Clear all flags. */
  351. node->is_valid = node->is_running = node->is_hs_dir =
  352. node->is_fast = node->is_stable =
  353. node->is_possible_guard = node->is_exit =
  354. node->is_bad_exit = node->ipv6_preferred = 0;
  355. }
  356. }
  357. } SMARTLIST_FOREACH_END(node);
  358. }
  359. }
  360. /** Helper: return true iff a node has a usable amount of information*/
  361. static inline int
  362. node_is_usable(const node_t *node)
  363. {
  364. return (node->rs) || (node->ri);
  365. }
  366. /** Tell the nodelist that <b>md</b> is no longer a microdescriptor for the
  367. * node with <b>identity_digest</b>. */
  368. void
  369. nodelist_remove_microdesc(const char *identity_digest, microdesc_t *md)
  370. {
  371. node_t *node = node_get_mutable_by_id(identity_digest);
  372. if (node && node->md == md) {
  373. node->md = NULL;
  374. md->held_by_nodes--;
  375. }
  376. }
  377. /** Tell the nodelist that <b>ri</b> is no longer in the routerlist. */
  378. void
  379. nodelist_remove_routerinfo(routerinfo_t *ri)
  380. {
  381. node_t *node = node_get_mutable_by_id(ri->cache_info.identity_digest);
  382. if (node && node->ri == ri) {
  383. node->ri = NULL;
  384. if (! node_is_usable(node)) {
  385. nodelist_drop_node(node, 1);
  386. node_free(node);
  387. }
  388. }
  389. }
  390. /** Remove <b>node</b> from the nodelist. (Asserts that it was there to begin
  391. * with.) */
  392. static void
  393. nodelist_drop_node(node_t *node, int remove_from_ht)
  394. {
  395. node_t *tmp;
  396. int idx;
  397. if (remove_from_ht) {
  398. tmp = HT_REMOVE(nodelist_map, &the_nodelist->nodes_by_id, node);
  399. tor_assert(tmp == node);
  400. }
  401. idx = node->nodelist_idx;
  402. tor_assert(idx >= 0);
  403. tor_assert(node == smartlist_get(the_nodelist->nodes, idx));
  404. smartlist_del(the_nodelist->nodes, idx);
  405. if (idx < smartlist_len(the_nodelist->nodes)) {
  406. tmp = smartlist_get(the_nodelist->nodes, idx);
  407. tmp->nodelist_idx = idx;
  408. }
  409. node->nodelist_idx = -1;
  410. }
  411. /** Return a newly allocated smartlist of the nodes that have <b>md</b> as
  412. * their microdescriptor. */
  413. smartlist_t *
  414. nodelist_find_nodes_with_microdesc(const microdesc_t *md)
  415. {
  416. smartlist_t *result = smartlist_new();
  417. if (the_nodelist == NULL)
  418. return result;
  419. SMARTLIST_FOREACH_BEGIN(the_nodelist->nodes, node_t *, node) {
  420. if (node->md == md) {
  421. smartlist_add(result, node);
  422. }
  423. } SMARTLIST_FOREACH_END(node);
  424. return result;
  425. }
  426. /** Release storage held by <b>node</b> */
  427. static void
  428. node_free(node_t *node)
  429. {
  430. if (!node)
  431. return;
  432. if (node->md)
  433. node->md->held_by_nodes--;
  434. tor_assert(node->nodelist_idx == -1);
  435. tor_free(node->hsdir_index);
  436. tor_free(node);
  437. }
  438. /** Remove all entries from the nodelist that don't have enough info to be
  439. * usable for anything. */
  440. void
  441. nodelist_purge(void)
  442. {
  443. node_t **iter;
  444. if (PREDICT_UNLIKELY(the_nodelist == NULL))
  445. return;
  446. /* Remove the non-usable nodes. */
  447. for (iter = HT_START(nodelist_map, &the_nodelist->nodes_by_id); iter; ) {
  448. node_t *node = *iter;
  449. if (node->md && !node->rs) {
  450. /* An md is only useful if there is an rs. */
  451. node->md->held_by_nodes--;
  452. node->md = NULL;
  453. }
  454. if (node_is_usable(node)) {
  455. iter = HT_NEXT(nodelist_map, &the_nodelist->nodes_by_id, iter);
  456. } else {
  457. iter = HT_NEXT_RMV(nodelist_map, &the_nodelist->nodes_by_id, iter);
  458. nodelist_drop_node(node, 0);
  459. node_free(node);
  460. }
  461. }
  462. nodelist_assert_ok();
  463. }
  464. /** Release all storage held by the nodelist. */
  465. void
  466. nodelist_free_all(void)
  467. {
  468. if (PREDICT_UNLIKELY(the_nodelist == NULL))
  469. return;
  470. HT_CLEAR(nodelist_map, &the_nodelist->nodes_by_id);
  471. SMARTLIST_FOREACH_BEGIN(the_nodelist->nodes, node_t *, node) {
  472. node->nodelist_idx = -1;
  473. node_free(node);
  474. } SMARTLIST_FOREACH_END(node);
  475. smartlist_free(the_nodelist->nodes);
  476. tor_free(the_nodelist);
  477. }
  478. /** Check that the nodelist is internally consistent, and consistent with
  479. * the directory info it's derived from.
  480. */
  481. void
  482. nodelist_assert_ok(void)
  483. {
  484. routerlist_t *rl = router_get_routerlist();
  485. networkstatus_t *ns = networkstatus_get_latest_consensus();
  486. digestmap_t *dm;
  487. if (!the_nodelist)
  488. return;
  489. dm = digestmap_new();
  490. /* every routerinfo in rl->routers should be in the nodelist. */
  491. if (rl) {
  492. SMARTLIST_FOREACH_BEGIN(rl->routers, routerinfo_t *, ri) {
  493. const node_t *node = node_get_by_id(ri->cache_info.identity_digest);
  494. tor_assert(node && node->ri == ri);
  495. tor_assert(fast_memeq(ri->cache_info.identity_digest,
  496. node->identity, DIGEST_LEN));
  497. tor_assert(! digestmap_get(dm, node->identity));
  498. digestmap_set(dm, node->identity, (void*)node);
  499. } SMARTLIST_FOREACH_END(ri);
  500. }
  501. /* every routerstatus in ns should be in the nodelist */
  502. if (ns) {
  503. SMARTLIST_FOREACH_BEGIN(ns->routerstatus_list, routerstatus_t *, rs) {
  504. const node_t *node = node_get_by_id(rs->identity_digest);
  505. tor_assert(node && node->rs == rs);
  506. tor_assert(fast_memeq(rs->identity_digest, node->identity, DIGEST_LEN));
  507. digestmap_set(dm, node->identity, (void*)node);
  508. if (ns->flavor == FLAV_MICRODESC) {
  509. /* If it's a microdesc consensus, every entry that has a
  510. * microdescriptor should be in the nodelist.
  511. */
  512. microdesc_t *md =
  513. microdesc_cache_lookup_by_digest256(NULL, rs->descriptor_digest);
  514. tor_assert(md == node->md);
  515. if (md)
  516. tor_assert(md->held_by_nodes >= 1);
  517. }
  518. } SMARTLIST_FOREACH_END(rs);
  519. }
  520. /* The nodelist should have no other entries, and its entries should be
  521. * well-formed. */
  522. SMARTLIST_FOREACH_BEGIN(the_nodelist->nodes, node_t *, node) {
  523. tor_assert(digestmap_get(dm, node->identity) != NULL);
  524. tor_assert(node_sl_idx == node->nodelist_idx);
  525. } SMARTLIST_FOREACH_END(node);
  526. tor_assert((long)smartlist_len(the_nodelist->nodes) ==
  527. (long)HT_SIZE(&the_nodelist->nodes_by_id));
  528. digestmap_free(dm, NULL);
  529. }
  530. /** Return a list of a node_t * for every node we know about. The caller
  531. * MUST NOT modify the list. (You can set and clear flags in the nodes if
  532. * you must, but you must not add or remove nodes.) */
  533. MOCK_IMPL(smartlist_t *,
  534. nodelist_get_list,(void))
  535. {
  536. init_nodelist();
  537. return the_nodelist->nodes;
  538. }
  539. /** Given a hex-encoded nickname of the format DIGEST, $DIGEST, $DIGEST=name,
  540. * or $DIGEST~name, return the node with the matching identity digest and
  541. * nickname (if any). Return NULL if no such node exists, or if <b>hex_id</b>
  542. * is not well-formed. */
  543. const node_t *
  544. node_get_by_hex_id(const char *hex_id)
  545. {
  546. char digest_buf[DIGEST_LEN];
  547. char nn_buf[MAX_NICKNAME_LEN+1];
  548. char nn_char='\0';
  549. if (hex_digest_nickname_decode(hex_id, digest_buf, &nn_char, nn_buf)==0) {
  550. const node_t *node = node_get_by_id(digest_buf);
  551. if (!node)
  552. return NULL;
  553. if (nn_char) {
  554. const char *real_name = node_get_nickname(node);
  555. if (!real_name || strcasecmp(real_name, nn_buf))
  556. return NULL;
  557. if (nn_char == '=') {
  558. const char *named_id =
  559. networkstatus_get_router_digest_by_nickname(nn_buf);
  560. if (!named_id || tor_memneq(named_id, digest_buf, DIGEST_LEN))
  561. return NULL;
  562. }
  563. }
  564. return node;
  565. }
  566. return NULL;
  567. }
  568. /** Given a nickname (possibly verbose, possibly a hexadecimal digest), return
  569. * the corresponding node_t, or NULL if none exists. Warn the user if
  570. * <b>warn_if_unnamed</b> is set, and they have specified a router by
  571. * nickname, but the Named flag isn't set for that router. */
  572. MOCK_IMPL(const node_t *,
  573. node_get_by_nickname,(const char *nickname, int warn_if_unnamed))
  574. {
  575. if (!the_nodelist)
  576. return NULL;
  577. /* Handle these cases: DIGEST, $DIGEST, $DIGEST=name, $DIGEST~name. */
  578. {
  579. const node_t *node;
  580. if ((node = node_get_by_hex_id(nickname)) != NULL)
  581. return node;
  582. }
  583. if (!strcasecmp(nickname, UNNAMED_ROUTER_NICKNAME))
  584. return NULL;
  585. /* Okay, so if we get here, the nickname is just a nickname. Is there
  586. * a binding for it in the consensus? */
  587. {
  588. const char *named_id =
  589. networkstatus_get_router_digest_by_nickname(nickname);
  590. if (named_id)
  591. return node_get_by_id(named_id);
  592. }
  593. /* Is it marked as owned-by-someone-else? */
  594. if (networkstatus_nickname_is_unnamed(nickname)) {
  595. log_info(LD_GENERAL, "The name %s is listed as Unnamed: there is some "
  596. "router that holds it, but not one listed in the current "
  597. "consensus.", escaped(nickname));
  598. return NULL;
  599. }
  600. /* Okay, so the name is not canonical for anybody. */
  601. {
  602. smartlist_t *matches = smartlist_new();
  603. const node_t *choice = NULL;
  604. SMARTLIST_FOREACH_BEGIN(the_nodelist->nodes, node_t *, node) {
  605. if (!strcasecmp(node_get_nickname(node), nickname))
  606. smartlist_add(matches, node);
  607. } SMARTLIST_FOREACH_END(node);
  608. if (smartlist_len(matches)>1 && warn_if_unnamed) {
  609. int any_unwarned = 0;
  610. SMARTLIST_FOREACH_BEGIN(matches, node_t *, node) {
  611. if (!node->name_lookup_warned) {
  612. node->name_lookup_warned = 1;
  613. any_unwarned = 1;
  614. }
  615. } SMARTLIST_FOREACH_END(node);
  616. if (any_unwarned) {
  617. log_warn(LD_CONFIG, "There are multiple matches for the name %s, "
  618. "but none is listed as Named in the directory consensus. "
  619. "Choosing one arbitrarily.", nickname);
  620. }
  621. } else if (smartlist_len(matches)==1 && warn_if_unnamed) {
  622. char fp[HEX_DIGEST_LEN+1];
  623. node_t *node = smartlist_get(matches, 0);
  624. if (! node->name_lookup_warned) {
  625. base16_encode(fp, sizeof(fp), node->identity, DIGEST_LEN);
  626. log_warn(LD_CONFIG,
  627. "You specified a relay \"%s\" by name, but nicknames can be "
  628. "used by any relay, not just the one you meant. "
  629. "To make sure you get the same relay in the future, refer "
  630. "to it by key, as \"$%s\".", nickname, fp);
  631. node->name_lookup_warned = 1;
  632. }
  633. }
  634. if (smartlist_len(matches))
  635. choice = smartlist_get(matches, 0);
  636. smartlist_free(matches);
  637. return choice;
  638. }
  639. }
  640. /** Return the Ed25519 identity key for the provided node, or NULL if it
  641. * doesn't have one. */
  642. const ed25519_public_key_t *
  643. node_get_ed25519_id(const node_t *node)
  644. {
  645. if (node->ri) {
  646. if (node->ri->cache_info.signing_key_cert) {
  647. const ed25519_public_key_t *pk =
  648. &node->ri->cache_info.signing_key_cert->signing_key;
  649. if (BUG(ed25519_public_key_is_zero(pk)))
  650. goto try_the_md;
  651. return pk;
  652. }
  653. }
  654. try_the_md:
  655. if (node->md) {
  656. if (node->md->ed25519_identity_pkey) {
  657. return node->md->ed25519_identity_pkey;
  658. }
  659. }
  660. return NULL;
  661. }
  662. /** Return true iff this node's Ed25519 identity matches <b>id</b>.
  663. * (An absent Ed25519 identity matches NULL or zero.) */
  664. int
  665. node_ed25519_id_matches(const node_t *node, const ed25519_public_key_t *id)
  666. {
  667. const ed25519_public_key_t *node_id = node_get_ed25519_id(node);
  668. if (node_id == NULL || ed25519_public_key_is_zero(node_id)) {
  669. return id == NULL || ed25519_public_key_is_zero(id);
  670. } else {
  671. return id && ed25519_pubkey_eq(node_id, id);
  672. }
  673. }
  674. /** Return true iff <b>node</b> supports authenticating itself
  675. * by ed25519 ID during the link handshake in a way that we can understand
  676. * when we probe it. */
  677. int
  678. node_supports_ed25519_link_authentication(const node_t *node)
  679. {
  680. /* XXXX Oh hm. What if some day in the future there are link handshake
  681. * versions that aren't 3 but which are ed25519 */
  682. if (! node_get_ed25519_id(node))
  683. return 0;
  684. if (node->ri) {
  685. const char *protos = node->ri->protocol_list;
  686. if (protos == NULL)
  687. return 0;
  688. return protocol_list_supports_protocol(protos, PRT_LINKAUTH, 3);
  689. }
  690. if (node->rs) {
  691. return node->rs->supports_ed25519_link_handshake;
  692. }
  693. tor_assert_nonfatal_unreached_once();
  694. return 0;
  695. }
  696. /** Return true iff <b>node</b> supports the hidden service directory version
  697. * 3 protocol (proposal 224). */
  698. int
  699. node_supports_v3_hsdir(const node_t *node)
  700. {
  701. tor_assert(node);
  702. if (node->rs) {
  703. return node->rs->supports_v3_hsdir;
  704. }
  705. if (node->ri) {
  706. if (node->ri->protocol_list == NULL) {
  707. return 0;
  708. }
  709. if (node->ri->platform) {
  710. /* Bug #22447 forces us to filter on this version. */
  711. return tor_version_as_new_as(node->ri->platform, "0.3.0.8");
  712. }
  713. return protocol_list_supports_protocol(node->ri->protocol_list,
  714. PRT_HSDIR, PROTOVER_HSDIR_V3);
  715. }
  716. tor_assert_nonfatal_unreached_once();
  717. return 0;
  718. }
  719. /** Return true iff <b>node</b> supports ed25519 authentication as an hidden
  720. * service introduction point.*/
  721. int
  722. node_supports_ed25519_hs_intro(const node_t *node)
  723. {
  724. tor_assert(node);
  725. if (node->rs) {
  726. return node->rs->supports_ed25519_hs_intro;
  727. }
  728. if (node->ri) {
  729. if (node->ri->protocol_list == NULL) {
  730. return 0;
  731. }
  732. return protocol_list_supports_protocol(node->ri->protocol_list,
  733. PRT_HSINTRO, PROTOVER_HS_INTRO_V3);
  734. }
  735. tor_assert_nonfatal_unreached_once();
  736. return 0;
  737. }
  738. /** Return the RSA ID key's SHA1 digest for the provided node. */
  739. const uint8_t *
  740. node_get_rsa_id_digest(const node_t *node)
  741. {
  742. tor_assert(node);
  743. return (const uint8_t*)node->identity;
  744. }
  745. /** Return the nickname of <b>node</b>, or NULL if we can't find one. */
  746. const char *
  747. node_get_nickname(const node_t *node)
  748. {
  749. tor_assert(node);
  750. if (node->rs)
  751. return node->rs->nickname;
  752. else if (node->ri)
  753. return node->ri->nickname;
  754. else
  755. return NULL;
  756. }
  757. /** Return true iff the nickname of <b>node</b> is canonical, based on the
  758. * latest consensus. */
  759. int
  760. node_is_named(const node_t *node)
  761. {
  762. const char *named_id;
  763. const char *nickname = node_get_nickname(node);
  764. if (!nickname)
  765. return 0;
  766. named_id = networkstatus_get_router_digest_by_nickname(nickname);
  767. if (!named_id)
  768. return 0;
  769. return tor_memeq(named_id, node->identity, DIGEST_LEN);
  770. }
  771. /** Return true iff <b>node</b> appears to be a directory authority or
  772. * directory cache */
  773. int
  774. node_is_dir(const node_t *node)
  775. {
  776. if (node->rs) {
  777. routerstatus_t * rs = node->rs;
  778. /* This is true if supports_tunnelled_dir_requests is true which
  779. * indicates that we support directory request tunnelled or through the
  780. * DirPort. */
  781. return rs->is_v2_dir;
  782. } else if (node->ri) {
  783. routerinfo_t * ri = node->ri;
  784. /* Both tunnelled request is supported or DirPort is set. */
  785. return ri->supports_tunnelled_dir_requests;
  786. } else {
  787. return 0;
  788. }
  789. }
  790. /** Return true iff <b>node</b> has either kind of usable descriptor -- that
  791. * is, a routerdescriptor or a microdescriptor. */
  792. int
  793. node_has_descriptor(const node_t *node)
  794. {
  795. return (node->ri ||
  796. (node->rs && node->md));
  797. }
  798. /** Return the router_purpose of <b>node</b>. */
  799. int
  800. node_get_purpose(const node_t *node)
  801. {
  802. if (node->ri)
  803. return node->ri->purpose;
  804. else
  805. return ROUTER_PURPOSE_GENERAL;
  806. }
  807. /** Compute the verbose ("extended") nickname of <b>node</b> and store it
  808. * into the MAX_VERBOSE_NICKNAME_LEN+1 character buffer at
  809. * <b>verbose_name_out</b> */
  810. void
  811. node_get_verbose_nickname(const node_t *node,
  812. char *verbose_name_out)
  813. {
  814. const char *nickname = node_get_nickname(node);
  815. int is_named = node_is_named(node);
  816. verbose_name_out[0] = '$';
  817. base16_encode(verbose_name_out+1, HEX_DIGEST_LEN+1, node->identity,
  818. DIGEST_LEN);
  819. if (!nickname)
  820. return;
  821. verbose_name_out[1+HEX_DIGEST_LEN] = is_named ? '=' : '~';
  822. strlcpy(verbose_name_out+1+HEX_DIGEST_LEN+1, nickname, MAX_NICKNAME_LEN+1);
  823. }
  824. /** Compute the verbose ("extended") nickname of node with
  825. * given <b>id_digest</b> and store it into the MAX_VERBOSE_NICKNAME_LEN+1
  826. * character buffer at <b>verbose_name_out</b>
  827. *
  828. * If node_get_by_id() returns NULL, base 16 encoding of
  829. * <b>id_digest</b> is returned instead. */
  830. void
  831. node_get_verbose_nickname_by_id(const char *id_digest,
  832. char *verbose_name_out)
  833. {
  834. const node_t *node = node_get_by_id(id_digest);
  835. if (!node) {
  836. verbose_name_out[0] = '$';
  837. base16_encode(verbose_name_out+1, HEX_DIGEST_LEN+1, id_digest, DIGEST_LEN);
  838. } else {
  839. node_get_verbose_nickname(node, verbose_name_out);
  840. }
  841. }
  842. /** Return true iff it seems that <b>node</b> allows circuits to exit
  843. * through it directlry from the client. */
  844. int
  845. node_allows_single_hop_exits(const node_t *node)
  846. {
  847. if (node && node->ri)
  848. return node->ri->allow_single_hop_exits;
  849. else
  850. return 0;
  851. }
  852. /** Return true iff it seems that <b>node</b> has an exit policy that doesn't
  853. * actually permit anything to exit, or we don't know its exit policy */
  854. int
  855. node_exit_policy_rejects_all(const node_t *node)
  856. {
  857. if (node->rejects_all)
  858. return 1;
  859. if (node->ri)
  860. return node->ri->policy_is_reject_star;
  861. else if (node->md)
  862. return node->md->exit_policy == NULL ||
  863. short_policy_is_reject_star(node->md->exit_policy);
  864. else
  865. return 1;
  866. }
  867. /** Return true iff the exit policy for <b>node</b> is such that we can treat
  868. * rejecting an address of type <b>family</b> unexpectedly as a sign of that
  869. * node's failure. */
  870. int
  871. node_exit_policy_is_exact(const node_t *node, sa_family_t family)
  872. {
  873. if (family == AF_UNSPEC) {
  874. return 1; /* Rejecting an address but not telling us what address
  875. * is a bad sign. */
  876. } else if (family == AF_INET) {
  877. return node->ri != NULL;
  878. } else if (family == AF_INET6) {
  879. return 0;
  880. }
  881. tor_fragile_assert();
  882. return 1;
  883. }
  884. /* Check if the "addr" and port_field fields from r are a valid non-listening
  885. * address/port. If so, set valid to true and add a newly allocated
  886. * tor_addr_port_t containing "addr" and port_field to sl.
  887. * "addr" is an IPv4 host-order address and port_field is a uint16_t.
  888. * r is typically a routerinfo_t or routerstatus_t.
  889. */
  890. #define SL_ADD_NEW_IPV4_AP(r, port_field, sl, valid) \
  891. STMT_BEGIN \
  892. if (tor_addr_port_is_valid_ipv4h((r)->addr, (r)->port_field, 0)) { \
  893. valid = 1; \
  894. tor_addr_port_t *ap = tor_malloc(sizeof(tor_addr_port_t)); \
  895. tor_addr_from_ipv4h(&ap->addr, (r)->addr); \
  896. ap->port = (r)->port_field; \
  897. smartlist_add((sl), ap); \
  898. } \
  899. STMT_END
  900. /* Check if the "addr" and port_field fields from r are a valid non-listening
  901. * address/port. If so, set valid to true and add a newly allocated
  902. * tor_addr_port_t containing "addr" and port_field to sl.
  903. * "addr" is a tor_addr_t and port_field is a uint16_t.
  904. * r is typically a routerinfo_t or routerstatus_t.
  905. */
  906. #define SL_ADD_NEW_IPV6_AP(r, port_field, sl, valid) \
  907. STMT_BEGIN \
  908. if (tor_addr_port_is_valid(&(r)->ipv6_addr, (r)->port_field, 0)) { \
  909. valid = 1; \
  910. tor_addr_port_t *ap = tor_malloc(sizeof(tor_addr_port_t)); \
  911. tor_addr_copy(&ap->addr, &(r)->ipv6_addr); \
  912. ap->port = (r)->port_field; \
  913. smartlist_add((sl), ap); \
  914. } \
  915. STMT_END
  916. /** Return list of tor_addr_port_t with all OR ports (in the sense IP
  917. * addr + TCP port) for <b>node</b>. Caller must free all elements
  918. * using tor_free() and free the list using smartlist_free().
  919. *
  920. * XXX this is potentially a memory fragmentation hog -- if on
  921. * critical path consider the option of having the caller allocate the
  922. * memory
  923. */
  924. smartlist_t *
  925. node_get_all_orports(const node_t *node)
  926. {
  927. smartlist_t *sl = smartlist_new();
  928. int valid = 0;
  929. /* Find a valid IPv4 address and port */
  930. if (node->ri != NULL) {
  931. SL_ADD_NEW_IPV4_AP(node->ri, or_port, sl, valid);
  932. }
  933. /* If we didn't find a valid address/port in the ri, try the rs */
  934. if (!valid && node->rs != NULL) {
  935. SL_ADD_NEW_IPV4_AP(node->rs, or_port, sl, valid);
  936. }
  937. /* Find a valid IPv6 address and port */
  938. valid = 0;
  939. if (node->ri != NULL) {
  940. SL_ADD_NEW_IPV6_AP(node->ri, ipv6_orport, sl, valid);
  941. }
  942. if (!valid && node->rs != NULL) {
  943. SL_ADD_NEW_IPV6_AP(node->rs, ipv6_orport, sl, valid);
  944. }
  945. if (!valid && node->md != NULL) {
  946. SL_ADD_NEW_IPV6_AP(node->md, ipv6_orport, sl, valid);
  947. }
  948. return sl;
  949. }
  950. #undef SL_ADD_NEW_IPV4_AP
  951. #undef SL_ADD_NEW_IPV6_AP
  952. /** Wrapper around node_get_prim_orport for backward
  953. compatibility. */
  954. void
  955. node_get_addr(const node_t *node, tor_addr_t *addr_out)
  956. {
  957. tor_addr_port_t ap;
  958. node_get_prim_orport(node, &ap);
  959. tor_addr_copy(addr_out, &ap.addr);
  960. }
  961. /** Return the host-order IPv4 address for <b>node</b>, or 0 if it doesn't
  962. * seem to have one. */
  963. uint32_t
  964. node_get_prim_addr_ipv4h(const node_t *node)
  965. {
  966. /* Don't check the ORPort or DirPort, as this function isn't port-specific,
  967. * and the node might have a valid IPv4 address, yet have a zero
  968. * ORPort or DirPort.
  969. */
  970. if (node->ri && tor_addr_is_valid_ipv4h(node->ri->addr, 0)) {
  971. return node->ri->addr;
  972. } else if (node->rs && tor_addr_is_valid_ipv4h(node->rs->addr, 0)) {
  973. return node->rs->addr;
  974. }
  975. return 0;
  976. }
  977. /** Copy a string representation of an IP address for <b>node</b> into
  978. * the <b>len</b>-byte buffer at <b>buf</b>. */
  979. void
  980. node_get_address_string(const node_t *node, char *buf, size_t len)
  981. {
  982. uint32_t ipv4_addr = node_get_prim_addr_ipv4h(node);
  983. if (tor_addr_is_valid_ipv4h(ipv4_addr, 0)) {
  984. tor_addr_t addr;
  985. tor_addr_from_ipv4h(&addr, ipv4_addr);
  986. tor_addr_to_str(buf, &addr, len, 0);
  987. } else if (len > 0) {
  988. buf[0] = '\0';
  989. }
  990. }
  991. /** Return <b>node</b>'s declared uptime, or -1 if it doesn't seem to have
  992. * one. */
  993. long
  994. node_get_declared_uptime(const node_t *node)
  995. {
  996. if (node->ri)
  997. return node->ri->uptime;
  998. else
  999. return -1;
  1000. }
  1001. /** Return <b>node</b>'s platform string, or NULL if we don't know it. */
  1002. const char *
  1003. node_get_platform(const node_t *node)
  1004. {
  1005. /* If we wanted, we could record the version in the routerstatus_t, since
  1006. * the consensus lists it. We don't, though, so this function just won't
  1007. * work with microdescriptors. */
  1008. if (node->ri)
  1009. return node->ri->platform;
  1010. else
  1011. return NULL;
  1012. }
  1013. /** Return true iff <b>node</b> is one representing this router. */
  1014. int
  1015. node_is_me(const node_t *node)
  1016. {
  1017. return router_digest_is_me(node->identity);
  1018. }
  1019. /** Return <b>node</b> declared family (as a list of names), or NULL if
  1020. * the node didn't declare a family. */
  1021. const smartlist_t *
  1022. node_get_declared_family(const node_t *node)
  1023. {
  1024. if (node->ri && node->ri->declared_family)
  1025. return node->ri->declared_family;
  1026. else if (node->md && node->md->family)
  1027. return node->md->family;
  1028. else
  1029. return NULL;
  1030. }
  1031. /* Does this node have a valid IPv6 address?
  1032. * Prefer node_has_ipv6_orport() or node_has_ipv6_dirport() for
  1033. * checking specific ports. */
  1034. int
  1035. node_has_ipv6_addr(const node_t *node)
  1036. {
  1037. /* Don't check the ORPort or DirPort, as this function isn't port-specific,
  1038. * and the node might have a valid IPv6 address, yet have a zero
  1039. * ORPort or DirPort.
  1040. */
  1041. if (node->ri && tor_addr_is_valid(&node->ri->ipv6_addr, 0))
  1042. return 1;
  1043. if (node->rs && tor_addr_is_valid(&node->rs->ipv6_addr, 0))
  1044. return 1;
  1045. if (node->md && tor_addr_is_valid(&node->md->ipv6_addr, 0))
  1046. return 1;
  1047. return 0;
  1048. }
  1049. /* Does this node have a valid IPv6 ORPort? */
  1050. int
  1051. node_has_ipv6_orport(const node_t *node)
  1052. {
  1053. tor_addr_port_t ipv6_orport;
  1054. node_get_pref_ipv6_orport(node, &ipv6_orport);
  1055. return tor_addr_port_is_valid_ap(&ipv6_orport, 0);
  1056. }
  1057. /* Does this node have a valid IPv6 DirPort? */
  1058. int
  1059. node_has_ipv6_dirport(const node_t *node)
  1060. {
  1061. tor_addr_port_t ipv6_dirport;
  1062. node_get_pref_ipv6_dirport(node, &ipv6_dirport);
  1063. return tor_addr_port_is_valid_ap(&ipv6_dirport, 0);
  1064. }
  1065. /** Return 1 if we prefer the IPv6 address and OR TCP port of
  1066. * <b>node</b>, else 0.
  1067. *
  1068. * We prefer the IPv6 address if the router has an IPv6 address,
  1069. * and we can use IPv6 addresses, and:
  1070. * i) the node_t says that it prefers IPv6
  1071. * or
  1072. * ii) the router has no IPv4 OR address.
  1073. *
  1074. * If you don't have a node, consider looking it up.
  1075. * If there is no node, use fascist_firewall_prefer_ipv6_orport().
  1076. */
  1077. int
  1078. node_ipv6_or_preferred(const node_t *node)
  1079. {
  1080. const or_options_t *options = get_options();
  1081. tor_addr_port_t ipv4_addr;
  1082. node_assert_ok(node);
  1083. /* XX/teor - node->ipv6_preferred is set from
  1084. * fascist_firewall_prefer_ipv6_orport() each time the consensus is loaded.
  1085. */
  1086. if (!fascist_firewall_use_ipv6(options)) {
  1087. return 0;
  1088. } else if (node->ipv6_preferred || node_get_prim_orport(node, &ipv4_addr)) {
  1089. return node_has_ipv6_orport(node);
  1090. }
  1091. return 0;
  1092. }
  1093. #define RETURN_IPV4_AP(r, port_field, ap_out) \
  1094. STMT_BEGIN \
  1095. if (r && tor_addr_port_is_valid_ipv4h((r)->addr, (r)->port_field, 0)) { \
  1096. tor_addr_from_ipv4h(&(ap_out)->addr, (r)->addr); \
  1097. (ap_out)->port = (r)->port_field; \
  1098. return 0; \
  1099. } \
  1100. STMT_END
  1101. /** Copy the primary (IPv4) OR port (IP address and TCP port) for
  1102. * <b>node</b> into *<b>ap_out</b>. Return 0 if a valid address and
  1103. * port was copied, else return non-zero.*/
  1104. int
  1105. node_get_prim_orport(const node_t *node, tor_addr_port_t *ap_out)
  1106. {
  1107. node_assert_ok(node);
  1108. tor_assert(ap_out);
  1109. /* Check ri first, because rewrite_node_address_for_bridge() updates
  1110. * node->ri with the configured bridge address. */
  1111. RETURN_IPV4_AP(node->ri, or_port, ap_out);
  1112. RETURN_IPV4_AP(node->rs, or_port, ap_out);
  1113. /* Microdescriptors only have an IPv6 address */
  1114. return -1;
  1115. }
  1116. /** Copy the preferred OR port (IP address and TCP port) for
  1117. * <b>node</b> into *<b>ap_out</b>. */
  1118. void
  1119. node_get_pref_orport(const node_t *node, tor_addr_port_t *ap_out)
  1120. {
  1121. tor_assert(ap_out);
  1122. if (node_ipv6_or_preferred(node)) {
  1123. node_get_pref_ipv6_orport(node, ap_out);
  1124. } else {
  1125. /* the primary ORPort is always on IPv4 */
  1126. node_get_prim_orport(node, ap_out);
  1127. }
  1128. }
  1129. /** Copy the preferred IPv6 OR port (IP address and TCP port) for
  1130. * <b>node</b> into *<b>ap_out</b>. */
  1131. void
  1132. node_get_pref_ipv6_orport(const node_t *node, tor_addr_port_t *ap_out)
  1133. {
  1134. node_assert_ok(node);
  1135. tor_assert(ap_out);
  1136. /* Check ri first, because rewrite_node_address_for_bridge() updates
  1137. * node->ri with the configured bridge address.
  1138. * Prefer rs over md for consistency with the fascist_firewall_* functions.
  1139. * Check if the address or port are valid, and try another alternative
  1140. * if they are not. */
  1141. if (node->ri && tor_addr_port_is_valid(&node->ri->ipv6_addr,
  1142. node->ri->ipv6_orport, 0)) {
  1143. tor_addr_copy(&ap_out->addr, &node->ri->ipv6_addr);
  1144. ap_out->port = node->ri->ipv6_orport;
  1145. } else if (node->rs && tor_addr_port_is_valid(&node->rs->ipv6_addr,
  1146. node->rs->ipv6_orport, 0)) {
  1147. tor_addr_copy(&ap_out->addr, &node->rs->ipv6_addr);
  1148. ap_out->port = node->rs->ipv6_orport;
  1149. } else if (node->md && tor_addr_port_is_valid(&node->md->ipv6_addr,
  1150. node->md->ipv6_orport, 0)) {
  1151. tor_addr_copy(&ap_out->addr, &node->md->ipv6_addr);
  1152. ap_out->port = node->md->ipv6_orport;
  1153. } else {
  1154. tor_addr_make_null(&ap_out->addr, AF_INET6);
  1155. ap_out->port = 0;
  1156. }
  1157. }
  1158. /** Return 1 if we prefer the IPv6 address and Dir TCP port of
  1159. * <b>node</b>, else 0.
  1160. *
  1161. * We prefer the IPv6 address if the router has an IPv6 address,
  1162. * and we can use IPv6 addresses, and:
  1163. * i) the router has no IPv4 Dir address.
  1164. * or
  1165. * ii) our preference is for IPv6 Dir addresses.
  1166. *
  1167. * If there is no node, use fascist_firewall_prefer_ipv6_dirport().
  1168. */
  1169. int
  1170. node_ipv6_dir_preferred(const node_t *node)
  1171. {
  1172. const or_options_t *options = get_options();
  1173. tor_addr_port_t ipv4_addr;
  1174. node_assert_ok(node);
  1175. /* node->ipv6_preferred is set from fascist_firewall_prefer_ipv6_orport(),
  1176. * so we can't use it to determine DirPort IPv6 preference.
  1177. * This means that bridge clients will use IPv4 DirPorts by default.
  1178. */
  1179. if (!fascist_firewall_use_ipv6(options)) {
  1180. return 0;
  1181. } else if (node_get_prim_dirport(node, &ipv4_addr)
  1182. || fascist_firewall_prefer_ipv6_dirport(get_options())) {
  1183. return node_has_ipv6_dirport(node);
  1184. }
  1185. return 0;
  1186. }
  1187. /** Copy the primary (IPv4) Dir port (IP address and TCP port) for
  1188. * <b>node</b> into *<b>ap_out</b>. Return 0 if a valid address and
  1189. * port was copied, else return non-zero.*/
  1190. int
  1191. node_get_prim_dirport(const node_t *node, tor_addr_port_t *ap_out)
  1192. {
  1193. node_assert_ok(node);
  1194. tor_assert(ap_out);
  1195. /* Check ri first, because rewrite_node_address_for_bridge() updates
  1196. * node->ri with the configured bridge address. */
  1197. RETURN_IPV4_AP(node->ri, dir_port, ap_out);
  1198. RETURN_IPV4_AP(node->rs, dir_port, ap_out);
  1199. /* Microdescriptors only have an IPv6 address */
  1200. return -1;
  1201. }
  1202. #undef RETURN_IPV4_AP
  1203. /** Copy the preferred Dir port (IP address and TCP port) for
  1204. * <b>node</b> into *<b>ap_out</b>. */
  1205. void
  1206. node_get_pref_dirport(const node_t *node, tor_addr_port_t *ap_out)
  1207. {
  1208. tor_assert(ap_out);
  1209. if (node_ipv6_dir_preferred(node)) {
  1210. node_get_pref_ipv6_dirport(node, ap_out);
  1211. } else {
  1212. /* the primary DirPort is always on IPv4 */
  1213. node_get_prim_dirport(node, ap_out);
  1214. }
  1215. }
  1216. /** Copy the preferred IPv6 Dir port (IP address and TCP port) for
  1217. * <b>node</b> into *<b>ap_out</b>. */
  1218. void
  1219. node_get_pref_ipv6_dirport(const node_t *node, tor_addr_port_t *ap_out)
  1220. {
  1221. node_assert_ok(node);
  1222. tor_assert(ap_out);
  1223. /* Check ri first, because rewrite_node_address_for_bridge() updates
  1224. * node->ri with the configured bridge address.
  1225. * Prefer rs over md for consistency with the fascist_firewall_* functions.
  1226. * Check if the address or port are valid, and try another alternative
  1227. * if they are not. */
  1228. /* Assume IPv4 and IPv6 dirports are the same */
  1229. if (node->ri && tor_addr_port_is_valid(&node->ri->ipv6_addr,
  1230. node->ri->dir_port, 0)) {
  1231. tor_addr_copy(&ap_out->addr, &node->ri->ipv6_addr);
  1232. ap_out->port = node->ri->dir_port;
  1233. } else if (node->rs && tor_addr_port_is_valid(&node->rs->ipv6_addr,
  1234. node->rs->dir_port, 0)) {
  1235. tor_addr_copy(&ap_out->addr, &node->rs->ipv6_addr);
  1236. ap_out->port = node->rs->dir_port;
  1237. } else {
  1238. tor_addr_make_null(&ap_out->addr, AF_INET6);
  1239. ap_out->port = 0;
  1240. }
  1241. }
  1242. /** Return true iff <b>md</b> has a curve25519 onion key.
  1243. * Use node_has_curve25519_onion_key() instead of calling this directly. */
  1244. static int
  1245. microdesc_has_curve25519_onion_key(const microdesc_t *md)
  1246. {
  1247. if (!md) {
  1248. return 0;
  1249. }
  1250. if (!md->onion_curve25519_pkey) {
  1251. return 0;
  1252. }
  1253. if (tor_mem_is_zero((const char*)md->onion_curve25519_pkey->public_key,
  1254. CURVE25519_PUBKEY_LEN)) {
  1255. return 0;
  1256. }
  1257. return 1;
  1258. }
  1259. /** Return true iff <b>node</b> has a curve25519 onion key. */
  1260. int
  1261. node_has_curve25519_onion_key(const node_t *node)
  1262. {
  1263. if (!node)
  1264. return 0;
  1265. if (node->ri)
  1266. return routerinfo_has_curve25519_onion_key(node->ri);
  1267. else if (node->md)
  1268. return microdesc_has_curve25519_onion_key(node->md);
  1269. else
  1270. return 0;
  1271. }
  1272. /** Refresh the country code of <b>ri</b>. This function MUST be called on
  1273. * each router when the GeoIP database is reloaded, and on all new routers. */
  1274. void
  1275. node_set_country(node_t *node)
  1276. {
  1277. tor_addr_t addr = TOR_ADDR_NULL;
  1278. /* XXXXipv6 */
  1279. if (node->rs)
  1280. tor_addr_from_ipv4h(&addr, node->rs->addr);
  1281. else if (node->ri)
  1282. tor_addr_from_ipv4h(&addr, node->ri->addr);
  1283. node->country = geoip_get_country_by_addr(&addr);
  1284. }
  1285. /** Set the country code of all routers in the routerlist. */
  1286. void
  1287. nodelist_refresh_countries(void)
  1288. {
  1289. smartlist_t *nodes = nodelist_get_list();
  1290. SMARTLIST_FOREACH(nodes, node_t *, node,
  1291. node_set_country(node));
  1292. }
  1293. /** Return true iff router1 and router2 have similar enough network addresses
  1294. * that we should treat them as being in the same family */
  1295. int
  1296. addrs_in_same_network_family(const tor_addr_t *a1,
  1297. const tor_addr_t *a2)
  1298. {
  1299. return 0 == tor_addr_compare_masked(a1, a2, 16, CMP_SEMANTIC);
  1300. }
  1301. /** Return true if <b>node</b>'s nickname matches <b>nickname</b>
  1302. * (case-insensitive), or if <b>node's</b> identity key digest
  1303. * matches a hexadecimal value stored in <b>nickname</b>. Return
  1304. * false otherwise. */
  1305. static int
  1306. node_nickname_matches(const node_t *node, const char *nickname)
  1307. {
  1308. const char *n = node_get_nickname(node);
  1309. if (n && nickname[0]!='$' && !strcasecmp(n, nickname))
  1310. return 1;
  1311. return hex_digest_nickname_matches(nickname,
  1312. node->identity,
  1313. n,
  1314. node_is_named(node));
  1315. }
  1316. /** Return true iff <b>node</b> is named by some nickname in <b>lst</b>. */
  1317. static inline int
  1318. node_in_nickname_smartlist(const smartlist_t *lst, const node_t *node)
  1319. {
  1320. if (!lst) return 0;
  1321. SMARTLIST_FOREACH(lst, const char *, name, {
  1322. if (node_nickname_matches(node, name))
  1323. return 1;
  1324. });
  1325. return 0;
  1326. }
  1327. /** Return true iff r1 and r2 are in the same family, but not the same
  1328. * router. */
  1329. int
  1330. nodes_in_same_family(const node_t *node1, const node_t *node2)
  1331. {
  1332. const or_options_t *options = get_options();
  1333. /* Are they in the same family because of their addresses? */
  1334. if (options->EnforceDistinctSubnets) {
  1335. tor_addr_t a1, a2;
  1336. node_get_addr(node1, &a1);
  1337. node_get_addr(node2, &a2);
  1338. if (addrs_in_same_network_family(&a1, &a2))
  1339. return 1;
  1340. }
  1341. /* Are they in the same family because the agree they are? */
  1342. {
  1343. const smartlist_t *f1, *f2;
  1344. f1 = node_get_declared_family(node1);
  1345. f2 = node_get_declared_family(node2);
  1346. if (f1 && f2 &&
  1347. node_in_nickname_smartlist(f1, node2) &&
  1348. node_in_nickname_smartlist(f2, node1))
  1349. return 1;
  1350. }
  1351. /* Are they in the same option because the user says they are? */
  1352. if (options->NodeFamilySets) {
  1353. SMARTLIST_FOREACH(options->NodeFamilySets, const routerset_t *, rs, {
  1354. if (routerset_contains_node(rs, node1) &&
  1355. routerset_contains_node(rs, node2))
  1356. return 1;
  1357. });
  1358. }
  1359. return 0;
  1360. }
  1361. /**
  1362. * Add all the family of <b>node</b>, including <b>node</b> itself, to
  1363. * the smartlist <b>sl</b>.
  1364. *
  1365. * This is used to make sure we don't pick siblings in a single path, or
  1366. * pick more than one relay from a family for our entry guard list.
  1367. * Note that a node may be added to <b>sl</b> more than once if it is
  1368. * part of <b>node</b>'s family for more than one reason.
  1369. */
  1370. void
  1371. nodelist_add_node_and_family(smartlist_t *sl, const node_t *node)
  1372. {
  1373. const smartlist_t *all_nodes = nodelist_get_list();
  1374. const smartlist_t *declared_family;
  1375. const or_options_t *options = get_options();
  1376. tor_assert(node);
  1377. declared_family = node_get_declared_family(node);
  1378. /* Let's make sure that we have the node itself, if it's a real node. */
  1379. {
  1380. const node_t *real_node = node_get_by_id(node->identity);
  1381. if (real_node)
  1382. smartlist_add(sl, (node_t*)real_node);
  1383. }
  1384. /* First, add any nodes with similar network addresses. */
  1385. if (options->EnforceDistinctSubnets) {
  1386. tor_addr_t node_addr;
  1387. node_get_addr(node, &node_addr);
  1388. SMARTLIST_FOREACH_BEGIN(all_nodes, const node_t *, node2) {
  1389. tor_addr_t a;
  1390. node_get_addr(node2, &a);
  1391. if (addrs_in_same_network_family(&a, &node_addr))
  1392. smartlist_add(sl, (void*)node2);
  1393. } SMARTLIST_FOREACH_END(node2);
  1394. }
  1395. /* Now, add all nodes in the declared_family of this node, if they
  1396. * also declare this node to be in their family. */
  1397. if (declared_family) {
  1398. /* Add every r such that router declares familyness with node, and node
  1399. * declares familyhood with router. */
  1400. SMARTLIST_FOREACH_BEGIN(declared_family, const char *, name) {
  1401. const node_t *node2;
  1402. const smartlist_t *family2;
  1403. if (!(node2 = node_get_by_nickname(name, 0)))
  1404. continue;
  1405. if (!(family2 = node_get_declared_family(node2)))
  1406. continue;
  1407. SMARTLIST_FOREACH_BEGIN(family2, const char *, name2) {
  1408. if (node_nickname_matches(node, name2)) {
  1409. smartlist_add(sl, (void*)node2);
  1410. break;
  1411. }
  1412. } SMARTLIST_FOREACH_END(name2);
  1413. } SMARTLIST_FOREACH_END(name);
  1414. }
  1415. /* If the user declared any families locally, honor those too. */
  1416. if (options->NodeFamilySets) {
  1417. SMARTLIST_FOREACH(options->NodeFamilySets, const routerset_t *, rs, {
  1418. if (routerset_contains_node(rs, node)) {
  1419. routerset_get_all_nodes(sl, rs, NULL, 0);
  1420. }
  1421. });
  1422. }
  1423. }
  1424. /** Find a router that's up, that has this IP address, and
  1425. * that allows exit to this address:port, or return NULL if there
  1426. * isn't a good one.
  1427. * Don't exit enclave to excluded relays -- it wouldn't actually
  1428. * hurt anything, but this way there are fewer confused users.
  1429. */
  1430. const node_t *
  1431. router_find_exact_exit_enclave(const char *address, uint16_t port)
  1432. {/*XXXX MOVE*/
  1433. uint32_t addr;
  1434. struct in_addr in;
  1435. tor_addr_t a;
  1436. const or_options_t *options = get_options();
  1437. if (!tor_inet_aton(address, &in))
  1438. return NULL; /* it's not an IP already */
  1439. addr = ntohl(in.s_addr);
  1440. tor_addr_from_ipv4h(&a, addr);
  1441. SMARTLIST_FOREACH(nodelist_get_list(), const node_t *, node, {
  1442. if (node_get_addr_ipv4h(node) == addr &&
  1443. node->is_running &&
  1444. compare_tor_addr_to_node_policy(&a, port, node) ==
  1445. ADDR_POLICY_ACCEPTED &&
  1446. !routerset_contains_node(options->ExcludeExitNodesUnion_, node))
  1447. return node;
  1448. });
  1449. return NULL;
  1450. }
  1451. /** Return 1 if <b>router</b> is not suitable for these parameters, else 0.
  1452. * If <b>need_uptime</b> is non-zero, we require a minimum uptime.
  1453. * If <b>need_capacity</b> is non-zero, we require a minimum advertised
  1454. * bandwidth.
  1455. * If <b>need_guard</b>, we require that the router is a possible entry guard.
  1456. */
  1457. int
  1458. node_is_unreliable(const node_t *node, int need_uptime,
  1459. int need_capacity, int need_guard)
  1460. {
  1461. if (need_uptime && !node->is_stable)
  1462. return 1;
  1463. if (need_capacity && !node->is_fast)
  1464. return 1;
  1465. if (need_guard && !node->is_possible_guard)
  1466. return 1;
  1467. return 0;
  1468. }
  1469. /** Return 1 if all running sufficiently-stable routers we can use will reject
  1470. * addr:port. Return 0 if any might accept it. */
  1471. int
  1472. router_exit_policy_all_nodes_reject(const tor_addr_t *addr, uint16_t port,
  1473. int need_uptime)
  1474. {
  1475. addr_policy_result_t r;
  1476. SMARTLIST_FOREACH_BEGIN(nodelist_get_list(), const node_t *, node) {
  1477. if (node->is_running &&
  1478. !node_is_unreliable(node, need_uptime, 0, 0)) {
  1479. r = compare_tor_addr_to_node_policy(addr, port, node);
  1480. if (r != ADDR_POLICY_REJECTED && r != ADDR_POLICY_PROBABLY_REJECTED)
  1481. return 0; /* this one could be ok. good enough. */
  1482. }
  1483. } SMARTLIST_FOREACH_END(node);
  1484. return 1; /* all will reject. */
  1485. }
  1486. /** Mark the router with ID <b>digest</b> as running or non-running
  1487. * in our routerlist. */
  1488. void
  1489. router_set_status(const char *digest, int up)
  1490. {
  1491. node_t *node;
  1492. tor_assert(digest);
  1493. SMARTLIST_FOREACH(router_get_fallback_dir_servers(),
  1494. dir_server_t *, d,
  1495. if (tor_memeq(d->digest, digest, DIGEST_LEN))
  1496. d->is_running = up);
  1497. SMARTLIST_FOREACH(router_get_trusted_dir_servers(),
  1498. dir_server_t *, d,
  1499. if (tor_memeq(d->digest, digest, DIGEST_LEN))
  1500. d->is_running = up);
  1501. node = node_get_mutable_by_id(digest);
  1502. if (node) {
  1503. #if 0
  1504. log_debug(LD_DIR,"Marking router %s as %s.",
  1505. node_describe(node), up ? "up" : "down");
  1506. #endif
  1507. if (!up && node_is_me(node) && !net_is_disabled())
  1508. log_warn(LD_NET, "We just marked ourself as down. Are your external "
  1509. "addresses reachable?");
  1510. if (bool_neq(node->is_running, up))
  1511. router_dir_info_changed();
  1512. node->is_running = up;
  1513. }
  1514. }
  1515. /** True iff, the last time we checked whether we had enough directory info
  1516. * to build circuits, the answer was "yes". If there are no exits in the
  1517. * consensus, we act as if we have 100% of the exit directory info. */
  1518. static int have_min_dir_info = 0;
  1519. /** Does the consensus contain nodes that can exit? */
  1520. static consensus_path_type_t have_consensus_path = CONSENSUS_PATH_UNKNOWN;
  1521. /** True iff enough has changed since the last time we checked whether we had
  1522. * enough directory info to build circuits that our old answer can no longer
  1523. * be trusted. */
  1524. static int need_to_update_have_min_dir_info = 1;
  1525. /** String describing what we're missing before we have enough directory
  1526. * info. */
  1527. static char dir_info_status[512] = "";
  1528. /** Return true iff we have enough consensus information to
  1529. * start building circuits. Right now, this means "a consensus that's
  1530. * less than a day old, and at least 60% of router descriptors (configurable),
  1531. * weighted by bandwidth. Treat the exit fraction as 100% if there are
  1532. * no exits in the consensus."
  1533. * To obtain the final weighted bandwidth, we multiply the
  1534. * weighted bandwidth fraction for each position (guard, middle, exit). */
  1535. int
  1536. router_have_minimum_dir_info(void)
  1537. {
  1538. static int logged_delay=0;
  1539. const char *delay_fetches_msg = NULL;
  1540. if (should_delay_dir_fetches(get_options(), &delay_fetches_msg)) {
  1541. if (!logged_delay)
  1542. log_notice(LD_DIR, "Delaying directory fetches: %s", delay_fetches_msg);
  1543. logged_delay=1;
  1544. strlcpy(dir_info_status, delay_fetches_msg, sizeof(dir_info_status));
  1545. return 0;
  1546. }
  1547. logged_delay = 0; /* reset it if we get this far */
  1548. if (PREDICT_UNLIKELY(need_to_update_have_min_dir_info)) {
  1549. update_router_have_minimum_dir_info();
  1550. }
  1551. return have_min_dir_info;
  1552. }
  1553. /** Set to CONSENSUS_PATH_EXIT if there is at least one exit node
  1554. * in the consensus. We update this flag in compute_frac_paths_available if
  1555. * there is at least one relay that has an Exit flag in the consensus.
  1556. * Used to avoid building exit circuits when they will almost certainly fail.
  1557. * Set to CONSENSUS_PATH_INTERNAL if there are no exits in the consensus.
  1558. * (This situation typically occurs during bootstrap of a test network.)
  1559. * Set to CONSENSUS_PATH_UNKNOWN if we have never checked, or have
  1560. * reason to believe our last known value was invalid or has expired.
  1561. * If we're in a network with TestingDirAuthVoteExit set,
  1562. * this can cause router_have_consensus_path() to be set to
  1563. * CONSENSUS_PATH_EXIT, even if there are no nodes with accept exit policies.
  1564. */
  1565. MOCK_IMPL(consensus_path_type_t,
  1566. router_have_consensus_path, (void))
  1567. {
  1568. return have_consensus_path;
  1569. }
  1570. /** Called when our internal view of the directory has changed. This can be
  1571. * when the authorities change, networkstatuses change, the list of routerdescs
  1572. * changes, or number of running routers changes.
  1573. */
  1574. void
  1575. router_dir_info_changed(void)
  1576. {
  1577. need_to_update_have_min_dir_info = 1;
  1578. rend_hsdir_routers_changed();
  1579. }
  1580. /** Return a string describing what we're missing before we have enough
  1581. * directory info. */
  1582. const char *
  1583. get_dir_info_status_string(void)
  1584. {
  1585. return dir_info_status;
  1586. }
  1587. /** Iterate over the servers listed in <b>consensus</b>, and count how many of
  1588. * them seem like ones we'd use (store this in *<b>num_usable</b>), and how
  1589. * many of <em>those</em> we have descriptors for (store this in
  1590. * *<b>num_present</b>).
  1591. *
  1592. * If <b>in_set</b> is non-NULL, only consider those routers in <b>in_set</b>.
  1593. * If <b>exit_only</b> is USABLE_DESCRIPTOR_EXIT_ONLY, only consider nodes
  1594. * with the Exit flag.
  1595. * If *<b>descs_out</b> is present, add a node_t for each usable descriptor
  1596. * to it.
  1597. */
  1598. static void
  1599. count_usable_descriptors(int *num_present, int *num_usable,
  1600. smartlist_t *descs_out,
  1601. const networkstatus_t *consensus,
  1602. time_t now,
  1603. routerset_t *in_set,
  1604. usable_descriptor_t exit_only)
  1605. {
  1606. const int md = (consensus->flavor == FLAV_MICRODESC);
  1607. *num_present = 0, *num_usable = 0;
  1608. SMARTLIST_FOREACH_BEGIN(consensus->routerstatus_list, routerstatus_t *, rs)
  1609. {
  1610. const node_t *node = node_get_by_id(rs->identity_digest);
  1611. if (!node)
  1612. continue; /* This would be a bug: every entry in the consensus is
  1613. * supposed to have a node. */
  1614. if (exit_only == USABLE_DESCRIPTOR_EXIT_ONLY && ! rs->is_exit)
  1615. continue;
  1616. if (in_set && ! routerset_contains_routerstatus(in_set, rs, -1))
  1617. continue;
  1618. if (client_would_use_router(rs, now)) {
  1619. const char * const digest = rs->descriptor_digest;
  1620. int present;
  1621. ++*num_usable; /* the consensus says we want it. */
  1622. if (md)
  1623. present = NULL != microdesc_cache_lookup_by_digest256(NULL, digest);
  1624. else
  1625. present = NULL != router_get_by_descriptor_digest(digest);
  1626. if (present) {
  1627. /* we have the descriptor listed in the consensus. */
  1628. ++*num_present;
  1629. }
  1630. if (descs_out)
  1631. smartlist_add(descs_out, (node_t*)node);
  1632. }
  1633. }
  1634. SMARTLIST_FOREACH_END(rs);
  1635. log_debug(LD_DIR, "%d usable, %d present (%s%s).",
  1636. *num_usable, *num_present,
  1637. md ? "microdesc" : "desc",
  1638. exit_only == USABLE_DESCRIPTOR_EXIT_ONLY ? " exits" : "s");
  1639. }
  1640. /** Return an estimate of which fraction of usable paths through the Tor
  1641. * network we have available for use. Count how many routers seem like ones
  1642. * we'd use (store this in *<b>num_usable_out</b>), and how many of
  1643. * <em>those</em> we have descriptors for (store this in
  1644. * *<b>num_present_out</b>.)
  1645. *
  1646. * If **<b>status_out</b> is present, allocate a new string and print the
  1647. * available percentages of guard, middle, and exit nodes to it, noting
  1648. * whether there are exits in the consensus.
  1649. * If there are no exits in the consensus, we treat the exit fraction as 100%,
  1650. * but set router_have_consensus_path() so that we can only build internal
  1651. * paths. */
  1652. static double
  1653. compute_frac_paths_available(const networkstatus_t *consensus,
  1654. const or_options_t *options, time_t now,
  1655. int *num_present_out, int *num_usable_out,
  1656. char **status_out)
  1657. {
  1658. smartlist_t *guards = smartlist_new();
  1659. smartlist_t *mid = smartlist_new();
  1660. smartlist_t *exits = smartlist_new();
  1661. double f_guard, f_mid, f_exit;
  1662. double f_path = 0.0;
  1663. /* Used to determine whether there are any exits in the consensus */
  1664. int np = 0;
  1665. /* Used to determine whether there are any exits with descriptors */
  1666. int nu = 0;
  1667. const int authdir = authdir_mode_v3(options);
  1668. count_usable_descriptors(num_present_out, num_usable_out,
  1669. mid, consensus, now, NULL,
  1670. USABLE_DESCRIPTOR_ALL);
  1671. if (options->EntryNodes) {
  1672. count_usable_descriptors(&np, &nu, guards, consensus, now,
  1673. options->EntryNodes, USABLE_DESCRIPTOR_ALL);
  1674. } else {
  1675. SMARTLIST_FOREACH(mid, const node_t *, node, {
  1676. if (authdir) {
  1677. if (node->rs && node->rs->is_possible_guard)
  1678. smartlist_add(guards, (node_t*)node);
  1679. } else {
  1680. if (node->is_possible_guard)
  1681. smartlist_add(guards, (node_t*)node);
  1682. }
  1683. });
  1684. }
  1685. /* All nodes with exit flag
  1686. * If we're in a network with TestingDirAuthVoteExit set,
  1687. * this can cause false positives on have_consensus_path,
  1688. * incorrectly setting it to CONSENSUS_PATH_EXIT. This is
  1689. * an unavoidable feature of forcing authorities to declare
  1690. * certain nodes as exits.
  1691. */
  1692. count_usable_descriptors(&np, &nu, exits, consensus, now,
  1693. NULL, USABLE_DESCRIPTOR_EXIT_ONLY);
  1694. log_debug(LD_NET,
  1695. "%s: %d present, %d usable",
  1696. "exits",
  1697. np,
  1698. nu);
  1699. /* We need at least 1 exit present in the consensus to consider
  1700. * building exit paths */
  1701. /* Update our understanding of whether the consensus has exits */
  1702. consensus_path_type_t old_have_consensus_path = have_consensus_path;
  1703. have_consensus_path = ((nu > 0) ?
  1704. CONSENSUS_PATH_EXIT :
  1705. CONSENSUS_PATH_INTERNAL);
  1706. if (have_consensus_path == CONSENSUS_PATH_INTERNAL
  1707. && old_have_consensus_path != have_consensus_path) {
  1708. log_notice(LD_NET,
  1709. "The current consensus has no exit nodes. "
  1710. "Tor can only build internal paths, "
  1711. "such as paths to hidden services.");
  1712. /* However, exit nodes can reachability self-test using this consensus,
  1713. * join the network, and appear in a later consensus. This will allow
  1714. * the network to build exit paths, such as paths for world wide web
  1715. * browsing (as distinct from hidden service web browsing). */
  1716. }
  1717. f_guard = frac_nodes_with_descriptors(guards, WEIGHT_FOR_GUARD);
  1718. f_mid = frac_nodes_with_descriptors(mid, WEIGHT_FOR_MID);
  1719. f_exit = frac_nodes_with_descriptors(exits, WEIGHT_FOR_EXIT);
  1720. log_debug(LD_NET,
  1721. "f_guard: %.2f, f_mid: %.2f, f_exit: %.2f",
  1722. f_guard,
  1723. f_mid,
  1724. f_exit);
  1725. smartlist_free(guards);
  1726. smartlist_free(mid);
  1727. smartlist_free(exits);
  1728. if (options->ExitNodes) {
  1729. double f_myexit, f_myexit_unflagged;
  1730. smartlist_t *myexits= smartlist_new();
  1731. smartlist_t *myexits_unflagged = smartlist_new();
  1732. /* All nodes with exit flag in ExitNodes option */
  1733. count_usable_descriptors(&np, &nu, myexits, consensus, now,
  1734. options->ExitNodes, USABLE_DESCRIPTOR_EXIT_ONLY);
  1735. log_debug(LD_NET,
  1736. "%s: %d present, %d usable",
  1737. "myexits",
  1738. np,
  1739. nu);
  1740. /* Now compute the nodes in the ExitNodes option where which we don't know
  1741. * what their exit policy is, or we know it permits something. */
  1742. count_usable_descriptors(&np, &nu, myexits_unflagged,
  1743. consensus, now,
  1744. options->ExitNodes, USABLE_DESCRIPTOR_ALL);
  1745. log_debug(LD_NET,
  1746. "%s: %d present, %d usable",
  1747. "myexits_unflagged (initial)",
  1748. np,
  1749. nu);
  1750. SMARTLIST_FOREACH_BEGIN(myexits_unflagged, const node_t *, node) {
  1751. if (node_has_descriptor(node) && node_exit_policy_rejects_all(node)) {
  1752. SMARTLIST_DEL_CURRENT(myexits_unflagged, node);
  1753. /* this node is not actually an exit */
  1754. np--;
  1755. /* this node is unusable as an exit */
  1756. nu--;
  1757. }
  1758. } SMARTLIST_FOREACH_END(node);
  1759. log_debug(LD_NET,
  1760. "%s: %d present, %d usable",
  1761. "myexits_unflagged (final)",
  1762. np,
  1763. nu);
  1764. f_myexit= frac_nodes_with_descriptors(myexits,WEIGHT_FOR_EXIT);
  1765. f_myexit_unflagged=
  1766. frac_nodes_with_descriptors(myexits_unflagged,WEIGHT_FOR_EXIT);
  1767. log_debug(LD_NET,
  1768. "f_exit: %.2f, f_myexit: %.2f, f_myexit_unflagged: %.2f",
  1769. f_exit,
  1770. f_myexit,
  1771. f_myexit_unflagged);
  1772. /* If our ExitNodes list has eliminated every possible Exit node, and there
  1773. * were some possible Exit nodes, then instead consider nodes that permit
  1774. * exiting to some ports. */
  1775. if (smartlist_len(myexits) == 0 &&
  1776. smartlist_len(myexits_unflagged)) {
  1777. f_myexit = f_myexit_unflagged;
  1778. }
  1779. smartlist_free(myexits);
  1780. smartlist_free(myexits_unflagged);
  1781. /* This is a tricky point here: we don't want to make it easy for a
  1782. * directory to trickle exits to us until it learns which exits we have
  1783. * configured, so require that we have a threshold both of total exits
  1784. * and usable exits. */
  1785. if (f_myexit < f_exit)
  1786. f_exit = f_myexit;
  1787. }
  1788. /* if the consensus has no exits, treat the exit fraction as 100% */
  1789. if (router_have_consensus_path() != CONSENSUS_PATH_EXIT) {
  1790. f_exit = 1.0;
  1791. }
  1792. f_path = f_guard * f_mid * f_exit;
  1793. if (status_out)
  1794. tor_asprintf(status_out,
  1795. "%d%% of guards bw, "
  1796. "%d%% of midpoint bw, and "
  1797. "%d%% of exit bw%s = "
  1798. "%d%% of path bw",
  1799. (int)(f_guard*100),
  1800. (int)(f_mid*100),
  1801. (int)(f_exit*100),
  1802. (router_have_consensus_path() == CONSENSUS_PATH_EXIT ?
  1803. "" :
  1804. " (no exits in consensus)"),
  1805. (int)(f_path*100));
  1806. return f_path;
  1807. }
  1808. /** We just fetched a new set of descriptors. Compute how far through
  1809. * the "loading descriptors" bootstrapping phase we are, so we can inform
  1810. * the controller of our progress. */
  1811. int
  1812. count_loading_descriptors_progress(void)
  1813. {
  1814. int num_present = 0, num_usable=0;
  1815. time_t now = time(NULL);
  1816. const or_options_t *options = get_options();
  1817. const networkstatus_t *consensus =
  1818. networkstatus_get_reasonably_live_consensus(now,usable_consensus_flavor());
  1819. double paths, fraction;
  1820. if (!consensus)
  1821. return 0; /* can't count descriptors if we have no list of them */
  1822. paths = compute_frac_paths_available(consensus, options, now,
  1823. &num_present, &num_usable,
  1824. NULL);
  1825. fraction = paths / get_frac_paths_needed_for_circs(options,consensus);
  1826. if (fraction > 1.0)
  1827. return 0; /* it's not the number of descriptors holding us back */
  1828. return BOOTSTRAP_STATUS_LOADING_DESCRIPTORS + (int)
  1829. (fraction*(BOOTSTRAP_STATUS_CONN_OR-1 -
  1830. BOOTSTRAP_STATUS_LOADING_DESCRIPTORS));
  1831. }
  1832. /** Return the fraction of paths needed before we're willing to build
  1833. * circuits, as configured in <b>options</b>, or in the consensus <b>ns</b>. */
  1834. static double
  1835. get_frac_paths_needed_for_circs(const or_options_t *options,
  1836. const networkstatus_t *ns)
  1837. {
  1838. #define DFLT_PCT_USABLE_NEEDED 60
  1839. if (options->PathsNeededToBuildCircuits >= 0.0) {
  1840. return options->PathsNeededToBuildCircuits;
  1841. } else {
  1842. return networkstatus_get_param(ns, "min_paths_for_circs_pct",
  1843. DFLT_PCT_USABLE_NEEDED,
  1844. 25, 95)/100.0;
  1845. }
  1846. }
  1847. /** Change the value of have_min_dir_info, setting it true iff we have enough
  1848. * network and router information to build circuits. Clear the value of
  1849. * need_to_update_have_min_dir_info. */
  1850. static void
  1851. update_router_have_minimum_dir_info(void)
  1852. {
  1853. time_t now = time(NULL);
  1854. int res;
  1855. const or_options_t *options = get_options();
  1856. const networkstatus_t *consensus =
  1857. networkstatus_get_reasonably_live_consensus(now,usable_consensus_flavor());
  1858. int using_md;
  1859. if (!consensus) {
  1860. if (!networkstatus_get_latest_consensus())
  1861. strlcpy(dir_info_status, "We have no usable consensus.",
  1862. sizeof(dir_info_status));
  1863. else
  1864. strlcpy(dir_info_status, "We have no recent usable consensus.",
  1865. sizeof(dir_info_status));
  1866. res = 0;
  1867. goto done;
  1868. }
  1869. using_md = consensus->flavor == FLAV_MICRODESC;
  1870. if (! entry_guards_have_enough_dir_info_to_build_circuits()) {
  1871. strlcpy(dir_info_status, "We're missing descriptors for some of our "
  1872. "primary entry guards", sizeof(dir_info_status));
  1873. res = 0;
  1874. goto done;
  1875. }
  1876. /* Check fraction of available paths */
  1877. {
  1878. char *status = NULL;
  1879. int num_present=0, num_usable=0;
  1880. double paths = compute_frac_paths_available(consensus, options, now,
  1881. &num_present, &num_usable,
  1882. &status);
  1883. if (paths < get_frac_paths_needed_for_circs(options,consensus)) {
  1884. tor_snprintf(dir_info_status, sizeof(dir_info_status),
  1885. "We need more %sdescriptors: we have %d/%d, and "
  1886. "can only build %d%% of likely paths. (We have %s.)",
  1887. using_md?"micro":"", num_present, num_usable,
  1888. (int)(paths*100), status);
  1889. tor_free(status);
  1890. res = 0;
  1891. control_event_bootstrap(BOOTSTRAP_STATUS_REQUESTING_DESCRIPTORS, 0);
  1892. goto done;
  1893. }
  1894. tor_free(status);
  1895. res = 1;
  1896. }
  1897. done:
  1898. /* If paths have just become available in this update. */
  1899. if (res && !have_min_dir_info) {
  1900. control_event_client_status(LOG_NOTICE, "ENOUGH_DIR_INFO");
  1901. if (control_event_bootstrap(BOOTSTRAP_STATUS_CONN_OR, 0) == 0) {
  1902. log_notice(LD_DIR,
  1903. "We now have enough directory information to build circuits.");
  1904. }
  1905. }
  1906. /* If paths have just become unavailable in this update. */
  1907. if (!res && have_min_dir_info) {
  1908. int quiet = directory_too_idle_to_fetch_descriptors(options, now);
  1909. tor_log(quiet ? LOG_INFO : LOG_NOTICE, LD_DIR,
  1910. "Our directory information is no longer up-to-date "
  1911. "enough to build circuits: %s", dir_info_status);
  1912. /* a) make us log when we next complete a circuit, so we know when Tor
  1913. * is back up and usable, and b) disable some activities that Tor
  1914. * should only do while circuits are working, like reachability tests
  1915. * and fetching bridge descriptors only over circuits. */
  1916. note_that_we_maybe_cant_complete_circuits();
  1917. have_consensus_path = CONSENSUS_PATH_UNKNOWN;
  1918. control_event_client_status(LOG_NOTICE, "NOT_ENOUGH_DIR_INFO");
  1919. }
  1920. have_min_dir_info = res;
  1921. need_to_update_have_min_dir_info = 0;
  1922. }