Searched refs:pollset (Results 1 - 25 of 44) sorted by relevance

12

/macosx-10.10/apr-32/apr/apr/poll/os2/
H A Dpollset.c27 int *pollset; member in struct:apr_pollset_t
38 APR_DECLARE(apr_status_t) apr_pollset_create(apr_pollset_t **pollset,
43 *pollset = apr_palloc(p, sizeof(**pollset));
44 (*pollset)->pool = p;
45 (*pollset)->nelts = 0;
46 (*pollset)->nalloc = size;
47 (*pollset)->pollset = apr_palloc(p, size * sizeof(int) * 3);
48 (*pollset)
126 make_pollset(apr_pollset_t *pollset) argument
[all...]
H A Dpoll.c24 int *pollset; local
38 pollset = alloca(sizeof(int) * num_total);
39 memset(pollset, 0, sizeof(int) * num_total);
48 pollset[pos_read++] = aprset[i].desc.s->socketdes;
52 pollset[pos_write++] = aprset[i].desc.s->socketdes;
56 pollset[pos_except++] = aprset[i].desc.s->socketdes;
67 i = select(pollset, num_read, num_write, num_except, timeout);
85 if (pollset[pos_read++] > 0) {
91 if (pollset[pos_write++] > 0) {
97 if (pollset[pos_excep
[all...]
/macosx-10.10/apr-32/apr/apr/poll/unix/
H A Dpollset.c38 static apr_status_t create_wakeup_pipe(apr_pollset_t *pollset) argument
42 if ((rv = apr_file_socket_pipe_create(&pollset->wakeup_pipe[0],
43 &pollset->wakeup_pipe[1],
44 pollset->pool)) != APR_SUCCESS)
47 pollset->wakeup_pfd.p = pollset->pool;
48 pollset->wakeup_pfd.reqevents = APR_POLLIN;
49 pollset->wakeup_pfd.desc_type = APR_POLL_FILE;
50 pollset->wakeup_pfd.desc.f = pollset
56 create_wakeup_pipe(apr_pollset_t *pollset) argument
71 create_wakeup_pipe(apr_pollset_t *pollset) argument
112 apr_pollset_drain_wakeup_pipe(apr_pollset_t *pollset) argument
130 apr_pollset_t *pollset = (apr_pollset_t *) p; local
211 apr_pollset_t *pollset; local
283 apr_pollset_method_name(apr_pollset_t *pollset) argument
[all...]
H A Dpoll.c78 struct pollfd pollset[num]; local
80 struct pollfd *pollset = alloca(sizeof(struct pollfd) * num); local
81 if (!pollset)
85 struct pollfd *pollset;
88 pollset = tmp_pollset;
94 pollset = malloc(sizeof(struct pollfd) * num);
98 if (!pollset)
104 pollset[i].fd = aprset[i].desc.s->socketdes;
107 pollset[i].fd = aprset[i].desc.f->filedes;
112 pollset[
152 struct pollfd *pollset; member in struct:apr_pollset_private_t
157 impl_pollset_create(apr_pollset_t *pollset, apr_uint32_t size, apr_pool_t *p, apr_uint32_t flags) argument
178 impl_pollset_add(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument
208 impl_pollset_remove(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument
236 impl_pollset_poll(apr_pollset_t *pollset, apr_interval_time_t timeout, apr_int32_t *num, const apr_pollfd_t **descriptors) argument
[all...]
H A Dselect.c197 static apr_status_t impl_pollset_create(apr_pollset_t *pollset, argument
203 pollset->p = NULL;
208 pollset->p = NULL;
212 pollset->p = apr_palloc(p, sizeof(apr_pollset_private_t));
213 FD_ZERO(&(pollset->p->readset));
214 FD_ZERO(&(pollset->p->writeset));
215 FD_ZERO(&(pollset->p->exceptset));
216 pollset->p->maxfd = 0;
218 pollset->p->set_type = APR_NO_DESC;
220 pollset
226 impl_pollset_add(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument
294 impl_pollset_remove(apr_pollset_t * pollset, const apr_pollfd_t * descriptor) argument
339 impl_pollset_poll(apr_pollset_t *pollset, apr_interval_time_t timeout, apr_int32_t *num, const apr_pollfd_t **descriptors) argument
[all...]
H A Dkqueue.c66 static apr_status_t impl_pollset_cleanup(apr_pollset_t *pollset) argument
68 close(pollset->p->kqueue_fd);
72 static apr_status_t impl_pollset_create(apr_pollset_t *pollset, argument
78 pollset->p = apr_palloc(p, sizeof(apr_pollset_private_t));
81 ((rv = apr_thread_mutex_create(&pollset->p->ring_lock,
84 pollset->p = NULL;
89 pollset->p = NULL;
101 pollset->p->setsize = 2 * size;
103 pollset->p->ke_set =
104 (struct kevent *) apr_palloc(p, pollset
135 impl_pollset_add(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument
191 impl_pollset_remove(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument
244 impl_pollset_poll(apr_pollset_t *pollset, apr_interval_time_t timeout, apr_int32_t *num, const apr_pollfd_t **descriptors) argument
[all...]
H A Dport.c150 static apr_status_t impl_pollset_cleanup(apr_pollset_t *pollset) argument
152 close(pollset->p->port_fd);
156 static apr_status_t impl_pollset_create(apr_pollset_t *pollset, argument
162 pollset->p = apr_palloc(p, sizeof(apr_pollset_private_t));
165 ((rv = apr_thread_mutex_create(&pollset->p->ring_lock,
168 pollset->p = NULL;
173 pollset->p = NULL;
177 pollset->p->waiting = 0;
179 pollset->p->port_set = apr_palloc(p, size * sizeof(port_event_t));
181 pollset
209 impl_pollset_add(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument
262 impl_pollset_remove(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument
343 impl_pollset_poll(apr_pollset_t *pollset, apr_interval_time_t timeout, apr_int32_t *num, const apr_pollfd_t **descriptors) argument
[all...]
H A Depoll.c65 struct epoll_event *pollset; member in struct:apr_pollset_private_t
80 static apr_status_t impl_pollset_cleanup(apr_pollset_t *pollset) argument
82 close(pollset->p->epoll_fd);
87 static apr_status_t impl_pollset_create(apr_pollset_t *pollset, argument
101 pollset->p = NULL;
118 pollset->p = apr_palloc(p, sizeof(apr_pollset_private_t));
122 ((rv = apr_thread_mutex_create(&pollset->p->ring_lock,
125 pollset->p = NULL;
130 pollset->p = NULL;
134 pollset
146 impl_pollset_add(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument
199 impl_pollset_remove(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument
243 impl_pollset_poll(apr_pollset_t *pollset, apr_interval_time_t timeout, apr_int32_t *num, const apr_pollfd_t **descriptors) argument
[all...]
/macosx-10.10/apr-32/apr/apr/support/unix/
H A Dwaitio.c72 apr_pollset_t *pollset; local
80 pollset = f->pollset;
81 if (pollset == NULL) {
82 status = apr_pollset_create(&(f->pollset), 1, f->pool, 0);
86 pollset = f->pollset;
94 pollset = s->pollset;
99 /* Remove the object if it was in the pollset, the
[all...]
/macosx-10.10/apr-32/apr/apr/include/
H A Dapr_poll.h115 /** Opaque structure used for pollset API */
119 * Set up a pollset object
120 * @param pollset The pointer in which to return the newly created object
121 * @param size The maximum number of descriptors that this pollset can hold
122 * @param p The pool from which to allocate the pollset
123 * @param flags Optional flags to modify the operation of the pollset.
125 * @remark If flags contains APR_POLLSET_THREADSAFE, then a pollset is
131 * @remark If flags contains APR_POLLSET_WAKEABLE, then a pollset is
133 * apr_pollset_wakeup() call. The actual size of pollset is
139 * must have a lifetime at least as long as the pollset
194 APR_DECLARE(apr_status_t) apr_pollset_destroy(apr_pollset_t *pollset); variable
276 APR_DECLARE(apr_status_t) apr_pollset_wakeup(apr_pollset_t *pollset); variable
304 APR_DECLARE(const char *) apr_pollset_method_name(apr_pollset_t *pollset); variable
[all...]
/macosx-10.10/apr-32/apr-util/apr-util/test/
H A Dtestssl.c52 apr_pollset_t *pollset,
63 rv = apr_pollset_add_ssl_socket(pollset, sock);
65 printf("\tFailed to add to pollset\n");
95 apr_pollset_t *pollset,
109 rv = apr_pollset_poll(pollset, 30 * APR_USEC_PER_SEC, &lrv, &descs);
137 apr_pollset_t *pollset,
151 rv = apr_pollset_poll(pollset, 30 * APR_USEC_PER_SEC, &lrv, &descs);
176 apr_status_t socketClose(apr_ssl_socket_t *sock, apr_pollset_t *pollset) argument
182 printf("\tUnable to remove socket from pollset?\n");
197 apr_pollset_t *pollset; local
51 createSocket(apr_ssl_factory_t *asf, apr_pollset_t *pollset, apr_pool_t *pool, int blocking) argument
94 socketRead(apr_ssl_socket_t *sock, apr_pollset_t *pollset, char *buf, apr_size_t *len) argument
136 socketWrite(apr_ssl_socket_t *sock, apr_pollset_t *pollset, const char *buf, apr_size_t *len) argument
[all...]
/macosx-10.10/apr-32/apr/apr/include/arch/unix/
H A Dapr_arch_poll_private.h85 if (pollset->flags & APR_POLLSET_THREADSAFE) \
86 apr_thread_mutex_lock(pollset->p->ring_lock);
88 if (pollset->flags & APR_POLLSET_THREADSAFE) \
89 apr_thread_mutex_unlock(pollset->p->ring_lock);
144 apr_pollcb_pset pollset; member in struct:apr_pollcb_t
167 void apr_pollset_drain_wakeup_pipe(apr_pollset_t *pollset);
H A Dapr_arch_networkio.h121 /* if there is a timeout set, then this pollset is used */
122 apr_pollset_t *pollset; member in struct:apr_socket_t
/macosx-10.10/apr-32/apr/apr/test/
H A Dtestpoll.c34 static apr_pollset_t *pollset; variable
38 * converted to use the pollset interface or removed. */
290 rv = apr_pollset_create(&pollset, LARGE_NUM_SOCKETS, p, 0);
306 rv = apr_pollset_add(pollset, &socket_pollfd);
311 rv = apr_pollset_poll(pollset, -1, &lrv, &descs);
337 rv = apr_pollset_poll(pollset, 0, &lrv, &descs);
344 rv = apr_pollset_remove(pollset, &socket_pollfd);
362 rv = apr_pollset_add(pollset, &socket_pollfd);
373 rv = apr_pollset_poll(pollset, 0, &lrv, &descs);
386 rv = apr_pollset_poll(pollset,
490 apr_pollset_t *pollset; local
672 apr_pollset_t *pollset; local
776 apr_pollset_t *pollset; local
[all...]
/macosx-10.10/apr-32/apr/apr/include/arch/os2/
H A Dapr_arch_networkio.h53 /* if there is a timeout set, then this pollset is used */
54 apr_pollset_t *pollset; member in struct:apr_socket_t
/macosx-10.10/apr-32/apr/apr/include/arch/win32/
H A Dapr_arch_networkio.h55 /* if there is a timeout set, then this pollset is used */
56 apr_pollset_t *pollset; member in struct:apr_socket_t
/macosx-10.10/apr-32/apr/apr/file_io/netware/
H A Dpipe.c166 (void) apr_pollset_create(&(*in)->pollset, 1, pool, 0);
167 (void) apr_pollset_create(&(*out)->pollset, 1, pool, 0);
/macosx-10.10/apr-32/apr/apr/file_io/unix/
H A Dfiledup.c120 /* Start out with no pollset. apr_wait_for_io_or_timeout() will
121 * initialize the pollset if needed.
123 (*new_file)->pollset = NULL;
179 (*new_file)->pollset = NULL;
H A Dopen.c58 if (file->pollset != NULL) {
59 apr_status_t pollset_rv = apr_pollset_destroy(file->pollset);
232 /* Start out with no pollset. apr_wait_for_io_or_timeout() will
233 * initialize the pollset if needed.
235 (*new)->pollset = NULL;
294 /* Start out with no pollset. apr_wait_for_io_or_timeout() will
295 * initialize the pollset if needed.
297 (*file)->pollset = NULL;
H A Dpipe.c164 /* Start out with no pollset. apr_wait_for_io_or_timeout() will
165 * initialize the pollset if needed.
167 (*file)->pollset = NULL;
201 (*in)->pollset = NULL;
216 (*out)->pollset = NULL;
/macosx-10.10/apache-793/httpd/modules/proxy/
H A Dmod_proxy_connect.c214 apr_pollset_t *pollset; local
313 if ((rv = apr_pollset_create(&pollset, 2, r->pool, 0)) != APR_SUCCESS) {
326 apr_pollset_add(pollset, &pollfd);
330 apr_pollset_add(pollset, &pollfd);
418 if ((rv = apr_pollset_poll(pollset, -1, &pollcnt, &signalled))
466 "unknown socket in pollset");
H A Dmod_proxy_wstunnel.c173 apr_pollset_t *pollset; local
212 if ((rv = apr_pollset_create(&pollset, 2, p, 0)) != APR_SUCCESS) {
230 apr_pollset_add(pollset, &pollfd);
233 apr_pollset_add(pollset, &pollfd);
244 if ((rv = apr_pollset_poll(pollset, -1, &pollcnt, &signalled))
302 "unknown socket in pollset");
/macosx-10.10/apache-793/httpd/modules/filters/
H A Dmod_reqtimeout.c237 apr_pollfd_t pollset; local
275 pollset.p = f->c->pool;
276 pollset.desc_type = APR_POLL_SOCKET;
277 pollset.reqevents = APR_POLLIN|APR_POLLHUP;
278 pollset.desc.s = ccfg->socket;
280 rv = apr_poll(&pollset, 1, &nsds, poll_timeout);
/macosx-10.10/apache-793/httpd/server/
H A Dcore_filters.c741 apr_pollfd_t pollset; local
743 pollset.p = c->pool;
744 pollset.desc_type = APR_POLL_SOCKET;
745 pollset.reqevents = APR_POLLOUT;
746 pollset.desc.s = s;
749 rv = apr_poll(&pollset, 1, &nsds, timeout);
/macosx-10.10/apache-793/httpd/server/mpm/mpmt_os2/
H A Dmpmt_os2_child.c102 apr_pollset_t *pollset; local
183 apr_pollset_create(&pollset, num_listeners, pchild, 0);
192 apr_pollset_add(pollset, &pfd);
221 rv = apr_pollset_poll(pollset, -1, &num_poll_results, &poll_results);

Completed in 217 milliseconds

12