diff options
Diffstat (limited to 'netinet/sctp_callout.c')
| -rwxr-xr-x | netinet/sctp_callout.c | 89 |
1 files changed, 73 insertions, 16 deletions
diff --git a/netinet/sctp_callout.c b/netinet/sctp_callout.c index 67b7566..3174e3f 100755 --- a/netinet/sctp_callout.c +++ b/netinet/sctp_callout.c @@ -30,9 +30,27 @@ * THE POSSIBILITY OF SUCH DAMAGE. */ +#if defined(__Userspace__) +#include <sys/types.h> +#if !defined (__Userspace_os_Windows) +#include <sys/wait.h> +#include <unistd.h> +#include <pthread.h> +#endif +#if defined(__Userspace_os_NaCl) +#include <sys/select.h> +#endif +#include <stdlib.h> +#include <string.h> +#include <stdio.h> +#include <errno.h> +#include <netinet/sctp_sysctl.h> +#include <netinet/sctp_pcb.h> +#else #include <netinet/sctp_os.h> #include <netinet/sctp_callout.h> #include <netinet/sctp_pcb.h> +#endif /* * Callout/Timer routines for OS that doesn't have them @@ -46,10 +64,8 @@ extern int ticks; /* * SCTP_TIMERQ_LOCK protects: * - SCTP_BASE_INFO(callqueue) - * - sctp_os_timer_current: current timer in process * - sctp_os_timer_next: next timer to check */ -static sctp_os_timer_t *sctp_os_timer_current = NULL; static sctp_os_timer_t *sctp_os_timer_next = NULL; void @@ -117,24 +133,16 @@ sctp_os_timer_stop(sctp_os_timer_t *c) return (1); } -#if defined(__APPLE__) -/* - * For __APPLE__, use a single main timer at a faster resolution than - * fastim. The timer just calls this existing callout infrastructure. - */ -#endif -void -sctp_timeout(void *arg SCTP_UNUSED) +static void +sctp_handle_tick(int delta) { sctp_os_timer_t *c; void (*c_func)(void *); void *c_arg; SCTP_TIMERQ_LOCK(); -#if defined(__APPLE__) /* update our tick count */ - ticks += SCTP_BASE_VAR(sctp_main_timer_ticks); -#endif + ticks += delta; c = TAILQ_FIRST(&SCTP_BASE_INFO(callqueue)); while (c) { if (c->c_time <= ticks) { @@ -143,11 +151,9 @@ sctp_timeout(void *arg SCTP_UNUSED) c_func = c->c_func; c_arg = c->c_arg; c->c_flags &= ~SCTP_CALLOUT_PENDING; - sctp_os_timer_current = c; SCTP_TIMERQ_UNLOCK(); c_func(c_arg); SCTP_TIMERQ_LOCK(); - sctp_os_timer_current = NULL; c = sctp_os_timer_next; } else { c = TAILQ_NEXT(c, tqe); @@ -155,9 +161,60 @@ sctp_timeout(void *arg SCTP_UNUSED) } sctp_os_timer_next = NULL; SCTP_TIMERQ_UNLOCK(); +} #if defined(__APPLE__) - /* restart the main timer */ +void +sctp_timeout(void *arg SCTP_UNUSED) +{ + sctp_handle_tick(SCTP_BASE_VAR(sctp_main_timer_ticks)); sctp_start_main_timer(); +} #endif + +#if defined(__Userspace__) +#define TIMEOUT_INTERVAL 10 + +void * +user_sctp_timer_iterate(void *arg) +{ + for (;;) { +#if defined (__Userspace_os_Windows) + Sleep(TIMEOUT_INTERVAL); +#else + struct timeval timeout; + + timeout.tv_sec = 0; + timeout.tv_usec = 1000 * TIMEOUT_INTERVAL; + select(0, NULL, NULL, NULL, &timeout); +#endif + if (SCTP_BASE_VAR(timer_thread_should_exit)) { + break; + } + sctp_handle_tick(MSEC_TO_TICKS(TIMEOUT_INTERVAL)); + } + return (NULL); } + +void +sctp_start_timer(void) +{ + /* + * No need to do SCTP_TIMERQ_LOCK_INIT(); + * here, it is being done in sctp_pcb_init() + */ +#if defined (__Userspace_os_Windows) + if ((SCTP_BASE_VAR(timer_thread) = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)user_sctp_timer_iterate, NULL, 0, NULL)) == NULL) { + SCTP_PRINTF("ERROR; Creating ithread failed\n"); + } +#else + int rc; + + rc = pthread_create(&SCTP_BASE_VAR(timer_thread), NULL, user_sctp_timer_iterate, NULL); + if (rc) { + SCTP_PRINTF("ERROR; return code from pthread_create() is %d\n", rc); + } +#endif +} + +#endif |