lib/events.c

ソースコードを見る。

データ構造
struct	timed_event
struct	fd_event
struct	event_context
関数
static int	timed_event_destructor (struct timed_event *te)
static void	add_event_by_time (struct timed_event *te)
timed_event *	event_add_timed (struct event_context *event_ctx, TALLOC_CTX *mem_ctx, struct timeval when, const char *event_name, void(*handler)(struct event_context *event_ctx, struct timed_event *te, const struct timeval *now, void *private_data), void *private_data)
static int	fd_event_destructor (struct fd_event *fde)
fd_event *	event_add_fd (struct event_context *event_ctx, TALLOC_CTX *mem_ctx, int fd, uint16_t flags, void(*handler)(struct event_context *event_ctx, struct fd_event *event, uint16 flags, void *private_data), void *private_data)
void	event_fd_set_writeable (struct fd_event *fde)
void	event_fd_set_not_writeable (struct fd_event *fde)
void	event_fd_set_readable (struct fd_event *fde)
void	event_fd_set_not_readable (struct fd_event *fde)
void	event_add_to_select_args (struct event_context *event_ctx, const struct timeval *now, fd_set *read_fds, fd_set *write_fds, struct timeval *timeout, int *maxfd)
BOOL	run_events (struct event_context *event_ctx, int selrtn, fd_set *read_fds, fd_set *write_fds)
timeval *	get_timed_events_timeout (struct event_context *event_ctx, struct timeval *to_ret)
event_context *	event_context_init (TALLOC_CTX *mem_ctx)
int	set_event_dispatch_time (struct event_context *event_ctx, const char *event_name, struct timeval when)
int	cancel_named_event (struct event_context *event_ctx, const char *event_name)

---

関数

static int timed_event_destructor

(

struct timed_event *

te

)

[static]

events.c の 63 行で定義されています。

参照先 timed_event::event_name.

参照元 event_add_timed().

{
        DEBUG(10, ("Destroying timed event %lx \"%s\"\n", (unsigned long)te,
                te->event_name));
        DLIST_REMOVE(te->event_ctx->timed_events, te);
        return 0;
}

static void add_event_by_time

(

struct timed_event *

te

)

[static]

events.c の 75 行で定義されています。

参照先 ctx・timed_event::event_ctx・timed_event::next・timeval_compare()・timeval_is_zero()・timed_event::when.

参照元 event_add_timed()・set_event_dispatch_time().

{
        struct event_context *ctx = te->event_ctx;
        struct timed_event *last_te, *cur_te;

        /* Keep the list ordered by time. We must preserve this. */
        last_te = NULL;
        for (cur_te = ctx->timed_events; cur_te; cur_te = cur_te->next) {
                /* if the new event comes before the current one break */
                if (!timeval_is_zero(&cur_te->when) &&
                                timeval_compare(&te->when, &cur_te->when) < 0) {
                        break;
                }
                last_te = cur_te;
        }

        DLIST_ADD_AFTER(ctx->timed_events, te, last_te);
}

struct timed_event* event_add_timed	(	struct event_context *	event_ctx,
		TALLOC_CTX *	mem_ctx,
		struct timeval	when,
		const char *	event_name,
		void(*)(struct event_context *event_ctx, struct timed_event *te, const struct timeval *now, void *private_data)	handler,
		void *	private_data
	)

events.c の 100 行で定義されています。

参照先 add_event_by_time()・timed_event::event_ctx・timed_event::event_name・timed_event::handler・timed_event::private_data・timed_event_destructor()・timed_event::when.

参照元 account_lockout_policy_handler()・add_ccache_to_list()・add_idle_event()・add_oplock_timeout_handler()・async_request_sent()・idle_event_handler()・krb5_ticket_gain_handler()・krb5_ticket_refresh_handler()・set_domain_offline()・set_domain_online_request().

{
        struct timed_event *te;

        te = TALLOC_P(mem_ctx, struct timed_event);
        if (te == NULL) {
                DEBUG(0, ("talloc failed\n"));
                return NULL;
        }

        te->event_ctx = event_ctx;
        te->when = when;
        te->event_name = event_name;
        te->handler = handler;
        te->private_data = private_data;

        add_event_by_time(te);

        talloc_set_destructor(te, timed_event_destructor);

        DEBUG(10, ("Added timed event \"%s\": %lx\n", event_name,
                        (unsigned long)te));
        return te;
}

static int fd_event_destructor

(

struct fd_event *

fde

)

[static]

events.c の 133 行で定義されています。

参照先 fd_event::event_ctx・event_context::fd_events.

参照元 event_add_fd().

{
        struct event_context *event_ctx = fde->event_ctx;

        DLIST_REMOVE(event_ctx->fd_events, fde);
        return 0;
}

struct fd_event* event_add_fd	(	struct event_context *	event_ctx,
		TALLOC_CTX *	mem_ctx,
		int	fd,
		uint16_t	flags,
		void(*)(struct event_context *event_ctx, struct fd_event *event, uint16 flags, void *private_data)	handler,
		void *	private_data
	)

events.c の 141 行で定義されています。

参照先 fd_event::event_ctx・fd_event::fd・fd_event_destructor()・fd_event::flags・fd_event::handler・fd_event::private_data.

参照元 fam_open_connection()・inotify_setup().

{
        struct fd_event *fde;

        if (!(fde = TALLOC_P(mem_ctx, struct fd_event))) {
                return NULL;
        }

        fde->event_ctx = event_ctx;
        fde->fd = fd;
        fde->flags = flags;
        fde->handler = handler;
        fde->private_data = private_data;

        DLIST_ADD(event_ctx->fd_events, fde);

        talloc_set_destructor(fde, fd_event_destructor);
        return fde;
}

void event_fd_set_writeable

(

struct fd_event *

fde

)

events.c の 168 行で定義されています。

参照先 fd_event::flags.

{
        fde->flags |= EVENT_FD_WRITE;
}

void event_fd_set_not_writeable

(

struct fd_event *

fde

)

events.c の 173 行で定義されています。

参照先 fd_event::flags.

{
        fde->flags &= ~EVENT_FD_WRITE;
}

void event_fd_set_readable

(

struct fd_event *

fde

)

events.c の 178 行で定義されています。

参照先 fd_event::flags.

{
        fde->flags |= EVENT_FD_READ;
}

void event_fd_set_not_readable

(

struct fd_event *

fde

)

events.c の 183 行で定義されています。

参照先 fd_event::flags.

{
        fde->flags &= ~EVENT_FD_READ;
}

void event_add_to_select_args	(	struct event_context *	event_ctx,
		const struct timeval *	now,
		fd_set *	read_fds,
		fd_set *	write_fds,
		struct timeval *	timeout,
		int *	maxfd
	)

events.c の 188 行で定義されています。

参照先 fd_event::fd・event_context::fd_events・fd_event::flags・fd_event::next・event_context::timed_events・timeval_min()・timeval_until()・timed_event::when.

参照元 receive_message_or_smb().

{
        struct fd_event *fde;
        struct timeval diff;

        for (fde = event_ctx->fd_events; fde; fde = fde->next) {
                if (fde->flags & EVENT_FD_READ) {
                        FD_SET(fde->fd, read_fds);
                }
                if (fde->flags & EVENT_FD_WRITE) {
                        FD_SET(fde->fd, write_fds);
                }

                if ((fde->flags & (EVENT_FD_READ|EVENT_FD_WRITE))
                    && (fde->fd > *maxfd)) {
                        *maxfd = fde->fd;
                }
        }

        if (event_ctx->timed_events == NULL) {
                return;
        }

        diff = timeval_until(now, &event_ctx->timed_events->when);
        *timeout = timeval_min(timeout, &diff);
}

BOOL run_events	(	struct event_context *	event_ctx,
		int	selrtn,
		fd_set *	read_fds,
		fd_set *	write_fds
	)

events.c の 218 行で定義されています。

参照先 fd_event::event_ctx・timed_event::event_name・fd_event::fd・event_context::fd_events・GetTimeOfDay()・fd_event::handler・timed_event::handler・fd_event::next・fd_event::private_data・timed_event::private_data・event_context::timed_events・timeval_compare()・timed_event::when.

参照元 process_loop()・receive_message_or_smb()・smbd_process().

{
        BOOL fired = False;
        struct fd_event *fde, *next;

        /* Run all events that are pending, not just one (as we
           did previously. */

        while (event_ctx->timed_events) {
                struct timeval now;
                GetTimeOfDay(&now);

                if (timeval_compare(
                            &now, &event_ctx->timed_events->when) < 0) {
                        /* Nothing to do yet */
                        DEBUG(11, ("run_events: Nothing to do\n"));
                        break;
                }

                DEBUG(10, ("Running event \"%s\" %lx\n",
                           event_ctx->timed_events->event_name,
                           (unsigned long)event_ctx->timed_events));

                event_ctx->timed_events->handler(
                        event_ctx,
                        event_ctx->timed_events, &now,
                        event_ctx->timed_events->private_data);

                fired = True;
        }

        if (fired) {
                /*
                 * We might have changed the socket status during the timed
                 * events, return to run select again.
                 */
                return True;
        }

        if (selrtn == 0) {
                /*
                 * No fd ready
                 */
                return fired;
        }

        for (fde = event_ctx->fd_events; fde; fde = next) {
                uint16 flags = 0;

                next = fde->next;
                if (FD_ISSET(fde->fd, read_fds)) flags |= EVENT_FD_READ;
                if (FD_ISSET(fde->fd, write_fds)) flags |= EVENT_FD_WRITE;

                if (flags) {
                        fde->handler(event_ctx, fde, flags, fde->private_data);
                        fired = True;
                }
        }

        return fired;
}

struct timeval* get_timed_events_timeout	(	struct event_context *	event_ctx,
		struct timeval *	to_ret
	)

events.c の 282 行で定義されています。

参照先 event_context::timed_events・timeval_current()・timeval_until()・timed_event::when.

参照元 process_loop().

{
        struct timeval now;

        if (event_ctx->timed_events == NULL) {
                return NULL;
        }

        now = timeval_current();
        *to_ret = timeval_until(&now, &event_ctx->timed_events->when);

        DEBUG(10, ("timed_events_timeout: %d/%d\n", (int)to_ret->tv_sec,
                (int)to_ret->tv_usec));

        return to_ret;
}

struct event_context* event_context_init

(

TALLOC_CTX *

mem_ctx

)

events.c の 300 行で定義されています。

参照元 smbd_event_context()・winbind_event_context().

{
        return TALLOC_ZERO_P(NULL, struct event_context);
}

int set_event_dispatch_time	(	struct event_context *	event_ctx,
		const char *	event_name,
		struct timeval	when
	)

events.c の 305 行で定義されています。

参照先 add_event_by_time()・timed_event::event_ctx・timed_event::event_name・timed_event::next・event_context::timed_events・timed_event::when.

参照元 set_domain_online()・set_domain_online_request().

{
        struct timed_event *te;

        for (te = event_ctx->timed_events; te; te = te->next) {
                if (strcmp(event_name, te->event_name) == 0) {
                        DLIST_REMOVE(event_ctx->timed_events, te);
                        te->when = when;
                        add_event_by_time(te);
                        return 1;
                }
        }
        return 0;
}

int cancel_named_event	(	struct event_context *	event_ctx,
		const char *	event_name
	)

events.c の 323 行で定義されています。

参照先 timed_event::event_ctx・timed_event::event_name・timed_event::next・event_context::timed_events.

{
        struct timed_event *te;

        for (te = event_ctx->timed_events; te; te = te->next) {
                if (strcmp(event_name, te->event_name) == 0) {
                        TALLOC_FREE(te);
                        return 1;
                }
        }
        return 0;
}

---