directory.h 6.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139
  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. /**
  7. * \file directory.h
  8. * \brief Header file for directory.c.
  9. **/
  10. #ifndef TOR_DIRECTORY_H
  11. #define TOR_DIRECTORY_H
  12. int directories_have_accepted_server_descriptor(void);
  13. void directory_post_to_dirservers(uint8_t dir_purpose, uint8_t router_purpose,
  14. dirinfo_type_t type, const char *payload,
  15. size_t payload_len, size_t extrainfo_len);
  16. MOCK_DECL(void, directory_get_from_dirserver, (
  17. uint8_t dir_purpose,
  18. uint8_t router_purpose,
  19. const char *resource,
  20. int pds_flags,
  21. download_want_authority_t want_authority));
  22. void directory_get_from_all_authorities(uint8_t dir_purpose,
  23. uint8_t router_purpose,
  24. const char *resource);
  25. /** Enumeration of ways to connect to a directory server */
  26. typedef enum {
  27. /** Default: connect over a one-hop Tor circuit but fall back to direct
  28. * connection */
  29. DIRIND_ONEHOP=0,
  30. /** Connect over a multi-hop anonymizing Tor circuit */
  31. DIRIND_ANONYMOUS=1,
  32. /** Connect to the DirPort directly */
  33. DIRIND_DIRECT_CONN,
  34. /** Connect over a multi-hop anonymizing Tor circuit to our dirport */
  35. DIRIND_ANON_DIRPORT,
  36. } dir_indirection_t;
  37. void directory_initiate_command_routerstatus(const routerstatus_t *status,
  38. uint8_t dir_purpose,
  39. uint8_t router_purpose,
  40. dir_indirection_t indirection,
  41. const char *resource,
  42. const char *payload,
  43. size_t payload_len,
  44. time_t if_modified_since);
  45. void directory_initiate_command_routerstatus_rend(const routerstatus_t *status,
  46. uint8_t dir_purpose,
  47. uint8_t router_purpose,
  48. dir_indirection_t indirection,
  49. const char *resource,
  50. const char *payload,
  51. size_t payload_len,
  52. time_t if_modified_since,
  53. const rend_data_t *rend_query);
  54. int parse_http_response(const char *headers, int *code, time_t *date,
  55. compress_method_t *compression, char **response);
  56. int connection_dir_is_encrypted(dir_connection_t *conn);
  57. int connection_dir_reached_eof(dir_connection_t *conn);
  58. int connection_dir_process_inbuf(dir_connection_t *conn);
  59. int connection_dir_finished_flushing(dir_connection_t *conn);
  60. int connection_dir_finished_connecting(dir_connection_t *conn);
  61. void connection_dir_about_to_close(dir_connection_t *dir_conn);
  62. void directory_initiate_command(const tor_addr_t *addr,
  63. uint16_t or_port, uint16_t dir_port,
  64. const char *digest,
  65. uint8_t dir_purpose, uint8_t router_purpose,
  66. dir_indirection_t indirection,
  67. const char *resource,
  68. const char *payload, size_t payload_len,
  69. time_t if_modified_since);
  70. #define DSR_HEX (1<<0)
  71. #define DSR_BASE64 (1<<1)
  72. #define DSR_DIGEST256 (1<<2)
  73. #define DSR_SORT_UNIQ (1<<3)
  74. int dir_split_resource_into_fingerprints(const char *resource,
  75. smartlist_t *fp_out, int *compressed_out,
  76. int flags);
  77. int dir_split_resource_into_fingerprint_pairs(const char *res,
  78. smartlist_t *pairs_out);
  79. char *directory_dump_request_log(void);
  80. void note_request(const char *key, size_t bytes);
  81. int router_supports_extrainfo(const char *identity_digest, int is_authority);
  82. time_t download_status_increment_failure(download_status_t *dls,
  83. int status_code, const char *item,
  84. int server, time_t now);
  85. /** Increment the failure count of the download_status_t <b>dls</b>, with
  86. * the optional status code <b>sc</b>. */
  87. #define download_status_failed(dls, sc) \
  88. download_status_increment_failure((dls), (sc), NULL, \
  89. get_options()->DirPort_set, time(NULL))
  90. void download_status_reset(download_status_t *dls);
  91. static int download_status_is_ready(download_status_t *dls, time_t now,
  92. int max_failures);
  93. /** Return true iff, as of <b>now</b>, the resource tracked by <b>dls</b> is
  94. * ready to get its download reattempted. */
  95. static INLINE int
  96. download_status_is_ready(download_status_t *dls, time_t now,
  97. int max_failures)
  98. {
  99. return (dls->n_download_failures <= max_failures
  100. && dls->next_attempt_at <= now);
  101. }
  102. static void download_status_mark_impossible(download_status_t *dl);
  103. /** Mark <b>dl</b> as never downloadable. */
  104. static INLINE void
  105. download_status_mark_impossible(download_status_t *dl)
  106. {
  107. dl->n_download_failures = IMPOSSIBLE_TO_DOWNLOAD;
  108. }
  109. int download_status_get_n_failures(const download_status_t *dls);
  110. #ifdef TOR_UNIT_TESTS
  111. /* Used only by directory.c and test_dir.c */
  112. STATIC int parse_http_url(const char *headers, char **url);
  113. STATIC int purpose_needs_anonymity(uint8_t dir_purpose,
  114. uint8_t router_purpose);
  115. STATIC dirinfo_type_t dir_fetch_type(int dir_purpose, int router_purpose,
  116. const char *resource);
  117. STATIC int directory_handle_command_get(dir_connection_t *conn,
  118. const char *headers,
  119. const char *req_body,
  120. size_t req_body_len);
  121. #endif
  122. #endif