connection_edge.h 6.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143
  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-2013, 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. void connection_mark_unattached_ap_(entry_connection_t *conn, int endreason,
  16. int line, const char *file);
  17. int connection_edge_reached_eof(edge_connection_t *conn);
  18. int connection_edge_process_inbuf(edge_connection_t *conn,
  19. int package_partial);
  20. int connection_edge_destroy(circid_t circ_id, edge_connection_t *conn);
  21. int connection_edge_end(edge_connection_t *conn, uint8_t reason);
  22. int connection_edge_end_errno(edge_connection_t *conn);
  23. int connection_edge_flushed_some(edge_connection_t *conn);
  24. int connection_edge_finished_flushing(edge_connection_t *conn);
  25. int connection_edge_finished_connecting(edge_connection_t *conn);
  26. void connection_ap_about_to_close(entry_connection_t *edge_conn);
  27. void connection_exit_about_to_close(edge_connection_t *edge_conn);
  28. int connection_ap_handshake_send_begin(entry_connection_t *ap_conn);
  29. int connection_ap_handshake_send_resolve(entry_connection_t *ap_conn);
  30. entry_connection_t *connection_ap_make_link(connection_t *partner,
  31. char *address, uint16_t port,
  32. const char *digest,
  33. int session_group,
  34. int isolation_flags,
  35. int use_begindir, int want_onehop);
  36. void connection_ap_handshake_socks_reply(entry_connection_t *conn, char *reply,
  37. size_t replylen,
  38. int endreason);
  39. void connection_ap_handshake_socks_resolved(entry_connection_t *conn,
  40. int answer_type,
  41. size_t answer_len,
  42. const uint8_t *answer,
  43. int ttl,
  44. time_t expires);
  45. int connection_exit_begin_conn(cell_t *cell, circuit_t *circ);
  46. int connection_exit_begin_resolve(cell_t *cell, or_circuit_t *circ);
  47. void connection_exit_connect(edge_connection_t *conn);
  48. int connection_edge_is_rendezvous_stream(edge_connection_t *conn);
  49. int connection_ap_can_use_exit(const entry_connection_t *conn,
  50. const node_t *exit);
  51. void connection_ap_expire_beginning(void);
  52. void connection_ap_attach_pending(void);
  53. void connection_ap_fail_onehop(const char *failed_digest,
  54. cpath_build_state_t *build_state);
  55. void circuit_discard_optional_exit_enclaves(extend_info_t *info);
  56. int connection_ap_detach_retriable(entry_connection_t *conn,
  57. origin_circuit_t *circ,
  58. int reason);
  59. int connection_ap_process_transparent(entry_connection_t *conn);
  60. int address_is_invalid_destination(const char *address, int client);
  61. int connection_ap_rewrite_and_attach_if_allowed(entry_connection_t *conn,
  62. origin_circuit_t *circ,
  63. crypt_path_t *cpath);
  64. int connection_ap_handshake_rewrite_and_attach(entry_connection_t *conn,
  65. origin_circuit_t *circ,
  66. crypt_path_t *cpath);
  67. /** Possible return values for parse_extended_hostname. */
  68. typedef enum hostname_type_t {
  69. NORMAL_HOSTNAME, ONION_HOSTNAME, EXIT_HOSTNAME, BAD_HOSTNAME
  70. } hostname_type_t;
  71. hostname_type_t parse_extended_hostname(char *address);
  72. #if defined(HAVE_NET_IF_H) && defined(HAVE_NET_PFVAR_H)
  73. int get_pf_socket(void);
  74. #endif
  75. int connection_edge_compatible_with_circuit(const entry_connection_t *conn,
  76. const origin_circuit_t *circ);
  77. int connection_edge_update_circuit_isolation(const entry_connection_t *conn,
  78. origin_circuit_t *circ,
  79. int dry_run);
  80. void circuit_clear_isolation(origin_circuit_t *circ);
  81. streamid_t get_unique_stream_id_by_circ(origin_circuit_t *circ);
  82. /** @name Begin-cell flags
  83. *
  84. * These flags are used in RELAY_BEGIN cells to change the default behavior
  85. * of the cell.
  86. *
  87. * @{
  88. **/
  89. /** When this flag is set, the client is willing to get connected to IPv6
  90. * addresses */
  91. #define BEGIN_FLAG_IPV6_OK (1u<<0)
  92. /** When this flag is set, the client DOES NOT support connecting to IPv4
  93. * addresses. (The sense of this flag is inverted from IPV6_OK, so that the
  94. * old default behavior of Tor is equivalent to having all flags set to 0.)
  95. **/
  96. #define BEGIN_FLAG_IPV4_NOT_OK (1u<<1)
  97. /** When this flag is set, if we find both an IPv4 and an IPv6 address,
  98. * we use the IPv6 address. Otherwise we use the IPv4 address. */
  99. #define BEGIN_FLAG_IPV6_PREFERRED (1u<<2)
  100. /**@}*/
  101. #ifdef CONNECTION_EDGE_PRIVATE
  102. /** A parsed BEGIN or BEGIN_DIR cell */
  103. typedef struct begin_cell_t {
  104. /** The address the client has asked us to connect to, or NULL if this is
  105. * a BEGIN_DIR cell*/
  106. char *address;
  107. /** The flags specified in the BEGIN cell's body. One or more of
  108. * BEGIN_FLAG_*. */
  109. uint32_t flags;
  110. /** The client's requested port. */
  111. uint16_t port;
  112. /** The client's requested Stream ID */
  113. uint16_t stream_id;
  114. /** True iff this is a BEGIN_DIR cell. */
  115. unsigned is_begindir : 1;
  116. } begin_cell_t;
  117. STATIC int begin_cell_parse(const cell_t *cell, begin_cell_t *bcell,
  118. uint8_t *end_reason_out);
  119. STATIC int connected_cell_format_payload(uint8_t *payload_out,
  120. const tor_addr_t *addr,
  121. uint32_t ttl);
  122. #endif
  123. #endif