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

Comparing libev/ev_port.c (file contents):
Revision 1.17 by root, Sun Jul 19 04:11:27 2009 UTC vs.
Revision 1.21 by root, Fri Oct 15 22:44:41 2010 UTC

… …
84 int res, i; 84 int res, i;
85 struct timespec ts; 85 struct timespec ts;
86 uint_t nget = 1; 86 uint_t nget = 1;
87 87
88 EV_RELEASE_CB; 88 EV_RELEASE_CB;
89 ts.tv_sec = (time_t)timeout; 89 EV_TS_SET (ts, timeout);
90 ts.tv_nsec = (long)(timeout - (ev_tstamp)ts.tv_sec) * 1e9;
91 res = port_getn (backend_fd, port_events, port_eventmax, &nget, &ts); 90 res = port_getn (backend_fd, port_events, port_eventmax, &nget, &ts);
92 EV_ACQUIRE_CB; 91 EV_ACQUIRE_CB;
93 92
94 if (res == -1) 93 if (res == -1)
95 { 94 {
96 if (errno != EINTR && errno != ETIME) 95 if (errno != EINTR && errno != ETIME)
97 ev_syserr ("(libev) port_getn"); 96 ev_syserr ("(libev) port_getn (see http://bugs.opensolaris.org/view_bug.do?bug_id=6268715, try LIBEV_FLAGS=3 env variable)");
98 97
99 return; 98 return;
100 } 99 }
101 100
102 for (i = 0; i < nget; ++i) 101 for (i = 0; i < nget; ++i)
… …
125} 124}
126 125
127int inline_size 126int inline_size
128port_init (EV_P_ int flags) 127port_init (EV_P_ int flags)
129{ 128{
130 /* Initalize the kernel queue */ 129 /* Initialize the kernel queue */
131 if ((backend_fd = port_create ()) < 0) 130 if ((backend_fd = port_create ()) < 0)
132 return 0; 131 return 0;
133 132
134 fcntl (backend_fd, F_SETFD, FD_CLOEXEC); /* not sure if necessary, hopefully doesn't hurt */ 133 fcntl (backend_fd, F_SETFD, FD_CLOEXEC); /* not sure if necessary, hopefully doesn't hurt */
135 134
136 backend_fudge = 1e-3; /* needed to compensate for port_getn returning early */ 135 backend_fudge = 1e-3; /* needed to compensate for port_getn returning early */
137 backend_modify = port_modify; 136 backend_modify = port_modify;
138 backend_poll = port_poll; 137 backend_poll = port_poll;
139 138
140 port_eventmax = 64; /* intiial number of events receivable per poll */ 139 port_eventmax = 64; /* initial number of events receivable per poll */
141 port_events = (port_event_t *)ev_malloc (sizeof (port_event_t) * port_eventmax); 140 port_events = (port_event_t *)ev_malloc (sizeof (port_event_t) * port_eventmax);
142 141
143 return EVBACKEND_PORT; 142 return EVBACKEND_PORT;
144} 143}
145 144

Diff Legend

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