Header file for circuitmux.c. More...

#include "core/or/or.h"
#include "lib/testsupport/testsupport.h"

Data Structures
struct	circuitmux_policy_t

struct	circuitmux_policy_data_t

struct	circuitmux_policy_circ_data_t

Macros
#define	TO_CMUX_POL_DATA(x) (&((x)->base_))

#define	TO_CMUX_POL_CIRC_DATA(x) (&((x)->base_))

#define	circuitmux_free(cmux) FREE_AND_NULL(circuitmux_t, circuitmux_free_, (cmux))

Functions
void	circuitmux_assert_okay (circuitmux_t *cmux)

circuitmux_t *	circuitmux_alloc (void)

void	circuitmux_detach_all_circuits (circuitmux_t cmux, smartlist_t detached_out)

void	circuitmux_free_ (circuitmux_t *cmux)

void	circuitmux_clear_policy (circuitmux_t *cmux)

const circuitmux_policy_t *	circuitmux_get_policy (circuitmux_t *cmux)

void	circuitmux_set_policy (circuitmux_t cmux, const circuitmux_policy_t pol)

cell_direction_t	circuitmux_attached_circuit_direction (circuitmux_t cmux, circuit_t circ)

int	circuitmux_is_circuit_attached (circuitmux_t cmux, circuit_t circ)

int	circuitmux_is_circuit_active (circuitmux_t cmux, circuit_t circ)

unsigned int	circuitmux_num_cells_for_circuit (circuitmux_t cmux, circuit_t circ)

unsigned int	circuitmux_num_cells (circuitmux_t *cmux)

unsigned int	circuitmux_num_circuits (circuitmux_t *cmux)

unsigned int	circuitmux_num_active_circuits (circuitmux_t *cmux)

int64_t	circuitmux_count_queued_destroy_cells (const channel_t chan, const circuitmux_t cmux)

circuit_t *	circuitmux_get_first_active_circuit (circuitmux_t cmux, destroy_cell_queue_t *destroy_queue_out)

void	circuitmux_notify_xmit_cells (circuitmux_t cmux, circuit_t circ, unsigned int n_cells)

void	circuitmux_notify_xmit_destroy (circuitmux_t *cmux)

void	circuitmux_attach_circuit (circuitmux_t cmux, circuit_t circ, cell_direction_t direction)

void	circuitmux_detach_circuit (circuitmux_t cmux, circuit_t circ)

void	circuitmux_clear_num_cells (circuitmux_t cmux, circuit_t circ)

void	circuitmux_set_num_cells (circuitmux_t cmux, circuit_t circ, unsigned int n_cells)

void	circuitmux_append_destroy_cell (channel_t chan, circuitmux_t cmux, circid_t circ_id, uint8_t reason)

void	circuitmux_mark_destroyed_circids_usable (circuitmux_t cmux, channel_t chan)

int	circuitmux_compare_muxes (circuitmux_t cmux_1, circuitmux_t cmux_2)

Detailed Description

Header file for circuitmux.c.

Definition in file circuitmux.h.

Macro Definition Documentation

◆ circuitmux_free

#define circuitmux_free ( cmux ) FREE_AND_NULL(circuitmux_t, circuitmux_free_, (cmux))

Definition at line 108 of file circuitmux.h.

◆ TO_CMUX_POL_CIRC_DATA

#define TO_CMUX_POL_CIRC_DATA ( x ) (&((x)->base_))

Convert a circuitmux_policy_circ_data_t subtype to a circuitmux_policy_circ_data_t.

Definition at line 98 of file circuitmux.h.

◆ TO_CMUX_POL_DATA

#define TO_CMUX_POL_DATA ( x ) (&((x)->base_))

Convert a circuitmux_policy_data_t subtype to a circuitmux_policy_data_t.

Definition at line 91 of file circuitmux.h.

Function Documentation

◆ circuitmux_alloc()

circuitmux_t * circuitmux_alloc ( void )

Allocate a new circuitmux_t

Definition at line 194 of file circuitmux.c.

◆ circuitmux_append_destroy_cell()

void circuitmux_append_destroy_cell	(	channel_t *	chan,
		circuitmux_t *	cmux,
		circid_t	circ_id,
		uint8_t	reason
	)

Definition at line 1180 of file circuitmux.c.

◆ circuitmux_attach_circuit()

void circuitmux_attach_circuit	(	circuitmux_t *	cmux,
		circuit_t *	circ,
		cell_direction_t	direction
	)

Attach a circuit to a circuitmux, for the specified direction.

Definition at line 731 of file circuitmux.c.

◆ circuitmux_attached_circuit_direction()

cell_direction_t circuitmux_attached_circuit_direction	(	circuitmux_t *	cmux,
		circuit_t *	circ
	)

Query the direction of an attached circuit

Definition at line 549 of file circuitmux.c.

◆ circuitmux_clear_num_cells()

void circuitmux_clear_num_cells	(	circuitmux_t *	cmux,
		circuit_t *	circ
	)

Clear the cell counter for a circuit on a circuitmux

Definition at line 988 of file circuitmux.c.

◆ circuitmux_clear_policy()

void circuitmux_clear_policy ( circuitmux_t * cmux )

Remove any policy installed on cmux; all policy data will be freed and cmux behavior will revert to the built-in round-robin active_circuits mechanism.

Definition at line 402 of file circuitmux.c.

◆ circuitmux_compare_muxes()

int circuitmux_compare_muxes	(	circuitmux_t *	cmux_1,
		circuitmux_t *	cmux_2
	)

Compare cmuxes to see which is more preferred; return < 0 if cmux_1 has higher priority (i.e., cmux_1 < cmux_2 in the scheduler's sort order), > 0 if cmux_2 has higher priority, or 0 if they are equally preferred.

If the cmuxes have different cmux policies or the policy does not support the cmp_cmux method, return 0.

Definition at line 1255 of file circuitmux.c.

Referenced by scheduler_compare_channels().

◆ circuitmux_count_queued_destroy_cells()

int64_t circuitmux_count_queued_destroy_cells	(	const channel_t *	chan,
		const circuitmux_t *	cmux
	)

Definition at line 1210 of file circuitmux.c.

◆ circuitmux_detach_all_circuits()

void circuitmux_detach_all_circuits	(	circuitmux_t *	cmux,
		smartlist_t *	detached_out
	)

Detach all circuits from a circuitmux (use before circuitmux_free())

If detached_out is non-NULL, add every detached circuit_t to detached_out.

Definition at line 214 of file circuitmux.c.

Referenced by channel_unlink_all_circuits().

◆ circuitmux_detach_circuit()

void circuitmux_detach_circuit	(	circuitmux_t *	cmux,
		circuit_t *	circ
	)

Detach a circuit from a circuitmux and update all counters as needed; no-op if not attached.

Definition at line 852 of file circuitmux.c.

Referenced by circuit_about_to_free_atexit().

◆ circuitmux_free_()

void circuitmux_free_ ( circuitmux_t * cmux )

Free a circuitmux_t; the circuits must be detached first with circuitmux_detach_all_circuits().

Definition at line 338 of file circuitmux.c.

◆ circuitmux_get_first_active_circuit()

circuit_t * circuitmux_get_first_active_circuit	(	circuitmux_t *	cmux,
		destroy_cell_queue_t **	destroy_queue_out
	)

Pick a circuit to send from, using the active circuits list or a circuitmux policy if one is available. This is called from channel.c.

If we would rather send a destroy cell, return NULL and set *destroy_queue_out to the destroy queue.

If we have nothing to send, set *destroy_queue_out to NULL and return NULL.

Definition at line 1061 of file circuitmux.c.

Referenced by channel_flush_from_first_active_circuit().

◆ circuitmux_get_policy()

const circuitmux_policy_t * circuitmux_get_policy ( circuitmux_t * cmux )

Return the policy currently installed on a circuitmux_t

Definition at line 415 of file circuitmux.c.

Referenced by scheduler_compare_channels().

◆ circuitmux_is_circuit_active()

int circuitmux_is_circuit_active	(	circuitmux_t *	cmux,
		circuit_t *	circ
	)

Query whether a circuit is active on a circuitmux

Definition at line 642 of file circuitmux.c.

◆ circuitmux_is_circuit_attached()

int circuitmux_is_circuit_attached	(	circuitmux_t *	cmux,
		circuit_t *	circ
	)

Query whether a circuit is attached to a circuitmux

Definition at line 627 of file circuitmux.c.

Referenced by circuit_clear_cell_queue(), and update_circuit_on_cmux_().

◆ circuitmux_mark_destroyed_circids_usable()

void circuitmux_mark_destroyed_circids_usable	(	circuitmux_t *	cmux,
		channel_t *	chan
	)

Reclaim all circuit IDs currently marked as unusable on chan because of pending destroy cells in cmux.

This function must be called AFTER circuits are unlinked from the (channel, circuid-id) map with circuit_unlink_all_from_channel(), but before calling circuitmux_free().

Definition at line 324 of file circuitmux.c.

◆ circuitmux_notify_xmit_cells()

void circuitmux_notify_xmit_cells	(	circuitmux_t *	cmux,
		circuit_t *	circ,
		unsigned int	n_cells
	)

Notify the circuitmux that cells have been sent on a circuit; this is called from channel.c.

Definition at line 1104 of file circuitmux.c.

◆ circuitmux_notify_xmit_destroy()

void circuitmux_notify_xmit_destroy ( circuitmux_t * cmux )

Notify the circuitmux that a destroy was sent, so we can update the counter.

Definition at line 1164 of file circuitmux.c.

Referenced by channel_flush_from_first_active_circuit().

◆ circuitmux_num_active_circuits()

unsigned int circuitmux_num_active_circuits ( circuitmux_t * cmux )

Query total number of circuits active on a circuitmux

Definition at line 702 of file circuitmux.c.

◆ circuitmux_num_cells()

unsigned int circuitmux_num_cells ( circuitmux_t * cmux )

Query total number of available cells on a circuitmux

Definition at line 690 of file circuitmux.c.

Referenced by channel_more_to_flush().

◆ circuitmux_num_cells_for_circuit()

unsigned int circuitmux_num_cells_for_circuit	(	circuitmux_t *	cmux,
		circuit_t *	circ
	)

Query number of available cells for a circuit on a circuitmux

Definition at line 666 of file circuitmux.c.

◆ circuitmux_num_circuits()

unsigned int circuitmux_num_circuits ( circuitmux_t * cmux )

Query total number of circuits attached to a circuitmux

Definition at line 714 of file circuitmux.c.

◆ circuitmux_set_num_cells()

void circuitmux_set_num_cells	(	circuitmux_t *	cmux,
		circuit_t *	circ,
		unsigned int	n_cells
	)

Set the cell counter for a circuit on a circuitmux

Definition at line 999 of file circuitmux.c.

Referenced by channel_flush_from_first_active_circuit(), and circuitmux_clear_num_cells().

◆ circuitmux_set_policy()

void circuitmux_set_policy	(	circuitmux_t *	cmux,
		const circuitmux_policy_t *	pol
	)

Set policy; allocate for new policy, detach all circuits from old policy if any, attach them to new policy, and free old policy data.

Definition at line 428 of file circuitmux.c.

Referenced by circuitmux_clear_policy().

Data Structures

Macros

Functions