22 size_t cell_queues_get_total_allocation(
void);
28 uint8_t relay_command,
const char *payload,
30 const char *filename,
int lineno));
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), \ 39 uint8_t relay_command,
const char *payload,
58 #define packed_cell_free(cell) \ 59 FREE_AND_NULL(packed_cell_t, packed_cell_free_, (cell)) 65 int exitward,
const cell_t *cell,
66 int wide_circ_ids,
int use_stats);
79 MOCK_DECL(
int, channel_flush_from_first_active_circuit,
82 const char *file,
int lineno);
83 #define update_circuit_on_cmux(circ, direction) \ 84 update_circuit_on_cmux_((circ), (direction), SHORT_FILE__, __LINE__) 88 const uint8_t *payload,
92 void stream_choice_seed_weak_rng(
void);
100 typedef struct address_ttl_s {
106 #define address_ttl_free(addr) \ 107 FREE_AND_NULL(address_ttl_t, address_ttl_free_, (addr)) STATIC void address_ttl_free_(address_ttl_t *addr)
Definition: relay.c:1013
STATIC destroy_cell_t * destroy_cell_queue_pop(destroy_cell_queue_t *queue)
Definition: relay.c:2428
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:975
uint64_t stats_n_relay_cells_relayed
Definition: relay.c:113
const uint8_t * decode_address_from_payload(tor_addr_t *addr_out, const uint8_t *payload, int payload_len)
Definition: relay.c:2991
STATIC int cell_queues_check_size(void)
Definition: relay.c:2494
STATIC packed_cell_t * packed_cell_new(void)
Definition: relay.c:2300
uint64_t stats_n_circ_max_cell_reached
Definition: relay.c:120
uint64_t stats_n_data_cells_received
Definition: relay.c:1855
void relay_header_unpack(relay_header_t *dest, const uint8_t *src)
Definition: relay.c:470
void cell_queue_init(cell_queue_t *queue)
Definition: relay.c:2372
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:2892
void packed_cell_free_(packed_cell_t *cell)
Definition: relay.c:2308
int connection_edge_send_command(edge_connection_t *fromconn, uint8_t relay_command, const char *payload, size_t payload_len)
Definition: relay.c:638
int connection_edge_package_raw_inbuf(edge_connection_t *conn, int package_partial, int *max_cells)
Definition: relay.c:1872
void connection_edge_consider_sending_sendme(edge_connection_t *conn)
Definition: relay.c:2011
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:1424
MOCK_DECL(int, router_have_minimum_dir_info,(void))
Definition: container.h:18
void relay_header_pack(uint8_t *dest, const relay_header_t *src)
Definition: relay.c:457
size_t packed_cell_mem_cost(void)
Definition: relay.c:2473
void cell_queue_append(cell_queue_t *queue, packed_cell_t *cell)
Definition: relay.c:2345
cell_direction_t
Definition: or.h:917
uint16_t streamid_t
Definition: or.h:1032
uint64_t stats_n_data_bytes_received
Definition: relay.c:1859
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:2356
STATIC packed_cell_t * cell_queue_pop(cell_queue_t *queue)
Definition: relay.c:2394
void destroy_cell_queue_init(destroy_cell_queue_t *queue)
Definition: relay.c:2406
void update_circuit_on_cmux_(circuit_t *circ, cell_direction_t direction, const char *file, int lineno)
Definition: relay.c:2543
uint64_t stats_n_data_cells_packaged
Definition: relay.c:1849
void destroy_cell_queue_clear(destroy_cell_queue_t *queue)
Definition: relay.c:2414
uint64_t stats_n_data_bytes_packaged
Definition: relay.c:1853
void channel_unlink_all_circuits(channel_t *chan, smartlist_t *detached_out)
Definition: relay.c:2588
void dump_cell_pool_usage(int severity)
Definition: relay.c:2318
uint64_t stats_n_relay_cells_delivered
Definition: relay.c:117
uint32_t circid_t
Definition: or.h:1030
int have_been_under_memory_pressure(void)
Definition: relay.c:2532
STATIC int connection_edge_process_resolved_cell(edge_connection_t *conn, const cell_t *cell, const relay_header_t *rh)
Definition: relay.c:1198
STATIC int resolved_cell_parse(const cell_t *cell, const relay_header_t *rh, smartlist_t *addresses_out, int *errcode_out)
Definition: relay.c:1027
void destroy_cell_queue_append(destroy_cell_queue_t *queue, circid_t circid, uint8_t reason)
Definition: relay.c:2440
void circuit_clear_cell_queue(circuit_t *circ, channel_t *chan)
Definition: relay.c:3019
circid_t packed_cell_get_circid(const packed_cell_t *cell, int wide_circ_ids)
Definition: relay.c:2665
int append_address_to_payload(uint8_t *payload_out, const tor_addr_t *addr)
Definition: relay.c:2965
int circuit_receive_relay_cell(cell_t *cell, circuit_t *circ, cell_direction_t cell_direction)
Definition: relay.c:214
void cell_queue_clear(cell_queue_t *queue)
Definition: relay.c:2380