connection_edge.h 8.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197
  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 connection_edge.h
  8. * \brief Header file for connection_edge.c.
  9. **/
  10. #ifndef TOR_CONNECTION_EDGE_H
  11. #define TOR_CONNECTION_EDGE_H
  12. #include "testsupport.h"
  13. #define connection_mark_unattached_ap(conn, endreason) \
  14. connection_mark_unattached_ap_((conn), (endreason), __LINE__, SHORT_FILE__)
  15. MOCK_DECL(void,connection_mark_unattached_ap_,
  16. (entry_connection_t *conn, int endreason,
  17. int line, const char *file));
  18. int connection_edge_reached_eof(edge_connection_t *conn);
  19. int connection_edge_process_inbuf(edge_connection_t *conn,
  20. int package_partial);
  21. int connection_edge_destroy(circid_t circ_id, edge_connection_t *conn);
  22. int connection_edge_end(edge_connection_t *conn, uint8_t reason);
  23. int connection_edge_end_errno(edge_connection_t *conn);
  24. int connection_edge_flushed_some(edge_connection_t *conn);
  25. int connection_edge_finished_flushing(edge_connection_t *conn);
  26. int connection_edge_finished_connecting(edge_connection_t *conn);
  27. void connection_ap_about_to_close(entry_connection_t *edge_conn);
  28. void connection_exit_about_to_close(edge_connection_t *edge_conn);
  29. MOCK_DECL(int,
  30. connection_ap_handshake_send_begin,(entry_connection_t *ap_conn));
  31. int connection_ap_handshake_send_resolve(entry_connection_t *ap_conn);
  32. entry_connection_t *connection_ap_make_link(connection_t *partner,
  33. char *address, uint16_t port,
  34. const char *digest,
  35. int session_group,
  36. int isolation_flags,
  37. int use_begindir, int want_onehop);
  38. void connection_ap_handshake_socks_reply(entry_connection_t *conn, char *reply,
  39. size_t replylen,
  40. int endreason);
  41. MOCK_DECL(void,connection_ap_handshake_socks_resolved,
  42. (entry_connection_t *conn,
  43. int answer_type,
  44. size_t answer_len,
  45. const uint8_t *answer,
  46. int ttl,
  47. time_t expires));
  48. void connection_ap_handshake_socks_resolved_addr(entry_connection_t *conn,
  49. const tor_addr_t *answer,
  50. int ttl,
  51. time_t expires);
  52. int connection_exit_begin_conn(cell_t *cell, circuit_t *circ);
  53. int connection_exit_begin_resolve(cell_t *cell, or_circuit_t *circ);
  54. void connection_exit_connect(edge_connection_t *conn);
  55. int connection_edge_is_rendezvous_stream(const edge_connection_t *conn);
  56. int connection_ap_can_use_exit(const entry_connection_t *conn,
  57. const node_t *exit);
  58. void connection_ap_expire_beginning(void);
  59. void connection_ap_rescan_and_attach_pending(void);
  60. void connection_ap_attach_pending(int retry);
  61. void connection_ap_mark_as_pending_circuit_(entry_connection_t *entry_conn,
  62. const char *file, int line);
  63. #define connection_ap_mark_as_pending_circuit(c) \
  64. connection_ap_mark_as_pending_circuit_((c), __FILE__, __LINE__)
  65. void connection_ap_mark_as_non_pending_circuit(entry_connection_t *entry_conn);
  66. #define CONNECTION_AP_EXPECT_NONPENDING(c) do { \
  67. if (ENTRY_TO_CONN(c)->state == AP_CONN_STATE_CIRCUIT_WAIT) { \
  68. log_warn(LD_BUG, "At %s:%d: %p was unexpectedly in circuit_wait.", \
  69. __FILE__, __LINE__, (c)); \
  70. connection_ap_mark_as_non_pending_circuit(c); \
  71. } \
  72. } while (0)
  73. void connection_ap_fail_onehop(const char *failed_digest,
  74. cpath_build_state_t *build_state);
  75. void circuit_discard_optional_exit_enclaves(extend_info_t *info);
  76. int connection_ap_detach_retriable(entry_connection_t *conn,
  77. origin_circuit_t *circ,
  78. int reason);
  79. int connection_ap_process_transparent(entry_connection_t *conn);
  80. int address_is_invalid_destination(const char *address, int client);
  81. MOCK_DECL(int, connection_ap_rewrite_and_attach_if_allowed,
  82. (entry_connection_t *conn,
  83. origin_circuit_t *circ,
  84. crypt_path_t *cpath));
  85. int connection_ap_handshake_rewrite_and_attach(entry_connection_t *conn,
  86. origin_circuit_t *circ,
  87. crypt_path_t *cpath);
  88. /** Possible return values for parse_extended_hostname. */
  89. typedef enum hostname_type_t {
  90. NORMAL_HOSTNAME, ONION_V2_HOSTNAME, ONION_V3_HOSTNAME,
  91. EXIT_HOSTNAME, BAD_HOSTNAME
  92. } hostname_type_t;
  93. hostname_type_t parse_extended_hostname(char *address);
  94. #if defined(HAVE_NET_IF_H) && defined(HAVE_NET_PFVAR_H)
  95. int get_pf_socket(void);
  96. #endif
  97. int connection_edge_compatible_with_circuit(const entry_connection_t *conn,
  98. const origin_circuit_t *circ);
  99. int connection_edge_update_circuit_isolation(const entry_connection_t *conn,
  100. origin_circuit_t *circ,
  101. int dry_run);
  102. void circuit_clear_isolation(origin_circuit_t *circ);
  103. streamid_t get_unique_stream_id_by_circ(origin_circuit_t *circ);
  104. void connection_edge_free_all(void);
  105. void connection_ap_warn_and_unmark_if_pending_circ(
  106. entry_connection_t *entry_conn,
  107. const char *where);
  108. /** @name Begin-cell flags
  109. *
  110. * These flags are used in RELAY_BEGIN cells to change the default behavior
  111. * of the cell.
  112. *
  113. * @{
  114. **/
  115. /** When this flag is set, the client is willing to get connected to IPv6
  116. * addresses */
  117. #define BEGIN_FLAG_IPV6_OK (1u<<0)
  118. /** When this flag is set, the client DOES NOT support connecting to IPv4
  119. * addresses. (The sense of this flag is inverted from IPV6_OK, so that the
  120. * old default behavior of Tor is equivalent to having all flags set to 0.)
  121. **/
  122. #define BEGIN_FLAG_IPV4_NOT_OK (1u<<1)
  123. /** When this flag is set, if we find both an IPv4 and an IPv6 address,
  124. * we use the IPv6 address. Otherwise we use the IPv4 address. */
  125. #define BEGIN_FLAG_IPV6_PREFERRED (1u<<2)
  126. /**@}*/
  127. #ifdef CONNECTION_EDGE_PRIVATE
  128. /** A parsed BEGIN or BEGIN_DIR cell */
  129. typedef struct begin_cell_t {
  130. /** The address the client has asked us to connect to, or NULL if this is
  131. * a BEGIN_DIR cell*/
  132. char *address;
  133. /** The flags specified in the BEGIN cell's body. One or more of
  134. * BEGIN_FLAG_*. */
  135. uint32_t flags;
  136. /** The client's requested port. */
  137. uint16_t port;
  138. /** The client's requested Stream ID */
  139. uint16_t stream_id;
  140. /** True iff this is a BEGIN_DIR cell. */
  141. unsigned is_begindir : 1;
  142. } begin_cell_t;
  143. STATIC int begin_cell_parse(const cell_t *cell, begin_cell_t *bcell,
  144. uint8_t *end_reason_out);
  145. STATIC int connected_cell_format_payload(uint8_t *payload_out,
  146. const tor_addr_t *addr,
  147. uint32_t ttl);
  148. typedef struct {
  149. /** Original address, after we lowercased it but before we started
  150. * mapping it.
  151. */
  152. char orig_address[MAX_SOCKS_ADDR_LEN];
  153. /** True iff the address has been automatically remapped to a local
  154. * address in VirtualAddrNetwork. (Only set true when we do a resolve
  155. * and get a virtual address; not when we connect to the address.) */
  156. int automap;
  157. /** If this connection has a .exit address, who put it there? */
  158. addressmap_entry_source_t exit_source;
  159. /** If we've rewritten the address, when does this map expire? */
  160. time_t map_expires;
  161. /** If we should close the connection, this is the end_reason to pass
  162. * to connection_mark_unattached_ap */
  163. int end_reason;
  164. /** True iff we should close the connection, either because of error or
  165. * because of successful early RESOLVED reply. */
  166. int should_close;
  167. } rewrite_result_t;
  168. STATIC void connection_ap_handshake_rewrite(entry_connection_t *conn,
  169. rewrite_result_t *out);
  170. STATIC int connection_ap_process_http_connect(entry_connection_t *conn);
  171. #endif /* defined(CONNECTION_EDGE_PRIVATE) */
  172. #endif /* !defined(TOR_CONNECTION_EDGE_H) */