eventl.c File Reference

#include <math.h>
#include <stdio.h>
#include <assert.h>
#include <unistd.h>
#include <stdlib.h>
#include <errno.h>
#include <string.h>
#include <yaz/yconfig.h>
#include <yaz/log.h>
#include <yaz/comstack.h>
#include <yaz/xmalloc.h>
#include <yaz/mutex.h>
#include <yaz/poll.h>
#include "eventl.h"
#include "sel_thread.h"

Go to the source code of this file.

Data Structures
struct	iochan_man_s

Functions
static int	iochan_use (int delta)
int	iochans_count (void)
int	iochans_count_total (void)
iochan_man_t	iochan_man_create (int no_threads)
IOCHAN	iochan_destroy_real (IOCHAN chan)
void	iochan_man_destroy (iochan_man_t *mp)
void	iochan_add (iochan_man_t man, IOCHAN chan)
IOCHAN	iochan_create (int fd, IOC_CALLBACK cb, int flags, const char *name)
static void	work_handler (void *work_data)
static void	run_fun (iochan_man_t man, IOCHAN p)
static int	event_loop (iochan_man_t man, IOCHAN *iochans)
void	iochan_man_events (iochan_man_t man)
void	pazpar2_sleep (double d)

Variables
static YAZ_MUTEX	g_mutex = 0
static int	no_iochans = 0
static int	no_iochans_total = 0

Function Documentation

static int event_loop ( iochan_man_t  man, IOCHAN *  iochans  )

static

Definition at line 210 of file eventl.c.

References iochan_man_s::channel_list, iochan::destroyed, EVENT_EXCEPT, EVENT_INPUT, EVENT_OUTPUT, EVENT_TIMEOUT, iochan::fd, iochan::flags, iochan_destroy_real(), iochan_man_s::iochan_mutex, iochan::last_event, iochan_man_s::log_level, iochan::max_idle, iochan::name, iochan::next, run_fun(), iochan_man_s::sel_fd, iochan_man_s::sel_thread, sel_thread_result(), iochan::this_event, and iochan::thread_users.

Referenced by iochan_man_events().

void iochan_add	(	iochan_man_t	man,
		IOCHAN	chan
	)

Definition at line 150 of file eventl.c.

References iochan_man_s::channel_list, iochan_man_s::iochan_mutex, iochan_man_s::log_level, iochan::man, and iochan::next.

Referenced by connection_connect(), getaddrinfo_start(), http_accept(), http_init(), http_proxy(), http_session_create(), and test_for_real_work().

IOCHAN iochan_create	(	int	fd,
		IOC_CALLBACK	cb,
		int	flags,
		const char *	name
	)

Definition at line 160 of file eventl.c.

References iochan::destroyed, iochan::fd, iochan::flags, iochan::fun, iochan_use(), iochan::last_event, iochan::man, iochan::max_idle, iochan::name, iochan::next, and iochan::thread_users.

Referenced by connection_connect(), getaddrinfo_start(), http_accept(), http_init(), http_proxy(), http_session_create(), and test_for_real_work().

IOCHAN iochan_destroy_real

(

IOCHAN

chan

)

Definition at line 121 of file eventl.c.

References iochan_use(), iochan::name, and iochan::next.

Referenced by event_loop(), and iochan_man_destroy().

iochan_man_t iochan_man_create

(

int

no_threads

)

Definition at line 109 of file eventl.c.

References iochan_man_s::channel_list, iochan_man_s::iochan_mutex, iochan_man_s::log_level, iochan_man_s::no_threads, iochan_man_s::sel_fd, and iochan_man_s::sel_thread.

Referenced by config_start_listeners(), and test_for_real_work().

void iochan_man_destroy

(

iochan_man_t *

mp

)

Definition at line 131 of file eventl.c.

References iochan_destroy_real(), and sel_thread_destroy().

Referenced by config_destroy(), and test_for_real_work().

void iochan_man_events

(

iochan_man_t

man

)

Definition at line 348 of file eventl.c.

References iochan_man_s::channel_list, event_loop(), iochan_man_s::log_level, iochan_man_s::no_threads, iochan_man_s::sel_fd, iochan_man_s::sel_thread, sel_thread_create(), and work_handler().

Referenced by config_process_events(), and test_for_real_work().

static int iochan_use ( int  delta )

static

Definition at line 66 of file eventl.c.

References g_mutex, no_iochans, and no_iochans_total.

Referenced by iochan_create(), iochan_destroy_real(), and iochans_count().

int iochans_count

(

void

)

Definition at line 81 of file eventl.c.

References iochan_use().

int iochans_count_total

(

void

)

Definition at line 85 of file eventl.c.

References g_mutex, and no_iochans_total.

void pazpar2_sleep

(

double

d

)

Definition at line 358 of file eventl.c.

static void run_fun ( iochan_man_t  man, IOCHAN  p  )

static

Definition at line 197 of file eventl.c.

References iochan_man_s::log_level, iochan::name, iochan_man_s::sel_thread, sel_thread_add(), iochan::this_event, iochan::thread_users, and work_handler().

Referenced by event_loop().

static void work_handler ( void *  work_data )

static

Definition at line 178 of file eventl.c.

References iochan::destroyed, EVENT_EXCEPT, EVENT_INPUT, EVENT_OUTPUT, EVENT_TIMEOUT, iochan::fun, iochan_man_s::log_level, iochan::man, iochan::name, and iochan::this_event.

Referenced by iochan_man_events(), run_fun(), and sel_thread_create().

Variable Documentation

YAZ_MUTEX g_mutex = 0

static

Definition at line 62 of file eventl.c.

Referenced by iochan_use(), and iochans_count_total().

int no_iochans = 0

static

Definition at line 63 of file eventl.c.

Referenced by iochan_use().

int no_iochans_total = 0

static

Definition at line 64 of file eventl.c.

Referenced by iochan_use(), and iochans_count_total().