Public APIs for conflux multipath support. More...

#include "core/or/circuit_st.h"
#include "core/or/conflux_st.h"
#include "core/or/relay_msg_st.h"

Data Structures
struct	conflux_msg_t

Macros
#define	CONFLUX_FOR_EACH_LEG_BEGIN(cfx, var) SMARTLIST_FOREACH_BEGIN(cfx->legs, conflux_leg_t *, var)

#define	CONFLUX_FOR_EACH_LEG_END(var) SMARTLIST_FOREACH_END(var)

#define	CONFLUX_NUM_LEGS(cfx) (smartlist_len(cfx->legs))

#define	conflux_relay_msg_free(msg) FREE_AND_NULL(conflux_msg_t, conflux_relay_msg_free_, (msg))

Functions
size_t	conflux_handle_oom (size_t bytes_to_remove)

uint64_t	conflux_get_total_bytes_allocation (void)

uint64_t	conflux_get_circ_bytes_allocation (const circuit_t *circ)

void	conflux_update_rtt (conflux_t cfx, circuit_t circ, uint64_t rtt_usec)

circuit_t *	conflux_decide_circ_for_send (conflux_t cfx, circuit_t orig_circ, uint8_t relay_command)

circuit_t *	conflux_decide_next_circ (conflux_t *cfx)

int	conflux_process_switch_command (circuit_t in_circ, crypt_path_t layer_hint, const relay_msg_t *msg)

bool	conflux_should_multiplex (int relay_command)

bool	conflux_process_relay_msg (conflux_t cfx, circuit_t in_circ, crypt_path_t layer_hint, const relay_msg_t msg)

conflux_msg_t *	conflux_dequeue_relay_msg (conflux_t *cfx)

void	conflux_note_cell_sent (conflux_t cfx, circuit_t circ, uint8_t relay_command)

void	conflux_relay_msg_free_ (conflux_msg_t *msg)

Detailed Description

Public APIs for conflux multipath support.

Definition in file conflux.h.

Macro Definition Documentation

◆ CONFLUX_FOR_EACH_LEG_BEGIN

#define CONFLUX_FOR_EACH_LEG_BEGIN	(	cfx,
		var
	)	SMARTLIST_FOREACH_BEGIN(cfx->legs, conflux_leg_t *, var)

Helpers to iterate over legs with better semantic.

Definition at line 20 of file conflux.h.

◆ CONFLUX_FOR_EACH_LEG_END

#define CONFLUX_FOR_EACH_LEG_END ( var ) SMARTLIST_FOREACH_END(var)

Definition at line 22 of file conflux.h.

◆ CONFLUX_NUM_LEGS

#define CONFLUX_NUM_LEGS ( cfx ) (smartlist_len(cfx->legs))

Helper: Return the number of legs a conflux object has.

Definition at line 26 of file conflux.h.

◆ conflux_relay_msg_free

#define conflux_relay_msg_free ( msg ) FREE_AND_NULL(conflux_msg_t, conflux_relay_msg_free_, (msg))

Definition at line 67 of file conflux.h.

Function Documentation

◆ conflux_decide_circ_for_send()

circuit_t * conflux_decide_circ_for_send	(	conflux_t *	cfx,
		circuit_t *	orig_circ,
		uint8_t	relay_command
	)

This function is called when we want to send a relay cell on a conflux, as well as when we want to compute available space in to package from streams.

It determines the circuit that relay command should be sent on, and sends a SWITCH cell if necessary.

It returns the circuit we should send on. If no circuits are ready to send, it returns NULL.

Definition at line 458 of file conflux.c.

Referenced by relay_send_command_from_edge_().

◆ conflux_decide_next_circ()

circuit_t * conflux_decide_next_circ ( conflux_t * cfx )

Returns the circuit that conflux would send on next, if conflux_decide_circ_for_send were called. This is used to compute available space in the package window.

Definition at line 610 of file conflux.c.

Referenced by circuit_get_package_window(), circuit_resume_edge_reading_helper(), conflux_can_send(), and conflux_decide_circ_for_send().

◆ conflux_dequeue_relay_msg()

conflux_msg_t * conflux_dequeue_relay_msg ( conflux_t * cfx )

Dequeue the top cell from our queue.

Returns the cell as a conflux_cell_t, or NULL if the queue is empty or has a hole.

Definition at line 912 of file conflux.c.

Referenced by connection_edge_process_relay_cell().

◆ conflux_get_circ_bytes_allocation()

uint64_t conflux_get_circ_bytes_allocation ( const circuit_t * circ )

Return the total memory allocation the circuit is using by conflux. If this circuit is not a Conflux circuit, 0 is returned.

Definition at line 172 of file conflux.c.

Referenced by circuits_handle_oom().

◆ conflux_get_total_bytes_allocation()

uint64_t conflux_get_total_bytes_allocation ( void )

Return the total memory allocation in bytes by the subsystem.

At the moment, only out of order queues are consiered.

Definition at line 185 of file conflux.c.

Referenced by cell_queues_check_size().

◆ conflux_handle_oom()

size_t conflux_handle_oom ( size_t bytes_to_remove )

The OOM handler is asking us to try to free at least bytes_to_remove.

Definition at line 192 of file conflux.c.

Referenced by cell_queues_check_size().

◆ conflux_note_cell_sent()

void conflux_note_cell_sent	(	conflux_t *	cfx,
		circuit_t *	circ,
		uint8_t	relay_command
	)

Called after conflux actually sent a cell on a circuit. This function updates sequence number counters, and switch counters.

Definition at line 529 of file conflux.c.

Referenced by relay_send_command_from_edge_().

◆ conflux_process_relay_msg()

bool conflux_process_relay_msg	(	conflux_t *	cfx,
		circuit_t *	in_circ,
		crypt_path_t *	layer_hint,
		const relay_msg_t *	msg
	)

Process an incoming relay cell for conflux. Called from connection_edge_process_relay_cell().

Returns true if the conflux system now has well-ordered cells to deliver to streams, false otherwise.

Definition at line 845 of file conflux.c.

Referenced by connection_edge_process_relay_cell().

◆ conflux_process_switch_command()

int conflux_process_switch_command	(	circuit_t *	in_circ,
		crypt_path_t *	layer_hint,
		const relay_msg_t *	msg
	)

Validate and handle RELAY_COMMAND_CONFLUX_SWITCH.

Definition at line 738 of file conflux.c.

Referenced by handle_relay_msg().

◆ conflux_relay_msg_free_()

void conflux_relay_msg_free_ ( conflux_msg_t * msg )

Free a given conflux msg object.

Definition at line 939 of file conflux.c.

◆ conflux_should_multiplex()

bool conflux_should_multiplex ( int relay_command )

Determine if we should multiplex a specific relay command or not.

TODO: Version of this that is the set of forbidden commands on linked circuits

Definition at line 50 of file conflux.c.

Referenced by conflux_decide_circ_for_send(), conflux_note_cell_sent(), connection_edge_process_relay_cell(), and relay_send_command_from_edge_().

◆ conflux_update_rtt()

void conflux_update_rtt	(	conflux_t *	cfx,
		circuit_t *	circ,
		uint64_t	rtt_usec
	)

Called when we have a new RTT estimate for a circuit.

Definition at line 659 of file conflux.c.

Referenced by congestion_control_dispatch_cc_alg().

Data Structures

Macros

Functions