ViewVC Help
View File | Revision Log | Show Annotations | Download File
/cvs/libev/ev_poll.c
(Generate patch)

Comparing libev/ev_poll.c (file contents):
Revision 1.21 by root, Tue Dec 25 07:05:45 2007 UTC vs.
Revision 1.27 by root, Wed Oct 29 06:32:48 2008 UTC

1/* 1/*
2 * libev poll fd activity backend 2 * libev poll fd activity backend
3 * 3 *
4 * Copyright (c) 2007 Marc Alexander Lehmann <libev@schmorp.de> 4 * Copyright (c) 2007,2008 Marc Alexander Lehmann <libev@schmorp.de>
5 * All rights reserved. 5 * All rights reserved.
6 * 6 *
7 * Redistribution and use in source and binary forms, with or without modifica- 7 * Redistribution and use in source and binary forms, with or without modifica-
8 * tion, are permitted provided that the following conditions are met: 8 * tion, are permitted provided that the following conditions are met:
9 * 9 *
… …
40#include <poll.h> 40#include <poll.h>
41 41
42void inline_size 42void inline_size
43pollidx_init (int *base, int count) 43pollidx_init (int *base, int count)
44{ 44{
45 /* consider using memset (.., -1, ...), which is pratically guarenteed
46 * to work on all systems implementing poll */
45 while (count--) 47 while (count--)
46 *base++ = -1; 48 *base++ = -1;
47} 49}
48 50
49static void 51static void
… …
84} 86}
85 87
86static void 88static void
87poll_poll (EV_P_ ev_tstamp timeout) 89poll_poll (EV_P_ ev_tstamp timeout)
88{ 90{
89 int i; 91 struct pollfd *p;
90 int res = poll (polls, pollcnt, (int)ceil (timeout * 1000.)); 92 int res = poll (polls, pollcnt, (int)ceil (timeout * 1000.));
91 93
92 if (expect_false (res < 0)) 94 if (expect_false (res < 0))
93 { 95 {
94 if (errno == EBADF) 96 if (errno == EBADF)
95 fd_ebadf (EV_A); 97 fd_ebadf (EV_A);
96 else if (errno == ENOMEM && !syserr_cb) 98 else if (errno == ENOMEM && !syserr_cb)
97 fd_enomem (EV_A); 99 fd_enomem (EV_A);
98 else if (errno != EINTR) 100 else if (errno != EINTR)
99 syserr ("(libev) poll"); 101 ev_syserr ("(libev) poll");
102 }
103 else
104 for (p = polls; res; ++p)
105 if (expect_false (p->revents)) /* this expect is debatable */
106 {
107 --res;
100 108
101 return;
102 }
103
104 for (i = 0; i < pollcnt; ++i)
105 if (expect_false (polls [i].revents & POLLNVAL)) 109 if (expect_false (p->revents & POLLNVAL))
106 fd_kill (EV_A_ polls [i].fd); 110 fd_kill (EV_A_ p->fd);
107 else 111 else
108 fd_event ( 112 fd_event (
109 EV_A_ 113 EV_A_
110 polls [i].fd, 114 p->fd,
111 (polls [i].revents & (POLLOUT | POLLERR | POLLHUP) ? EV_WRITE : 0) 115 (p->revents & (POLLOUT | POLLERR | POLLHUP) ? EV_WRITE : 0)
112 | (polls [i].revents & (POLLIN | POLLERR | POLLHUP) ? EV_READ : 0) 116 | (p->revents & (POLLIN | POLLERR | POLLHUP) ? EV_READ : 0)
113 ); 117 );
118 }
114} 119}
115 120
116int inline_size 121int inline_size
117poll_init (EV_P_ int flags) 122poll_init (EV_P_ int flags)
118{ 123{

Diff Legend

– Removed lines
+ Added lines
< Changed lines
> Changed lines