relay.h 4.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109
  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 relay.h
  8. * \brief Header file for relay.c.
  9. **/
  10. #ifndef TOR_RELAY_H
  11. #define TOR_RELAY_H
  12. extern uint64_t stats_n_relay_cells_relayed;
  13. extern uint64_t stats_n_relay_cells_delivered;
  14. int circuit_receive_relay_cell(cell_t *cell, circuit_t *circ,
  15. cell_direction_t cell_direction);
  16. void relay_header_pack(uint8_t *dest, const relay_header_t *src);
  17. void relay_header_unpack(relay_header_t *dest, const uint8_t *src);
  18. int relay_send_command_from_edge_(streamid_t stream_id, circuit_t *circ,
  19. uint8_t relay_command, const char *payload,
  20. size_t payload_len, crypt_path_t *cpath_layer,
  21. const char *filename, int lineno);
  22. #define relay_send_command_from_edge(stream_id, circ, relay_command, payload, \
  23. payload_len, cpath_layer) \
  24. relay_send_command_from_edge_((stream_id), (circ), (relay_command), \
  25. (payload), (payload_len), (cpath_layer), \
  26. __FILE__, __LINE__)
  27. int connection_edge_send_command(edge_connection_t *fromconn,
  28. uint8_t relay_command, const char *payload,
  29. size_t payload_len);
  30. int connection_edge_package_raw_inbuf(edge_connection_t *conn,
  31. int package_partial,
  32. int *max_cells);
  33. void connection_edge_consider_sending_sendme(edge_connection_t *conn);
  34. extern uint64_t stats_n_data_cells_packaged;
  35. extern uint64_t stats_n_data_bytes_packaged;
  36. extern uint64_t stats_n_data_cells_received;
  37. extern uint64_t stats_n_data_bytes_received;
  38. #ifdef ENABLE_MEMPOOLS
  39. void init_cell_pool(void);
  40. void free_cell_pool(void);
  41. void clean_cell_pool(void);
  42. #endif /* ENABLE_MEMPOOLS */
  43. void dump_cell_pool_usage(int severity);
  44. size_t packed_cell_mem_cost(void);
  45. /* For channeltls.c */
  46. void packed_cell_free(packed_cell_t *cell);
  47. void cell_queue_init(cell_queue_t *queue);
  48. void cell_queue_clear(cell_queue_t *queue);
  49. void cell_queue_append(cell_queue_t *queue, packed_cell_t *cell);
  50. void cell_queue_append_packed_copy(circuit_t *circ, cell_queue_t *queue,
  51. int exitward, const cell_t *cell,
  52. int wide_circ_ids, int use_stats);
  53. void append_cell_to_circuit_queue(circuit_t *circ, channel_t *chan,
  54. cell_t *cell, cell_direction_t direction,
  55. streamid_t fromstream);
  56. void channel_unlink_all_circuits(channel_t *chan, smartlist_t *detached_out);
  57. int channel_flush_from_first_active_circuit(channel_t *chan, int max);
  58. void assert_circuit_mux_okay(channel_t *chan);
  59. void update_circuit_on_cmux_(circuit_t *circ, cell_direction_t direction,
  60. const char *file, int lineno);
  61. #define update_circuit_on_cmux(circ, direction) \
  62. update_circuit_on_cmux_((circ), (direction), SHORT_FILE__, __LINE__)
  63. int append_address_to_payload(uint8_t *payload_out, const tor_addr_t *addr);
  64. const uint8_t *decode_address_from_payload(tor_addr_t *addr_out,
  65. const uint8_t *payload,
  66. int payload_len);
  67. void circuit_clear_cell_queue(circuit_t *circ, channel_t *chan);
  68. void stream_choice_seed_weak_rng(void);
  69. int relay_crypt(circuit_t *circ, cell_t *cell, cell_direction_t cell_direction,
  70. crypt_path_t **layer_hint, char *recognized);
  71. circid_t packed_cell_get_circid(const packed_cell_t *cell, int wide_circ_ids);
  72. #ifdef RELAY_PRIVATE
  73. STATIC int connected_cell_parse(const relay_header_t *rh, const cell_t *cell,
  74. tor_addr_t *addr_out, int *ttl_out);
  75. /** An address-and-ttl tuple as yielded by resolved_cell_parse */
  76. typedef struct address_ttl_s {
  77. tor_addr_t addr;
  78. char *hostname;
  79. int ttl;
  80. } address_ttl_t;
  81. STATIC void address_ttl_free(address_ttl_t *addr);
  82. STATIC int resolved_cell_parse(const cell_t *cell, const relay_header_t *rh,
  83. smartlist_t *addresses_out, int *errcode_out);
  84. STATIC int connection_edge_process_resolved_cell(edge_connection_t *conn,
  85. const cell_t *cell,
  86. const relay_header_t *rh);
  87. STATIC packed_cell_t *packed_cell_new(void);
  88. STATIC packed_cell_t *cell_queue_pop(cell_queue_t *queue);
  89. STATIC size_t cell_queues_get_total_allocation(void);
  90. STATIC int cell_queues_check_size(void);
  91. #endif
  92. #endif