kc3-lang/libevent/devpoll.c

• Show log

  Commit

• Hash : 8ac3c4c2
  Author :
  Date : 2012-02-29T15:07:33
  

  Have all visible internal function names end with an underscore.
  
  We haven't had a convention for naming internal functions in -internal.h
  versus naming visible functions in include/**.h.  This patch changes every
  function declared in a -internal.h file to be named ending with an
  underscore.
  
  Static function names are unaffected, since there's no risk of calling them
  from outside Libevent.
  
  This is an automatic conversion.  The script that produced was made by
  running the following script over the output of
  
  ctags --c-kinds=pf -o - *-internal.h |  cut -f 1 | sort| uniq
  
  (GNU ctags was required.)
  
  =====
  #!/usr/bin/perl -w -n
  
  use strict;
  
  BEGIN { print "#!/usr/bin/perl -w -i -p\n\n"; }
  
  chomp;
  
  my $ident = $_;
  
  next if ($ident =~ /_$/);
  next if ($ident =~ /^TAILQ/);
  
  my $better = "${ident}_";
  
  print "s/(?<![A-Za-z0-9_])$ident(?![A-Za-z0-9_])/$better/g;\n";
  
  === And then running the script below that it generated over all
  === the .c and .h files again
  #!/usr/bin/perl -w -i -p
  
  s/(?<![A-Za-z0-9_])bufferevent_async_can_connect(?![A-Za-z0-9_])/bufferevent_async_can_connect_/g;
  s/(?<![A-Za-z0-9_])bufferevent_async_connect(?![A-Za-z0-9_])/bufferevent_async_connect_/g;
  s/(?<![A-Za-z0-9_])bufferevent_async_new(?![A-Za-z0-9_])/bufferevent_async_new_/g;
  s/(?<![A-Za-z0-9_])bufferevent_async_set_connected(?![A-Za-z0-9_])/bufferevent_async_set_connected_/g;
  s/(?<![A-Za-z0-9_])bufferevent_decref(?![A-Za-z0-9_])/bufferevent_decref_/g;
  s/(?<![A-Za-z0-9_])bufferevent_disable_hard(?![A-Za-z0-9_])/bufferevent_disable_hard_/g;
  s/(?<![A-Za-z0-9_])bufferevent_enable_locking(?![A-Za-z0-9_])/bufferevent_enable_locking_/g;
  s/(?<![A-Za-z0-9_])bufferevent_incref(?![A-Za-z0-9_])/bufferevent_incref_/g;
  s/(?<![A-Za-z0-9_])bufferevent_init_common(?![A-Za-z0-9_])/bufferevent_init_common_/g;
  s/(?<![A-Za-z0-9_])bufferevent_remove_from_rate_limit_group_internal(?![A-Za-z0-9_])/bufferevent_remove_from_rate_limit_group_internal_/g;
  s/(?<![A-Za-z0-9_])bufferevent_suspend_read(?![A-Za-z0-9_])/bufferevent_suspend_read_/g;
  s/(?<![A-Za-z0-9_])bufferevent_suspend_write(?![A-Za-z0-9_])/bufferevent_suspend_write_/g;
  s/(?<![A-Za-z0-9_])bufferevent_unsuspend_read(?![A-Za-z0-9_])/bufferevent_unsuspend_read_/g;
  s/(?<![A-Za-z0-9_])bufferevent_unsuspend_write(?![A-Za-z0-9_])/bufferevent_unsuspend_write_/g;
  s/(?<![A-Za-z0-9_])evbuffer_commit_read(?![A-Za-z0-9_])/evbuffer_commit_read_/g;
  s/(?<![A-Za-z0-9_])evbuffer_commit_write(?![A-Za-z0-9_])/evbuffer_commit_write_/g;
  s/(?<![A-Za-z0-9_])evbuffer_invoke_callbacks(?![A-Za-z0-9_])/evbuffer_invoke_callbacks_/g;
  s/(?<![A-Za-z0-9_])evbuffer_launch_read(?![A-Za-z0-9_])/evbuffer_launch_read_/g;
  s/(?<![A-Za-z0-9_])evbuffer_launch_write(?![A-Za-z0-9_])/evbuffer_launch_write_/g;
  s/(?<![A-Za-z0-9_])evbuffer_overlapped_new(?![A-Za-z0-9_])/evbuffer_overlapped_new_/g;
  s/(?<![A-Za-z0-9_])evbuffer_set_parent(?![A-Za-z0-9_])/evbuffer_set_parent_/g;
  s/(?<![A-Za-z0-9_])event_active_nolock(?![A-Za-z0-9_])/event_active_nolock_/g;
  s/(?<![A-Za-z0-9_])event_base_add_virtual(?![A-Za-z0-9_])/event_base_add_virtual_/g;
  s/(?<![A-Za-z0-9_])event_base_assert_ok(?![A-Za-z0-9_])/event_base_assert_ok_/g;
  s/(?<![A-Za-z0-9_])event_base_del_virtual(?![A-Za-z0-9_])/event_base_del_virtual_/g;
  s/(?<![A-Za-z0-9_])event_base_get_deferred_cb_queue(?![A-Za-z0-9_])/event_base_get_deferred_cb_queue_/g;
  s/(?<![A-Za-z0-9_])event_base_get_iocp(?![A-Za-z0-9_])/event_base_get_iocp_/g;
  s/(?<![A-Za-z0-9_])event_base_start_iocp(?![A-Za-z0-9_])/event_base_start_iocp_/g;
  s/(?<![A-Za-z0-9_])event_base_stop_iocp(?![A-Za-z0-9_])/event_base_stop_iocp_/g;
  s/(?<![A-Za-z0-9_])event_changelist_add(?![A-Za-z0-9_])/event_changelist_add_/g;
  s/(?<![A-Za-z0-9_])event_changelist_del(?![A-Za-z0-9_])/event_changelist_del_/g;
  s/(?<![A-Za-z0-9_])event_changelist_freemem(?![A-Za-z0-9_])/event_changelist_freemem_/g;
  s/(?<![A-Za-z0-9_])event_changelist_init(?![A-Za-z0-9_])/event_changelist_init_/g;
  s/(?<![A-Za-z0-9_])event_changelist_remove_all(?![A-Za-z0-9_])/event_changelist_remove_all_/g;
  s/(?<![A-Za-z0-9_])event_deferred_cb_cancel(?![A-Za-z0-9_])/event_deferred_cb_cancel_/g;
  s/(?<![A-Za-z0-9_])event_deferred_cb_init(?![A-Za-z0-9_])/event_deferred_cb_init_/g;
  s/(?<![A-Za-z0-9_])event_deferred_cb_queue_init(?![A-Za-z0-9_])/event_deferred_cb_queue_init_/g;
  s/(?<![A-Za-z0-9_])event_deferred_cb_schedule(?![A-Za-z0-9_])/event_deferred_cb_schedule_/g;
  s/(?<![A-Za-z0-9_])event_get_win32_extension_fns(?![A-Za-z0-9_])/event_get_win32_extension_fns_/g;
  s/(?<![A-Za-z0-9_])event_iocp_activate_overlapped(?![A-Za-z0-9_])/event_iocp_activate_overlapped_/g;
  s/(?<![A-Za-z0-9_])event_iocp_port_associate(?![A-Za-z0-9_])/event_iocp_port_associate_/g;
  s/(?<![A-Za-z0-9_])event_iocp_port_launch(?![A-Za-z0-9_])/event_iocp_port_launch_/g;
  s/(?<![A-Za-z0-9_])event_iocp_shutdown(?![A-Za-z0-9_])/event_iocp_shutdown_/g;
  s/(?<![A-Za-z0-9_])event_overlapped_init(?![A-Za-z0-9_])/event_overlapped_init_/g;
  s/(?<![A-Za-z0-9_])evhttp_connection_connect(?![A-Za-z0-9_])/evhttp_connection_connect_/g;
  s/(?<![A-Za-z0-9_])evhttp_connection_fail(?![A-Za-z0-9_])/evhttp_connection_fail_/g;
  s/(?<![A-Za-z0-9_])evhttp_connection_reset(?![A-Za-z0-9_])/evhttp_connection_reset_/g;
  s/(?<![A-Za-z0-9_])evhttp_parse_firstline(?![A-Za-z0-9_])/evhttp_parse_firstline_/g;
  s/(?<![A-Za-z0-9_])evhttp_parse_headers(?![A-Za-z0-9_])/evhttp_parse_headers_/g;
  s/(?<![A-Za-z0-9_])evhttp_response_code(?![A-Za-z0-9_])/evhttp_response_code_/g;
  s/(?<![A-Za-z0-9_])evhttp_send_page(?![A-Za-z0-9_])/evhttp_send_page_/g;
  s/(?<![A-Za-z0-9_])evhttp_start_read(?![A-Za-z0-9_])/evhttp_start_read_/g;
  s/(?<![A-Za-z0-9_])EVLOCK_TRY_LOCK(?![A-Za-z0-9_])/EVLOCK_TRY_LOCK_/g;
  s/(?<![A-Za-z0-9_])evmap_check_integrity(?![A-Za-z0-9_])/evmap_check_integrity_/g;
  s/(?<![A-Za-z0-9_])evmap_delete_all(?![A-Za-z0-9_])/evmap_delete_all_/g;
  s/(?<![A-Za-z0-9_])evmap_foreach_event(?![A-Za-z0-9_])/evmap_foreach_event_/g;
  s/(?<![A-Za-z0-9_])evmap_io_active(?![A-Za-z0-9_])/evmap_io_active_/g;
  s/(?<![A-Za-z0-9_])evmap_io_add(?![A-Za-z0-9_])/evmap_io_add_/g;
  s/(?<![A-Za-z0-9_])evmap_io_clear(?![A-Za-z0-9_])/evmap_io_clear_/g;
  s/(?<![A-Za-z0-9_])evmap_io_del(?![A-Za-z0-9_])/evmap_io_del_/g;
  s/(?<![A-Za-z0-9_])evmap_io_get_fdinfo(?![A-Za-z0-9_])/evmap_io_get_fdinfo_/g;
  s/(?<![A-Za-z0-9_])evmap_io_initmap(?![A-Za-z0-9_])/evmap_io_initmap_/g;
  s/(?<![A-Za-z0-9_])evmap_reinit(?![A-Za-z0-9_])/evmap_reinit_/g;
  s/(?<![A-Za-z0-9_])evmap_signal_active(?![A-Za-z0-9_])/evmap_signal_active_/g;
  s/(?<![A-Za-z0-9_])evmap_signal_add(?![A-Za-z0-9_])/evmap_signal_add_/g;
  s/(?<![A-Za-z0-9_])evmap_signal_clear(?![A-Za-z0-9_])/evmap_signal_clear_/g;
  s/(?<![A-Za-z0-9_])evmap_signal_del(?![A-Za-z0-9_])/evmap_signal_del_/g;
  s/(?<![A-Za-z0-9_])evmap_signal_initmap(?![A-Za-z0-9_])/evmap_signal_initmap_/g;
  s/(?<![A-Za-z0-9_])evrpc_hook_associate_meta(?![A-Za-z0-9_])/evrpc_hook_associate_meta_/g;
  s/(?<![A-Za-z0-9_])evrpc_hook_context_free(?![A-Za-z0-9_])/evrpc_hook_context_free_/g;
  s/(?<![A-Za-z0-9_])evrpc_hook_meta_new(?![A-Za-z0-9_])/evrpc_hook_meta_new_/g;
  s/(?<![A-Za-z0-9_])evrpc_reqstate_free(?![A-Za-z0-9_])/evrpc_reqstate_free_/g;
  s/(?<![A-Za-z0-9_])evsig_dealloc(?![A-Za-z0-9_])/evsig_dealloc_/g;
  s/(?<![A-Za-z0-9_])evsig_init(?![A-Za-z0-9_])/evsig_init_/g;
  s/(?<![A-Za-z0-9_])evsig_set_base(?![A-Za-z0-9_])/evsig_set_base_/g;
  s/(?<![A-Za-z0-9_])ev_token_bucket_get_tick(?![A-Za-z0-9_])/ev_token_bucket_get_tick_/g;
  s/(?<![A-Za-z0-9_])ev_token_bucket_init(?![A-Za-z0-9_])/ev_token_bucket_init_/g;
  s/(?<![A-Za-z0-9_])ev_token_bucket_update(?![A-Za-z0-9_])/ev_token_bucket_update_/g;
  s/(?<![A-Za-z0-9_])evutil_accept4(?![A-Za-z0-9_])/evutil_accept4_/g;
  s/(?<![A-Za-z0-9_])evutil_addrinfo_append(?![A-Za-z0-9_])/evutil_addrinfo_append_/g;
  s/(?<![A-Za-z0-9_])evutil_adjust_hints_for_addrconfig(?![A-Za-z0-9_])/evutil_adjust_hints_for_addrconfig_/g;
  s/(?<![A-Za-z0-9_])evutil_ersatz_socketpair(?![A-Za-z0-9_])/evutil_ersatz_socketpair_/g;
  s/(?<![A-Za-z0-9_])evutil_eventfd(?![A-Za-z0-9_])/evutil_eventfd_/g;
  s/(?<![A-Za-z0-9_])evutil_format_sockaddr_port(?![A-Za-z0-9_])/evutil_format_sockaddr_port_/g;
  s/(?<![A-Za-z0-9_])evutil_getaddrinfo_async(?![A-Za-z0-9_])/evutil_getaddrinfo_async_/g;
  s/(?<![A-Za-z0-9_])evutil_getaddrinfo_common(?![A-Za-z0-9_])/evutil_getaddrinfo_common_/g;
  s/(?<![A-Za-z0-9_])evutil_getenv(?![A-Za-z0-9_])/evutil_getenv_/g;
  s/(?<![A-Za-z0-9_])evutil_hex_char_to_int(?![A-Za-z0-9_])/evutil_hex_char_to_int_/g;
  s/(?<![A-Za-z0-9_])EVUTIL_ISALNUM(?![A-Za-z0-9_])/EVUTIL_ISALNUM_/g;
  s/(?<![A-Za-z0-9_])EVUTIL_ISALPHA(?![A-Za-z0-9_])/EVUTIL_ISALPHA_/g;
  s/(?<![A-Za-z0-9_])EVUTIL_ISDIGIT(?![A-Za-z0-9_])/EVUTIL_ISDIGIT_/g;
  s/(?<![A-Za-z0-9_])EVUTIL_ISLOWER(?![A-Za-z0-9_])/EVUTIL_ISLOWER_/g;
  s/(?<![A-Za-z0-9_])EVUTIL_ISPRINT(?![A-Za-z0-9_])/EVUTIL_ISPRINT_/g;
  s/(?<![A-Za-z0-9_])EVUTIL_ISSPACE(?![A-Za-z0-9_])/EVUTIL_ISSPACE_/g;
  s/(?<![A-Za-z0-9_])EVUTIL_ISUPPER(?![A-Za-z0-9_])/EVUTIL_ISUPPER_/g;
  s/(?<![A-Za-z0-9_])EVUTIL_ISXDIGIT(?![A-Za-z0-9_])/EVUTIL_ISXDIGIT_/g;
  s/(?<![A-Za-z0-9_])evutil_load_windows_system_library(?![A-Za-z0-9_])/evutil_load_windows_system_library_/g;
  s/(?<![A-Za-z0-9_])evutil_make_internal_pipe(?![A-Za-z0-9_])/evutil_make_internal_pipe_/g;
  s/(?<![A-Za-z0-9_])evutil_new_addrinfo(?![A-Za-z0-9_])/evutil_new_addrinfo_/g;
  s/(?<![A-Za-z0-9_])evutil_open_closeonexec(?![A-Za-z0-9_])/evutil_open_closeonexec_/g;
  s/(?<![A-Za-z0-9_])evutil_read_file(?![A-Za-z0-9_])/evutil_read_file_/g;
  s/(?<![A-Za-z0-9_])evutil_resolve(?![A-Za-z0-9_])/evutil_resolve_/g;
  s/(?<![A-Za-z0-9_])evutil_set_evdns_getaddrinfo_fn(?![A-Za-z0-9_])/evutil_set_evdns_getaddrinfo_fn_/g;
  s/(?<![A-Za-z0-9_])evutil_sockaddr_is_loopback(?![A-Za-z0-9_])/evutil_sockaddr_is_loopback_/g;
  s/(?<![A-Za-z0-9_])evutil_socket(?![A-Za-z0-9_])/evutil_socket_/g;
  s/(?<![A-Za-z0-9_])evutil_socket_connect(?![A-Za-z0-9_])/evutil_socket_connect_/g;
  s/(?<![A-Za-z0-9_])evutil_socket_finished_connecting(?![A-Za-z0-9_])/evutil_socket_finished_connecting_/g;
  s/(?<![A-Za-z0-9_])EVUTIL_TOLOWER(?![A-Za-z0-9_])/EVUTIL_TOLOWER_/g;
  s/(?<![A-Za-z0-9_])EVUTIL_TOUPPER(?![A-Za-z0-9_])/EVUTIL_TOUPPER_/g;
  s/(?<![A-Za-z0-9_])evutil_tv_to_msec(?![A-Za-z0-9_])/evutil_tv_to_msec_/g;
  s/(?<![A-Za-z0-9_])evutil_usleep(?![A-Za-z0-9_])/evutil_usleep_/g;
  s/(?<![A-Za-z0-9_])ht_improve_hash(?![A-Za-z0-9_])/ht_improve_hash_/g;
  s/(?<![A-Za-z0-9_])ht_string_hash(?![A-Za-z0-9_])/ht_string_hash_/g;
  s/(?<![A-Za-z0-9_])min_heap_adjust(?![A-Za-z0-9_])/min_heap_adjust_/g;
  s/(?<![A-Za-z0-9_])min_heap_ctor(?![A-Za-z0-9_])/min_heap_ctor_/g;
  s/(?<![A-Za-z0-9_])min_heap_dtor(?![A-Za-z0-9_])/min_heap_dtor_/g;
  s/(?<![A-Za-z0-9_])min_heap_elem_init(?![A-Za-z0-9_])/min_heap_elem_init_/g;
  s/(?<![A-Za-z0-9_])min_heap_elt_is_top(?![A-Za-z0-9_])/min_heap_elt_is_top_/g;
  s/(?<![A-Za-z0-9_])min_heap_empty(?![A-Za-z0-9_])/min_heap_empty_/g;
  s/(?<![A-Za-z0-9_])min_heap_erase(?![A-Za-z0-9_])/min_heap_erase_/g;
  s/(?<![A-Za-z0-9_])min_heap_pop(?![A-Za-z0-9_])/min_heap_pop_/g;
  s/(?<![A-Za-z0-9_])min_heap_push(?![A-Za-z0-9_])/min_heap_push_/g;
  s/(?<![A-Za-z0-9_])min_heap_reserve(?![A-Za-z0-9_])/min_heap_reserve_/g;
  s/(?<![A-Za-z0-9_])min_heap_size(?![A-Za-z0-9_])/min_heap_size_/g;
  s/(?<![A-Za-z0-9_])min_heap_top(?![A-Za-z0-9_])/min_heap_top_/g;
  

Download

• devpoll.c

• /*
   * Copyright 2000-2009 Niels Provos <provos@citi.umich.edu>
   * Copyright 2009-2012 Niels Provos and Nick Mathewson
   *
   * Redistribution and use in source and binary forms, with or without
   * modification, are permitted provided that the following conditions
   * are met:
   * 1. Redistributions of source code must retain the above copyright
   *    notice, this list of conditions and the following disclaimer.
   * 2. Redistributions in binary form must reproduce the above copyright
   *    notice, this list of conditions and the following disclaimer in the
   *    documentation and/or other materials provided with the distribution.
   * 3. The name of the author may not be used to endorse or promote products
   *    derived from this software without specific prior written permission.
   *
   * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR
   * IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
   * OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED.
   * IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT,
   * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT
   * NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
   * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
   * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
   * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
   * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
   */
  #include "event2/event-config.h"
  #include "evconfig-private.h"
  
  #ifdef EVENT__HAVE_DEVPOLL
  
  #include <sys/types.h>
  #include <sys/resource.h>
  #ifdef EVENT__HAVE_SYS_TIME_H
  #include <sys/time.h>
  #endif
  #include <sys/queue.h>
  #include <sys/devpoll.h>
  #include <signal.h>
  #include <stdio.h>
  #include <stdlib.h>
  #include <string.h>
  #include <unistd.h>
  #include <fcntl.h>
  #include <errno.h>
  
  #include "event2/event.h"
  #include "event2/event_struct.h"
  #include "event2/thread.h"
  #include "event-internal.h"
  #include "evsignal-internal.h"
  #include "log-internal.h"
  #include "evmap-internal.h"
  #include "evthread-internal.h"
  
  struct devpollop {
  	struct pollfd *events;
  	int nevents;
  	int dpfd;
  	struct pollfd *changes;
  	int nchanges;
  };
  
  static void *devpoll_init(struct event_base *);
  static int devpoll_add(struct event_base *, int fd, short old, short events, void *);
  static int devpoll_del(struct event_base *, int fd, short old, short events, void *);
  static int devpoll_dispatch(struct event_base *, struct timeval *);
  static void devpoll_dealloc(struct event_base *);
  
  const struct eventop devpollops = {
  	"devpoll",
  	devpoll_init,
  	devpoll_add,
  	devpoll_del,
  	devpoll_dispatch,
  	devpoll_dealloc,
  	1, /* need reinit */
  	EV_FEATURE_FDS|EV_FEATURE_O1,
  	0
  };
  
  #define NEVENT	32000
  
  static int
  devpoll_commit(struct devpollop *devpollop)
  {
  	/*
  	 * Due to a bug in Solaris, we have to use pwrite with an offset of 0.
  	 * Write is limited to 2GB of data, until it will fail.
  	 */
  	if (pwrite(devpollop->dpfd, devpollop->changes,
  		sizeof(struct pollfd) * devpollop->nchanges, 0) == -1)
  		return (-1);
  
  	devpollop->nchanges = 0;
  	return (0);
  }
  
  static int
  devpoll_queue(struct devpollop *devpollop, int fd, int events) {
  	struct pollfd *pfd;
  
  	if (devpollop->nchanges >= devpollop->nevents) {
  		/*
  		 * Change buffer is full, must commit it to /dev/poll before
  		 * adding more
  		 */
  		if (devpoll_commit(devpollop) != 0)
  			return (-1);
  	}
  
  	pfd = &devpollop->changes[devpollop->nchanges++];
  	pfd->fd = fd;
  	pfd->events = events;
  	pfd->revents = 0;
  
  	return (0);
  }
  
  static void *
  devpoll_init(struct event_base *base)
  {
  	int dpfd, nfiles = NEVENT;
  	struct rlimit rl;
  	struct devpollop *devpollop;
  
  	if (!(devpollop = mm_calloc(1, sizeof(struct devpollop))))
  		return (NULL);
  
  	if (getrlimit(RLIMIT_NOFILE, &rl) == 0 &&
  	    rl.rlim_cur != RLIM_INFINITY)
  		nfiles = rl.rlim_cur;
  
  	/* Initialize the kernel queue */
  	if ((dpfd = evutil_open_closeonexec_("/dev/poll", O_RDWR, 0)) == -1) {
  		event_warn("open: /dev/poll");
  		mm_free(devpollop);
  		return (NULL);
  	}
  
  	devpollop->dpfd = dpfd;
  
  	/* Initialize fields */
  	/* FIXME: allocating 'nfiles' worth of space here can be
  	 * expensive and unnecessary.  See how epoll.c does it instead. */
  	devpollop->events = mm_calloc(nfiles, sizeof(struct pollfd));
  	if (devpollop->events == NULL) {
  		mm_free(devpollop);
  		close(dpfd);
  		return (NULL);
  	}
  	devpollop->nevents = nfiles;
  
  	devpollop->changes = mm_calloc(nfiles, sizeof(struct pollfd));
  	if (devpollop->changes == NULL) {
  		mm_free(devpollop->events);
  		mm_free(devpollop);
  		close(dpfd);
  		return (NULL);
  	}
  
  	evsig_init_(base);
  
  	return (devpollop);
  }
  
  static int
  devpoll_dispatch(struct event_base *base, struct timeval *tv)
  {
  	struct devpollop *devpollop = base->evbase;
  	struct pollfd *events = devpollop->events;
  	struct dvpoll dvp;
  	int i, res, timeout = -1;
  
  	if (devpollop->nchanges)
  		devpoll_commit(devpollop);
  
  	if (tv != NULL)
  		timeout = tv->tv_sec * 1000 + (tv->tv_usec + 999) / 1000;
  
  	dvp.dp_fds = devpollop->events;
  	dvp.dp_nfds = devpollop->nevents;
  	dvp.dp_timeout = timeout;
  
  	EVBASE_RELEASE_LOCK(base, th_base_lock);
  
  	res = ioctl(devpollop->dpfd, DP_POLL, &dvp);
  
  	EVBASE_ACQUIRE_LOCK(base, th_base_lock);
  
  	if (res == -1) {
  		if (errno != EINTR) {
  			event_warn("ioctl: DP_POLL");
  			return (-1);
  		}
  
  		return (0);
  	}
  
  	event_debug(("%s: devpoll_wait reports %d", __func__, res));
  
  	for (i = 0; i < res; i++) {
  		int which = 0;
  		int what = events[i].revents;
  
  		if (what & POLLHUP)
  			what |= POLLIN | POLLOUT;
  		else if (what & POLLERR)
  			what |= POLLIN | POLLOUT;
  
  		if (what & POLLIN)
  			which |= EV_READ;
  		if (what & POLLOUT)
  			which |= EV_WRITE;
  
  		if (!which)
  			continue;
  
  		/* XXX(niels): not sure if this works for devpoll */
  		evmap_io_active_(base, events[i].fd, which);
  	}
  
  	return (0);
  }
  
  
  static int
  devpoll_add(struct event_base *base, int fd, short old, short events, void *p)
  {
  	struct devpollop *devpollop = base->evbase;
  	int res;
  	(void)p;
  
  	/*
  	 * It's not necessary to OR the existing read/write events that we
  	 * are currently interested in with the new event we are adding.
  	 * The /dev/poll driver ORs any new events with the existing events
  	 * that it has cached for the fd.
  	 */
  
  	res = 0;
  	if (events & EV_READ)
  		res |= POLLIN;
  	if (events & EV_WRITE)
  		res |= POLLOUT;
  
  	if (devpoll_queue(devpollop, fd, res) != 0)
  		return (-1);
  
  	return (0);
  }
  
  static int
  devpoll_del(struct event_base *base, int fd, short old, short events, void *p)
  {
  	struct devpollop *devpollop = base->evbase;
  	int res;
  	(void)p;
  
  	res = 0;
  	if (events & EV_READ)
  		res |= POLLIN;
  	if (events & EV_WRITE)
  		res |= POLLOUT;
  
  	/*
  	 * The only way to remove an fd from the /dev/poll monitored set is
  	 * to use POLLREMOVE by itself.  This removes ALL events for the fd
  	 * provided so if we care about two events and are only removing one
  	 * we must re-add the other event after POLLREMOVE.
  	 */
  
  	if (devpoll_queue(devpollop, fd, POLLREMOVE) != 0)
  		return (-1);
  
  	if ((res & (POLLIN|POLLOUT)) != (POLLIN|POLLOUT)) {
  		/*
  		 * We're not deleting all events, so we must resubmit the
  		 * event that we are still interested in if one exists.
  		 */
  
  		if ((res & POLLIN) && (old & EV_WRITE)) {
  			/* Deleting read, still care about write */
  			devpoll_queue(devpollop, fd, POLLOUT);
  		} else if ((res & POLLOUT) && (old & EV_READ)) {
  			/* Deleting write, still care about read */
  			devpoll_queue(devpollop, fd, POLLIN);
  		}
  	}
  
  	return (0);
  }
  
  static void
  devpoll_dealloc(struct event_base *base)
  {
  	struct devpollop *devpollop = base->evbase;
  
  	evsig_dealloc_(base);
  	if (devpollop->events)
  		mm_free(devpollop->events);
  	if (devpollop->changes)
  		mm_free(devpollop->changes);
  	if (devpollop->dpfd >= 0)
  		close(devpollop->dpfd);
  
  	memset(devpollop, 0, sizeof(struct devpollop));
  	mm_free(devpollop);
  }
  
  #endif /* EVENT__HAVE_DEVPOLL */
  

Download