--- /dev/null
+/*
+ * Unix SMB/CIFS implementation.
+ * Copyright (C) Volker Lendecke 2013
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * 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. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+/**
+ * @file poll_funcs.h
+ *
+ * @brief event loop abstraction
+ */
+
+/*
+ * This is inspired by AvahiWatch, the avahi event loop abstraction.
+ */
+
+#ifndef __POLL_FUNCS_H__
+#define __POLL_FUNCS_H__
+
+#include "replace.h"
+
+/**
+ * poll_watch and poll_timeout are undefined here, every implementation can
+ * implement its own structures.
+ */
+
+struct poll_watch;
+struct poll_timeout;
+
+struct poll_funcs {
+
+ /**
+ * @brief Create a new file descriptor watch
+ *
+ * @param[in] funcs The callback array
+ * @param[in] fd The fd to watch
+ * @param[in] events POLLIN and POLLOUT or'ed together
+ * @param[in] callback Function to call by the implementation
+ * @param[in] private_data Pointer to give back to callback
+ *
+ * @return A new poll_watch struct
+ */
+
+ struct poll_watch *(*watch_new)(
+ const struct poll_funcs *funcs, int fd, short events,
+ void (*callback)(struct poll_watch *w, int fd,
+ short events, void *private_data),
+ void *private_data);
+
+ /**
+ * @brief Change the watched events for a struct poll_watch
+ *
+ * @param[in] w The poll_watch to change
+ * @param[in] events new POLLIN and POLLOUT or'ed together
+ */
+
+ void (*watch_update)(struct poll_watch *w, short events);
+
+ /**
+ * @brief Read events currently watched
+ *
+ * @param[in] w The poll_watch to inspect
+ *
+ * @returns The events currently watched
+ */
+
+ short (*watch_get_events)(struct poll_watch *w);
+
+ /**
+ * @brief Free a struct poll_watch
+ *
+ * @param[in] w The poll_watch struct to free
+ */
+
+ void (*watch_free)(struct poll_watch *w);
+
+
+ /**
+ * @brief Create a new timeout watch
+ *
+ * @param[in] funcs The callback array
+ * @param[in] tv The time when the timeout should trigger
+ * @param[in] callback Function to call at time "ts"
+ * @param[in] private_data Pointer to give back to callback
+ *
+ * @return A new poll_timeout struct
+ */
+
+ struct poll_timeout *(*timeout_new)(
+ const struct poll_funcs *funcs, const struct timeval *tv,
+ void (*callback)(struct poll_timeout *t, void *private_data),
+ void *private_data);
+
+ /**
+ * @brief Change the timeout of a watch
+ *
+ * @param[in] t The timeout watch to change
+ * @param[in] ts The new trigger time
+ */
+
+ void (*timeout_update)(struct poll_timeout *t,
+ const struct timespec *ts);
+
+ /**
+ * @brief Free a poll_timeout
+ *
+ * @param[in] t The poll_timeout to free
+ */
+
+ void (*timeout_free)(struct poll_timeout *t);
+
+ /**
+ * @brief private data for use by the implmentation
+ */
+
+ void *private_data;
+};
+
+#endif
--- /dev/null
+/*
+ * Unix SMB/CIFS implementation.
+ * Copyright (C) Volker Lendecke 2013
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * 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. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+#include "poll_funcs_tevent.h"
+#include "tevent.h"
+#include "system/select.h"
+
+struct poll_watch {
+ struct tevent_fd *fde;
+ int fd;
+ void (*callback)(struct poll_watch *w, int fd, short events,
+ void *private_data);
+ void *private_data;
+};
+
+static uint16_t poll_events_to_tevent(short events)
+{
+ uint16_t ret = 0;
+
+ if (events & POLLIN) {
+ ret |= TEVENT_FD_READ;
+ }
+ if (events & POLLOUT) {
+ ret |= TEVENT_FD_WRITE;
+ }
+ return ret;
+}
+
+static short tevent_to_poll_events(uint16_t flags)
+{
+ short ret = 0;
+
+ if (flags & TEVENT_FD_READ) {
+ ret |= POLLIN;
+ }
+ if (flags & TEVENT_FD_WRITE) {
+ ret |= POLLOUT;
+ }
+ return ret;
+}
+
+static void tevent_watch_handler(struct tevent_context *ev,
+ struct tevent_fd *fde, uint16_t flags,
+ void *private_data);
+
+static struct poll_watch *tevent_watch_new(
+ const struct poll_funcs *funcs, int fd, short events,
+ void (*callback)(struct poll_watch *w, int fd, short events,
+ void *private_data),
+ void *private_data)
+{
+ struct tevent_context *ev = talloc_get_type_abort(
+ funcs->private_data, struct tevent_context);
+ struct poll_watch *w;
+
+ w = talloc(ev, struct poll_watch);
+ if (w == NULL) {
+ return NULL;
+ }
+ w->fde = tevent_add_fd(ev, w, fd, poll_events_to_tevent(events),
+ tevent_watch_handler, w);
+ if (w->fde == NULL) {
+ TALLOC_FREE(w);
+ return NULL;
+ }
+ w->fd = fd;
+ w->callback = callback;
+ w->private_data = private_data;
+ return w;
+}
+
+static void tevent_watch_handler(struct tevent_context *ev,
+ struct tevent_fd *fde, uint16_t flags,
+ void *private_data)
+{
+ struct poll_watch *w = talloc_get_type_abort(
+ private_data, struct poll_watch);
+
+ w->callback(w, w->fd, tevent_to_poll_events(flags),
+ w->private_data);
+}
+
+static void tevent_watch_update(struct poll_watch *w, short events)
+{
+ tevent_fd_set_flags(w->fde, poll_events_to_tevent(events));
+}
+
+static short tevent_watch_get_events(struct poll_watch *w)
+{
+ return tevent_to_poll_events(tevent_fd_get_flags(w->fde));
+}
+
+static void tevent_watch_free(struct poll_watch *w)
+{
+ TALLOC_FREE(w);
+}
+
+static struct poll_timeout *tevent_timeout_new(
+ const struct poll_funcs *funcs, const struct timeval *tv,
+ void (*callback)(struct poll_timeout *t, void *private_data),
+ void *private_data)
+{
+ /* not implemented yet */
+ return NULL;
+}
+
+static void tevent_timeout_update(struct poll_timeout *t,
+ const struct timespec *ts)
+{
+ return;
+}
+
+static void tevent_timeout_free(struct poll_timeout *t)
+{
+ return;
+}
+
+void poll_funcs_init_tevent(struct poll_funcs *f, struct tevent_context *ev)
+{
+ f->watch_new = tevent_watch_new;
+ f->watch_update = tevent_watch_update;
+ f->watch_get_events = tevent_watch_get_events;
+ f->watch_free = tevent_watch_free;
+ f->timeout_new = tevent_timeout_new;
+ f->timeout_update = tevent_timeout_update;
+ f->timeout_free = tevent_timeout_free;
+ f->private_data = ev;
+}
--- /dev/null
+/*
+ * Unix SMB/CIFS implementation.
+ * Copyright (C) Volker Lendecke 2013
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; either version 3 of the License, or
+ * (at your option) any later version.
+ *
+ * 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. If not, see <http://www.gnu.org/licenses/>.
+ */
+
+#ifndef __POLL_FUNCS_TEVENT_H__
+#define __POLL_FUNCS_TEVENT_H__
+
+#include "poll_funcs.h"
+#include "tevent.h"
+
+void poll_funcs_init_tevent(struct poll_funcs *f, struct tevent_context *ev);
+
+#endif
--- /dev/null
+#!/usr/bin/env python
+
+bld.SAMBA3_SUBSYSTEM('POLL_FUNCS_TEVENT',
+ source='poll_funcs_tevent.c',
+ deps='tevent')
bld.RECURSE('libgpo/gpext')
bld.RECURSE('lib/pthreadpool')
bld.RECURSE('lib/asys')
+bld.RECURSE('lib/poll_funcs')
bld.RECURSE('librpc')
bld.RECURSE('librpc/idl')
bld.RECURSE('libsmb')
git.samba.org / kai / samba-autobuild / .git / commitdiff