dirvote.h 8.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247
  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-2018, The Tor Project, Inc. */
  5. /* See LICENSE for licensing information */
  6. /**
  7. * \file dirvote.h
  8. * \brief Header file for dirvote.c.
  9. **/
  10. #ifndef TOR_DIRVOTE_H
  11. #define TOR_DIRVOTE_H
  12. /*
  13. * Ideally, assuming synced clocks, we should only need 1 second for each of:
  14. * - Vote
  15. * - Distribute
  16. * - Consensus Publication
  17. * As we can gather descriptors continuously.
  18. * (Could we even go as far as publishing the previous consensus,
  19. * in the same second that we vote for the next one?)
  20. * But we're not there yet: these are the lowest working values at this time.
  21. */
  22. /** Lowest allowable value for VoteSeconds. */
  23. #define MIN_VOTE_SECONDS 2
  24. /** Lowest allowable value for VoteSeconds when TestingTorNetwork is 1 */
  25. #define MIN_VOTE_SECONDS_TESTING 2
  26. /** Lowest allowable value for DistSeconds. */
  27. #define MIN_DIST_SECONDS 2
  28. /** Lowest allowable value for DistSeconds when TestingTorNetwork is 1 */
  29. #define MIN_DIST_SECONDS_TESTING 2
  30. /** Lowest allowable voting interval. */
  31. #define MIN_VOTE_INTERVAL 300
  32. /** Lowest allowable voting interval when TestingTorNetwork is 1:
  33. * Voting Interval can be:
  34. * 10, 12, 15, 18, 20, 24, 25, 30, 36, 40, 45, 50, 60, ...
  35. * Testing Initial Voting Interval can be:
  36. * 5, 6, 8, 9, or any of the possible values for Voting Interval,
  37. * as they both need to evenly divide 30 minutes.
  38. * If clock desynchronisation is an issue, use an interval of at least:
  39. * 18 * drift in seconds, to allow for a clock slop factor */
  40. #define MIN_VOTE_INTERVAL_TESTING \
  41. (((MIN_VOTE_SECONDS_TESTING)+(MIN_DIST_SECONDS_TESTING)+1)*2)
  42. #define MIN_VOTE_INTERVAL_TESTING_INITIAL \
  43. ((MIN_VOTE_SECONDS_TESTING)+(MIN_DIST_SECONDS_TESTING)+1)
  44. /* A placeholder for routerstatus_format_entry() when the consensus method
  45. * argument is not applicable. */
  46. #define ROUTERSTATUS_FORMAT_NO_CONSENSUS_METHOD 0
  47. /** The lowest consensus method that we currently support. */
  48. #define MIN_SUPPORTED_CONSENSUS_METHOD 25
  49. /** The highest consensus method that we currently support. */
  50. #define MAX_SUPPORTED_CONSENSUS_METHOD 28
  51. /** Lowest consensus method where authorities vote on required/recommended
  52. * protocols. */
  53. #define MIN_METHOD_FOR_RECOMMENDED_PROTOCOLS 25
  54. /** Lowest consensus method where authorities add protocols to routerstatus
  55. * entries. */
  56. #define MIN_METHOD_FOR_RS_PROTOCOLS 25
  57. /** Lowest consensus method where authorities initialize bandwidth weights to 1
  58. * instead of 0. See #14881 */
  59. #define MIN_METHOD_FOR_INIT_BW_WEIGHTS_ONE 26
  60. /** Lowest consensus method where the microdesc consensus contains relay IPv6
  61. * addresses. See #23826 and #20916. */
  62. #define MIN_METHOD_FOR_A_LINES_IN_MICRODESC_CONSENSUS 27
  63. /** Lowest consensus method where microdescriptors do not contain relay IPv6
  64. * addresses. See #23828 and #20916. */
  65. #define MIN_METHOD_FOR_NO_A_LINES_IN_MICRODESC 28
  66. /** Default bandwidth to clip unmeasured bandwidths to using method >=
  67. * MIN_METHOD_TO_CLIP_UNMEASURED_BW. (This is not a consensus method; do not
  68. * get confused with the above macros.) */
  69. #define DEFAULT_MAX_UNMEASURED_BW_KB 20
  70. /* Directory Get Vote (DGV) flags for dirvote_get_vote(). */
  71. #define DGV_BY_ID 1
  72. #define DGV_INCLUDE_PENDING 2
  73. #define DGV_INCLUDE_PREVIOUS 4
  74. /*
  75. * Public API. Used outside of the dirauth subsystem.
  76. *
  77. * We need to nullify them if the module is disabled.
  78. */
  79. #ifdef HAVE_MODULE_DIRAUTH
  80. time_t dirvote_act(const or_options_t *options, time_t now);
  81. void dirvote_free_all(void);
  82. void dirvote_parse_sr_commits(networkstatus_t *ns, const smartlist_t *tokens);
  83. void dirvote_clear_commits(networkstatus_t *ns);
  84. void dirvote_dirreq_get_status_vote(const char *url, smartlist_t *items,
  85. smartlist_t *dir_items);
  86. /* Storing signatures and votes functions */
  87. struct pending_vote_t * dirvote_add_vote(const char *vote_body,
  88. const char **msg_out,
  89. int *status_out);
  90. int dirvote_add_signatures(const char *detached_signatures_body,
  91. const char *source,
  92. const char **msg_out);
  93. #else /* HAVE_MODULE_DIRAUTH */
  94. static inline time_t
  95. dirvote_act(const or_options_t *options, time_t now)
  96. {
  97. (void) options;
  98. (void) now;
  99. return TIME_MAX;
  100. }
  101. static inline void
  102. dirvote_free_all(void)
  103. {
  104. }
  105. static inline void
  106. dirvote_parse_sr_commits(networkstatus_t *ns, const smartlist_t *tokens)
  107. {
  108. (void) ns;
  109. (void) tokens;
  110. }
  111. static inline void
  112. dirvote_clear_commits(networkstatus_t *ns)
  113. {
  114. (void) ns;
  115. }
  116. static inline void
  117. dirvote_dirreq_get_status_vote(const char *url, smartlist_t *items,
  118. smartlist_t *dir_items)
  119. {
  120. (void) url;
  121. (void) items;
  122. (void) dir_items;
  123. }
  124. static inline struct pending_vote_t *
  125. dirvote_add_vote(const char *vote_body, const char **msg_out, int *status_out)
  126. {
  127. (void) vote_body;
  128. /* If the dirauth module is disabled, this should NEVER be called else we
  129. * failed to safeguard the dirauth module. */
  130. tor_assert_nonfatal_unreached();
  131. /* We need to send out an error code. */
  132. *status_out = 400;
  133. *msg_out = "No directory authority support";
  134. return NULL;
  135. }
  136. static inline int
  137. dirvote_add_signatures(const char *detached_signatures_body,
  138. const char *source,
  139. const char **msg_out)
  140. {
  141. (void) detached_signatures_body;
  142. (void) source;
  143. (void) msg_out;
  144. /* If the dirauth module is disabled, this should NEVER be called else we
  145. * failed to safeguard the dirauth module. */
  146. tor_assert_nonfatal_unreached();
  147. return 0;
  148. }
  149. #endif /* HAVE_MODULE_DIRAUTH */
  150. /* Item access */
  151. MOCK_DECL(const char*, dirvote_get_pending_consensus,
  152. (consensus_flavor_t flav));
  153. MOCK_DECL(const char*, dirvote_get_pending_detached_signatures, (void));
  154. const cached_dir_t *dirvote_get_vote(const char *fp, int flags);
  155. /*
  156. * API used _only_ by the dirauth subsystem.
  157. */
  158. void set_routerstatus_from_routerinfo(routerstatus_t *rs,
  159. node_t *node,
  160. routerinfo_t *ri, time_t now,
  161. int listbadexits);
  162. networkstatus_t *
  163. dirserv_generate_networkstatus_vote_obj(crypto_pk_t *private_key,
  164. authority_cert_t *cert);
  165. vote_microdesc_hash_t *dirvote_format_all_microdesc_vote_lines(
  166. const routerinfo_t *ri,
  167. time_t now,
  168. smartlist_t *microdescriptors_out);
  169. /*
  170. * Exposed functions for unit tests.
  171. */
  172. #ifdef DIRVOTE_PRIVATE
  173. /* Cert manipulation */
  174. STATIC authority_cert_t *authority_cert_dup(authority_cert_t *cert);
  175. STATIC int32_t dirvote_get_intermediate_param_value(
  176. const smartlist_t *param_list,
  177. const char *keyword,
  178. int32_t default_val);
  179. STATIC char *format_networkstatus_vote(crypto_pk_t *private_key,
  180. networkstatus_t *v3_ns);
  181. STATIC smartlist_t *dirvote_compute_params(smartlist_t *votes, int method,
  182. int total_authorities);
  183. STATIC char *compute_consensus_package_lines(smartlist_t *votes);
  184. STATIC char *make_consensus_method_list(int low, int high, const char *sep);
  185. STATIC int
  186. networkstatus_compute_bw_weights_v10(smartlist_t *chunks, int64_t G,
  187. int64_t M, int64_t E, int64_t D,
  188. int64_t T, int64_t weight_scale);
  189. STATIC
  190. char *networkstatus_compute_consensus(smartlist_t *votes,
  191. int total_authorities,
  192. crypto_pk_t *identity_key,
  193. crypto_pk_t *signing_key,
  194. const char *legacy_identity_key_digest,
  195. crypto_pk_t *legacy_signing_key,
  196. consensus_flavor_t flavor);
  197. STATIC
  198. int networkstatus_add_detached_signatures(networkstatus_t *target,
  199. ns_detached_signatures_t *sigs,
  200. const char *source,
  201. int severity,
  202. const char **msg_out);
  203. STATIC
  204. char *networkstatus_get_detached_signatures(smartlist_t *consensuses);
  205. STATIC microdesc_t *dirvote_create_microdescriptor(const routerinfo_t *ri,
  206. int consensus_method);
  207. #endif /* defined(DIRVOTE_PRIVATE) */
  208. #endif /* !defined(TOR_DIRVOTE_H) */