Tor  0.4.6.0-alpha-dev
relay.h
Go to the documentation of this file.
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-2020, The Tor Project, Inc. */
5 /* See LICENSE for licensing information */
6 
7 /**
8  * \file relay.h
9  * \brief Header file for relay.c.
10  **/
11 
12 #ifndef TOR_RELAY_H
13 #define TOR_RELAY_H
14 
15 extern uint64_t stats_n_relay_cells_relayed;
16 extern uint64_t stats_n_relay_cells_delivered;
17 extern uint64_t stats_n_circ_max_cell_reached;
18 
19 void relay_consensus_has_changed(const networkstatus_t *ns);
21  cell_direction_t cell_direction);
22 size_t cell_queues_get_total_allocation(void);
23 
24 void relay_header_pack(uint8_t *dest, const relay_header_t *src);
25 void relay_header_unpack(relay_header_t *dest, const uint8_t *src);
26 MOCK_DECL(int,
28  uint8_t relay_command, const char *payload,
29  size_t payload_len, crypt_path_t *cpath_layer,
30  const char *filename, int lineno));
31 /* Indicates to relay_send_command_from_edge() that it is a control cell. */
32 #define CONTROL_CELL_ID 0
33 #define relay_send_command_from_edge(stream_id, circ, relay_command, payload, \
34  payload_len, cpath_layer) \
35  relay_send_command_from_edge_((stream_id), (circ), (relay_command), \
36  (payload), (payload_len), (cpath_layer), \
37  __FILE__, __LINE__)
39  uint8_t relay_command, const char *payload,
40  size_t payload_len);
42  int package_partial,
43  int *max_cells);
44 void connection_edge_consider_sending_sendme(edge_connection_t *conn);
46 
47 extern uint64_t stats_n_data_cells_packaged;
48 extern uint64_t stats_n_data_bytes_packaged;
49 extern uint64_t stats_n_data_cells_received;
50 extern uint64_t stats_n_data_bytes_received;
51 
52 void dump_cell_pool_usage(int severity);
53 size_t packed_cell_mem_cost(void);
54 
56 
57 /* For channeltls.c */
59 #define packed_cell_free(cell) \
60  FREE_AND_NULL(packed_cell_t, packed_cell_free_, (cell))
61 
62 void cell_queue_init(cell_queue_t *queue);
63 void cell_queue_clear(cell_queue_t *queue);
64 void cell_queue_append(cell_queue_t *queue, packed_cell_t *cell);
66  int exitward, const cell_t *cell,
67  int wide_circ_ids, int use_stats);
68 
70  cell_t *cell, cell_direction_t direction,
71  streamid_t fromstream);
72 
76  circid_t circid,
77  uint8_t reason);
78 
79 void channel_unlink_all_circuits(channel_t *chan, smartlist_t *detached_out);
81  (channel_t *chan, int max));
83  cell_direction_t cell_direction,
84  crypt_path_t *layer_hint, streamid_t on_stream,
85  const char *filename, int lineno));
86 
88  const char *file, int lineno);
89 #define update_circuit_on_cmux(circ, direction) \
90  update_circuit_on_cmux_((circ), (direction), SHORT_FILE__, __LINE__)
91 
92 int append_address_to_payload(uint8_t *payload_out, const tor_addr_t *addr);
93 const uint8_t *decode_address_from_payload(tor_addr_t *addr_out,
94  const uint8_t *payload,
95  int payload_len);
97 
98 circid_t packed_cell_get_circid(const packed_cell_t *cell, int wide_circ_ids);
99 uint8_t packed_cell_get_command(const packed_cell_t *cell, int wide_circ_ids);
100 
101 #ifdef RELAY_PRIVATE
102 STATIC int
104  edge_connection_t *conn, crypt_path_t *layer_hint,
105  relay_header_t *rh, int optimistic_data);
106 
107 STATIC int connected_cell_parse(const relay_header_t *rh, const cell_t *cell,
108  tor_addr_t *addr_out, int *ttl_out);
109 /** An address-and-ttl tuple as yielded by resolved_cell_parse */
110 typedef struct address_ttl_t {
111  tor_addr_t addr;
112  char *hostname;
113  int ttl;
114 } address_ttl_t;
115 STATIC void address_ttl_free_(address_ttl_t *addr);
116 #define address_ttl_free(addr) \
117  FREE_AND_NULL(address_ttl_t, address_ttl_free_, (addr))
118 STATIC int resolved_cell_parse(const cell_t *cell, const relay_header_t *rh,
119  smartlist_t *addresses_out, int *errcode_out);
121  const cell_t *cell,
122  const relay_header_t *rh);
128  edge_connection_t *conn,
129  crypt_path_t *layer_hint);
130 STATIC size_t get_pad_cell_offset(size_t payload_len);
131 STATIC size_t connection_edge_get_inbuf_bytes_to_package(size_t n_available,
132  int package_partial,
133  circuit_t *on_circuit);
134 
135 #endif /* defined(RELAY_PRIVATE) */
136 
137 #endif /* !defined(TOR_RELAY_H) */
packed_cell_new
STATIC packed_cell_t * packed_cell_new(void)
Definition: relay.c:2513
dump_cell_pool_usage
void dump_cell_pool_usage(int severity)
Definition: relay.c:2531
destroy_cell_queue_append
void destroy_cell_queue_append(destroy_cell_queue_t *queue, circid_t circid, uint8_t reason)
Definition: relay.c:2653
tor_addr_t
Definition: address.h:69
stats_n_data_bytes_received
uint64_t stats_n_data_bytes_received
Definition: relay.c:2062
append_cell_to_circuit_queue
void append_cell_to_circuit_queue(circuit_t *circ, channel_t *chan, cell_t *cell, cell_direction_t direction, streamid_t fromstream)
Definition: relay.c:3113
packed_cell_mem_cost
size_t packed_cell_mem_cost(void)
Definition: relay.c:2686
resolved_cell_parse
STATIC int resolved_cell_parse(const cell_t *cell, const relay_header_t *rh, smartlist_t *addresses_out, int *errcode_out)
Definition: relay.c:1121
stats_n_data_cells_received
uint64_t stats_n_data_cells_received
Definition: relay.c:2058
decode_address_from_payload
const uint8_t * decode_address_from_payload(tor_addr_t *addr_out, const uint8_t *payload, int payload_len)
Definition: relay.c:3212
cell_direction_t
cell_direction_t
Definition: or.h:483
destroy_cell_queue_t
Definition: destroy_cell_queue_st.h:27
relay_send_command_from_edge_
int relay_send_command_from_edge_(streamid_t stream_id, circuit_t *circ, uint8_t relay_command, const char *payload, size_t payload_len, crypt_path_t *cpath_layer, const char *filename, int lineno)
Definition: relay.c:611
packed_cell_get_command
uint8_t packed_cell_get_command(const packed_cell_t *cell, int wide_circ_ids)
Definition: relay.c:2875
crypt_path_t
Definition: crypt_path_st.h:47
cell_queue_append_packed_copy
void cell_queue_append_packed_copy(circuit_t *circ, cell_queue_t *queue, int exitward, const cell_t *cell, int wide_circ_ids, int use_stats)
Definition: relay.c:2569
destroy_cell_queue_init
void destroy_cell_queue_init(destroy_cell_queue_t *queue)
Definition: relay.c:2619
address_ttl_free_
STATIC void address_ttl_free_(address_ttl_t *addr)
Definition: relay.c:1107
cell_t
Definition: cell_st.h:17
destroy_cell_queue_clear
void destroy_cell_queue_clear(destroy_cell_queue_t *queue)
Definition: relay.c:2627
stats_n_circ_max_cell_reached
uint64_t stats_n_circ_max_cell_reached
Definition: relay.c:135
packed_cell_t
Definition: cell_queue_st.h:18
circuit_package_relay_cell
int circuit_package_relay_cell(cell_t *cell, circuit_t *circ, cell_direction_t cell_direction, crypt_path_t *layer_hint, streamid_t on_stream, const char *filename, int lineno)
Definition: relay.c:364
relay_header_unpack
void relay_header_unpack(relay_header_t *dest, const uint8_t *src)
Definition: relay.c:491
circuit_receive_relay_cell
int circuit_receive_relay_cell(cell_t *cell, circuit_t *circ, cell_direction_t cell_direction)
Definition: relay.c:226
stats_n_relay_cells_delivered
uint64_t stats_n_relay_cells_delivered
Definition: relay.c:132
cell_queue_clear
void cell_queue_clear(cell_queue_t *queue)
Definition: relay.c:2593
packed_cell_free_
void packed_cell_free_(packed_cell_t *cell)
Definition: relay.c:2521
connection_edge_send_command
int connection_edge_send_command(edge_connection_t *fromconn, uint8_t relay_command, const char *payload, size_t payload_len)
Definition: relay.c:732
connection_edge_get_inbuf_bytes_to_package
STATIC size_t connection_edge_get_inbuf_bytes_to_package(size_t n_available, int package_partial, circuit_t *on_circuit)
Definition: relay.c:2089
have_been_under_memory_pressure
int have_been_under_memory_pressure(void)
Definition: relay.c:2753
circuit_t
Definition: circuit_st.h:61
cell_queue_t
Definition: cell_queue_st.h:28
MOCK_DECL
#define MOCK_DECL(rv, funcname, arglist)
Definition: testsupport.h:127
cell_queue_pop
STATIC packed_cell_t * cell_queue_pop(cell_queue_t *queue)
Definition: relay.c:2607
channel_t
Definition: channel.h:181
connected_cell_parse
STATIC int connected_cell_parse(const relay_header_t *rh, const cell_t *cell, tor_addr_t *addr_out, int *ttl_out)
Definition: relay.c:1069
circuit_clear_cell_queue
void circuit_clear_cell_queue(circuit_t *circ, channel_t *chan)
Definition: relay.c:3240
destroy_cell_queue_pop
STATIC destroy_cell_t * destroy_cell_queue_pop(destroy_cell_queue_t *queue)
Definition: relay.c:2641
relay_header_pack
void relay_header_pack(uint8_t *dest, const relay_header_t *src)
Definition: relay.c:478
update_circuit_on_cmux_
void update_circuit_on_cmux_(circuit_t *circ, cell_direction_t direction, const char *file, int lineno)
Definition: relay.c:2764
get_pad_cell_offset
STATIC size_t get_pad_cell_offset(size_t data_len)
Definition: relay.c:556
packed_cell_get_circid
circid_t packed_cell_get_circid(const packed_cell_t *cell, int wide_circ_ids)
Definition: relay.c:2886
channel_unlink_all_circuits
void channel_unlink_all_circuits(channel_t *chan, smartlist_t *detached_out)
Definition: relay.c:2809
circuit_reset_sendme_randomness
void circuit_reset_sendme_randomness(circuit_t *circ)
Definition: relay.c:2070
cell_queue_append
void cell_queue_append(cell_queue_t *queue, packed_cell_t *cell)
Definition: relay.c:2558
relay_header_t
Definition: or.h:638
connection_edge_package_raw_inbuf
int connection_edge_package_raw_inbuf(edge_connection_t *conn, int package_partial, int *max_cells)
Definition: relay.c:2153
destroy_cell_t
Definition: destroy_cell_queue_st.h:18
stats_n_relay_cells_relayed
uint64_t stats_n_relay_cells_relayed
Definition: relay.c:128
connection_edge_process_relay_cell
STATIC int connection_edge_process_relay_cell(cell_t *cell, circuit_t *circ, edge_connection_t *conn, crypt_path_t *layer_hint)
Definition: relay.c:1982
edge_connection_t
Definition: edge_connection_st.h:21
streamid_t
uint16_t streamid_t
Definition: or.h:611
handle_relay_cell_command
STATIC int handle_relay_cell_command(cell_t *cell, circuit_t *circ, edge_connection_t *conn, crypt_path_t *layer_hint, relay_header_t *rh, int optimistic_data)
Definition: relay.c:1592
connection_edge_process_resolved_cell
STATIC int connection_edge_process_resolved_cell(edge_connection_t *conn, const cell_t *cell, const relay_header_t *rh)
Definition: relay.c:1292
append_address_to_payload
int append_address_to_payload(uint8_t *payload_out, const tor_addr_t *addr)
Definition: relay.c:3186
cell_queue_init
void cell_queue_init(cell_queue_t *queue)
Definition: relay.c:2585
STATIC
#define STATIC
Definition: testsupport.h:32
stats_n_data_cells_packaged
uint64_t stats_n_data_cells_packaged
Definition: relay.c:2052
networkstatus_t
Definition: networkstatus_st.h:26
channel_flush_from_first_active_circuit
int channel_flush_from_first_active_circuit(channel_t *chan, int max)
Definition: relay.c:2900
smartlist_t
Definition: smartlist_core.h:26
cell_queues_check_size
STATIC int cell_queues_check_size(void)
Definition: relay.c:2707
circid_t
uint32_t circid_t
Definition: or.h:609
stats_n_data_bytes_packaged
uint64_t stats_n_data_bytes_packaged
Definition: relay.c:2056