forward.c File Reference

#include "syshead.h"
#include "forward.h"
#include "init.h"
#include "push.h"
#include "gremlin.h"
#include "mss.h"
#include "event.h"
#include "occ.h"
#include "otime.h"
#include "ping.h"
#include "ps.h"
#include "dhcp.h"
#include "common.h"
#include "ssl_verify.h"
#include "dco.h"
#include "auth_token.h"
#include "tun_afunix.h"
#include "memdbg.h"

Include dependency graph for forward.c:

Go to the source code of this file.

Macros
#define	MAX_ICMPV6LEN   1280

Functions
static void	check_tls_errors_co (struct context *c)
static void	check_tls_errors_nco (struct context *c)
static void	check_tls_errors (struct context *c)
static void	context_immediate_reschedule (struct context *c)
static void	context_reschedule_sec (struct context *c, time_t sec)
void	check_dco_key_status (struct context *c)
static void	check_tls (struct context *c)
static void	parse_incoming_control_channel_command (struct context *c, struct buffer *buf)
static void	check_incoming_control_channel (struct context *c)
static void	check_push_request (struct context *c)
static void	check_connection_established (struct context *c)
bool	send_control_channel_string_dowork (struct tls_session *session, const char *str, msglvl_t msglevel)
void	reschedule_multi_process (struct context *c)
	Reschedule tls_multi_process.
bool	send_control_channel_string (struct context *c, const char *str, msglvl_t msglevel)
static void	check_add_routes_action (struct context *c, const bool errors)
static void	check_add_routes (struct context *c)
static void	check_inactivity_timeout (struct context *c)
int	get_server_poll_remaining_time (struct event_timeout *server_poll_timeout)
static void	check_server_poll_timeout (struct context *c)
bool	schedule_exit (struct context *c)
static void	check_scheduled_exit (struct context *c)
static void	check_status_file (struct context *c)
static void	check_fragment (struct context *c)
static void	buffer_turnover (const uint8_t *orig_buf, struct buffer *dest_stub, struct buffer *src_stub, struct buffer *storage)
void	encrypt_sign (struct context *c, bool comp_frag)
	Process a data channel packet that will be sent through a VPN tunnel.
static void	check_session_timeout (struct context *c)
static void	process_coarse_timers (struct context *c)
static void	check_coarse_timers (struct context *c)
static void	check_timeout_random_component_dowork (struct context *c)
static void	check_timeout_random_component (struct context *c)
static void	socks_postprocess_incoming_link (struct context *c, struct link_socket *sock)
static void	socks_preprocess_outgoing_link (struct context *c, struct link_socket *sock, struct link_socket_actual **to_addr, int *size_delta)
static void	link_socket_write_post_size_adjust (int *size, int size_delta, struct buffer *buf)
void	read_incoming_link (struct context *c, struct link_socket *sock)
	Read a packet from the external network interface.
bool	process_incoming_link_part1 (struct context *c, struct link_socket_info *lsi, bool floated)
	Starts processing a packet read from the external network interface.
void	process_incoming_link_part2 (struct context *c, struct link_socket_info *lsi, const uint8_t *orig_buf)
	Continues processing a packet read from the external network interface.
static void	process_incoming_link (struct context *c, struct link_socket *sock)
void	extract_dco_float_peer_addr (const sa_family_t socket_family, struct openvpn_sockaddr *out_osaddr, const struct sockaddr *float_sa)
	Transfers float_sa data extracted from an incoming DCO PEER_FLOAT_NTF to out_osaddr for later processing.
void	process_incoming_dco (dco_context_t *dco)
	Process an incoming DCO message (from kernel space).
void	read_incoming_tun (struct context *c)
	Read a packet from the virtual tun/tap network interface.
static void	drop_if_recursive_routing (struct context *c, struct buffer *buf)
	Drops UDP packets which OS decided to route via tun.
void	process_incoming_tun (struct context *c, struct link_socket *out_sock)
	Process a packet read from the virtual tun/tap network interface.
void	ipv6_send_icmp_unreachable (struct context *c, struct buffer *buf, bool client)
	Forges a IPv6 ICMP packet with a no route to host error code from the IPv6 packet in buf and sends it directly back to the client via the tun device when used on a client and via the link if used on the server.
void	process_ip_header (struct context *c, unsigned int flags, struct buffer *buf, struct link_socket *sock)
void	process_outgoing_link (struct context *c, struct link_socket *sock)
	Write a packet to the external network interface.
void	process_outgoing_tun (struct context *c, struct link_socket *in_sock)
	Write a packet to the virtual tun/tap network interface.
void	pre_select (struct context *c)
static void	multi_io_process_flags (struct context *c, struct event_set *es, const unsigned int flags, unsigned int *out_socket, unsigned int *out_tuntap)
void	get_io_flags_dowork_udp (struct context *c, struct multi_io *multi_io, const unsigned int flags)
void	get_io_flags_udp (struct context *c, struct multi_io *multi_io, const unsigned int flags)
void	io_wait_dowork (struct context *c, const unsigned int flags)
void	process_io (struct context *c, struct link_socket *sock)

Variables
counter_type	link_read_bytes_global
counter_type	link_write_bytes_global

Macro Definition Documentation

MAX_ICMPV6LEN

#define MAX_ICMPV6LEN   1280

Function Documentation

buffer_turnover()

static void buffer_turnover ( const uint8_t *  orig_buf, struct buffer *  dest_stub, struct buffer *  src_stub, struct buffer *  storage  )

inlinestatic

Definition at line 601 of file forward.c.

References buf_assign(), and buffer::data.

Referenced by encrypt_sign(), and process_incoming_link_part2().

check_add_routes()

static void check_add_routes ( struct context *  c )

static

Definition at line 430 of file forward.c.

References context::c1, context::c2, check_add_routes_action(), D_ROUTE, ETT_DEFAULT, event_timeout_init(), event_timeout_reset(), event_timeout_trigger(), M_INFO, M_NOPREFIX, msg, event_timeout::n, now, context::persist, context_2::ping_rec_interval, register_signal(), context_persist::restart_sleep_seconds, context_1::route_list, context_2::route_wakeup, context_2::route_wakeup_expire, show_adapters(), show_routes(), context::sig, SIGHUP, test_routes(), context_2::timeval, tun_standby(), context_1::tuntap, and update_time().

Referenced by process_coarse_timers().

check_add_routes_action()

static void check_add_routes_action ( struct context *  c, const bool  errors  )

static

Definition at line 415 of file forward.c.

References context::c1, context::c2, do_route(), context_2::es, event_timeout_clear(), initialization_sequence_completed(), ISC_ERRORS, ISC_ROUTE_ERRORS, context::net_ctx, context::options, context::plugins, context_1::route_ipv6_list, context_1::route_list, context_2::route_wakeup, context_2::route_wakeup_expire, context_1::tuntap, and update_time().

Referenced by check_add_routes().

check_coarse_timers()

static void check_coarse_timers ( struct context *  c )

static

Definition at line 834 of file forward.c.

References BIG_TIMEOUT, context::c2, context_2::coarse_timer_wakeup, context_reschedule_sec(), D_INTERVAL, dmsg, now, process_coarse_timers(), and context_2::timeval.

Referenced by pre_select().

check_connection_established()

static void check_connection_established ( struct context *  c )

static

Definition at line 333 of file forward.c.

References connection_established(), do_up(), event_timeout_clear(), event_timeout_init(), buffer::len, management_set_state(), now, OPENVPN_STATE_GET_CONFIG, register_signal(), reset_coarse_timers(), and SIGUSR1.

Referenced by process_coarse_timers().

check_dco_key_status()

void check_dco_key_status

(

struct context *

c

)

Definition at line 145 of file forward.c.

References context::c1, context::c2, tuntap::dco, dco_enabled(), tls_multi::dco_peer_id, dco_update_keys(), context::options, register_signal(), context::sig, SIGUSR1, context_2::tls_multi, and context_1::tuntap.

Referenced by check_tls().

check_fragment()

static void check_fragment ( struct context *  c )

static

Definition at line 572 of file forward.c.

References ASSERT, context_2::buf, context::c2, encrypt_sign(), context_2::fragment, fragment_housekeeping(), fragment_outgoing_defined(), fragment_ready_to_send(), frame_adjust_path_mtu(), context_2::frame_fragment, get_link_socket_info(), buffer::len, link_socket_info::lsa, link_socket_info::mtu_changed, context_2::timeval, and context_2::to_link.

Referenced by pre_select().

check_inactivity_timeout()

static void check_inactivity_timeout ( struct context *  c )

static

Definition at line 480 of file forward.c.

References context::c2, dco_enabled(), dco_get_peer_stats(), context_2::dco_read_bytes, context_2::dco_write_bytes, event_timeout_reset(), context_2::inactivity_bytes, context_2::inactivity_interval, options::inactivity_minimum_bytes, M_INFO, msg, context::options, register_signal(), context::sig, SIGTERM, context_2::tun_read_bytes, and context_2::tun_write_bytes.

Referenced by process_coarse_timers().

check_incoming_control_channel()

static void check_incoming_control_channel ( struct context *  c )

static

Definition at line 283 of file forward.c.

References alloc_buf_gc(), ASSERT, BLEN, context::c2, D_PUSH_ERRORS, extract_command_buffer(), gc, gc_free(), gc_new(), buffer::len, msg, parse_incoming_control_channel_command(), context_2::tls_multi, tls_rec_payload(), and tls_test_payload_len().

Referenced by pre_select().

check_push_request()

static void check_push_request ( struct context *  c )

static

Definition at line 315 of file forward.c.

References event_timeout_modify_wakeup(), buffer::len, PUSH_REQUEST_INTERVAL, and send_push_request().

Referenced by process_coarse_timers().

check_scheduled_exit()

static void check_scheduled_exit ( struct context *  c )

static

Definition at line 549 of file forward.c.

References context::c2, register_signal(), context_2::scheduled_exit_signal, and context::sig.

Referenced by process_coarse_timers().

check_server_poll_timeout()

static void check_server_poll_timeout ( struct context *  c )

static

Definition at line 512 of file forward.c.

References ASSERT, context::c2, event_timeout_reset(), M_INFO, msg, context::persist, register_signal(), context_persist::restart_sleep_seconds, context_2::server_poll_interval, context::sig, SIGUSR1, tls_initial_packet_received(), and context_2::tls_multi.

Referenced by process_coarse_timers().

check_session_timeout()

static void check_session_timeout ( struct context *  c )

static

Definition at line 708 of file forward.c.

References context::c2, ETT_DEFAULT, event_timeout_trigger(), M_INFO, msg, context::options, register_signal(), context_2::session_interval, options::session_timeout, context::sig, SIGTERM, and context_2::timeval.

Referenced by process_coarse_timers().

check_status_file()

static void check_status_file ( struct context *  c )

static

Definition at line 558 of file forward.c.

References context::c1, print_status(), and context_1::status_output.

Referenced by process_coarse_timers().

check_timeout_random_component()

static void check_timeout_random_component ( struct context *  c )

inlinestatic

Definition at line 870 of file forward.c.

References context::c2, check_timeout_random_component_dowork(), now, context_2::timeout_random_component, context_2::timeval, tv_add(), and context_2::update_timeout_random_component.

Referenced by pre_select().

check_timeout_random_component_dowork()

static void check_timeout_random_component_dowork ( struct context *  c )

static

Definition at line 859 of file forward.c.

References context::c2, D_INTERVAL, dmsg, get_random(), now, context_2::timeout_random_component, and context_2::update_timeout_random_component.

Referenced by check_timeout_random_component().

check_tls()

static void check_tls ( struct context *  c )

static

Definition at line 178 of file forward.c.

References BIG_TIMEOUT, context::c2, check_dco_key_status(), tls_multi::client_reason, context_reschedule_sec(), event_timeout_init(), get_link_socket_info(), interval_action(), interval_future_trigger(), interval_schedule_wakeup(), interval_test(), options::mode, MODE_SERVER, now, context::options, register_signal(), reset_coarse_timers(), send_auth_failed(), context::sig, SIGTERM, context_2::tls_multi, tls_multi_process(), TLSMP_ACTIVE, TLSMP_KILL, TLSMP_RECONNECT, context_2::tmp_int, context_2::to_link, context_2::to_link_addr, update_time(), and context_2::wait_for_connect.

Referenced by pre_select().

check_tls_errors()

static void check_tls_errors ( struct context *  c )

inlinestatic

Definition at line 98 of file forward.c.

References context::c2, check_tls_errors_co(), check_tls_errors_nco(), link_socket_connection_oriented(), context_2::link_sockets, tls_multi::n_hard_errors, tls_multi::n_soft_errors, context_2::tls_exit_signal, and context_2::tls_multi.

Referenced by pre_select().

check_tls_errors_co()

static void check_tls_errors_co ( struct context *  c )

static

Definition at line 81 of file forward.c.

References context::c2, D_STREAM_ERRORS, msg, register_signal(), context::sig, and context_2::tls_exit_signal.

Referenced by check_tls_errors().

check_tls_errors_nco()

static void check_tls_errors_nco ( struct context *  c )

static

Definition at line 88 of file forward.c.

References context::c2, register_signal(), context::sig, and context_2::tls_exit_signal.

Referenced by check_tls_errors().

context_immediate_reschedule()

static void context_immediate_reschedule ( struct context *  c )

inlinestatic

Definition at line 124 of file forward.c.

References context::c2, and context_2::timeval.

Referenced by reschedule_multi_process().

context_reschedule_sec()

static void context_reschedule_sec ( struct context *  c, time_t  sec  )

inlinestatic

Definition at line 131 of file forward.c.

References context::c2, and context_2::timeval.

Referenced by check_coarse_timers(), and check_tls().

drop_if_recursive_routing()

static void drop_if_recursive_routing ( struct context *  c, struct buffer *  buf  )

static

Drops UDP packets which OS decided to route via tun.

On Windows and OS X when netwotk adapter is disabled or disconnected, platform starts to use tun as external interface. When packet is sent to tun, it comes to openvpn, encapsulated and sent to routing table, which sends it again to tun.

Definition at line 1369 of file forward.c.

References openvpn_sockaddr::addr, BLEN, BPTR, context::c1, context::c2, D_LOW, openvpn_iphdr::daddr, openvpn_ipv6hdr::daddr, link_socket_actual::dest, gc, gc_free(), gc_new(), get_link_socket_info(), get_tun_ip_ver(), IA_NET_ORDER, openvpn_sockaddr::in4, openvpn_sockaddr::in6, buffer::len, msg, openvpn_ipv6hdr::nexthdr, OPENVPN_IN6_ARE_ADDR_EQUAL, OPENVPN_IPH_GET_LEN, OPENVPN_IPPROTO_TCP, OPENVPN_IPPROTO_UDP, print_in6_addr(), print_in_addr_t(), print_link_socket_actual(), link_socket_info::proto, PROTO_TCP, PROTO_UDP, openvpn_iphdr::protocol, openvpn_sockaddr::sa, openvpn_iphdr::saddr, openvpn_ipv6hdr::saddr, context_2::to_link_addr, TUNNEL_TYPE, context_1::tuntap, and openvpn_iphdr::version_len.

Referenced by process_incoming_tun().

extract_dco_float_peer_addr()

void extract_dco_float_peer_addr	(	sa_family_t	socket_family,
		struct openvpn_sockaddr *	out_osaddr,
		const struct sockaddr *	float_sa
	)

Transfers float_sa data extracted from an incoming DCO PEER_FLOAT_NTF to out_osaddr for later processing.

Parameters

socket_family	- The address family of the socket
out_osaddr	- openvpn_sockaddr struct that will be filled the new address data
float_sa	- The sockaddr struct containing the data received from the DCO notification

Definition at line 1213 of file forward.c.

References openvpn_sockaddr::addr, openvpn_sockaddr::in4, and openvpn_sockaddr::in6.

get_io_flags_dowork_udp()

void get_io_flags_dowork_udp	(	struct context *	c,
		struct multi_io *	multi_io,
		const unsigned int	flags
	)

Definition at line 2163 of file forward.c.

References multi_io::es, multi_io_process_flags(), SOCKET_SHIFT, and multi_io::udp_flags.

Referenced by get_io_flags_udp().

get_io_flags_udp()

void get_io_flags_udp	(	struct context *	c,
		struct multi_io *	multi_io,
		const unsigned int	flags
	)

Definition at line 2172 of file forward.c.

References context::c2, ES_ERROR, context_2::fast_io, get_io_flags_dowork_udp(), IOW_MBUF, IOW_TO_LINK, IOW_TO_TUN, SOCKET_WRITE, TUN_WRITE, and multi_io::udp_flags.

Referenced by multi_io_wait().

get_server_poll_remaining_time()

int get_server_poll_remaining_time

(

struct event_timeout *

server_poll_timeout

)

Definition at line 504 of file forward.c.

References event_timeout_remaining(), max_int(), and update_time().

Referenced by dco_p2p_new_peer(), establish_http_proxy_passthru(), phase2_socks_client(), phase2_tcp_client(), and socks_proxy_recv_char().

io_wait_dowork()

void io_wait_dowork	(	struct context *	c,
		const unsigned int	flags
	)

Definition at line 2197 of file forward.c.

References event_set_return::arg, context::c1, context::c2, check_debug_level(), check_status(), D_EVENT_WAIT, D_LINK_ERRORS, tuntap::dco, dco_event_set(), DCO_SHIFT, context_2::did_open_tun, dmsg, ES_ERROR, ES_TIMEOUT, EVENT_ARG_LINK_SOCKET, EVENT_READ, event_reset(), context_2::event_set, context_2::event_set_status, event_wait(), get_signal(), IOW_CHECK_RESIDUAL, MANAGEMENT_SHIFT, management_socket_set(), msg, multi_io_process_flags(), MULTI_N, event_set_return::rwflags, context::sig, signal_info::signal_received, SIZE, SOCKET_READ, SOCKET_SHIFT, sockets_read_residual(), status, context_2::timeval, context_1::tuntap, event_arg::type, and update_time().

Referenced by io_wait().

ipv6_send_icmp_unreachable()

void ipv6_send_icmp_unreachable	(	struct context *	c,
		struct buffer *	buf,
		bool	client
	)

Forges a IPv6 ICMP packet with a no route to host error code from the IPv6 packet in buf and sends it directly back to the client via the tun device when used on a client and via the link if used on the server.

Parameters

c	Tunnel context
buf	The buf containing the packet for which the icmp6 unreachable should be constructed.
client	Determines whether to the send packet back via tun or link

Definition at line 1545 of file forward.c.

References ASSERT, BLEN, BPTR, buf_copy_n(), buf_init, buf_safe(), buf_write_prepend(), context::c1, context::c2, CLEAR, openvpn_ipv6hdr::daddr, openvpn_ethhdr::dest, DEV_TYPE_TAP, context_2::frame, openvpn_icmp6hdr::icmp6_cksum, openvpn_icmp6hdr::icmp6_code, openvpn_icmp6hdr::icmp6_type, options::ifconfig_ipv6_remote, ip_checksum(), is_ipv6(), buffer::len, MAX_ICMPV6LEN, min_int(), openvpn_ipv6hdr::nexthdr, OPENVPN_ETH_ALEN, OPENVPN_ETH_P_IPV6, OPENVPN_ICMP6_DESTINATION_UNREACHABLE, OPENVPN_ICMP6_DU_NOROUTE, OPENVPN_IPPROTO_ICMPV6, context::options, openvpn_ipv6hdr::payload_len, openvpn_ethhdr::proto, openvpn_ipv6hdr::saddr, openvpn_ethhdr::source, frame::tun_mtu, TUNNEL_TYPE, context_1::tuntap, and openvpn_ipv6hdr::version_prio.

Referenced by process_ip_header().

link_socket_write_post_size_adjust()

static void link_socket_write_post_size_adjust ( int *  size, int  size_delta, struct buffer *  buf  )

inlinestatic

Definition at line 909 of file forward.c.

References buf_advance().

Referenced by process_outgoing_link().

multi_io_process_flags()

static void multi_io_process_flags ( struct context *  c, struct event_set *  es, const unsigned int  flags, unsigned int *  out_socket, unsigned int *  out_tuntap  )

static

Definition at line 2043 of file forward.c.

References context::c1, context::c2, ERR_SHIFT, es, link_socket::ev_arg, EVENT_READ, EVENT_WRITE, link_socket::info, IOW_FRAG, IOW_MBUF, IOW_READ_LINK, IOW_READ_TUN, IOW_READ_TUN_FORCE, IOW_SHAPER, IOW_TO_LINK, IOW_TO_TUN, IOW_WAIT_SIGNAL, context_2::link_sockets, context_1::link_sockets_num, max_int(), options::mode, MODE_SERVER, context::options, link_socket_info::proto, proto_is_dgram(), context_2::shaper, options::shaper, shaper_delay(), shaper_soonest_event(), socket_set(), context_2::timeval, TO_LINK_FRAG, tun_set(), TUN_SHIFT, context_1::tuntap, and wait_signal().

Referenced by get_io_flags_dowork_udp(), and io_wait_dowork().

parse_incoming_control_channel_command()

static void parse_incoming_control_channel_command ( struct context *  c, struct buffer *  buf  )

static

Definition at line 234 of file forward.c.

References BSTR, buf_string_match_head_str(), D_PUSH_ERRORS, incoming_push_message(), msg, receive_auth_failed(), receive_auth_pending(), receive_cr_response(), receive_exit_message(), server_pushed_info(), and server_pushed_signal().

Referenced by check_incoming_control_channel().

pre_select()

void pre_select

(

struct context *

c

)

Definition at line 1977 of file forward.c.

References BIG_TIMEOUT, context::c1, context::c2, check_coarse_timers(), check_debug_level(), check_fragment(), check_incoming_control_channel(), check_send_occ_msg(), check_timeout_random_component(), check_tls(), check_tls_errors(), D_TAP_WIN_DEBUG, context_2::fragment, context::sig, signal_info::signal_received, context_2::timeval, context_2::tls_multi, tls_test_payload_len(), tun_show_debug(), context_1::tuntap, and tuntap_defined().

Referenced by multi_process_post(), and tunnel_point_to_point().

process_coarse_timers()

static void process_coarse_timers ( struct context *  c )

static

Definition at line 722 of file forward.c.

References context_2::auth_token_renewal_interval, context::c1, context::c2, options::ce, check_add_routes(), check_connection_established(), check_inactivity_timeout(), check_ping_restart(), check_ping_send(), check_push_request(), check_scheduled_exit(), check_send_auth_token(), check_send_occ_load_test(), check_send_occ_req(), check_server_poll_timeout(), check_session_timeout(), check_status_file(), connection_entry::connect_timeout, status_output::et, ETT_DEFAULT, event_timeout_trigger(), context_2::explicit_exit_notification_time_wait, context_2::inactivity_interval, options::inactivity_timeout, management_check_bytecount_client(), context::options, packet_id_persist_enabled(), context_2::packet_id_persist_interval, packet_id_persist_save(), context_1::pid_persist, process_explicit_exit_notification_timer_wakeup(), context_2::push_request_interval, context_2::route_wakeup, context_2::scheduled_exit, context_2::server_poll_interval, context::sig, signal_info::signal_received, context_1::status_output, context_2::timeval, context_2::tls_multi, and context_2::wait_for_connect.

Referenced by check_coarse_timers().

process_incoming_dco()

void process_incoming_dco

(

dco_context_t *

dco

)

Process an incoming DCO message (from kernel space).

Parameters

dco	- Pointer to the structure representing the DCO context.

Definition at line 1247 of file forward.c.

References context::c2, D_DCO_DEBUG, tls_multi::dco_peer_id, msg, OVPN_CMD_DEL_PEER, OVPN_CMD_SWAP_KEYS, OVPN_DEL_PEER_REASON_EXPIRED, context_2::tls_multi, tls_session_soft_reset(), and trigger_ping_timeout_signal().

Referenced by dco_read_and_process().

process_incoming_link()

static void process_incoming_link ( struct context *  c, struct link_socket *  sock  )

static

Definition at line 1203 of file forward.c.

References context_2::buf, context::c2, buffer::data, link_socket::info, process_incoming_link_part1(), and process_incoming_link_part2().

Referenced by process_io().

process_io()

void process_io	(	struct context *	c,
		struct link_socket *	sock
	)

Definition at line 2320 of file forward.c.

References ASSERT, context::c1, context::c2, tuntap::dco, DCO_READ, dco_read_and_process(), context_2::event_set_status, IS_SIG, management_io(), MANAGEMENT_READ, MANAGEMENT_WRITE, process_incoming_link(), process_incoming_tun(), process_outgoing_link(), process_outgoing_tun(), read_incoming_link(), read_incoming_tun(), event_arg::sock, SOCKET_READ, SOCKET_WRITE, status, TUN_READ, TUN_WRITE, and context_1::tuntap.

Referenced by tunnel_point_to_point().

process_ip_header()

void process_ip_header	(	struct context *	c,
		unsigned int	flags,
		struct buffer *	buf,
		struct link_socket *	sock
	)

Definition at line 1673 of file forward.c.

References options::block_ipv6, options::ce, options::client_nat, client_nat_transform(), CN_INCOMING, CN_OUTGOING, dhcp_extract_router_msg(), ipv6_send_icmp_unreachable(), is_ipv4(), is_ipv6(), buffer::len, mss_fixup_ipv4(), mss_fixup_ipv6(), connection_entry::mssfix, context::options, PIP_MSSFIX, PIP_OUTGOING, PIPV4_CLIENT_NAT, PIPV4_EXTRACT_DHCP_ROUTER, PIPV4_PASSTOS, PIPV6_ICMP_NOHOST_CLIENT, PIPV6_ICMP_NOHOST_SERVER, options::route_gateway_via_dhcp, route_list_add_vpn_gateway(), and TUNNEL_TYPE.

Referenced by multi_get_queue(), process_incoming_tun(), and process_outgoing_tun().

reschedule_multi_process()

void reschedule_multi_process

(

struct context *

c

)

Reschedule tls_multi_process.

NOTE: in multi-client mode, usually calling the function is insufficient to reschedule the client instance object unless multi_schedule_context_wakeup(m, mi) is also called.

Definition at line 391 of file forward.c.

References context::c2, context_immediate_reschedule(), interval_action(), and context_2::tmp_int.

Referenced by management_client_pending_auth(), send_auth_failed(), and send_control_channel_string().

schedule_exit()

bool schedule_exit

(

struct context *

c

)

Definition at line 528 of file forward.c.

References context::c2, D_SCHED_EXIT, event_timeout_defined(), event_timeout_init(), msg, now, context::options, reset_coarse_timers(), context_2::scheduled_exit, options::scheduled_exit_interval, context_2::scheduled_exit_signal, SIGTERM, context_2::tls_multi, tls_set_single_session(), and update_time().

Referenced by receive_exit_message(), send_auth_failed(), and send_restart().

send_control_channel_string()

bool send_control_channel_string	(	struct context *	c,
		const char *	str,
		msglvl_t	msglevel
	)

Definition at line 398 of file forward.c.

References context::c2, reschedule_multi_process(), send_control_channel_string_dowork(), tls_multi::session, context_2::tls_multi, and TM_ACTIVE.

Referenced by management_callback_send_cc_message(), multi_push_restart_schedule_exit(), process_explicit_exit_notification_init(), send_push_options(), send_push_reply(), send_push_request(), send_restart(), and send_single_push_update().

send_control_channel_string_dowork()

bool send_control_channel_string_dowork	(	struct tls_session *	session,
		const char *	str,
		msglvl_t	msglevel
	)

Definition at line 370 of file forward.c.

References ASSERT, gc, gc_free(), gc_new(), session::key, KS_PRIMARY, msg, sanitize_control_message(), and tls_send_payload().

Referenced by send_auth_failed(), send_auth_pending_messages(), send_control_channel_string(), and send_push_reply_auth_token().

socks_postprocess_incoming_link()

static void socks_postprocess_incoming_link ( struct context *  c, struct link_socket *  sock  )

inlinestatic

Definition at line 888 of file forward.c.

References context_2::buf, context::c2, context_2::from, link_socket::info, link_socket_info::proto, PROTO_UDP, socks_process_incoming_udp(), and link_socket::socks_proxy.

Referenced by read_incoming_link().

socks_preprocess_outgoing_link()

static void socks_preprocess_outgoing_link ( struct context *  c, struct link_socket *  sock, struct link_socket_actual **  to_addr, int *  size_delta  )

inlinestatic

Definition at line 897 of file forward.c.

References context::c2, link_socket::info, link_socket_info::proto, PROTO_UDP, socks_process_outgoing_udp(), link_socket::socks_proxy, link_socket::socks_relay, context_2::to_link, and context_2::to_link_addr.

Referenced by process_outgoing_link().

Variable Documentation

link_read_bytes_global

counter_type link_read_bytes_global

Definition at line 48 of file forward.c.

Referenced by man_load_stats(), and process_incoming_link_part1().

link_write_bytes_global

counter_type link_write_bytes_global

Definition at line 49 of file forward.c.

Referenced by man_load_stats(), and process_outgoing_link().