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

/freebsd-10.2-release/contrib/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
219 apr_pollset_t *pollset; local
291 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...]
H A Dz_asio.c21 * socket is added to the pollset, an async poll is issued for that individual
24 * that is part of the pollset. apr_pollset_poll waits on the arrival of IPC
74 struct pollfd *pollset; member in struct:apr_pollset_private_t
244 static apr_status_t asio_pollset_cleanup(apr_pollset_t *pollset) argument
250 rv = msgctl(pollset->p->msg_q, IPC_RMID, NULL);
256 static apr_status_t asio_pollset_create(apr_pollset_t *pollset, argument
267 priv = pollset->p = apr_palloc(p, sizeof(*priv));
275 pollset = NULL;
283 pollset = NULL;
287 DBG2(4, "pollset
329 posix_add(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument
364 asio_pollset_add(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument
438 posix_remove(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument
471 asio_pollset_remove(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument
535 posix_poll(apr_pollset_t *pollset, apr_interval_time_t timeout, apr_int32_t *num, const apr_pollfd_t **descriptors) argument
575 process_msg(apr_pollset_t *pollset, struct asio_msgbuf_t *msg) argument
603 asio_pollset_poll(apr_pollset_t *pollset, apr_interval_time_t timeout, apr_int32_t *num, const apr_pollfd_t **descriptors) argument
[all...]
/freebsd-10.2-release/contrib/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...]
/freebsd-10.2-release/contrib/apr/include/
H A Dapr_poll.h122 /** Opaque structure used for pollset API */
126 * Set up a pollset object
127 * @param pollset The pointer in which to return the newly created object
128 * @param size The maximum number of descriptors that this pollset can hold
129 * @param p The pool from which to allocate the pollset
130 * @param flags Optional flags to modify the operation of the pollset.
132 * @remark If flags contains APR_POLLSET_THREADSAFE, then a pollset is
138 * @remark If flags contains APR_POLLSET_WAKEABLE, then a pollset is
140 * apr_pollset_wakeup() call. The actual size of pollset is
146 * must have a lifetime at least as long as the pollset
201 APR_DECLARE(apr_status_t) apr_pollset_destroy(apr_pollset_t *pollset); variable
282 APR_DECLARE(apr_status_t) apr_pollset_wakeup(apr_pollset_t *pollset); variable
308 APR_DECLARE(const char *) apr_pollset_method_name(apr_pollset_t *pollset); variable
[all...]
/freebsd-10.2-release/contrib/apr/include/arch/unix/
H A Dapr_arch_poll_private.h93 if (pollset->flags & APR_POLLSET_THREADSAFE) \
94 apr_thread_mutex_lock(pollset->p->ring_lock);
96 if (pollset->flags & APR_POLLSET_THREADSAFE) \
97 apr_thread_mutex_unlock(pollset->p->ring_lock);
153 apr_pollcb_pset pollset; member in struct:apr_pollcb_t
176 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
H A Dapr_arch_file_io.h105 /* if there is a timeout set, then this pollset is used */
106 apr_pollset_t *pollset; member in struct:apr_file_t
/freebsd-10.2-release/contrib/serf/
H A Dcontext.c86 return apr_pollset_add(s->pollset, pfd);
95 return apr_pollset_remove(s->pollset, pfd);
136 /* build the pollset with a (default) number of connections */
141 ### Probably move creation of the pollset to later when we have
153 (void) apr_pollset_create_ex(&ps->pollset, MAX_CONN, pool, 0,
156 (void) apr_pollset_create(&ps->pollset, MAX_CONN, pool, 0);
208 * to remove it from the pollset again
277 if ((status = apr_pollset_poll(ps->pollset, duration, &num,
H A Dserf_private.h21 ### stop, rebuild a pollset, and repopulate it. what suckage. */
115 apr_pollset_t *pollset; member in struct:serf_pollset_t
134 /* one of our connections has a dirty pollset state. */
212 /* the events we've seen for this connection in our returned pollset */
/freebsd-10.2-release/contrib/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;
178 (*new_file)->pollset = NULL;
H A Dopen.c58 if (file->pollset != NULL) {
59 apr_status_t pollset_rv = apr_pollset_destroy(file->pollset);
240 /* Start out with no pollset. apr_wait_for_io_or_timeout() will
241 * initialize the pollset if needed.
243 (*new)->pollset = NULL;
302 /* Start out with no pollset. apr_wait_for_io_or_timeout() will
303 * initialize the pollset if needed.
305 (*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;
/freebsd-10.2-release/contrib/subversion/subversion/libsvn_subr/
H A Dprompt.c446 apr_pollfd_t pollset;
449 pollset.desc_type = APR_POLL_FILE;
450 pollset.desc.f = terminal->infd;
451 pollset.p = pool;
452 pollset.reqevents = APR_POLLIN;
454 status = apr_poll(&pollset, 1, &n, -1);
456 if (n == 1 && pollset.rtnevents & APR_POLLIN)
444 apr_pollfd_t pollset; local
/freebsd-10.2-release/usr.bin/svn/lib/libapr/
H A DMakefile15 otherchild.c pipe.c poll.c pollcb.c pollset.c port.c \
/freebsd-10.2-release/contrib/apr-util/memcache/
H A Dapr_memcache.c1206 apr_pollset_t* pollset; local
1279 rv = apr_pollset_create(&pollset, apr_hash_count(server_queries), temp_pool, 0);
1326 apr_pollset_add (pollset, &pollfds[queries_sent]);
1332 rv = apr_pollset_poll(pollset, MULT_GET_TIMEOUT, &queries_recvd, &activefds);
1347 apr_pollset_remove (pollset, &activefds[i]);
1384 apr_pollset_remove (pollset, &activefds[i]);
1396 apr_pollset_remove (pollset, &activefds[i]);
1405 apr_pollset_remove (pollset, &activefds[i]);
1433 apr_pollset_remove (pollset, &activefds[i]);
1462 apr_pollset_destroy(pollset);
[all...]
/freebsd-10.2-release/contrib/apr/
H A Dapr.mak90 -@erase "$(INTDIR)\pollset.obj"
217 "$(INTDIR)\pollset.obj" \
304 -@erase "$(INTDIR)\pollset.obj"
431 "$(INTDIR)\pollset.obj" \
518 -@erase "$(INTDIR)\pollset.obj"
645 "$(INTDIR)\pollset.obj" \
732 -@erase "$(INTDIR)\pollset.obj"
859 "$(INTDIR)\pollset.obj" \
946 -@erase "$(INTDIR)\pollset.obj"
1073 "$(INTDIR)\pollset
[all...]
H A Dlibapr.mak92 -@erase "$(INTDIR)\pollset.obj"
225 "$(INTDIR)\pollset.obj" \
328 -@erase "$(INTDIR)\pollset.obj"
461 "$(INTDIR)\pollset.obj" \
564 -@erase "$(INTDIR)\pollset.obj"
697 "$(INTDIR)\pollset.obj" \
800 -@erase "$(INTDIR)\pollset.obj"
933 "$(INTDIR)\pollset.obj" \
1036 -@erase "$(INTDIR)\pollset.obj"
1169 "$(INTDIR)\pollset
[all...]
H A Dbuild-outputs.mk83 poll/unix/pollset.lo: poll/unix/pollset.c .make.dirs include/apr_allocator.h include/apr_dso.h include/apr_errno.h include/apr_file_info.h include/apr_file_io.h include/apr_general.h include/apr_global_mutex.h include/apr_inherit.h include/apr_network_io.h include/apr_poll.h include/apr_pools.h include/apr_portable.h include/apr_proc_mutex.h include/apr_shm.h include/apr_tables.h include/apr_thread_mutex.h include/apr_thread_proc.h include/apr_time.h include/apr_user.h include/apr_want.h
88 OBJECTS_poll_unix = poll/unix/epoll.lo poll/unix/kqueue.lo poll/unix/poll.lo poll/unix/pollcb.lo poll/unix/pollset.lo poll/unix/port.lo poll/unix/select.lo poll/unix/z_asio.lo
215 poll/os2/pollset.lo: poll/os2/pollset.c .make.dirs include/apr_allocator.h include/apr_errno.h include/apr_file_info.h include/apr_file_io.h include/apr_general.h include/apr_inherit.h include/apr_network_io.h include/apr_poll.h include/apr_pools.h include/apr_tables.h include/apr_thread_mutex.h include/apr_time.h include/apr_user.h include/apr_want.h
217 OBJECTS_poll_os2 = poll/os2/poll.lo poll/os2/pollset.lo
/freebsd-10.2-release/contrib/apr/network_io/unix/
H A Dsockets.c79 /* Create a pollset with room for one descriptor. */
81 (void) apr_pollset_create(&(*new)->pollset, 1, p, 0);

Completed in 162 milliseconds