circuitlist.h 5.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107
  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-2018, The Tor Project, Inc. */
  5. /* See LICENSE for licensing information */
  6. /**
  7. * \file circuitlist.h
  8. * \brief Header file for circuitlist.c.
  9. **/
  10. #ifndef TOR_CIRCUITLIST_H
  11. #define TOR_CIRCUITLIST_H
  12. #include "lib/testsupport/testsupport.h"
  13. #include "or/hs_ident.h"
  14. /** Convert a circuit_t* to a pointer to the enclosing or_circuit_t. Assert
  15. * if the cast is impossible. */
  16. or_circuit_t *TO_OR_CIRCUIT(circuit_t *);
  17. const or_circuit_t *CONST_TO_OR_CIRCUIT(const circuit_t *);
  18. /** Convert a circuit_t* to a pointer to the enclosing origin_circuit_t.
  19. * Assert if the cast is impossible. */
  20. origin_circuit_t *TO_ORIGIN_CIRCUIT(circuit_t *);
  21. const origin_circuit_t *CONST_TO_ORIGIN_CIRCUIT(const circuit_t *);
  22. MOCK_DECL(smartlist_t *, circuit_get_global_list, (void));
  23. smartlist_t *circuit_get_global_origin_circuit_list(void);
  24. int circuit_any_opened_circuits(void);
  25. int circuit_any_opened_circuits_cached(void);
  26. void circuit_cache_opened_circuit_state(int circuits_are_opened);
  27. const char *circuit_state_to_string(int state);
  28. const char *circuit_purpose_to_controller_string(uint8_t purpose);
  29. const char *circuit_purpose_to_controller_hs_state_string(uint8_t purpose);
  30. const char *circuit_purpose_to_string(uint8_t purpose);
  31. void circuit_dump_by_conn(connection_t *conn, int severity);
  32. void circuit_set_p_circid_chan(or_circuit_t *circ, circid_t id,
  33. channel_t *chan);
  34. void circuit_set_n_circid_chan(circuit_t *circ, circid_t id,
  35. channel_t *chan);
  36. void channel_mark_circid_unusable(channel_t *chan, circid_t id);
  37. void channel_mark_circid_usable(channel_t *chan, circid_t id);
  38. time_t circuit_id_when_marked_unusable_on_channel(circid_t circ_id,
  39. channel_t *chan);
  40. void circuit_set_state(circuit_t *circ, uint8_t state);
  41. void circuit_close_all_marked(void);
  42. int32_t circuit_initial_package_window(void);
  43. origin_circuit_t *origin_circuit_new(void);
  44. or_circuit_t *or_circuit_new(circid_t p_circ_id, channel_t *p_chan);
  45. circuit_t *circuit_get_by_circid_channel(circid_t circ_id,
  46. channel_t *chan);
  47. circuit_t *
  48. circuit_get_by_circid_channel_even_if_marked(circid_t circ_id,
  49. channel_t *chan);
  50. int circuit_id_in_use_on_channel(circid_t circ_id, channel_t *chan);
  51. circuit_t *circuit_get_by_edge_conn(edge_connection_t *conn);
  52. void circuit_unlink_all_from_channel(channel_t *chan, int reason);
  53. origin_circuit_t *circuit_get_by_global_id(uint32_t id);
  54. origin_circuit_t *circuit_get_ready_rend_circ_by_rend_data(
  55. const rend_data_t *rend_data);
  56. origin_circuit_t *circuit_get_next_by_pk_and_purpose(origin_circuit_t *start,
  57. const uint8_t *digest, uint8_t purpose);
  58. origin_circuit_t *circuit_get_next_service_intro_circ(origin_circuit_t *start);
  59. origin_circuit_t *circuit_get_next_service_rp_circ(origin_circuit_t *start);
  60. origin_circuit_t *circuit_get_next_service_hsdir_circ(origin_circuit_t *start);
  61. origin_circuit_t *circuit_find_to_cannibalize(uint8_t purpose,
  62. extend_info_t *info, int flags);
  63. void circuit_mark_all_unused_circs(void);
  64. void circuit_mark_all_dirty_circs_as_unusable(void);
  65. MOCK_DECL(void, circuit_mark_for_close_, (circuit_t *circ, int reason,
  66. int line, const char *file));
  67. int circuit_get_cpath_len(origin_circuit_t *circ);
  68. int circuit_get_cpath_opened_len(const origin_circuit_t *);
  69. void circuit_clear_cpath(origin_circuit_t *circ);
  70. crypt_path_t *circuit_get_cpath_hop(origin_circuit_t *circ, int hopnum);
  71. void circuit_get_all_pending_on_channel(smartlist_t *out,
  72. channel_t *chan);
  73. int circuit_count_pending_on_channel(channel_t *chan);
  74. #define circuit_mark_for_close(c, reason) \
  75. circuit_mark_for_close_((c), (reason), __LINE__, SHORT_FILE__)
  76. void assert_cpath_layer_ok(const crypt_path_t *cp);
  77. MOCK_DECL(void, assert_circuit_ok,(const circuit_t *c));
  78. void circuit_free_all(void);
  79. void circuits_handle_oom(size_t current_allocation);
  80. void circuit_clear_testing_cell_stats(circuit_t *circ);
  81. void channel_note_destroy_pending(channel_t *chan, circid_t id);
  82. MOCK_DECL(void, channel_note_destroy_not_pending,
  83. (channel_t *chan, circid_t id));
  84. smartlist_t *circuit_find_circuits_to_upgrade_from_guard_wait(void);
  85. #ifdef CIRCUITLIST_PRIVATE
  86. STATIC void circuit_free_(circuit_t *circ);
  87. #define circuit_free(circ) FREE_AND_NULL(circuit_t, circuit_free_, (circ))
  88. STATIC size_t n_cells_in_circ_queues(const circuit_t *c);
  89. STATIC uint32_t circuit_max_queued_data_age(const circuit_t *c, uint32_t now);
  90. STATIC uint32_t circuit_max_queued_cell_age(const circuit_t *c, uint32_t now);
  91. STATIC uint32_t circuit_max_queued_item_age(const circuit_t *c, uint32_t now);
  92. #endif /* defined(CIRCUITLIST_PRIVATE) */
  93. #endif /* !defined(TOR_CIRCUITLIST_H) */