12#ifndef TOR_CONNECTION_EDGE_H
13#define TOR_CONNECTION_EDGE_H
28#define EXIT_CONN_STATE_MIN_ 1
30#define EXIT_CONN_STATE_RESOLVING 1
32#define EXIT_CONN_STATE_CONNECTING 2
34#define EXIT_CONN_STATE_OPEN 3
36#define EXIT_CONN_STATE_RESOLVEFAILED 4
37#define EXIT_CONN_STATE_MAX_ 4
40#define AP_CONN_STATE_MIN_ 5
42#define AP_CONN_STATE_SOCKS_WAIT 5
45#define AP_CONN_STATE_RENDDESC_WAIT 6
48#define AP_CONN_STATE_CONTROLLER_WAIT 7
50#define AP_CONN_STATE_CIRCUIT_WAIT 8
52#define AP_CONN_STATE_CONNECT_WAIT 9
54#define AP_CONN_STATE_RESOLVE_WAIT 10
56#define AP_CONN_STATE_OPEN 11
59#define AP_CONN_STATE_NATD_WAIT 12
61#define AP_CONN_STATE_HTTP_CONNECT_WAIT 13
62#define AP_CONN_STATE_MAX_ 13
64#define EXIT_PURPOSE_MIN_ 1
66#define EXIT_PURPOSE_CONNECT 1
68#define EXIT_PURPOSE_RESOLVE 2
69#define EXIT_PURPOSE_MAX_ 2
73#define AP_CONN_STATE_IS_UNATTACHED(s) \
74 ((s) <= AP_CONN_STATE_CIRCUIT_WAIT || (s) == AP_CONN_STATE_NATD_WAIT)
76#define connection_mark_unattached_ap(conn, endreason) \
77 connection_mark_unattached_ap_((conn), (endreason), __LINE__, SHORT_FILE__)
89 int line,
const char *file));
112 char *address, uint16_t port,
116 int use_begindir,
int want_onehop);
124 const uint8_t *answer,
142 const char *file,
int line);
143#define connection_ap_mark_as_pending_circuit(c) \
144 connection_ap_mark_as_pending_circuit_((c), __FILE__, __LINE__)
149#define CONNECTION_AP_EXPECT_NONPENDING(c) do { \
150 if (ENTRY_TO_CONN(c)->state == AP_CONN_STATE_CIRCUIT_WAIT) { \
151 log_warn(LD_BUG, "At %s:%d: %p was unexpectedly in circuit_wait.", \
152 __FILE__, __LINE__, (c)); \
153 connection_ap_mark_as_non_pending_circuit(c); \
174#if defined(HAVE_NET_IF_H) && defined(HAVE_NET_PFVAR_H)
175int get_pf_socket(
void);
188void connection_ap_warn_and_unmark_if_pending_circ(
193#define MIN_DNS_TTL (5*60)
195#define MAX_DNS_TTL (60*60)
198#define MAX_DNS_ENTRY_AGE (3*60*60)
201#define DEFAULT_DNS_TTL (30*60)
208#define FUZZY_DNS_TTL (4*60)
228#define half_edge_free(he) \
229 FREE_AND_NULL(half_edge_t, half_edge_free_, (he))
240#define BEGIN_FLAG_IPV6_OK (1u<<0)
245#define BEGIN_FLAG_IPV4_NOT_OK (1u<<1)
248#define BEGIN_FLAG_IPV6_PREFERRED (1u<<2)
251#ifdef CONNECTION_EDGE_PRIVATE
256typedef struct begin_cell_t {
268 unsigned is_begindir : 1;
272 uint8_t *end_reason_out);
281 char orig_address[MAX_SOCKS_ADDR_LEN];
299 rewrite_result_t *out);
STATIC int connection_ap_process_http_connect(entry_connection_t *conn)
STATIC int connected_cell_format_payload(uint8_t *payload_out, const tor_addr_t *addr, uint32_t ttl)
STATIC bool parse_extended_hostname(char *address, hostname_type_t *type_out)
STATIC int begin_cell_parse(const cell_t *cell, begin_cell_t *bcell, uint8_t *end_reason_out)
STATIC void connection_half_edge_add(const edge_connection_t *conn, origin_circuit_t *circ)
STATIC half_edge_t * connection_half_edge_find_stream_id(const smartlist_t *half_conns, streamid_t stream_id)
int connection_edge_compatible_with_circuit(const entry_connection_t *conn, const origin_circuit_t *circ)
int connection_ap_handshake_rewrite_and_attach(entry_connection_t *conn, origin_circuit_t *circ, crypt_path_t *cpath)
int connection_half_edge_is_valid_data(const smartlist_t *half_conns, streamid_t stream_id)
const entry_connection_t * CONST_TO_ENTRY_CONN(const connection_t *)
void connection_ap_mark_as_waiting_for_renddesc(entry_connection_t *entry_conn)
edge_connection_t * TO_EDGE_CONN(connection_t *)
void connection_mark_unattached_ap_(entry_connection_t *conn, int endreason, int line, const char *file)
void connection_ap_about_to_close(entry_connection_t *edge_conn)
const entry_connection_t * CONST_EDGE_TO_ENTRY_CONN(const edge_connection_t *)
void connection_edge_free_all(void)
void connection_ap_mark_as_pending_circuit_(entry_connection_t *entry_conn, const char *file, int line)
void connection_ap_mark_as_non_pending_circuit(entry_connection_t *entry_conn)
int connection_ap_rewrite_and_attach_if_allowed(entry_connection_t *conn, origin_circuit_t *circ, crypt_path_t *cpath)
uint32_t clip_dns_fuzzy_ttl(uint32_t ttl)
entry_connection_t * connection_ap_make_link(connection_t *partner, char *address, uint16_t port, const char *digest, int session_group, int isolation_flags, int use_begindir, int want_onehop)
void connection_ap_expire_beginning(void)
void connection_ap_fail_onehop(const char *failed_digest, cpath_build_state_t *build_state)
int connection_ap_detach_retriable(entry_connection_t *conn, origin_circuit_t *circ, int reason)
void connection_ap_rescan_and_attach_pending(void)
int connection_ap_can_use_exit(const entry_connection_t *conn, const node_t *exit)
int connection_ap_handshake_send_begin(entry_connection_t *ap_conn)
int address_is_invalid_destination(const char *address, int client)
void connection_ap_handshake_socks_reply(entry_connection_t *conn, char *reply, size_t replylen, int endreason)
int connection_half_edge_is_valid_end(smartlist_t *half_conns, streamid_t stream_id)
uint32_t clip_dns_ttl(uint32_t ttl)
bool connection_half_edges_waiting(const origin_circuit_t *circ)
void half_edge_free_(struct half_edge_t *he)
int connection_ap_process_transparent(entry_connection_t *conn)
void connection_edge_end_close(edge_connection_t *conn, uint8_t reason)
int connection_edge_destroy(circid_t circ_id, edge_connection_t *conn)
int connection_edge_finished_flushing(edge_connection_t *conn)
void circuit_clear_isolation(origin_circuit_t *circ)
int connection_exit_begin_resolve(cell_t *cell, or_circuit_t *circ)
void connection_exit_about_to_close(edge_connection_t *edge_conn)
int connection_half_edge_is_valid_connected(const smartlist_t *half_conns, streamid_t stream_id)
int connection_edge_flushed_some(edge_connection_t *conn)
int connection_ap_handshake_send_resolve(entry_connection_t *ap_conn)
void connection_ap_handshake_socks_resolved_addr(entry_connection_t *conn, const tor_addr_t *answer, int ttl, time_t expires)
int connection_edge_update_circuit_isolation(const entry_connection_t *conn, origin_circuit_t *circ, int dry_run)
int connection_edge_reached_eof(edge_connection_t *conn)
entry_connection_t * TO_ENTRY_CONN(connection_t *)
int connection_half_edge_is_valid_resolved(smartlist_t *half_conns, streamid_t stream_id)
int connection_edge_finished_connecting(edge_connection_t *conn)
int connection_edge_end_errno(edge_connection_t *conn)
int connection_edge_end(edge_connection_t *conn, uint8_t reason)
void connection_ap_attach_pending(int retry)
size_t half_streams_get_total_allocation(void)
int connection_half_edge_is_valid_sendme(const smartlist_t *half_conns, streamid_t stream_id)
int connection_edge_is_rendezvous_stream(const edge_connection_t *conn)
entry_connection_t * EDGE_TO_ENTRY_CONN(edge_connection_t *)
void connection_ap_handshake_socks_resolved(entry_connection_t *conn, int answer_type, size_t answer_len, const uint8_t *answer, int ttl, time_t expires)
int connection_exit_begin_conn(cell_t *cell, circuit_t *circ)
void connection_entry_set_controller_wait(entry_connection_t *conn)
streamid_t get_unique_stream_id_by_circ(origin_circuit_t *circ)
const edge_connection_t * CONST_TO_EDGE_CONN(const connection_t *)
void circuit_discard_optional_exit_enclaves(extend_info_t *info)
void connection_exit_connect(edge_connection_t *conn)
int connection_edge_process_inbuf(edge_connection_t *conn, int package_partial)
Header file containing service data for the HS subsystem.
addressmap_entry_source_t
Macros to implement mocking and selective exposure for the test code.
#define MOCK_DECL(rv, funcname, arglist)