12 #ifndef TOR_CONNECTION_H 13 #define TOR_CONNECTION_H 33 #define connection_free(conn) \ 34 FREE_AND_NULL(connection_t, connection_free_, (conn)) 39 int line,
const char *file);
40 MOCK_DECL(
void, connection_mark_for_close_internal_,
43 #define connection_mark_for_close(c) \ 44 connection_mark_for_close_((c), __LINE__, SHORT_FILE__) 45 #define connection_mark_for_close_internal(c) \ 46 connection_mark_for_close_internal_((c), __LINE__, SHORT_FILE__) 58 #define connection_mark_and_flush_internal_(c,line,file) \ 60 connection_t *tmp_conn__ = (c); \ 61 connection_mark_for_close_internal_(tmp_conn__, (line), (file)); \ 62 tmp_conn__->hold_open_until_flushed = 1; \ 65 #define connection_mark_and_flush_internal(c) \ 66 connection_mark_and_flush_internal_((c), __LINE__, SHORT_FILE__) 71 #define connection_mark_and_flush_(c,line,file) \ 73 connection_t *tmp_conn_ = (c); \ 74 if (tmp_conn_->type == CONN_TYPE_OR) { \ 75 log_warn(LD_CHANNEL | LD_BUG, \ 76 "Something tried to close (and flush) an or_connection_t" \ 77 " without going through channels at %s:%d", \ 79 connection_or_close_for_error(TO_OR_CONN(tmp_conn_), 1); \ 81 connection_mark_and_flush_internal_(c, line, file); \ 85 #define connection_mark_and_flush(c) \ 86 connection_mark_and_flush_((c), __LINE__, SHORT_FILE__) 92 uint16_t port,
int *socket_error);
96 int connection_connect_unix(
connection_t *conn,
const char *socket_path,
103 #define MAX_SOCKS5_AUTH_FIELD_SIZE 255 107 #define MAX_SOCKS5_AUTH_SIZE_TOTAL 2*MAX_SOCKS5_AUTH_FIELD_SIZE 117 int close_all_noncontrol);
126 void connection_bucket_refill_all(time_t now,
139 char **headers_out,
size_t max_headerlen,
140 char **body_out,
size_t *body_used,
141 size_t max_bodylen,
int force_complete);
145 int connection_handle_write(
connection_t *conn,
int force);
148 MOCK_DECL(
void, connection_write_to_buf_impl_,
149 (
const char *
string,
size_t len,
connection_t *conn,
int zlib));
151 static void connection_buf_add(
const char *
string,
size_t len,
154 static void connection_buf_add_compress(
const char *
string,
size_t len,
157 connection_buf_add(
const char *
string,
size_t len,
connection_t *conn)
159 connection_write_to_buf_impl_(
string, len, conn, 0);
162 connection_buf_add_compress(
const char *
string,
size_t len,
165 connection_write_to_buf_impl_(
string, len,
TO_CONN(conn), done ? -1 : 1);
170 static size_t connection_get_inbuf_len(
connection_t *conn);
172 static size_t connection_get_outbuf_len(
connection_t *conn);
177 return conn->
inbuf ? buf_datalen(conn->
inbuf) : 0;
191 uint16_t port,
int purpose));
194 const char *rendquery);
195 smartlist_t *connection_list_by_type_state(
int type,
int state);
196 smartlist_t *connection_list_by_type_purpose(
int type,
int purpose);
199 const char *resource);
202 const char *resource,
205 #define CONN_LEN_AND_FREE_TEMPLATE(sl) \ 207 int len = smartlist_len(sl); \ 208 smartlist_free(sl); \ 215 connection_dir_count_by_purpose_and_resource(
217 const char *resource)
222 CONN_LEN_AND_FREE_TEMPLATE(conns);
228 connection_dir_count_by_purpose_resource_and_state(
230 const char *resource,
238 CONN_LEN_AND_FREE_TEMPLATE(conns);
241 #undef CONN_LEN_AND_FREE_TEMPLATE 246 #define connection_speaks_cells(conn) (((conn)->type == CONN_TYPE_OR) || 0) 258 (
const connection_t *conn,
long apparent_skew,
int trusted,
260 const char *source));
278 #ifdef CONNECTION_PRIVATE 282 MOCK_DECL(STATIC
int,connection_connect_sockaddr,
284 const struct sockaddr *sa,
286 const struct sockaddr *bindaddr,
287 socklen_t bindaddr_len,
int connection_is_listener(connection_t *conn)
Definition: connection.c:4340
const char * conn_state_to_string(int type, int state)
Definition: connection.c:206
#define TO_CONN(c)
Definition: or.h:1917
int connection_outbuf_too_full(connection_t *conn)
Definition: connection.c:3677
void connection_close_immediate(connection_t *conn)
Definition: connection.c:761
connection_t * connection_get_by_type(int type)
Definition: connection.c:4204
entry_connection_t * entry_connection_new(int type, int socket_family)
Definition: connection.c:327
listener_connection_t * listener_connection_new(int type, int socket_family)
Definition: connection.c:369
int conn_array_index
Definition: or.h:1375
void connection_mark_all_noncontrol_connections(void)
Definition: connection.c:2766
void connection_dump_buffer_mem_stats(int severity)
Definition: connection.c:4905
void connection_read_bw_exhausted(connection_t *conn, bool is_global_bw)
Definition: connection.c:3092
MOCK_DECL(int, router_have_minimum_dir_info,(void))
connection_t * connection_get_by_type_state_rendquery(int type, int state, const char *rendquery)
Definition: connection.c:4223
edge_connection_t * edge_connection_new(int type, int socket_family)
Definition: connection.c:346
Definition: container.h:18
STATIC void connection_free_minimal(connection_t *conn)
Definition: connection.c:502
void connection_check_oos(int n_socks, int failed)
Definition: connection.c:4821
int connection_state_is_open(connection_t *conn)
Definition: connection.c:4359
int get_proxy_addrport(tor_addr_t *addr, uint16_t *port, int *proxy_type, const connection_t *conn)
Definition: connection.c:5106
void connection_write_bw_exhausted(connection_t *conn, bool is_global_bw)
Definition: connection.c:3107
int global_write_bucket_low(connection_t *conn, size_t attempt, int priority)
Definition: connection.c:2962
void connection_about_to_close_connection(connection_t *conn)
Definition: connection.c:730
struct buf_t * outbuf
Definition: or.h:1380
const char * conn_type_to_string(int type)
Definition: connection.c:174
void connection_free_all(void)
Definition: connection.c:5196
struct buf_t * inbuf
Definition: or.h:1379
int connection_buf_get_line(connection_t *conn, char *data, size_t *data_len)
Definition: connection.c:3646
int connection_state_is_connecting(connection_t *conn)
Definition: connection.c:4379
int connection_connect(connection_t *conn, const char *address, const tor_addr_t *addr, uint16_t port, int *socket_error)
Definition: connection.c:1990
dir_connection_t * dir_connection_new(int socket_family)
Definition: connection.c:291
uint16_t marked_for_close
Definition: or.h:1400
int connection_wants_to_flush(connection_t *conn)
Definition: connection.c:3667
void connection_bucket_adjust(const or_options_t *options)
Definition: connection.c:3200
int connection_or_nonopen_was_started_here(or_connection_t *conn)
Definition: connection_or.c:1709
int conn_listener_type_supports_af_unix(int type)
Definition: connection.c:484
int connection_buf_get_bytes(char *string, size_t len, connection_t *conn)
Definition: connection.c:3639
connection_t * connection_new(int type, int socket_family)
Definition: connection.c:381
int connection_flush(connection_t *conn)
Definition: connection.c:4003
int connection_fetch_from_buf_http(connection_t *conn, char **headers_out, size_t max_headerlen, char **body_out, size_t *body_used, size_t max_bodylen, int force_complete)
Definition: connection.c:3655
uint32_t log_domain_mask_t
Definition: torlog.h:124
int connection_init_accepted_conn(connection_t *conn, const listener_connection_t *listener)
Definition: connection.c:1688
void assert_connection_ok(connection_t *conn, time_t now)
Definition: connection.c:4954
smartlist_t * connection_dir_list_by_purpose_resource_and_state(int purpose, const char *resource, int state)
Definition: connection.c:4293
or_connection_t * or_connection_new(int type, int socket_family)
Definition: connection.c:306
int any_other_active_or_conns(const or_connection_t *this_conn)
Definition: connection.c:4324
control_connection_t * control_connection_new(int socket_family)
Definition: connection.c:357
void connection_consider_empty_write_buckets(connection_t *conn)
Definition: connection.c:3147
int connection_read_proxy_handshake(connection_t *conn)
Definition: connection.c:2401
void connection_buf_add_buf(connection_t *conn, buf_t *buf)
Definition: connection.c:4117
smartlist_t * connection_dir_list_by_purpose_and_resource(int purpose, const char *resource)
Definition: connection.c:4275
char * alloc_http_authenticator(const char *authenticator)
Definition: connection.c:4402
void connection_mark_for_close_(connection_t *conn, int line, const char *file)
Definition: connection.c:795
Header file for buffers.c.
ssize_t connection_bucket_write_limit(connection_t *conn, time_t now)
Definition: connection.c:2912
void connection_bucket_init(void)
Definition: connection.c:3175
void connection_mark_all_noncontrol_listeners(void)
Definition: connection.c:2752
void log_failed_proxy_connection(connection_t *conn)
Definition: connection.c:5158
void connection_consider_empty_read_buckets(connection_t *conn)
Definition: connection.c:3118
void connection_expire_held_open(void)
Definition: connection.c:872
void connection_link_connections(connection_t *conn_a, connection_t *conn_b)
Definition: connection.c:470
connection_t * connection_get_by_global_id(uint64_t id)
Definition: connection.c:4196
int connection_proxy_connect(connection_t *conn, int type)
Definition: connection.c:2136
int retry_all_listeners(smartlist_t *replaced_conns, smartlist_t *new_conns, int close_all_noncontrol)
Definition: connection.c:2699
connection_t * connection_get_by_type_state(int type, int state)
Definition: connection.c:4213