15 void control_initialize_event_queue(
void);
27 #define LOG_FN_CONN(conn, args) \ 28 CONN_LOG_PROTECT(conn, log_fn args) 30 #define CC_LOCAL_FD_IS_OWNER (1u<<0) 31 #define CC_LOCAL_FD_IS_AUTHENTICATED (1u<<1) 40 #define EVENT_NS 0x000F 52 const struct timeval *old_tv_created);
69 time_t expires,
const char *error,
98 int init_control_cookie_authentication(
int enabled);
107 MOCK_DECL(
void, control_event_bootstrap_prob_or,(const
char *warn,
115 const
char *transport_name,
118 MOCK_DECL(const
char *, node_describe_longname_by_id,(const
char *id_digest));
121 const
char *id_digest,
123 const
char *hsdir_index);
130 const
char *hsdir_index);
132 const
char *onion_address,
136 const
char *onion_address);
139 const
char *id_digest,
143 const
char *id_digest);
147 const
char *hsdir_id_digest,
149 void control_event_hsv3_descriptor_received(const
char *onion_address,
151 const
char *hsdir_id_digest);
153 const
char *onion_address,
157 const
char *hsdir_fp,
158 const
char *content);
162 #ifdef CONTROL_PRIVATE 168 #define EVENT_MIN_ 0x0001 169 #define EVENT_CIRCUIT_STATUS 0x0001 170 #define EVENT_STREAM_STATUS 0x0002 171 #define EVENT_OR_CONN_STATUS 0x0003 172 #define EVENT_BANDWIDTH_USED 0x0004 173 #define EVENT_CIRCUIT_STATUS_MINOR 0x0005 174 #define EVENT_NEW_DESC 0x0006 175 #define EVENT_DEBUG_MSG 0x0007 176 #define EVENT_INFO_MSG 0x0008 177 #define EVENT_NOTICE_MSG 0x0009 178 #define EVENT_WARN_MSG 0x000A 179 #define EVENT_ERR_MSG 0x000B 180 #define EVENT_ADDRMAP 0x000C 183 #define EVENT_DESCCHANGED 0x000E 186 #define EVENT_STATUS_CLIENT 0x0010 187 #define EVENT_STATUS_SERVER 0x0011 188 #define EVENT_STATUS_GENERAL 0x0012 189 #define EVENT_GUARD 0x0013 190 #define EVENT_STREAM_BANDWIDTH_USED 0x0014 191 #define EVENT_CLIENTS_SEEN 0x0015 192 #define EVENT_NEWCONSENSUS 0x0016 193 #define EVENT_BUILDTIMEOUT_SET 0x0017 194 #define EVENT_GOT_SIGNAL 0x0018 195 #define EVENT_CONF_CHANGED 0x0019 196 #define EVENT_CONN_BW 0x001A 197 #define EVENT_CELL_STATS 0x001B 199 #define EVENT_CIRC_BANDWIDTH_USED 0x001D 200 #define EVENT_TRANSPORT_LAUNCHED 0x0020 201 #define EVENT_HS_DESC 0x0021 202 #define EVENT_HS_DESC_CONTENT 0x0022 203 #define EVENT_NETWORK_LIVENESS 0x0023 204 #define EVENT_MAX_ 0x0023 207 #define EVENT_CAPACITY_ 0x0040 212 #if EVENT_MAX_ >= EVENT_CAPACITY_ 213 #error control_connection_t.event_mask has an event greater than its capacity 216 #define EVENT_MASK_(e) (((uint64_t)1)<<(e)) 218 #define EVENT_MASK_NONE_ ((uint64_t)0x0) 220 #define EVENT_MASK_ABOVE_MIN_ ((~((uint64_t)0x0)) << EVENT_MIN_) 221 #define EVENT_MASK_BELOW_MAX_ ((~((uint64_t)0x0)) \ 222 >> (EVENT_CAPACITY_ - EVENT_MAX_ \ 225 #define EVENT_MASK_ALL_ (EVENT_MASK_ABOVE_MIN_ \ 226 & EVENT_MASK_BELOW_MAX_) 232 #ifdef TOR_UNIT_TESTS 234 send_control_event_string,(uint16_t event,
const char *msg));
237 queue_control_event_string,(uint16_t event,
char *msg));
239 void control_testing_set_global_event_mask(uint64_t mask);
243 typedef struct cell_stats_t {
245 uint64_t added_cells_appward[CELL_COMMAND_MAX_ + 1];
247 uint64_t added_cells_exitward[CELL_COMMAND_MAX_ + 1];
249 uint64_t removed_cells_appward[CELL_COMMAND_MAX_ + 1];
251 uint64_t removed_cells_exitward[CELL_COMMAND_MAX_ + 1];
253 uint64_t total_time_appward[CELL_COMMAND_MAX_ + 1];
255 uint64_t total_time_exitward[CELL_COMMAND_MAX_ + 1];
258 cell_stats_t *cell_stats);
261 const uint64_t *include_if_non_zero,
262 const uint64_t *number_to_include);
264 cell_stats_t *cell_stats);
265 STATIC
char *get_bw_samples(
void);
270 typedef union add_onion_secret_key_t {
275 } add_onion_secret_key_t;
278 const char **key_new_alg_out,
279 char **key_new_blob_out,
280 add_onion_secret_key_t *decoded_key,
281 int *hs_version,
char **err_msg_out);
288 const char *question,
290 const char **errmsg);
294 const char **errmsg);
296 const char *fp_sk_req,
299 const char **errmsg);
301 const char *desc_req,
304 const char **errmsg);
306 const char *bridge_req,
309 const char **errmsg);
312 const char *question,
char **answer,
313 const char **errmsg);
316 const char *question,
char **answer,
317 const char **errmsg);
320 const char *question,
char **answer,
321 const char **errmsg);
int connection_control_finished_flushing(control_connection_t *conn)
Definition: control.c:5174
STATIC int add_onion_helper_keyarg(const char *arg, int discard_pk, const char **key_new_alg_out, char **key_new_blob_out, add_onion_secret_key_t *decoded_key, int *hs_version, char **err_msg_out)
Definition: control.c:4900
void control_adjust_event_log_severity(void)
Definition: control.c:333
Definition: confline.h:23
void format_cell_stats(char **event_string, circuit_t *circ, cell_stats_t *cell_stats)
Definition: control.c:6124
int connection_control_reached_eof(control_connection_t *conn)
Definition: control.c:5182
bootstrap_status_t
Definition: or.h:5069
smartlist_t * decode_hashed_passwords(config_line_t *passwords)
Definition: control.c:1368
int control_any_per_second_event_enabled(void)
Definition: control.c:377
int control_event_stream_bandwidth_used(void)
Definition: control.c:5942
STATIC void getinfo_helper_downloads_cert(const char *fp_sk_req, download_status_t **dl_to_emit, smartlist_t **digest_list, const char **errmsg)
Definition: control.c:2465
int control_connection_add_local_fd(tor_socket_t sock, unsigned flags)
Definition: control.c:639
void control_event_transport_launched(const char *mode, const char *transport_name, tor_addr_t *addr, uint16_t port)
Definition: control.c:7223
int control_event_descriptors_changed(smartlist_t *routers)
Definition: control.c:6348
int control_event_circ_bandwidth_used(void)
Definition: control.c:5978
int int int int int int int control_event_guard(const char *nickname, const char *digest, const char *status)
Definition: control.c:6742
void control_ports_write_to_file(void)
Definition: control.c:701
void sum_up_cell_stats_by_command(circuit_t *circ, cell_stats_t *cell_stats)
Definition: control.c:6068
circuit_status_event_t
Definition: or.h:5001
int control_event_circuit_status(origin_circuit_t *circ, circuit_status_event_t e, int reason)
Definition: control.c:5542
int control_event_networkstatus_changed(smartlist_t *statuses)
Definition: control.c:6495
int control_event_my_descriptor_changed(void)
Definition: control.c:6609
void control_event_bootstrap_problem(const char *warn, const char *reason, const connection_t *conn, int dowarn)
Definition: control.c:7102
int control_event_general_error(const char *format,...)
Definition: control.c:6690
int control_event_conn_bandwidth(connection_t *conn)
Definition: control.c:6018
MOCK_DECL(int, router_have_minimum_dir_info,(void))
Definition: container.h:18
STATIC size_t read_escaped_data(const char *data, size_t len, char **out)
Definition: control.c:508
void control_event_clients_seen(const char *controller_str)
Definition: control.c:7210
stream_status_event_t
Definition: or.h:5018
STATIC void getinfo_helper_downloads_networkstatus(const char *flavor, download_status_t **dl_to_emit, const char **errmsg)
Definition: control.c:2436
STATIC void getinfo_helper_downloads_bridge(const char *bridge_req, download_status_t **dl_to_emit, smartlist_t **digest_list, const char **errmsg)
Definition: control.c:2611
rend_auth_type_t
Definition: or.h:826
void control_event_logmsg(int severity, uint32_t domain, const char *msg)
Definition: control.c:6275
char * get_controller_cookie_file_name(void)
Definition: control.c:6800
void append_cell_stats_by_command(smartlist_t *event_parts, const char *key, const uint64_t *include_if_non_zero, const uint64_t *number_to_include)
Definition: control.c:6099
int control_event_signal(uintptr_t signal)
Definition: control.c:6551
void control_event_hsv3_descriptor_failed(const char *onion_address, const char *desc_id, const char *hsdir_id_digest, const char *reason)
Definition: control.c:7617
STATIC int getinfo_helper_onions(control_connection_t *control_conn, const char *question, char **answer, const char **errmsg)
Definition: control.c:3060
int control_event_general_status(int severity, const char *format,...)
Definition: control.c:6681
int control_event_conn_bandwidth_used(void)
Definition: control.c:6053
void control_event_hs_descriptor_upload_failed(const char *hs_dir, const char *onion_address, const char *reason)
Definition: control.c:7680
void enable_control_logging(void)
Definition: control.c:6267
int control_event_address_mapped(const char *from, const char *to, time_t expires, const char *error, const int cached)
Definition: control.c:6380
void connection_control_closed(control_connection_t *conn)
Definition: control.c:5204
void control_update_global_event_mask(void)
Definition: control.c:277
int control_event_networkstatus_changed_single(const routerstatus_t *rs)
Definition: control.c:6591
STATIC void getinfo_helper_downloads_desc(const char *desc_req, download_status_t **dl_to_emit, smartlist_t **digest_list, const char **errmsg)
Definition: control.c:2565
STATIC int getinfo_helper_dir(control_connection_t *control_conn, const char *question, char **answer, const char **errmsg)
Definition: control.c:2046
Definition: compat_time.h:33
void control_event_logmsg_pending(void)
Definition: control.c:6330
void control_event_hsv2_descriptor_received(const char *onion_address, const rend_data_t *rend_data, const char *id_digest)
Definition: control.c:7511
void disable_control_logging(void)
Definition: control.c:6259
STATIC int getinfo_helper_downloads(control_connection_t *control_conn, const char *question, char **answer, const char **errmsg)
Definition: control.c:2654
int control_event_circuit_purpose_changed(origin_circuit_t *circ, int old_purpose)
Definition: control.c:5671
int control_event_stream_bandwidth(edge_connection_t *edge_conn)
Definition: control.c:5916
STATIC size_t write_escaped_data(const char *data, size_t len, char **out)
Definition: control.c:452
STATIC rend_authorized_client_t * add_onion_helper_clientauth(const char *arg, int *created, char **err_msg)
Definition: control.c:5036
buildtimeout_set_event_t
Definition: or.h:5041
int control_event_bootstrap(bootstrap_status_t status, int progress)
Definition: control.c:7036
int control_event_server_status(int severity, const char *format,...)
Definition: control.c:6721
int control_event_stream_status(entry_connection_t *conn, stream_status_event_t e, int reason)
Definition: control.c:5721
int control_event_newconsensus(const networkstatus_t *consensus)
Definition: control.c:6503
int connection_control_process_inbuf(control_connection_t *conn)
Definition: control.c:5301
void control_event_hsv2_descriptor_failed(const rend_data_t *rend_data, const char *id_digest, const char *reason)
Definition: control.c:7583
void control_event_hs_descriptor_uploaded(const char *hs_dir, const char *onion_address)
Definition: control.c:7566
Definition: crypto_ed25519.h:28
void control_event_hs_descriptor_requested(const char *onion_address, rend_auth_type_t auth_type, const char *id_digest, const char *desc_id, const char *hsdir_index)
Definition: control.c:7301
const char * rend_auth_type_to_string(rend_auth_type_t auth_type)
Definition: control.c:7234
int control_event_buildtimeout_set(buildtimeout_set_event_t type, const char *args)
Definition: control.c:6513
Definition: crypto_rsa.c:41
int control_event_client_error(const char *format,...)
Definition: control.c:6710
void control_event_hs_descriptor_upload(const char *onion_address, const char *desc_id, const char *hs_dir, const char *hsdir_index)
Definition: control.c:7407
STATIC int getinfo_helper_current_time(control_connection_t *control_conn, const char *question, char **answer, const char **errmsg)
Definition: control.c:2021
void control_event_hs_descriptor_content(const char *onion_address, const char *desc_id, const char *hsdir_fp, const char *content)
Definition: control.c:7643
void control_event_hs_descriptor_created(const char *onion_address, const char *desc_id, int replica)
Definition: control.c:7379
void control_free_all(void)
Definition: control.c:7693
int control_event_client_status(int severity, const char *format,...)
Definition: control.c:6701
int control_event_circuit_cannibalized(origin_circuit_t *circ, int old_purpose, const struct timeval *old_tv_created)
Definition: control.c:5685
int control_event_is_interesting(int event)
Definition: control.c:370
int control_event_bandwidth_used(uint32_t n_read, uint32_t n_written)
Definition: control.c:6207
int control_event_network_liveness_update(int liveness)
Definition: control.c:6429
void control_per_second_events(void)
Definition: control.c:419
int control_event_server_error(const char *format,...)
Definition: control.c:6730
int control_event_circuit_cell_stats(void)
Definition: control.c:6171
or_conn_status_event_t
Definition: or.h:5032
int control_event_or_conn_status(or_connection_t *conn, or_conn_status_event_t e, int reason)
Definition: control.c:5868
void monitor_owning_controller_process(const char *process_spec)
Definition: control.c:6855
void control_event_hs_descriptor_upload_end(const char *action, const char *onion_address, const char *hs_dir, const char *reason)
Definition: control.c:7481
int control_event_conf_changed(const smartlist_t *elements)
Definition: control.c:6769