nodelist.c 54 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733
  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-2015, The Tor Project, Inc. */
  5. /* See LICENSE for licensing information */
  6. #include "or.h"
  7. #include "address.h"
  8. #include "config.h"
  9. #include "control.h"
  10. #include "dirserv.h"
  11. #include "geoip.h"
  12. #include "main.h"
  13. #include "microdesc.h"
  14. #include "networkstatus.h"
  15. #include "nodelist.h"
  16. #include "policies.h"
  17. #include "rendservice.h"
  18. #include "router.h"
  19. #include "routerlist.h"
  20. #include "routerset.h"
  21. #include <string.h>
  22. static void nodelist_drop_node(node_t *node, int remove_from_ht);
  23. static void node_free(node_t *node);
  24. /** count_usable_descriptors counts descriptors with these flag(s)
  25. */
  26. typedef enum {
  27. /* All descriptors regardless of flags */
  28. USABLE_DESCRIPTOR_ALL = 0,
  29. /* Only descriptors with the Exit flag */
  30. USABLE_DESCRIPTOR_EXIT_ONLY = 1
  31. } usable_descriptor_t;
  32. static void count_usable_descriptors(int *num_present,
  33. int *num_usable,
  34. smartlist_t *descs_out,
  35. const networkstatus_t *consensus,
  36. const or_options_t *options,
  37. time_t now,
  38. routerset_t *in_set,
  39. usable_descriptor_t exit_only);
  40. static void update_router_have_minimum_dir_info(void);
  41. static double get_frac_paths_needed_for_circs(const or_options_t *options,
  42. const networkstatus_t *ns);
  43. /** A nodelist_t holds a node_t object for every router we're "willing to use
  44. * for something". Specifically, it should hold a node_t for every node that
  45. * is currently in the routerlist, or currently in the consensus we're using.
  46. */
  47. typedef struct nodelist_t {
  48. /* A list of all the nodes. */
  49. smartlist_t *nodes;
  50. /* Hash table to map from node ID digest to node. */
  51. HT_HEAD(nodelist_map, node_t) nodes_by_id;
  52. } nodelist_t;
  53. static inline unsigned int
  54. node_id_hash(const node_t *node)
  55. {
  56. return (unsigned) siphash24g(node->identity, DIGEST_LEN);
  57. }
  58. static inline unsigned int
  59. node_id_eq(const node_t *node1, const node_t *node2)
  60. {
  61. return tor_memeq(node1->identity, node2->identity, DIGEST_LEN);
  62. }
  63. HT_PROTOTYPE(nodelist_map, node_t, ht_ent, node_id_hash, node_id_eq);
  64. HT_GENERATE2(nodelist_map, node_t, ht_ent, node_id_hash, node_id_eq,
  65. 0.6, tor_reallocarray_, tor_free_)
  66. /** The global nodelist. */
  67. static nodelist_t *the_nodelist=NULL;
  68. /** Create an empty nodelist if we haven't done so already. */
  69. static void
  70. init_nodelist(void)
  71. {
  72. if (PREDICT_UNLIKELY(the_nodelist == NULL)) {
  73. the_nodelist = tor_malloc_zero(sizeof(nodelist_t));
  74. HT_INIT(nodelist_map, &the_nodelist->nodes_by_id);
  75. the_nodelist->nodes = smartlist_new();
  76. }
  77. }
  78. /** As node_get_by_id, but returns a non-const pointer */
  79. node_t *
  80. node_get_mutable_by_id(const char *identity_digest)
  81. {
  82. node_t search, *node;
  83. if (PREDICT_UNLIKELY(the_nodelist == NULL))
  84. return NULL;
  85. memcpy(&search.identity, identity_digest, DIGEST_LEN);
  86. node = HT_FIND(nodelist_map, &the_nodelist->nodes_by_id, &search);
  87. return node;
  88. }
  89. /** Return the node_t whose identity is <b>identity_digest</b>, or NULL
  90. * if no such node exists. */
  91. MOCK_IMPL(const node_t *,
  92. node_get_by_id,(const char *identity_digest))
  93. {
  94. return node_get_mutable_by_id(identity_digest);
  95. }
  96. /** Internal: return the node_t whose identity_digest is
  97. * <b>identity_digest</b>. If none exists, create a new one, add it to the
  98. * nodelist, and return it.
  99. *
  100. * Requires that the nodelist be initialized.
  101. */
  102. static node_t *
  103. node_get_or_create(const char *identity_digest)
  104. {
  105. node_t *node;
  106. if ((node = node_get_mutable_by_id(identity_digest)))
  107. return node;
  108. node = tor_malloc_zero(sizeof(node_t));
  109. memcpy(node->identity, identity_digest, DIGEST_LEN);
  110. HT_INSERT(nodelist_map, &the_nodelist->nodes_by_id, node);
  111. smartlist_add(the_nodelist->nodes, node);
  112. node->nodelist_idx = smartlist_len(the_nodelist->nodes) - 1;
  113. node->country = -1;
  114. return node;
  115. }
  116. /** Called when a node's address changes. */
  117. static void
  118. node_addrs_changed(node_t *node)
  119. {
  120. node->last_reachable = node->last_reachable6 = 0;
  121. node->country = -1;
  122. }
  123. /** Add <b>ri</b> to an appropriate node in the nodelist. If we replace an
  124. * old routerinfo, and <b>ri_old_out</b> is not NULL, set *<b>ri_old_out</b>
  125. * to the previous routerinfo.
  126. */
  127. node_t *
  128. nodelist_set_routerinfo(routerinfo_t *ri, routerinfo_t **ri_old_out)
  129. {
  130. node_t *node;
  131. const char *id_digest;
  132. int had_router = 0;
  133. tor_assert(ri);
  134. init_nodelist();
  135. id_digest = ri->cache_info.identity_digest;
  136. node = node_get_or_create(id_digest);
  137. if (node->ri) {
  138. if (!routers_have_same_or_addrs(node->ri, ri)) {
  139. node_addrs_changed(node);
  140. }
  141. had_router = 1;
  142. if (ri_old_out)
  143. *ri_old_out = node->ri;
  144. } else {
  145. if (ri_old_out)
  146. *ri_old_out = NULL;
  147. }
  148. node->ri = ri;
  149. if (node->country == -1)
  150. node_set_country(node);
  151. if (authdir_mode(get_options()) && !had_router) {
  152. const char *discard=NULL;
  153. uint32_t status = dirserv_router_get_status(ri, &discard, LOG_INFO);
  154. dirserv_set_node_flags_from_authoritative_status(node, status);
  155. }
  156. return node;
  157. }
  158. /** Set the appropriate node_t to use <b>md</b> as its microdescriptor.
  159. *
  160. * Called when a new microdesc has arrived and the usable consensus flavor
  161. * is "microdesc".
  162. **/
  163. node_t *
  164. nodelist_add_microdesc(microdesc_t *md)
  165. {
  166. networkstatus_t *ns =
  167. networkstatus_get_latest_consensus_by_flavor(FLAV_MICRODESC);
  168. const routerstatus_t *rs;
  169. node_t *node;
  170. if (ns == NULL)
  171. return NULL;
  172. init_nodelist();
  173. /* Microdescriptors don't carry an identity digest, so we need to figure
  174. * it out by looking up the routerstatus. */
  175. rs = router_get_consensus_status_by_descriptor_digest(ns, md->digest);
  176. if (rs == NULL)
  177. return NULL;
  178. node = node_get_mutable_by_id(rs->identity_digest);
  179. if (node) {
  180. if (node->md)
  181. node->md->held_by_nodes--;
  182. node->md = md;
  183. md->held_by_nodes++;
  184. }
  185. return node;
  186. }
  187. /** Tell the nodelist that the current usable consensus is <b>ns</b>.
  188. * This makes the nodelist change all of the routerstatus entries for
  189. * the nodes, drop nodes that no longer have enough info to get used,
  190. * and grab microdescriptors into nodes as appropriate.
  191. */
  192. void
  193. nodelist_set_consensus(networkstatus_t *ns)
  194. {
  195. const or_options_t *options = get_options();
  196. int authdir = authdir_mode_v3(options);
  197. int client = !server_mode(options);
  198. init_nodelist();
  199. if (ns->flavor == FLAV_MICRODESC)
  200. (void) get_microdesc_cache(); /* Make sure it exists first. */
  201. SMARTLIST_FOREACH(the_nodelist->nodes, node_t *, node,
  202. node->rs = NULL);
  203. SMARTLIST_FOREACH_BEGIN(ns->routerstatus_list, routerstatus_t *, rs) {
  204. node_t *node = node_get_or_create(rs->identity_digest);
  205. node->rs = rs;
  206. if (ns->flavor == FLAV_MICRODESC) {
  207. if (node->md == NULL ||
  208. tor_memneq(node->md->digest,rs->descriptor_digest,DIGEST256_LEN)) {
  209. if (node->md)
  210. node->md->held_by_nodes--;
  211. node->md = microdesc_cache_lookup_by_digest256(NULL,
  212. rs->descriptor_digest);
  213. if (node->md)
  214. node->md->held_by_nodes++;
  215. }
  216. }
  217. node_set_country(node);
  218. /* If we're not an authdir, believe others. */
  219. if (!authdir) {
  220. node->is_valid = rs->is_valid;
  221. node->is_running = rs->is_flagged_running;
  222. node->is_fast = rs->is_fast;
  223. node->is_stable = rs->is_stable;
  224. node->is_possible_guard = rs->is_possible_guard;
  225. node->is_exit = rs->is_exit;
  226. node->is_bad_exit = rs->is_bad_exit;
  227. node->is_hs_dir = rs->is_hs_dir;
  228. node->ipv6_preferred = 0;
  229. if (client && options->ClientPreferIPv6ORPort == 1 &&
  230. (tor_addr_is_null(&rs->ipv6_addr) == 0 ||
  231. (node->md && tor_addr_is_null(&node->md->ipv6_addr) == 0)))
  232. node->ipv6_preferred = 1;
  233. }
  234. } SMARTLIST_FOREACH_END(rs);
  235. nodelist_purge();
  236. if (! authdir) {
  237. SMARTLIST_FOREACH_BEGIN(the_nodelist->nodes, node_t *, node) {
  238. /* We have no routerstatus for this router. Clear flags so we can skip
  239. * it, maybe.*/
  240. if (!node->rs) {
  241. tor_assert(node->ri); /* if it had only an md, or nothing, purge
  242. * would have removed it. */
  243. if (node->ri->purpose == ROUTER_PURPOSE_GENERAL) {
  244. /* Clear all flags. */
  245. node->is_valid = node->is_running = node->is_hs_dir =
  246. node->is_fast = node->is_stable =
  247. node->is_possible_guard = node->is_exit =
  248. node->is_bad_exit = node->ipv6_preferred = 0;
  249. }
  250. }
  251. } SMARTLIST_FOREACH_END(node);
  252. }
  253. }
  254. /** Helper: return true iff a node has a usable amount of information*/
  255. static inline int
  256. node_is_usable(const node_t *node)
  257. {
  258. return (node->rs) || (node->ri);
  259. }
  260. /** Tell the nodelist that <b>md</b> is no longer a microdescriptor for the
  261. * node with <b>identity_digest</b>. */
  262. void
  263. nodelist_remove_microdesc(const char *identity_digest, microdesc_t *md)
  264. {
  265. node_t *node = node_get_mutable_by_id(identity_digest);
  266. if (node && node->md == md) {
  267. node->md = NULL;
  268. md->held_by_nodes--;
  269. }
  270. }
  271. /** Tell the nodelist that <b>ri</b> is no longer in the routerlist. */
  272. void
  273. nodelist_remove_routerinfo(routerinfo_t *ri)
  274. {
  275. node_t *node = node_get_mutable_by_id(ri->cache_info.identity_digest);
  276. if (node && node->ri == ri) {
  277. node->ri = NULL;
  278. if (! node_is_usable(node)) {
  279. nodelist_drop_node(node, 1);
  280. node_free(node);
  281. }
  282. }
  283. }
  284. /** Remove <b>node</b> from the nodelist. (Asserts that it was there to begin
  285. * with.) */
  286. static void
  287. nodelist_drop_node(node_t *node, int remove_from_ht)
  288. {
  289. node_t *tmp;
  290. int idx;
  291. if (remove_from_ht) {
  292. tmp = HT_REMOVE(nodelist_map, &the_nodelist->nodes_by_id, node);
  293. tor_assert(tmp == node);
  294. }
  295. idx = node->nodelist_idx;
  296. tor_assert(idx >= 0);
  297. tor_assert(node == smartlist_get(the_nodelist->nodes, idx));
  298. smartlist_del(the_nodelist->nodes, idx);
  299. if (idx < smartlist_len(the_nodelist->nodes)) {
  300. tmp = smartlist_get(the_nodelist->nodes, idx);
  301. tmp->nodelist_idx = idx;
  302. }
  303. node->nodelist_idx = -1;
  304. }
  305. /** Return a newly allocated smartlist of the nodes that have <b>md</b> as
  306. * their microdescriptor. */
  307. smartlist_t *
  308. nodelist_find_nodes_with_microdesc(const microdesc_t *md)
  309. {
  310. smartlist_t *result = smartlist_new();
  311. if (the_nodelist == NULL)
  312. return result;
  313. SMARTLIST_FOREACH_BEGIN(the_nodelist->nodes, node_t *, node) {
  314. if (node->md == md) {
  315. smartlist_add(result, node);
  316. }
  317. } SMARTLIST_FOREACH_END(node);
  318. return result;
  319. }
  320. /** Release storage held by <b>node</b> */
  321. static void
  322. node_free(node_t *node)
  323. {
  324. if (!node)
  325. return;
  326. if (node->md)
  327. node->md->held_by_nodes--;
  328. tor_assert(node->nodelist_idx == -1);
  329. tor_free(node);
  330. }
  331. /** Remove all entries from the nodelist that don't have enough info to be
  332. * usable for anything. */
  333. void
  334. nodelist_purge(void)
  335. {
  336. node_t **iter;
  337. if (PREDICT_UNLIKELY(the_nodelist == NULL))
  338. return;
  339. /* Remove the non-usable nodes. */
  340. for (iter = HT_START(nodelist_map, &the_nodelist->nodes_by_id); iter; ) {
  341. node_t *node = *iter;
  342. if (node->md && !node->rs) {
  343. /* An md is only useful if there is an rs. */
  344. node->md->held_by_nodes--;
  345. node->md = NULL;
  346. }
  347. if (node_is_usable(node)) {
  348. iter = HT_NEXT(nodelist_map, &the_nodelist->nodes_by_id, iter);
  349. } else {
  350. iter = HT_NEXT_RMV(nodelist_map, &the_nodelist->nodes_by_id, iter);
  351. nodelist_drop_node(node, 0);
  352. node_free(node);
  353. }
  354. }
  355. nodelist_assert_ok();
  356. }
  357. /** Release all storage held by the nodelist. */
  358. void
  359. nodelist_free_all(void)
  360. {
  361. if (PREDICT_UNLIKELY(the_nodelist == NULL))
  362. return;
  363. HT_CLEAR(nodelist_map, &the_nodelist->nodes_by_id);
  364. SMARTLIST_FOREACH_BEGIN(the_nodelist->nodes, node_t *, node) {
  365. node->nodelist_idx = -1;
  366. node_free(node);
  367. } SMARTLIST_FOREACH_END(node);
  368. smartlist_free(the_nodelist->nodes);
  369. tor_free(the_nodelist);
  370. }
  371. /** Check that the nodelist is internally consistent, and consistent with
  372. * the directory info it's derived from.
  373. */
  374. void
  375. nodelist_assert_ok(void)
  376. {
  377. routerlist_t *rl = router_get_routerlist();
  378. networkstatus_t *ns = networkstatus_get_latest_consensus();
  379. digestmap_t *dm;
  380. if (!the_nodelist)
  381. return;
  382. dm = digestmap_new();
  383. /* every routerinfo in rl->routers should be in the nodelist. */
  384. if (rl) {
  385. SMARTLIST_FOREACH_BEGIN(rl->routers, routerinfo_t *, ri) {
  386. const node_t *node = node_get_by_id(ri->cache_info.identity_digest);
  387. tor_assert(node && node->ri == ri);
  388. tor_assert(fast_memeq(ri->cache_info.identity_digest,
  389. node->identity, DIGEST_LEN));
  390. tor_assert(! digestmap_get(dm, node->identity));
  391. digestmap_set(dm, node->identity, (void*)node);
  392. } SMARTLIST_FOREACH_END(ri);
  393. }
  394. /* every routerstatus in ns should be in the nodelist */
  395. if (ns) {
  396. SMARTLIST_FOREACH_BEGIN(ns->routerstatus_list, routerstatus_t *, rs) {
  397. const node_t *node = node_get_by_id(rs->identity_digest);
  398. tor_assert(node && node->rs == rs);
  399. tor_assert(fast_memeq(rs->identity_digest, node->identity, DIGEST_LEN));
  400. digestmap_set(dm, node->identity, (void*)node);
  401. if (ns->flavor == FLAV_MICRODESC) {
  402. /* If it's a microdesc consensus, every entry that has a
  403. * microdescriptor should be in the nodelist.
  404. */
  405. microdesc_t *md =
  406. microdesc_cache_lookup_by_digest256(NULL, rs->descriptor_digest);
  407. tor_assert(md == node->md);
  408. if (md)
  409. tor_assert(md->held_by_nodes >= 1);
  410. }
  411. } SMARTLIST_FOREACH_END(rs);
  412. }
  413. /* The nodelist should have no other entries, and its entries should be
  414. * well-formed. */
  415. SMARTLIST_FOREACH_BEGIN(the_nodelist->nodes, node_t *, node) {
  416. tor_assert(digestmap_get(dm, node->identity) != NULL);
  417. tor_assert(node_sl_idx == node->nodelist_idx);
  418. } SMARTLIST_FOREACH_END(node);
  419. tor_assert((long)smartlist_len(the_nodelist->nodes) ==
  420. (long)HT_SIZE(&the_nodelist->nodes_by_id));
  421. digestmap_free(dm, NULL);
  422. }
  423. /** Return a list of a node_t * for every node we know about. The caller
  424. * MUST NOT modify the list. (You can set and clear flags in the nodes if
  425. * you must, but you must not add or remove nodes.) */
  426. MOCK_IMPL(smartlist_t *,
  427. nodelist_get_list,(void))
  428. {
  429. init_nodelist();
  430. return the_nodelist->nodes;
  431. }
  432. /** Given a hex-encoded nickname of the format DIGEST, $DIGEST, $DIGEST=name,
  433. * or $DIGEST~name, return the node with the matching identity digest and
  434. * nickname (if any). Return NULL if no such node exists, or if <b>hex_id</b>
  435. * is not well-formed. */
  436. const node_t *
  437. node_get_by_hex_id(const char *hex_id)
  438. {
  439. char digest_buf[DIGEST_LEN];
  440. char nn_buf[MAX_NICKNAME_LEN+1];
  441. char nn_char='\0';
  442. if (hex_digest_nickname_decode(hex_id, digest_buf, &nn_char, nn_buf)==0) {
  443. const node_t *node = node_get_by_id(digest_buf);
  444. if (!node)
  445. return NULL;
  446. if (nn_char) {
  447. const char *real_name = node_get_nickname(node);
  448. if (!real_name || strcasecmp(real_name, nn_buf))
  449. return NULL;
  450. if (nn_char == '=') {
  451. const char *named_id =
  452. networkstatus_get_router_digest_by_nickname(nn_buf);
  453. if (!named_id || tor_memneq(named_id, digest_buf, DIGEST_LEN))
  454. return NULL;
  455. }
  456. }
  457. return node;
  458. }
  459. return NULL;
  460. }
  461. /** Given a nickname (possibly verbose, possibly a hexadecimal digest), return
  462. * the corresponding node_t, or NULL if none exists. Warn the user if
  463. * <b>warn_if_unnamed</b> is set, and they have specified a router by
  464. * nickname, but the Named flag isn't set for that router. */
  465. MOCK_IMPL(const node_t *,
  466. node_get_by_nickname,(const char *nickname, int warn_if_unnamed))
  467. {
  468. const node_t *node;
  469. if (!the_nodelist)
  470. return NULL;
  471. /* Handle these cases: DIGEST, $DIGEST, $DIGEST=name, $DIGEST~name. */
  472. if ((node = node_get_by_hex_id(nickname)) != NULL)
  473. return node;
  474. if (!strcasecmp(nickname, UNNAMED_ROUTER_NICKNAME))
  475. return NULL;
  476. /* Okay, so if we get here, the nickname is just a nickname. Is there
  477. * a binding for it in the consensus? */
  478. {
  479. const char *named_id =
  480. networkstatus_get_router_digest_by_nickname(nickname);
  481. if (named_id)
  482. return node_get_by_id(named_id);
  483. }
  484. /* Is it marked as owned-by-someone-else? */
  485. if (networkstatus_nickname_is_unnamed(nickname)) {
  486. log_info(LD_GENERAL, "The name %s is listed as Unnamed: there is some "
  487. "router that holds it, but not one listed in the current "
  488. "consensus.", escaped(nickname));
  489. return NULL;
  490. }
  491. /* Okay, so the name is not canonical for anybody. */
  492. {
  493. smartlist_t *matches = smartlist_new();
  494. const node_t *choice = NULL;
  495. SMARTLIST_FOREACH_BEGIN(the_nodelist->nodes, node_t *, node) {
  496. if (!strcasecmp(node_get_nickname(node), nickname))
  497. smartlist_add(matches, node);
  498. } SMARTLIST_FOREACH_END(node);
  499. if (smartlist_len(matches)>1 && warn_if_unnamed) {
  500. int any_unwarned = 0;
  501. SMARTLIST_FOREACH_BEGIN(matches, node_t *, node) {
  502. if (!node->name_lookup_warned) {
  503. node->name_lookup_warned = 1;
  504. any_unwarned = 1;
  505. }
  506. } SMARTLIST_FOREACH_END(node);
  507. if (any_unwarned) {
  508. log_warn(LD_CONFIG, "There are multiple matches for the name %s, "
  509. "but none is listed as Named in the directory consensus. "
  510. "Choosing one arbitrarily.", nickname);
  511. }
  512. } else if (smartlist_len(matches)>1 && warn_if_unnamed) {
  513. char fp[HEX_DIGEST_LEN+1];
  514. node_t *node = smartlist_get(matches, 0);
  515. if (node->name_lookup_warned) {
  516. base16_encode(fp, sizeof(fp), node->identity, DIGEST_LEN);
  517. log_warn(LD_CONFIG,
  518. "You specified a server \"%s\" by name, but the directory "
  519. "authorities do not have any key registered for this "
  520. "nickname -- so it could be used by any server, not just "
  521. "the one you meant. "
  522. "To make sure you get the same server in the future, refer "
  523. "to it by key, as \"$%s\".", nickname, fp);
  524. node->name_lookup_warned = 1;
  525. }
  526. }
  527. if (smartlist_len(matches))
  528. choice = smartlist_get(matches, 0);
  529. smartlist_free(matches);
  530. return choice;
  531. }
  532. }
  533. /** Return the nickname of <b>node</b>, or NULL if we can't find one. */
  534. const char *
  535. node_get_nickname(const node_t *node)
  536. {
  537. tor_assert(node);
  538. if (node->rs)
  539. return node->rs->nickname;
  540. else if (node->ri)
  541. return node->ri->nickname;
  542. else
  543. return NULL;
  544. }
  545. /** Return true iff the nickname of <b>node</b> is canonical, based on the
  546. * latest consensus. */
  547. int
  548. node_is_named(const node_t *node)
  549. {
  550. const char *named_id;
  551. const char *nickname = node_get_nickname(node);
  552. if (!nickname)
  553. return 0;
  554. named_id = networkstatus_get_router_digest_by_nickname(nickname);
  555. if (!named_id)
  556. return 0;
  557. return tor_memeq(named_id, node->identity, DIGEST_LEN);
  558. }
  559. /** Return true iff <b>node</b> appears to be a directory authority or
  560. * directory cache */
  561. int
  562. node_is_dir(const node_t *node)
  563. {
  564. if (node->rs) {
  565. routerstatus_t * rs = node->rs;
  566. /* This is true if supports_tunnelled_dir_requests is true which
  567. * indicates that we support directory request tunnelled or through the
  568. * DirPort. */
  569. return rs->is_v2_dir;
  570. } else if (node->ri) {
  571. routerinfo_t * ri = node->ri;
  572. /* Both tunnelled request is supported or DirPort is set. */
  573. return ri->supports_tunnelled_dir_requests;
  574. } else {
  575. return 0;
  576. }
  577. }
  578. /** Return true iff <b>node</b> has either kind of usable descriptor -- that
  579. * is, a routerdescriptor or a microdescriptor. */
  580. int
  581. node_has_descriptor(const node_t *node)
  582. {
  583. return (node->ri ||
  584. (node->rs && node->md));
  585. }
  586. /** Return the router_purpose of <b>node</b>. */
  587. int
  588. node_get_purpose(const node_t *node)
  589. {
  590. if (node->ri)
  591. return node->ri->purpose;
  592. else
  593. return ROUTER_PURPOSE_GENERAL;
  594. }
  595. /** Compute the verbose ("extended") nickname of <b>node</b> and store it
  596. * into the MAX_VERBOSE_NICKNAME_LEN+1 character buffer at
  597. * <b>verbose_name_out</b> */
  598. void
  599. node_get_verbose_nickname(const node_t *node,
  600. char *verbose_name_out)
  601. {
  602. const char *nickname = node_get_nickname(node);
  603. int is_named = node_is_named(node);
  604. verbose_name_out[0] = '$';
  605. base16_encode(verbose_name_out+1, HEX_DIGEST_LEN+1, node->identity,
  606. DIGEST_LEN);
  607. if (!nickname)
  608. return;
  609. verbose_name_out[1+HEX_DIGEST_LEN] = is_named ? '=' : '~';
  610. strlcpy(verbose_name_out+1+HEX_DIGEST_LEN+1, nickname, MAX_NICKNAME_LEN+1);
  611. }
  612. /** Compute the verbose ("extended") nickname of node with
  613. * given <b>id_digest</b> and store it into the MAX_VERBOSE_NICKNAME_LEN+1
  614. * character buffer at <b>verbose_name_out</b>
  615. *
  616. * If node_get_by_id() returns NULL, base 16 encoding of
  617. * <b>id_digest</b> is returned instead. */
  618. void
  619. node_get_verbose_nickname_by_id(const char *id_digest,
  620. char *verbose_name_out)
  621. {
  622. const node_t *node = node_get_by_id(id_digest);
  623. if (!node) {
  624. verbose_name_out[0] = '$';
  625. base16_encode(verbose_name_out+1, HEX_DIGEST_LEN+1, id_digest, DIGEST_LEN);
  626. } else {
  627. node_get_verbose_nickname(node, verbose_name_out);
  628. }
  629. }
  630. /** Return true iff it seems that <b>node</b> allows circuits to exit
  631. * through it directlry from the client. */
  632. int
  633. node_allows_single_hop_exits(const node_t *node)
  634. {
  635. if (node && node->ri)
  636. return node->ri->allow_single_hop_exits;
  637. else
  638. return 0;
  639. }
  640. /** Return true iff it seems that <b>node</b> has an exit policy that doesn't
  641. * actually permit anything to exit, or we don't know its exit policy */
  642. int
  643. node_exit_policy_rejects_all(const node_t *node)
  644. {
  645. if (node->rejects_all)
  646. return 1;
  647. if (node->ri)
  648. return node->ri->policy_is_reject_star;
  649. else if (node->md)
  650. return node->md->exit_policy == NULL ||
  651. short_policy_is_reject_star(node->md->exit_policy);
  652. else
  653. return 1;
  654. }
  655. /** Return true iff the exit policy for <b>node</b> is such that we can treat
  656. * rejecting an address of type <b>family</b> unexpectedly as a sign of that
  657. * node's failure. */
  658. int
  659. node_exit_policy_is_exact(const node_t *node, sa_family_t family)
  660. {
  661. if (family == AF_UNSPEC) {
  662. return 1; /* Rejecting an address but not telling us what address
  663. * is a bad sign. */
  664. } else if (family == AF_INET) {
  665. return node->ri != NULL;
  666. } else if (family == AF_INET6) {
  667. return 0;
  668. }
  669. tor_fragile_assert();
  670. return 1;
  671. }
  672. /** Return list of tor_addr_port_t with all OR ports (in the sense IP
  673. * addr + TCP port) for <b>node</b>. Caller must free all elements
  674. * using tor_free() and free the list using smartlist_free().
  675. *
  676. * XXX this is potentially a memory fragmentation hog -- if on
  677. * critical path consider the option of having the caller allocate the
  678. * memory
  679. */
  680. smartlist_t *
  681. node_get_all_orports(const node_t *node)
  682. {
  683. smartlist_t *sl = smartlist_new();
  684. if (node->ri != NULL) {
  685. if (node->ri->addr != 0) {
  686. tor_addr_port_t *ap = tor_malloc(sizeof(tor_addr_port_t));
  687. tor_addr_from_ipv4h(&ap->addr, node->ri->addr);
  688. ap->port = node->ri->or_port;
  689. smartlist_add(sl, ap);
  690. }
  691. if (!tor_addr_is_null(&node->ri->ipv6_addr)) {
  692. tor_addr_port_t *ap = tor_malloc(sizeof(tor_addr_port_t));
  693. tor_addr_copy(&ap->addr, &node->ri->ipv6_addr);
  694. ap->port = node->ri->or_port;
  695. smartlist_add(sl, ap);
  696. }
  697. } else if (node->rs != NULL) {
  698. tor_addr_port_t *ap = tor_malloc(sizeof(tor_addr_port_t));
  699. tor_addr_from_ipv4h(&ap->addr, node->rs->addr);
  700. ap->port = node->rs->or_port;
  701. smartlist_add(sl, ap);
  702. }
  703. return sl;
  704. }
  705. /** Wrapper around node_get_prim_orport for backward
  706. compatibility. */
  707. void
  708. node_get_addr(const node_t *node, tor_addr_t *addr_out)
  709. {
  710. tor_addr_port_t ap;
  711. node_get_prim_orport(node, &ap);
  712. tor_addr_copy(addr_out, &ap.addr);
  713. }
  714. /** Return the host-order IPv4 address for <b>node</b>, or 0 if it doesn't
  715. * seem to have one. */
  716. uint32_t
  717. node_get_prim_addr_ipv4h(const node_t *node)
  718. {
  719. if (node->ri) {
  720. return node->ri->addr;
  721. } else if (node->rs) {
  722. return node->rs->addr;
  723. }
  724. return 0;
  725. }
  726. /** Copy a string representation of an IP address for <b>node</b> into
  727. * the <b>len</b>-byte buffer at <b>buf</b>. */
  728. void
  729. node_get_address_string(const node_t *node, char *buf, size_t len)
  730. {
  731. if (node->ri) {
  732. strlcpy(buf, fmt_addr32(node->ri->addr), len);
  733. } else if (node->rs) {
  734. tor_addr_t addr;
  735. tor_addr_from_ipv4h(&addr, node->rs->addr);
  736. tor_addr_to_str(buf, &addr, len, 0);
  737. } else {
  738. buf[0] = '\0';
  739. }
  740. }
  741. /** Return <b>node</b>'s declared uptime, or -1 if it doesn't seem to have
  742. * one. */
  743. long
  744. node_get_declared_uptime(const node_t *node)
  745. {
  746. if (node->ri)
  747. return node->ri->uptime;
  748. else
  749. return -1;
  750. }
  751. /** Return <b>node</b>'s platform string, or NULL if we don't know it. */
  752. const char *
  753. node_get_platform(const node_t *node)
  754. {
  755. /* If we wanted, we could record the version in the routerstatus_t, since
  756. * the consensus lists it. We don't, though, so this function just won't
  757. * work with microdescriptors. */
  758. if (node->ri)
  759. return node->ri->platform;
  760. else
  761. return NULL;
  762. }
  763. /** Return <b>node</b>'s time of publication, or 0 if we don't have one. */
  764. time_t
  765. node_get_published_on(const node_t *node)
  766. {
  767. if (node->ri)
  768. return node->ri->cache_info.published_on;
  769. else
  770. return 0;
  771. }
  772. /** Return true iff <b>node</b> is one representing this router. */
  773. int
  774. node_is_me(const node_t *node)
  775. {
  776. return router_digest_is_me(node->identity);
  777. }
  778. /** Return <b>node</b> declared family (as a list of names), or NULL if
  779. * the node didn't declare a family. */
  780. const smartlist_t *
  781. node_get_declared_family(const node_t *node)
  782. {
  783. if (node->ri && node->ri->declared_family)
  784. return node->ri->declared_family;
  785. else if (node->md && node->md->family)
  786. return node->md->family;
  787. else
  788. return NULL;
  789. }
  790. /** Return 1 if we prefer the IPv6 address and OR TCP port of
  791. * <b>node</b>, else 0.
  792. *
  793. * We prefer the IPv6 address if the router has an IPv6 address and
  794. * i) the node_t says that it prefers IPv6
  795. * or
  796. * ii) the router has no IPv4 address. */
  797. int
  798. node_ipv6_preferred(const node_t *node)
  799. {
  800. tor_addr_port_t ipv4_addr;
  801. node_assert_ok(node);
  802. if (node->ipv6_preferred || node_get_prim_orport(node, &ipv4_addr)) {
  803. if (node->ri)
  804. return !tor_addr_is_null(&node->ri->ipv6_addr);
  805. if (node->md)
  806. return !tor_addr_is_null(&node->md->ipv6_addr);
  807. if (node->rs)
  808. return !tor_addr_is_null(&node->rs->ipv6_addr);
  809. }
  810. return 0;
  811. }
  812. /** Copy the primary (IPv4) OR port (IP address and TCP port) for
  813. * <b>node</b> into *<b>ap_out</b>. Return 0 if a valid address and
  814. * port was copied, else return non-zero.*/
  815. int
  816. node_get_prim_orport(const node_t *node, tor_addr_port_t *ap_out)
  817. {
  818. node_assert_ok(node);
  819. tor_assert(ap_out);
  820. if (node->ri) {
  821. if (node->ri->addr == 0 || node->ri->or_port == 0)
  822. return -1;
  823. tor_addr_from_ipv4h(&ap_out->addr, node->ri->addr);
  824. ap_out->port = node->ri->or_port;
  825. return 0;
  826. }
  827. if (node->rs) {
  828. if (node->rs->addr == 0 || node->rs->or_port == 0)
  829. return -1;
  830. tor_addr_from_ipv4h(&ap_out->addr, node->rs->addr);
  831. ap_out->port = node->rs->or_port;
  832. return 0;
  833. }
  834. return -1;
  835. }
  836. /** Copy the preferred OR port (IP address and TCP port) for
  837. * <b>node</b> into *<b>ap_out</b>. */
  838. void
  839. node_get_pref_orport(const node_t *node, tor_addr_port_t *ap_out)
  840. {
  841. const or_options_t *options = get_options();
  842. tor_assert(ap_out);
  843. /* Cheap implementation of config option ClientUseIPv6 -- simply
  844. don't prefer IPv6 when ClientUseIPv6 is not set and we're not a
  845. client running with bridges. See #4455 for more on this subject.
  846. Note that this filter is too strict since we're hindering not
  847. only clients! Erring on the safe side shouldn't be a problem
  848. though. XXX move this check to where outgoing connections are
  849. made? -LN */
  850. if ((options->ClientUseIPv6 || options->UseBridges) &&
  851. node_ipv6_preferred(node)) {
  852. node_get_pref_ipv6_orport(node, ap_out);
  853. } else {
  854. node_get_prim_orport(node, ap_out);
  855. }
  856. }
  857. /** Copy the preferred IPv6 OR port (IP address and TCP port) for
  858. * <b>node</b> into *<b>ap_out</b>. */
  859. void
  860. node_get_pref_ipv6_orport(const node_t *node, tor_addr_port_t *ap_out)
  861. {
  862. node_assert_ok(node);
  863. tor_assert(ap_out);
  864. /* We prefer the microdesc over a potential routerstatus here. They
  865. are not being synchronised atm so there might be a chance that
  866. they differ at some point, f.ex. when flipping
  867. UseMicrodescriptors? -LN */
  868. if (node->ri) {
  869. tor_addr_copy(&ap_out->addr, &node->ri->ipv6_addr);
  870. ap_out->port = node->ri->ipv6_orport;
  871. } else if (node->md) {
  872. tor_addr_copy(&ap_out->addr, &node->md->ipv6_addr);
  873. ap_out->port = node->md->ipv6_orport;
  874. } else if (node->rs) {
  875. tor_addr_copy(&ap_out->addr, &node->rs->ipv6_addr);
  876. ap_out->port = node->rs->ipv6_orport;
  877. }
  878. }
  879. /** Return true iff <b>node</b> has a curve25519 onion key. */
  880. int
  881. node_has_curve25519_onion_key(const node_t *node)
  882. {
  883. if (node->ri)
  884. return node->ri->onion_curve25519_pkey != NULL;
  885. else if (node->md)
  886. return node->md->onion_curve25519_pkey != NULL;
  887. else
  888. return 0;
  889. }
  890. /** Refresh the country code of <b>ri</b>. This function MUST be called on
  891. * each router when the GeoIP database is reloaded, and on all new routers. */
  892. void
  893. node_set_country(node_t *node)
  894. {
  895. tor_addr_t addr = TOR_ADDR_NULL;
  896. /* XXXXipv6 */
  897. if (node->rs)
  898. tor_addr_from_ipv4h(&addr, node->rs->addr);
  899. else if (node->ri)
  900. tor_addr_from_ipv4h(&addr, node->ri->addr);
  901. node->country = geoip_get_country_by_addr(&addr);
  902. }
  903. /** Set the country code of all routers in the routerlist. */
  904. void
  905. nodelist_refresh_countries(void)
  906. {
  907. smartlist_t *nodes = nodelist_get_list();
  908. SMARTLIST_FOREACH(nodes, node_t *, node,
  909. node_set_country(node));
  910. }
  911. /** Return true iff router1 and router2 have similar enough network addresses
  912. * that we should treat them as being in the same family */
  913. static inline int
  914. addrs_in_same_network_family(const tor_addr_t *a1,
  915. const tor_addr_t *a2)
  916. {
  917. return 0 == tor_addr_compare_masked(a1, a2, 16, CMP_SEMANTIC);
  918. }
  919. /** Return true if <b>node</b>'s nickname matches <b>nickname</b>
  920. * (case-insensitive), or if <b>node's</b> identity key digest
  921. * matches a hexadecimal value stored in <b>nickname</b>. Return
  922. * false otherwise. */
  923. static int
  924. node_nickname_matches(const node_t *node, const char *nickname)
  925. {
  926. const char *n = node_get_nickname(node);
  927. if (n && nickname[0]!='$' && !strcasecmp(n, nickname))
  928. return 1;
  929. return hex_digest_nickname_matches(nickname,
  930. node->identity,
  931. n,
  932. node_is_named(node));
  933. }
  934. /** Return true iff <b>node</b> is named by some nickname in <b>lst</b>. */
  935. static inline int
  936. node_in_nickname_smartlist(const smartlist_t *lst, const node_t *node)
  937. {
  938. if (!lst) return 0;
  939. SMARTLIST_FOREACH(lst, const char *, name, {
  940. if (node_nickname_matches(node, name))
  941. return 1;
  942. });
  943. return 0;
  944. }
  945. /** Return true iff r1 and r2 are in the same family, but not the same
  946. * router. */
  947. int
  948. nodes_in_same_family(const node_t *node1, const node_t *node2)
  949. {
  950. const or_options_t *options = get_options();
  951. /* Are they in the same family because of their addresses? */
  952. if (options->EnforceDistinctSubnets) {
  953. tor_addr_t a1, a2;
  954. node_get_addr(node1, &a1);
  955. node_get_addr(node2, &a2);
  956. if (addrs_in_same_network_family(&a1, &a2))
  957. return 1;
  958. }
  959. /* Are they in the same family because the agree they are? */
  960. {
  961. const smartlist_t *f1, *f2;
  962. f1 = node_get_declared_family(node1);
  963. f2 = node_get_declared_family(node2);
  964. if (f1 && f2 &&
  965. node_in_nickname_smartlist(f1, node2) &&
  966. node_in_nickname_smartlist(f2, node1))
  967. return 1;
  968. }
  969. /* Are they in the same option because the user says they are? */
  970. if (options->NodeFamilySets) {
  971. SMARTLIST_FOREACH(options->NodeFamilySets, const routerset_t *, rs, {
  972. if (routerset_contains_node(rs, node1) &&
  973. routerset_contains_node(rs, node2))
  974. return 1;
  975. });
  976. }
  977. return 0;
  978. }
  979. /**
  980. * Add all the family of <b>node</b>, including <b>node</b> itself, to
  981. * the smartlist <b>sl</b>.
  982. *
  983. * This is used to make sure we don't pick siblings in a single path, or
  984. * pick more than one relay from a family for our entry guard list.
  985. * Note that a node may be added to <b>sl</b> more than once if it is
  986. * part of <b>node</b>'s family for more than one reason.
  987. */
  988. void
  989. nodelist_add_node_and_family(smartlist_t *sl, const node_t *node)
  990. {
  991. const smartlist_t *all_nodes = nodelist_get_list();
  992. const smartlist_t *declared_family;
  993. const or_options_t *options = get_options();
  994. tor_assert(node);
  995. declared_family = node_get_declared_family(node);
  996. /* Let's make sure that we have the node itself, if it's a real node. */
  997. {
  998. const node_t *real_node = node_get_by_id(node->identity);
  999. if (real_node)
  1000. smartlist_add(sl, (node_t*)real_node);
  1001. }
  1002. /* First, add any nodes with similar network addresses. */
  1003. if (options->EnforceDistinctSubnets) {
  1004. tor_addr_t node_addr;
  1005. node_get_addr(node, &node_addr);
  1006. SMARTLIST_FOREACH_BEGIN(all_nodes, const node_t *, node2) {
  1007. tor_addr_t a;
  1008. node_get_addr(node2, &a);
  1009. if (addrs_in_same_network_family(&a, &node_addr))
  1010. smartlist_add(sl, (void*)node2);
  1011. } SMARTLIST_FOREACH_END(node2);
  1012. }
  1013. /* Now, add all nodes in the declared_family of this node, if they
  1014. * also declare this node to be in their family. */
  1015. if (declared_family) {
  1016. /* Add every r such that router declares familyness with node, and node
  1017. * declares familyhood with router. */
  1018. SMARTLIST_FOREACH_BEGIN(declared_family, const char *, name) {
  1019. const node_t *node2;
  1020. const smartlist_t *family2;
  1021. if (!(node2 = node_get_by_nickname(name, 0)))
  1022. continue;
  1023. if (!(family2 = node_get_declared_family(node2)))
  1024. continue;
  1025. SMARTLIST_FOREACH_BEGIN(family2, const char *, name2) {
  1026. if (node_nickname_matches(node, name2)) {
  1027. smartlist_add(sl, (void*)node2);
  1028. break;
  1029. }
  1030. } SMARTLIST_FOREACH_END(name2);
  1031. } SMARTLIST_FOREACH_END(name);
  1032. }
  1033. /* If the user declared any families locally, honor those too. */
  1034. if (options->NodeFamilySets) {
  1035. SMARTLIST_FOREACH(options->NodeFamilySets, const routerset_t *, rs, {
  1036. if (routerset_contains_node(rs, node)) {
  1037. routerset_get_all_nodes(sl, rs, NULL, 0);
  1038. }
  1039. });
  1040. }
  1041. }
  1042. /** Find a router that's up, that has this IP address, and
  1043. * that allows exit to this address:port, or return NULL if there
  1044. * isn't a good one.
  1045. * Don't exit enclave to excluded relays -- it wouldn't actually
  1046. * hurt anything, but this way there are fewer confused users.
  1047. */
  1048. const node_t *
  1049. router_find_exact_exit_enclave(const char *address, uint16_t port)
  1050. {/*XXXX MOVE*/
  1051. uint32_t addr;
  1052. struct in_addr in;
  1053. tor_addr_t a;
  1054. const or_options_t *options = get_options();
  1055. if (!tor_inet_aton(address, &in))
  1056. return NULL; /* it's not an IP already */
  1057. addr = ntohl(in.s_addr);
  1058. tor_addr_from_ipv4h(&a, addr);
  1059. SMARTLIST_FOREACH(nodelist_get_list(), const node_t *, node, {
  1060. if (node_get_addr_ipv4h(node) == addr &&
  1061. node->is_running &&
  1062. compare_tor_addr_to_node_policy(&a, port, node) ==
  1063. ADDR_POLICY_ACCEPTED &&
  1064. !routerset_contains_node(options->ExcludeExitNodesUnion_, node))
  1065. return node;
  1066. });
  1067. return NULL;
  1068. }
  1069. /** Return 1 if <b>router</b> is not suitable for these parameters, else 0.
  1070. * If <b>need_uptime</b> is non-zero, we require a minimum uptime.
  1071. * If <b>need_capacity</b> is non-zero, we require a minimum advertised
  1072. * bandwidth.
  1073. * If <b>need_guard</b>, we require that the router is a possible entry guard.
  1074. */
  1075. int
  1076. node_is_unreliable(const node_t *node, int need_uptime,
  1077. int need_capacity, int need_guard)
  1078. {
  1079. if (need_uptime && !node->is_stable)
  1080. return 1;
  1081. if (need_capacity && !node->is_fast)
  1082. return 1;
  1083. if (need_guard && !node->is_possible_guard)
  1084. return 1;
  1085. return 0;
  1086. }
  1087. /** Return 1 if all running sufficiently-stable routers we can use will reject
  1088. * addr:port. Return 0 if any might accept it. */
  1089. int
  1090. router_exit_policy_all_nodes_reject(const tor_addr_t *addr, uint16_t port,
  1091. int need_uptime)
  1092. {
  1093. addr_policy_result_t r;
  1094. SMARTLIST_FOREACH_BEGIN(nodelist_get_list(), const node_t *, node) {
  1095. if (node->is_running &&
  1096. !node_is_unreliable(node, need_uptime, 0, 0)) {
  1097. r = compare_tor_addr_to_node_policy(addr, port, node);
  1098. if (r != ADDR_POLICY_REJECTED && r != ADDR_POLICY_PROBABLY_REJECTED)
  1099. return 0; /* this one could be ok. good enough. */
  1100. }
  1101. } SMARTLIST_FOREACH_END(node);
  1102. return 1; /* all will reject. */
  1103. }
  1104. /** Mark the router with ID <b>digest</b> as running or non-running
  1105. * in our routerlist. */
  1106. void
  1107. router_set_status(const char *digest, int up)
  1108. {
  1109. node_t *node;
  1110. tor_assert(digest);
  1111. SMARTLIST_FOREACH(router_get_fallback_dir_servers(),
  1112. dir_server_t *, d,
  1113. if (tor_memeq(d->digest, digest, DIGEST_LEN))
  1114. d->is_running = up);
  1115. SMARTLIST_FOREACH(router_get_trusted_dir_servers(),
  1116. dir_server_t *, d,
  1117. if (tor_memeq(d->digest, digest, DIGEST_LEN))
  1118. d->is_running = up);
  1119. node = node_get_mutable_by_id(digest);
  1120. if (node) {
  1121. #if 0
  1122. log_debug(LD_DIR,"Marking router %s as %s.",
  1123. node_describe(node), up ? "up" : "down");
  1124. #endif
  1125. if (!up && node_is_me(node) && !net_is_disabled())
  1126. log_warn(LD_NET, "We just marked ourself as down. Are your external "
  1127. "addresses reachable?");
  1128. if (bool_neq(node->is_running, up))
  1129. router_dir_info_changed();
  1130. node->is_running = up;
  1131. }
  1132. }
  1133. /** True iff, the last time we checked whether we had enough directory info
  1134. * to build circuits, the answer was "yes". If there are no exits in the
  1135. * consensus, we act as if we have 100% of the exit directory info. */
  1136. static int have_min_dir_info = 0;
  1137. /** Does the consensus contain nodes that can exit? */
  1138. static consensus_path_type_t have_consensus_path = CONSENSUS_PATH_UNKNOWN;
  1139. /** True iff enough has changed since the last time we checked whether we had
  1140. * enough directory info to build circuits that our old answer can no longer
  1141. * be trusted. */
  1142. static int need_to_update_have_min_dir_info = 1;
  1143. /** String describing what we're missing before we have enough directory
  1144. * info. */
  1145. static char dir_info_status[512] = "";
  1146. /** Return true iff we have enough consensus information to
  1147. * start building circuits. Right now, this means "a consensus that's
  1148. * less than a day old, and at least 60% of router descriptors (configurable),
  1149. * weighted by bandwidth. Treat the exit fraction as 100% if there are
  1150. * no exits in the consensus."
  1151. * To obtain the final weighted bandwidth, we multiply the
  1152. * weighted bandwidth fraction for each position (guard, middle, exit). */
  1153. int
  1154. router_have_minimum_dir_info(void)
  1155. {
  1156. static int logged_delay=0;
  1157. const char *delay_fetches_msg = NULL;
  1158. if (should_delay_dir_fetches(get_options(), &delay_fetches_msg)) {
  1159. if (!logged_delay)
  1160. log_notice(LD_DIR, "Delaying directory fetches: %s", delay_fetches_msg);
  1161. logged_delay=1;
  1162. strlcpy(dir_info_status, delay_fetches_msg, sizeof(dir_info_status));
  1163. return 0;
  1164. }
  1165. logged_delay = 0; /* reset it if we get this far */
  1166. if (PREDICT_UNLIKELY(need_to_update_have_min_dir_info)) {
  1167. update_router_have_minimum_dir_info();
  1168. }
  1169. return have_min_dir_info;
  1170. }
  1171. /** Set to CONSENSUS_PATH_EXIT if there is at least one exit node
  1172. * in the consensus. We update this flag in compute_frac_paths_available if
  1173. * there is at least one relay that has an Exit flag in the consensus.
  1174. * Used to avoid building exit circuits when they will almost certainly fail.
  1175. * Set to CONSENSUS_PATH_INTERNAL if there are no exits in the consensus.
  1176. * (This situation typically occurs during bootstrap of a test network.)
  1177. * Set to CONSENSUS_PATH_UNKNOWN if we have never checked, or have
  1178. * reason to believe our last known value was invalid or has expired.
  1179. * If we're in a network with TestingDirAuthVoteExit set,
  1180. * this can cause router_have_consensus_path() to be set to
  1181. * CONSENSUS_PATH_EXIT, even if there are no nodes with accept exit policies.
  1182. */
  1183. consensus_path_type_t
  1184. router_have_consensus_path(void)
  1185. {
  1186. return have_consensus_path;
  1187. }
  1188. /** Called when our internal view of the directory has changed. This can be
  1189. * when the authorities change, networkstatuses change, the list of routerdescs
  1190. * changes, or number of running routers changes.
  1191. */
  1192. void
  1193. router_dir_info_changed(void)
  1194. {
  1195. need_to_update_have_min_dir_info = 1;
  1196. rend_hsdir_routers_changed();
  1197. }
  1198. /** Return a string describing what we're missing before we have enough
  1199. * directory info. */
  1200. const char *
  1201. get_dir_info_status_string(void)
  1202. {
  1203. return dir_info_status;
  1204. }
  1205. /** Iterate over the servers listed in <b>consensus</b>, and count how many of
  1206. * them seem like ones we'd use (store this in *<b>num_usable</b>), and how
  1207. * many of <em>those</em> we have descriptors for (store this in
  1208. * *<b>num_present</b>).
  1209. *
  1210. * If <b>in_set</b> is non-NULL, only consider those routers in <b>in_set</b>.
  1211. * If <b>exit_only</b> is USABLE_DESCRIPTOR_EXIT_ONLY, only consider nodes
  1212. * with the Exit flag.
  1213. * If *<b>descs_out</b> is present, add a node_t for each usable descriptor
  1214. * to it.
  1215. */
  1216. static void
  1217. count_usable_descriptors(int *num_present, int *num_usable,
  1218. smartlist_t *descs_out,
  1219. const networkstatus_t *consensus,
  1220. const or_options_t *options, time_t now,
  1221. routerset_t *in_set,
  1222. usable_descriptor_t exit_only)
  1223. {
  1224. const int md = (consensus->flavor == FLAV_MICRODESC);
  1225. *num_present = 0, *num_usable = 0;
  1226. SMARTLIST_FOREACH_BEGIN(consensus->routerstatus_list, routerstatus_t *, rs)
  1227. {
  1228. const node_t *node = node_get_by_id(rs->identity_digest);
  1229. if (!node)
  1230. continue; /* This would be a bug: every entry in the consensus is
  1231. * supposed to have a node. */
  1232. if (exit_only == USABLE_DESCRIPTOR_EXIT_ONLY && ! rs->is_exit)
  1233. continue;
  1234. if (in_set && ! routerset_contains_routerstatus(in_set, rs, -1))
  1235. continue;
  1236. if (client_would_use_router(rs, now, options)) {
  1237. const char * const digest = rs->descriptor_digest;
  1238. int present;
  1239. ++*num_usable; /* the consensus says we want it. */
  1240. if (md)
  1241. present = NULL != microdesc_cache_lookup_by_digest256(NULL, digest);
  1242. else
  1243. present = NULL != router_get_by_descriptor_digest(digest);
  1244. if (present) {
  1245. /* we have the descriptor listed in the consensus. */
  1246. ++*num_present;
  1247. }
  1248. if (descs_out)
  1249. smartlist_add(descs_out, (node_t*)node);
  1250. }
  1251. }
  1252. SMARTLIST_FOREACH_END(rs);
  1253. log_debug(LD_DIR, "%d usable, %d present (%s%s).",
  1254. *num_usable, *num_present,
  1255. md ? "microdesc" : "desc",
  1256. exit_only == USABLE_DESCRIPTOR_EXIT_ONLY ? " exits" : "s");
  1257. }
  1258. /** Return an estimate of which fraction of usable paths through the Tor
  1259. * network we have available for use. Count how many routers seem like ones
  1260. * we'd use (store this in *<b>num_usable_out</b>), and how many of
  1261. * <em>those</em> we have descriptors for (store this in
  1262. * *<b>num_present_out</b>.)
  1263. *
  1264. * If **<b>status_out</b> is present, allocate a new string and print the
  1265. * available percentages of guard, middle, and exit nodes to it, noting
  1266. * whether there are exits in the consensus.
  1267. * If there are no guards in the consensus,
  1268. * we treat the exit fraction as 100%.
  1269. */
  1270. static double
  1271. compute_frac_paths_available(const networkstatus_t *consensus,
  1272. const or_options_t *options, time_t now,
  1273. int *num_present_out, int *num_usable_out,
  1274. char **status_out)
  1275. {
  1276. smartlist_t *guards = smartlist_new();
  1277. smartlist_t *mid = smartlist_new();
  1278. smartlist_t *exits = smartlist_new();
  1279. double f_guard, f_mid, f_exit;
  1280. double f_path = 0.0;
  1281. /* Used to determine whether there are any exits in the consensus */
  1282. int np = 0;
  1283. /* Used to determine whether there are any exits with descriptors */
  1284. int nu = 0;
  1285. const int authdir = authdir_mode_v3(options);
  1286. count_usable_descriptors(num_present_out, num_usable_out,
  1287. mid, consensus, options, now, NULL,
  1288. USABLE_DESCRIPTOR_ALL);
  1289. if (options->EntryNodes) {
  1290. count_usable_descriptors(&np, &nu, guards, consensus, options, now,
  1291. options->EntryNodes, USABLE_DESCRIPTOR_ALL);
  1292. } else {
  1293. SMARTLIST_FOREACH(mid, const node_t *, node, {
  1294. if (authdir) {
  1295. if (node->rs && node->rs->is_possible_guard)
  1296. smartlist_add(guards, (node_t*)node);
  1297. } else {
  1298. if (node->is_possible_guard)
  1299. smartlist_add(guards, (node_t*)node);
  1300. }
  1301. });
  1302. }
  1303. /* All nodes with exit flag
  1304. * If we're in a network with TestingDirAuthVoteExit set,
  1305. * this can cause false positives on have_consensus_path,
  1306. * incorrectly setting it to CONSENSUS_PATH_EXIT. This is
  1307. * an unavoidable feature of forcing authorities to declare
  1308. * certain nodes as exits.
  1309. */
  1310. count_usable_descriptors(&np, &nu, exits, consensus, options, now,
  1311. NULL, USABLE_DESCRIPTOR_EXIT_ONLY);
  1312. log_debug(LD_NET,
  1313. "%s: %d present, %d usable",
  1314. "exits",
  1315. np,
  1316. nu);
  1317. /* We need at least 1 exit present in the consensus to consider
  1318. * building exit paths */
  1319. /* Update our understanding of whether the consensus has exits */
  1320. consensus_path_type_t old_have_consensus_path = have_consensus_path;
  1321. have_consensus_path = ((nu > 0) ?
  1322. CONSENSUS_PATH_EXIT :
  1323. CONSENSUS_PATH_INTERNAL);
  1324. if (have_consensus_path == CONSENSUS_PATH_INTERNAL
  1325. && old_have_consensus_path != have_consensus_path) {
  1326. log_notice(LD_NET,
  1327. "The current consensus has no exit nodes. "
  1328. "Tor can only build internal paths, "
  1329. "such as paths to hidden services.");
  1330. /* However, exit nodes can reachability self-test using this consensus,
  1331. * join the network, and appear in a later consensus. This will allow
  1332. * the network to build exit paths, such as paths for world wide web
  1333. * browsing (as distinct from hidden service web browsing). */
  1334. }
  1335. f_guard = frac_nodes_with_descriptors(guards, WEIGHT_FOR_GUARD);
  1336. f_mid = frac_nodes_with_descriptors(mid, WEIGHT_FOR_MID);
  1337. f_exit = frac_nodes_with_descriptors(exits, WEIGHT_FOR_EXIT);
  1338. log_debug(LD_NET,
  1339. "f_guard: %.2f, f_mid: %.2f, f_exit: %.2f",
  1340. f_guard,
  1341. f_mid,
  1342. f_exit);
  1343. smartlist_free(guards);
  1344. smartlist_free(mid);
  1345. smartlist_free(exits);
  1346. if (options->ExitNodes) {
  1347. double f_myexit, f_myexit_unflagged;
  1348. smartlist_t *myexits= smartlist_new();
  1349. smartlist_t *myexits_unflagged = smartlist_new();
  1350. /* All nodes with exit flag in ExitNodes option */
  1351. count_usable_descriptors(&np, &nu, myexits, consensus, options, now,
  1352. options->ExitNodes, USABLE_DESCRIPTOR_EXIT_ONLY);
  1353. log_debug(LD_NET,
  1354. "%s: %d present, %d usable",
  1355. "myexits",
  1356. np,
  1357. nu);
  1358. /* Now compute the nodes in the ExitNodes option where which we don't know
  1359. * what their exit policy is, or we know it permits something. */
  1360. count_usable_descriptors(&np, &nu, myexits_unflagged,
  1361. consensus, options, now,
  1362. options->ExitNodes, USABLE_DESCRIPTOR_ALL);
  1363. log_debug(LD_NET,
  1364. "%s: %d present, %d usable",
  1365. "myexits_unflagged (initial)",
  1366. np,
  1367. nu);
  1368. SMARTLIST_FOREACH_BEGIN(myexits_unflagged, const node_t *, node) {
  1369. if (node_has_descriptor(node) && node_exit_policy_rejects_all(node)) {
  1370. SMARTLIST_DEL_CURRENT(myexits_unflagged, node);
  1371. /* this node is not actually an exit */
  1372. np--;
  1373. /* this node is unusable as an exit */
  1374. nu--;
  1375. }
  1376. } SMARTLIST_FOREACH_END(node);
  1377. log_debug(LD_NET,
  1378. "%s: %d present, %d usable",
  1379. "myexits_unflagged (final)",
  1380. np,
  1381. nu);
  1382. f_myexit= frac_nodes_with_descriptors(myexits,WEIGHT_FOR_EXIT);
  1383. f_myexit_unflagged=
  1384. frac_nodes_with_descriptors(myexits_unflagged,WEIGHT_FOR_EXIT);
  1385. log_debug(LD_NET,
  1386. "f_exit: %.2f, f_myexit: %.2f, f_myexit_unflagged: %.2f",
  1387. f_exit,
  1388. f_myexit,
  1389. f_myexit_unflagged);
  1390. /* If our ExitNodes list has eliminated every possible Exit node, and there
  1391. * were some possible Exit nodes, then instead consider nodes that permit
  1392. * exiting to some ports. */
  1393. if (smartlist_len(myexits) == 0 &&
  1394. smartlist_len(myexits_unflagged)) {
  1395. f_myexit = f_myexit_unflagged;
  1396. }
  1397. smartlist_free(myexits);
  1398. smartlist_free(myexits_unflagged);
  1399. /* This is a tricky point here: we don't want to make it easy for a
  1400. * directory to trickle exits to us until it learns which exits we have
  1401. * configured, so require that we have a threshold both of total exits
  1402. * and usable exits. */
  1403. if (f_myexit < f_exit)
  1404. f_exit = f_myexit;
  1405. }
  1406. /* if the consensus has no exits, treat the exit fraction as 100% */
  1407. if (router_have_consensus_path() != CONSENSUS_PATH_EXIT) {
  1408. f_exit = 1.0;
  1409. }
  1410. f_path = f_guard * f_mid * f_exit;
  1411. if (status_out)
  1412. tor_asprintf(status_out,
  1413. "%d%% of guards bw, "
  1414. "%d%% of midpoint bw, and "
  1415. "%d%% of exit bw%s = "
  1416. "%d%% of path bw",
  1417. (int)(f_guard*100),
  1418. (int)(f_mid*100),
  1419. (int)(f_exit*100),
  1420. (router_have_consensus_path() == CONSENSUS_PATH_EXIT ?
  1421. "" :
  1422. " (no exits in consensus)"),
  1423. (int)(f_path*100));
  1424. return f_path;
  1425. }
  1426. /** We just fetched a new set of descriptors. Compute how far through
  1427. * the "loading descriptors" bootstrapping phase we are, so we can inform
  1428. * the controller of our progress. */
  1429. int
  1430. count_loading_descriptors_progress(void)
  1431. {
  1432. int num_present = 0, num_usable=0;
  1433. time_t now = time(NULL);
  1434. const or_options_t *options = get_options();
  1435. const networkstatus_t *consensus =
  1436. networkstatus_get_reasonably_live_consensus(now,usable_consensus_flavor());
  1437. double paths, fraction;
  1438. if (!consensus)
  1439. return 0; /* can't count descriptors if we have no list of them */
  1440. paths = compute_frac_paths_available(consensus, options, now,
  1441. &num_present, &num_usable,
  1442. NULL);
  1443. fraction = paths / get_frac_paths_needed_for_circs(options,consensus);
  1444. if (fraction > 1.0)
  1445. return 0; /* it's not the number of descriptors holding us back */
  1446. return BOOTSTRAP_STATUS_LOADING_DESCRIPTORS + (int)
  1447. (fraction*(BOOTSTRAP_STATUS_CONN_OR-1 -
  1448. BOOTSTRAP_STATUS_LOADING_DESCRIPTORS));
  1449. }
  1450. /** Return the fraction of paths needed before we're willing to build
  1451. * circuits, as configured in <b>options</b>, or in the consensus <b>ns</b>. */
  1452. static double
  1453. get_frac_paths_needed_for_circs(const or_options_t *options,
  1454. const networkstatus_t *ns)
  1455. {
  1456. #define DFLT_PCT_USABLE_NEEDED 60
  1457. if (options->PathsNeededToBuildCircuits >= 0.0) {
  1458. return options->PathsNeededToBuildCircuits;
  1459. } else {
  1460. return networkstatus_get_param(ns, "min_paths_for_circs_pct",
  1461. DFLT_PCT_USABLE_NEEDED,
  1462. 25, 95)/100.0;
  1463. }
  1464. }
  1465. /** Change the value of have_min_dir_info, setting it true iff we have enough
  1466. * network and router information to build circuits. Clear the value of
  1467. * need_to_update_have_min_dir_info. */
  1468. static void
  1469. update_router_have_minimum_dir_info(void)
  1470. {
  1471. time_t now = time(NULL);
  1472. int res;
  1473. const or_options_t *options = get_options();
  1474. const networkstatus_t *consensus =
  1475. networkstatus_get_reasonably_live_consensus(now,usable_consensus_flavor());
  1476. int using_md;
  1477. if (!consensus) {
  1478. if (!networkstatus_get_latest_consensus())
  1479. strlcpy(dir_info_status, "We have no usable consensus.",
  1480. sizeof(dir_info_status));
  1481. else
  1482. strlcpy(dir_info_status, "We have no recent usable consensus.",
  1483. sizeof(dir_info_status));
  1484. res = 0;
  1485. goto done;
  1486. }
  1487. using_md = consensus->flavor == FLAV_MICRODESC;
  1488. /* Check fraction of available paths */
  1489. {
  1490. char *status = NULL;
  1491. int num_present=0, num_usable=0;
  1492. double paths = compute_frac_paths_available(consensus, options, now,
  1493. &num_present, &num_usable,
  1494. &status);
  1495. if (paths < get_frac_paths_needed_for_circs(options,consensus)) {
  1496. tor_snprintf(dir_info_status, sizeof(dir_info_status),
  1497. "We need more %sdescriptors: we have %d/%d, and "
  1498. "can only build %d%% of likely paths. (We have %s.)",
  1499. using_md?"micro":"", num_present, num_usable,
  1500. (int)(paths*100), status);
  1501. tor_free(status);
  1502. res = 0;
  1503. control_event_bootstrap(BOOTSTRAP_STATUS_REQUESTING_DESCRIPTORS, 0);
  1504. goto done;
  1505. }
  1506. tor_free(status);
  1507. res = 1;
  1508. }
  1509. done:
  1510. /* If paths have just become available in this update. */
  1511. if (res && !have_min_dir_info) {
  1512. control_event_client_status(LOG_NOTICE, "ENOUGH_DIR_INFO");
  1513. if (control_event_bootstrap(BOOTSTRAP_STATUS_CONN_OR, 0) == 0) {
  1514. log_notice(LD_DIR,
  1515. "We now have enough directory information to build circuits.");
  1516. }
  1517. }
  1518. /* If paths have just become unavailable in this update. */
  1519. if (!res && have_min_dir_info) {
  1520. int quiet = directory_too_idle_to_fetch_descriptors(options, now);
  1521. tor_log(quiet ? LOG_INFO : LOG_NOTICE, LD_DIR,
  1522. "Our directory information is no longer up-to-date "
  1523. "enough to build circuits: %s", dir_info_status);
  1524. /* a) make us log when we next complete a circuit, so we know when Tor
  1525. * is back up and usable, and b) disable some activities that Tor
  1526. * should only do while circuits are working, like reachability tests
  1527. * and fetching bridge descriptors only over circuits. */
  1528. note_that_we_maybe_cant_complete_circuits();
  1529. have_consensus_path = CONSENSUS_PATH_UNKNOWN;
  1530. control_event_client_status(LOG_NOTICE, "NOT_ENOUGH_DIR_INFO");
  1531. }
  1532. have_min_dir_info = res;
  1533. need_to_update_have_min_dir_info = 0;
  1534. }