From fffd213c8cba2135afda493d797c41c10354770e Mon Sep 17 00:00:00 2001 From: Othmar Gsenger Date: Sat, 12 Apr 2008 11:38:42 +0000 Subject: big svn cleanup --- openvpn/multi.h | 445 -------------------------------------------------------- 1 file changed, 445 deletions(-) delete mode 100644 openvpn/multi.h (limited to 'openvpn/multi.h') diff --git a/openvpn/multi.h b/openvpn/multi.h deleted file mode 100644 index da1e471..0000000 --- a/openvpn/multi.h +++ /dev/null @@ -1,445 +0,0 @@ -/* - * OpenVPN -- An application to securely tunnel IP networks - * over a single TCP/UDP port, with support for SSL/TLS-based - * session authentication and key exchange, - * packet encryption, packet authentication, and - * packet compression. - * - * Copyright (C) 2002-2005 OpenVPN Solutions LLC - * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License version 2 - * as published by the Free Software Foundation. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License - * along with this program (see the file COPYING included with this - * distribution); if not, write to the Free Software Foundation, Inc., - * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA - */ - -#ifndef MULTI_H -#define MULTI_H - -#if P2MP_SERVER - -#include "init.h" -#include "forward.h" -#include "mroute.h" -#include "mbuf.h" -#include "list.h" -#include "schedule.h" -#include "pool.h" -#include "mudp.h" -#include "mtcp.h" -#include "perf.h" - -/* - * Walk (don't run) through the routing table, - * deleting old entries, and possibly multi_instance - * structs as well which have been marked for deletion. - */ -struct multi_reap -{ - int bucket_base; - int buckets_per_pass; - time_t last_call; -}; - -/* - * One multi_instance object per client instance. - */ -struct multi_instance { - struct schedule_entry se; /* this must be the first element of the structure */ - struct gc_arena gc; - MUTEX_DEFINE (mutex); - bool defined; - bool halt; - int refcount; - int route_count; /* number of routes (including cached routes) owned by this instance */ - time_t created; - struct timeval wakeup; /* absolute time */ - struct mroute_addr real; - ifconfig_pool_handle vaddr_handle; - const char *msg_prefix; - - /* queued outgoing data in Server/TCP mode */ - unsigned int tcp_rwflags; - struct mbuf_set *tcp_link_out_deferred; - bool socket_set_called; - - in_addr_t reporting_addr; /* IP address shown in status listing */ - - bool did_open_context; - bool did_real_hash; - bool did_iter; - bool connection_established_flag; - bool did_iroutes; - - struct context context; -}; - -/* - * One multi_context object per server daemon thread. - */ -struct multi_context { -# define MC_UNDEF 0 -# define MC_SINGLE_THREADED (1<<0) -# define MC_MULTI_THREADED_MASTER (1<<1) -# define MC_MULTI_THREADED_WORKER (1<<2) -# define MC_MULTI_THREADED_SCHEDULER (1<<3) -# define MC_WORK_THREAD (MC_MULTI_THREADED_WORKER|MC_MULTI_THREADED_SCHEDULER) - int thread_mode; - - struct hash *hash; /* client instances indexed by real address */ - struct hash *vhash; /* client instances indexed by virtual address */ - struct hash *iter; /* like real address hash but optimized for iteration */ - struct schedule *schedule; - struct mbuf_set *mbuf; - struct multi_tcp *mtcp; - struct ifconfig_pool *ifconfig_pool; - struct frequency_limit *new_connection_limiter; - struct mroute_helper *route_helper; - struct multi_reap *reaper; - struct mroute_addr local; - bool enable_c2c; - int max_clients; - int tcp_queue_limit; - int status_file_version; - - struct multi_instance *pending; - struct multi_instance *earliest_wakeup; - struct multi_instance **mpp_touched; - struct context_buffers *context_buffers; - time_t per_second_trigger; - - struct context top; -}; - -/* - * Host route - */ -struct multi_route -{ - struct mroute_addr addr; - struct multi_instance *instance; - -# define MULTI_ROUTE_CACHE (1<<0) -# define MULTI_ROUTE_AGEABLE (1<<1) - unsigned int flags; - - unsigned int cache_generation; - time_t last_reference; -}; - -/* - * top level function, called by openvpn.c - */ -void tunnel_server (struct context *top); - -const char *multi_instance_string (const struct multi_instance *mi, bool null, struct gc_arena *gc); - -void multi_bcast (struct multi_context *m, - const struct buffer *buf, - struct multi_instance *omit); - -/* - * Called by mtcp.c, mudp.c, or other (to be written) protocol drivers - */ - -void multi_init (struct multi_context *m, struct context *t, bool tcp_mode, int thread_mode); -void multi_uninit (struct multi_context *m); - -void multi_top_init (struct multi_context *m, const struct context *top, const bool alloc_buffers); -void multi_top_free (struct multi_context *m); - -struct multi_instance *multi_create_instance (struct multi_context *m, const struct mroute_addr *real); -void multi_close_instance (struct multi_context *m, struct multi_instance *mi, bool shutdown); - -bool multi_process_timeout (struct multi_context *m, const unsigned int mpp_flags); - -#define MPP_PRE_SELECT (1<<0) -#define MPP_CONDITIONAL_PRE_SELECT (1<<1) -#define MPP_CLOSE_ON_SIGNAL (1<<2) -#define MPP_RECORD_TOUCH (1<<3) -bool multi_process_post (struct multi_context *m, struct multi_instance *mi, const unsigned int flags); - -bool multi_process_incoming_link (struct multi_context *m, struct multi_instance *instance, const unsigned int mpp_flags); -bool multi_process_incoming_tun (struct multi_context *m, const unsigned int mpp_flags); - -void multi_process_drop_outgoing_tun (struct multi_context *m, const unsigned int mpp_flags); - -void multi_print_status (struct multi_context *m, struct status_output *so, const int version); - -struct multi_instance *multi_get_queue (struct mbuf_set *ms); - -void multi_add_mbuf (struct multi_context *m, - struct multi_instance *mi, - struct mbuf_buffer *mb); - -void multi_ifconfig_pool_persist (struct multi_context *m, bool force); - -bool multi_process_signal (struct multi_context *m); - -void multi_close_instance_on_signal (struct multi_context *m, struct multi_instance *mi); - -void init_management_callback_multi (struct multi_context *m); -void uninit_management_callback_multi (struct multi_context *m); - -/* - * Return true if our output queue is not full - */ -static inline bool -multi_output_queue_ready (const struct multi_context *m, - const struct multi_instance *mi) -{ - if (mi->tcp_link_out_deferred) - return mbuf_len (mi->tcp_link_out_deferred) <= m->tcp_queue_limit; - else - return true; -} - -/* - * Determine which instance has pending output - * and prepare the output for sending in - * the to_link buffer. - */ -static inline struct multi_instance * -multi_process_outgoing_link_pre (struct multi_context *m) -{ - struct multi_instance *mi = NULL; - - if (m->pending) - mi = m->pending; - else if (mbuf_defined (m->mbuf)) - mi = multi_get_queue (m->mbuf); - return mi; -} - -/* - * Per-client route quota management - */ - -void route_quota_exceeded (const struct multi_context *m, const struct multi_instance *mi); - -static inline void -route_quota_inc (struct multi_instance *mi) -{ - ++mi->route_count; -} - -static inline void -route_quota_dec (struct multi_instance *mi) -{ - --mi->route_count; -} - -/* can we add a new route? */ -static inline bool -route_quota_test (const struct multi_context *m, const struct multi_instance *mi) -{ - if (mi->route_count >= mi->context.options.max_routes_per_client) - { - route_quota_exceeded (m, mi); - return false; - } - else - return true; -} - -/* - * Instance reference counting - */ - -static inline void -multi_instance_inc_refcount (struct multi_instance *mi) -{ - ++mi->refcount; -} - -static inline void -multi_instance_dec_refcount (struct multi_instance *mi) -{ - if (--mi->refcount <= 0) - { - gc_free (&mi->gc); - mutex_destroy (&mi->mutex); - free (mi); - } -} - -static inline void -multi_route_del (struct multi_route *route) -{ - struct multi_instance *mi = route->instance; - route_quota_dec (mi); - multi_instance_dec_refcount (mi); - free (route); -} - -static inline bool -multi_route_defined (const struct multi_context *m, - const struct multi_route *r) -{ - if (r->instance->halt) - return false; - else if ((r->flags & MULTI_ROUTE_CACHE) - && r->cache_generation != m->route_helper->cache_generation) - return false; - else if ((r->flags & MULTI_ROUTE_AGEABLE) - && r->last_reference + m->route_helper->ageable_ttl_secs < now) - return false; - else - return true; -} - -/* - * Set a msg() function prefix with our current client instance ID. - */ - -static inline void -set_prefix (struct multi_instance *mi) -{ -#ifdef MULTI_DEBUG_EVENT_LOOP - if (mi->msg_prefix) - printf ("[%s]\n", mi->msg_prefix); -#endif - msg_set_prefix (mi->msg_prefix); -} - -static inline void -clear_prefix (void) -{ -#ifdef MULTI_DEBUG_EVENT_LOOP - printf ("[NULL]\n"); -#endif - msg_set_prefix (NULL); -} - -/* - * Instance Reaper - * - * Reaper constants. The reaper is the process where the virtual address - * and virtual route hash table is scanned for dead entries which are - * then removed. The hash table could potentially be quite large, so we - * don't want to reap in a single pass. - */ - -#define REAP_MAX_WAKEUP 10 /* Do reap pass at least once per n seconds */ -#define REAP_DIVISOR 256 /* How many passes to cover whole hash table */ -#define REAP_MIN 16 /* Minimum number of buckets per pass */ -#define REAP_MAX 1024 /* Maximum number of buckets per pass */ - -/* - * Mark a cached host route for deletion after this - * many seconds without any references. - */ -#define MULTI_CACHE_ROUTE_TTL 60 - -static inline void -multi_reap_process (const struct multi_context *m) -{ - void multi_reap_process_dowork (const struct multi_context *m); - if (m->reaper->last_call != now) - multi_reap_process_dowork (m); -} - -static inline void -multi_process_per_second_timers (struct multi_context *m) -{ - if (m->per_second_trigger != now) - { - void multi_process_per_second_timers_dowork (struct multi_context *m); - multi_process_per_second_timers_dowork (m); - m->per_second_trigger = now; - } -} - -/* - * Compute earliest timeout expiry from the set of - * all instances. Output: - * - * m->earliest_wakeup : instance needing the earliest service. - * dest : earliest timeout as a delta in relation - * to current time. - */ -static inline void -multi_get_timeout (struct multi_context *m, struct timeval *dest) -{ - struct timeval tv, current; - - CLEAR (tv); - m->earliest_wakeup = (struct multi_instance *) schedule_get_earliest_wakeup (m->schedule, &tv); - if (m->earliest_wakeup) - { - ASSERT (!gettimeofday (¤t, NULL)); - tv_delta (dest, ¤t, &tv); - if (dest->tv_sec >= REAP_MAX_WAKEUP) - { - m->earliest_wakeup = NULL; - dest->tv_sec = REAP_MAX_WAKEUP; - dest->tv_usec = 0; - } - } - else - { - dest->tv_sec = REAP_MAX_WAKEUP; - dest->tv_usec = 0; - } -} - -/* - * Send a packet to TUN/TAP interface. - */ -static inline bool -multi_process_outgoing_tun (struct multi_context *m, const unsigned int mpp_flags) -{ - struct multi_instance *mi = m->pending; - bool ret = true; - - ASSERT (mi); -#ifdef MULTI_DEBUG_EVENT_LOOP - printf ("%s -> TUN len=%d\n", - id(mi), - mi->context.c2.to_tun.len); -#endif - set_prefix (mi); - process_outgoing_tun (&mi->context); - ret = multi_process_post (m, mi, mpp_flags); - clear_prefix (); - return ret; -} - -static inline bool -multi_process_outgoing_link_dowork (struct multi_context *m, struct multi_instance *mi, const unsigned int mpp_flags) -{ - bool ret = true; - set_prefix (mi); - process_outgoing_link (&mi->context); - ret = multi_process_post (m, mi, mpp_flags); - clear_prefix (); - return ret; -} - -/* - * Check for signals. - */ -#define MULTI_CHECK_SIG(m) EVENT_LOOP_CHECK_SIGNAL (&(m)->top, multi_process_signal, (m)) - -static inline void -multi_set_pending (struct multi_context *m, struct multi_instance *mi) -{ - m->pending = mi; -} - -static inline void -multi_release_io_lock (struct multi_context *m) -{ -} - -#endif /* P2MP_SERVER */ -#endif /* MULTI_H */ -- cgit v1.2.3