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

/freebsd-11-stable/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;
202 (*in)->pollset = NULL;
217 (*out)->pollset = NULL;
/freebsd-11-stable/contrib/apr/include/arch/unix/
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
H A Dapr_arch_networkio.h124 /* if there is a timeout set, then this pollset is used */
125 apr_pollset_t *pollset; member in struct:apr_socket_t
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);
157 apr_pollcb_pset pollset; member in struct:apr_pollcb_t
/freebsd-11-stable/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-11-stable/contrib/apr-util/memcache/
H A Dapr_memcache.c1223 apr_pollset_t* pollset; local
1296 rv = apr_pollset_create(&pollset, apr_hash_count(server_queries), temp_pool, 0);
1343 apr_pollset_add (pollset, &pollfds[queries_sent]);
1349 rv = apr_pollset_poll(pollset, MULT_GET_TIMEOUT, &queries_recvd, &activefds);
1364 apr_pollset_remove (pollset, &activefds[i]);
1393 apr_pollset_remove (pollset, &activefds[i]);
1408 apr_pollset_remove (pollset, &activefds[i]);
1417 apr_pollset_remove (pollset, &activefds[i]);
1444 apr_pollset_remove (pollset, &activefds[i]);
1454 apr_pollset_remove (pollset,
[all...]
/freebsd-11-stable/contrib/apr/
H A Dapr.mak94 -@erase "$(INTDIR)\pollset.obj"
188 "$(INTDIR)\pollset.obj" \
280 -@erase "$(INTDIR)\pollset.obj"
374 "$(INTDIR)\pollset.obj" \
466 -@erase "$(INTDIR)\pollset.obj"
560 "$(INTDIR)\pollset.obj" \
652 -@erase "$(INTDIR)\pollset.obj"
747 "$(INTDIR)\pollset.obj" \
1128 SOURCE=.\poll\unix\pollset.c
1130 "$(INTDIR)\pollset
[all...]
H A Dbuild-outputs.mk85 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_perms_set.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
91 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/wakeup.lo poll/unix/z_asio.lo
220 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_perms_set.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
222 OBJECTS_poll_os2 = poll/os2/poll.lo poll/os2/pollset.lo
H A Dlibapr.mak93 -@erase "$(INTDIR)\pollset.obj"
229 "$(INTDIR)\pollset.obj" \
337 -@erase "$(INTDIR)\pollset.obj"
473 "$(INTDIR)\pollset.obj" \
581 -@erase "$(INTDIR)\pollset.obj"
717 "$(INTDIR)\pollset.obj" \
825 -@erase "$(INTDIR)\pollset.obj"
961 "$(INTDIR)\pollset.obj" \
1326 SOURCE=.\poll\unix\pollset.c
1328 "$(INTDIR)\pollset
[all...]
/freebsd-11-stable/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-11-stable/contrib/apr/network_io/unix/
H A Dsockets.c104 /* Create a pollset with room for one descriptor. */
106 (void) apr_pollset_create(&(*new)->pollset, 1, p, 0);
/freebsd-11-stable/contrib/apr/poll/unix/
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;
112 pollset->p = NULL;
120 pollset->p = NULL;
126 pollset->p = apr_palloc(p, sizeof(apr_pollset_private_t));
130 ((rv = apr_thread_mutex_create(&pollset->p->ring_lock,
134 pollset
156 impl_pollset_add(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument
209 impl_pollset_remove(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument
253 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
143 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
252 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 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 Dpollset.c35 apr_pollset_t *pollset = (apr_pollset_t *) p; local
36 if (pollset->provider->cleanup) {
37 (*pollset->provider->cleanup)(pollset);
39 if (pollset->flags & APR_POLLSET_WAKEABLE) {
40 apr_poll_close_wakeup_pipe(pollset->wakeup_pipe);
108 apr_pollset_t *pollset; local
141 pollset = apr_palloc(p, sizeof(*pollset));
142 pollset
186 apr_pollset_method_name(apr_pollset_t *pollset) 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
217 impl_pollset_add(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument
270 impl_pollset_remove(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument
351 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 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 if (pollset->flags & APR_POLLSET_THREADSAFE) {
251 rv = msgctl(pollset->p->msg_q, IPC_RMID, NULL);
258 static apr_status_t asio_pollset_create(apr_pollset_t *pollset, argument
269 priv = pollset->p = apr_pcalloc(p, sizeof(*priv));
277 pollset->p = NULL;
285 pollset
336 posix_add(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument
371 asio_pollset_add(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument
446 posix_remove(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument
479 asio_pollset_remove(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument
544 posix_poll(apr_pollset_t *pollset, apr_interval_time_t timeout, apr_int32_t *num, const apr_pollfd_t **descriptors) argument
584 process_msg(apr_pollset_t *pollset, struct asio_msgbuf_t *msg) argument
612 asio_pollset_poll(apr_pollset_t *pollset, apr_interval_time_t timeout, apr_int32_t *num, const apr_pollfd_t **descriptors) argument
[all...]
/freebsd-11-stable/contrib/serf/
H A Dcontext.c91 return apr_pollset_add(s->pollset, pfd);
100 return apr_pollset_remove(s->pollset, pfd);
141 /* build the pollset with a (default) number of connections */
146 ### Probably move creation of the pollset to later when we have
158 (void) apr_pollset_create_ex(&ps->pollset, MAX_CONN, pool, 0,
161 (void) apr_pollset_create(&ps->pollset, MAX_CONN, pool, 0);
213 * to remove it from the pollset again
282 if ((status = apr_pollset_poll(ps->pollset, duration, &num,
H A Dserf_private.h26 ### stop, rebuild a pollset, and repopulate it. what suckage. */
120 apr_pollset_t *pollset; member in struct:serf_pollset_t
139 /* one of our connections has a dirty pollset state. */
217 /* the events we've seen for this connection in our returned pollset */
/freebsd-11-stable/contrib/subversion/subversion/libsvn_subr/
H A Dprompt.c442 apr_pollfd_t pollset;
445 pollset.desc_type = APR_POLL_FILE;
446 pollset.desc.f = terminal->infd;
447 pollset.p = pool;
448 pollset.reqevents = APR_POLLIN;
450 status = apr_poll(&pollset, 1, &n, -1);
452 if (n == 1 && pollset.rtnevents & APR_POLLIN)
440 apr_pollfd_t pollset; local
/freebsd-11-stable/usr.bin/svn/lib/libapr/
H A DMakefile55 pollset.c \

Completed in 233 milliseconds