Home
last modified time | relevance | path

Searched refs:pollset (Results 1 – 25 of 32) sorted by relevance

12

/freebsd-12.1/contrib/apr/poll/unix/
H A Dpollset.c47 pollset->wakeup_pfd.p = pollset->pool; in create_wakeup_pipe()
50 pollset->wakeup_pfd.desc.f = pollset->wakeup_pipe[0]; in create_wakeup_pipe()
52 return apr_pollset_add(pollset, &pollset->wakeup_pfd); in create_wakeup_pipe()
80 pollset->wakeup_pfd.p = pollset->pool; in create_wakeup_pipe()
83 pollset->wakeup_pfd.desc.f = pollset->wakeup_pipe[0]; in create_wakeup_pipe()
106 return apr_pollset_add(pollset, &pollset->wakeup_pfd); in create_wakeup_pipe()
132 (*pollset->provider->cleanup)(pollset); in pollset_cleanup()
252 pollset = apr_palloc(p, sizeof(*pollset)); in apr_pollset_create_ex()
320 return apr_pool_cleanup_run(pollset->pool, pollset, in apr_pollset_destroy()
337 return (*pollset->provider->add)(pollset, descriptor); in apr_pollset_add()
[all …]
H A Dpoll.c81 if (!pollset) in apr_poll()
181 if (pollset->nelts == pollset->nalloc) { in impl_pollset_add()
185 pollset->p->query_set[pollset->nelts] = *descriptor; in impl_pollset_add()
188 pollset->p->pollset[pollset->nelts].fd = descriptor->desc.s->socketdes; in impl_pollset_add()
192 pollset->p->pollset[pollset->nelts].fd = descriptor->desc.f->filedes; in impl_pollset_add()
196 pollset->p->pollset[pollset->nelts].fd = (SOCKET)descriptor->desc.f->filedes; in impl_pollset_add()
201 pollset->p->pollset[pollset->nelts].events = in impl_pollset_add()
224 pollset->p->pollset[dst] = pollset->p->pollset[i]; in impl_pollset_remove()
257 ret = WSAPoll(pollset->p->pollset, pollset->nelts, (int)timeout); in impl_pollset_poll()
262 ret = poll(pollset->p->pollset, pollset->nelts, timeout); in impl_pollset_poll()
[all …]
H A Dselect.c203 pollset->p = NULL; in impl_pollset_create()
208 pollset->p = NULL; in impl_pollset_create()
216 pollset->p->maxfd = 0; in impl_pollset_create()
231 if (pollset->nelts == pollset->nalloc) { in impl_pollset_add()
235 pollset->p->query_set[pollset->nelts] = *descriptor; in impl_pollset_add()
290 pollset->nelts++; in impl_pollset_add()
316 pollset->nelts--; in impl_pollset_remove()
322 pollset->p->query_set[dst] = pollset->p->query_set[i]; in impl_pollset_remove()
329 if (((int) fd == pollset->p->maxfd) && (pollset->p->maxfd > 0)) { in impl_pollset_remove()
403 pollset->p->query_set[i].desc.f == pollset->wakeup_pipe[0]) { in impl_pollset_poll()
[all …]
H A Dkqueue.c84 pollset->p = NULL; in impl_pollset_create()
89 pollset->p = NULL; in impl_pollset_create()
103 pollset->p->ke_set = in impl_pollset_create()
106 memset(pollset->p->ke_set, 0, pollset->p->setsize * sizeof(struct kevent)); in impl_pollset_create()
111 pollset->p = NULL; in impl_pollset_create()
172 if (kevent(pollset->p->kqueue_fd, &pollset->p->kevent, 1, NULL, 0, in impl_pollset_add()
181 if (kevent(pollset->p->kqueue_fd, &pollset->p->kevent, 1, NULL, 0, in impl_pollset_add()
219 if (kevent(pollset->p->kqueue_fd, &pollset->p->kevent, 1, NULL, 0, in impl_pollset_remove()
228 if (kevent(pollset->p->kqueue_fd, &pollset->p->kevent, 1, NULL, 0, in impl_pollset_remove()
271 ret = kevent(pollset->p->kqueue_fd, NULL, 0, pollset->p->ke_set, in impl_pollset_poll()
[all …]
H A Dport.c152 close(pollset->p->port_fd); in impl_pollset_cleanup()
168 pollset->p = NULL; in impl_pollset_create()
173 pollset->p = NULL; in impl_pollset_create()
177 pollset->p->waiting = 0; in impl_pollset_create()
183 if (pollset->p->port_fd < 0) { in impl_pollset_create()
184 pollset->p = NULL; in impl_pollset_create()
193 close(pollset->p->port_fd); in impl_pollset_create()
194 pollset->p = NULL; in impl_pollset_create()
202 pollset->p = NULL; in impl_pollset_create()
399 rv = call_port_getn(pollset->p->port_fd, pollset->p->port_set, in impl_pollset_poll()
[all …]
H A Depoll.c101 pollset->p = NULL; in impl_pollset_create()
112 pollset->p = NULL; in impl_pollset_create()
120 pollset->p = NULL; in impl_pollset_create()
134 pollset->p = NULL; in impl_pollset_create()
140 pollset->p = NULL; in impl_pollset_create()
144 pollset->p->epoll_fd = fd; in impl_pollset_create()
145 pollset->p->pollset = apr_palloc(p, size * sizeof(struct epoll_event)); in impl_pollset_create()
266 ret = epoll_wait(pollset->p->epoll_fd, pollset->p->pollset, pollset->nalloc, in impl_pollset_poll()
279 fdptr = (apr_pollfd_t *)(pollset->p->pollset[i].data.ptr); in impl_pollset_poll()
282 fdptr = &(((pfd_elem_t *) (pollset->p->pollset[i].data.ptr))->pfd); in impl_pollset_poll()
[all …]
H A Dz_asio.c295 pollset->p = NULL; in asio_pollset_create()
312 pollset->nelts = 0; in asio_pollset_create()
314 pollset->pool = p; in asio_pollset_create()
321 pollset->p = NULL; in asio_pollset_create()
326 pollset, in asio_pollset_create()
356 priv->pollset[pollset->nelts].fd = fd; in posix_add()
358 priv->pollset[pollset->nelts].events = in posix_add()
361 pollset->nelts++; in posix_add()
462 priv->pollset[dst] = priv->pollset[i]; in posix_remove()
556 rv = poll(priv->pollset, pollset->nelts, timeout); in posix_poll()
[all …]
/freebsd-12.1/contrib/apr/support/unix/
H A Dwaitio.c72 apr_pollset_t *pollset; in apr_wait_for_io_or_timeout() local
80 pollset = f->pollset; in apr_wait_for_io_or_timeout()
81 if (pollset == NULL) { in apr_wait_for_io_or_timeout()
82 status = apr_pollset_create(&(f->pollset), 1, f->pool, 0); in apr_wait_for_io_or_timeout()
86 pollset = f->pollset; in apr_wait_for_io_or_timeout()
94 pollset = s->pollset; in apr_wait_for_io_or_timeout()
103 (void) apr_pollset_remove(pollset, &pfd); in apr_wait_for_io_or_timeout()
106 (void) apr_pollset_add(pollset, &pfd); in apr_wait_for_io_or_timeout()
112 status = apr_pollset_poll(pollset, timeout, &numdesc, &pdesc); in apr_wait_for_io_or_timeout()
/freebsd-12.1/contrib/apr/include/
H A Dapr_poll.h154 APR_DECLARE(apr_status_t) apr_pollset_create(apr_pollset_t **pollset,
191 APR_DECLARE(apr_status_t) apr_pollset_create_ex(apr_pollset_t **pollset,
201 APR_DECLARE(apr_status_t) apr_pollset_destroy(apr_pollset_t *pollset);
229 APR_DECLARE(apr_status_t) apr_pollset_add(apr_pollset_t *pollset,
250 APR_DECLARE(apr_status_t) apr_pollset_remove(apr_pollset_t *pollset,
271 APR_DECLARE(apr_status_t) apr_pollset_poll(apr_pollset_t *pollset,
282 APR_DECLARE(apr_status_t) apr_pollset_wakeup(apr_pollset_t *pollset);
308 APR_DECLARE(const char *) apr_pollset_method_name(apr_pollset_t *pollset);
/freebsd-12.1/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
176 void apr_pollset_drain_wakeup_pipe(apr_pollset_t *pollset);
H A Dapr_arch_networkio.h122 apr_pollset_t *pollset; member
H A Dapr_arch_file_io.h106 apr_pollset_t *pollset; member
/freebsd-12.1/contrib/serf/
H A Dcontext.c91 return apr_pollset_add(s->pollset, pfd); in pollset_add()
100 return apr_pollset_remove(s->pollset, pfd); in pollset_rm()
158 (void) apr_pollset_create_ex(&ps->pollset, MAX_CONN, pool, 0, in serf_context_create_ex()
161 (void) apr_pollset_create(&ps->pollset, MAX_CONN, pool, 0); in serf_context_create_ex()
282 if ((status = apr_pollset_poll(ps->pollset, duration, &num, in serf_context_run()
H A Dserf_private.h120 apr_pollset_t *pollset; member
/freebsd-12.1/contrib/subversion/subversion/libsvn_subr/
H A Dprompt.c440 apr_pollfd_t pollset; in terminal_getc() local
443 pollset.desc_type = APR_POLL_FILE; in terminal_getc()
444 pollset.desc.f = terminal->infd; in terminal_getc()
445 pollset.p = pool; in terminal_getc()
446 pollset.reqevents = APR_POLLIN; in terminal_getc()
448 status = apr_poll(&pollset, 1, &n, -1); in terminal_getc()
450 if (n == 1 && pollset.rtnevents & APR_POLLIN) in terminal_getc()
/freebsd-12.1/contrib/apr/file_io/unix/
H A Dopen.c58 if (file->pollset != NULL) { in file_cleanup()
59 apr_status_t pollset_rv = apr_pollset_destroy(file->pollset); in file_cleanup()
243 (*new)->pollset = NULL; in apr_file_open()
305 (*file)->pollset = NULL; in apr_os_file_put()
H A Dpipe.c167 (*file)->pollset = NULL; in apr_os_pipe_put_ex()
201 (*in)->pollset = NULL; in apr_file_pipe_create()
216 (*out)->pollset = NULL; in apr_file_pipe_create()
H A Dfiledup.c123 (*new_file)->pollset = NULL; in file_dup()
178 (*new_file)->pollset = NULL; in apr_file_setaside()
/freebsd-12.1/contrib/apr-util/memcache/
H A Dapr_memcache.c1206 apr_pollset_t* pollset; in apr_memcache_multgetp() local
1279 rv = apr_pollset_create(&pollset, apr_hash_count(server_queries), temp_pool, 0); in apr_memcache_multgetp()
1326 apr_pollset_add (pollset, &pollfds[queries_sent]); in apr_memcache_multgetp()
1332 rv = apr_pollset_poll(pollset, MULT_GET_TIMEOUT, &queries_recvd, &activefds); in apr_memcache_multgetp()
1347 apr_pollset_remove (pollset, &activefds[i]); in apr_memcache_multgetp()
1384 apr_pollset_remove (pollset, &activefds[i]); in apr_memcache_multgetp()
1396 apr_pollset_remove (pollset, &activefds[i]); in apr_memcache_multgetp()
1405 apr_pollset_remove (pollset, &activefds[i]); in apr_memcache_multgetp()
1433 apr_pollset_remove (pollset, &activefds[i]); in apr_memcache_multgetp()
1462 apr_pollset_destroy(pollset); in apr_memcache_multgetp()
/freebsd-12.1/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" \
1073 "$(INTDIR)\pollset.obj" \
1287 "$(INTDIR)\pollset.obj" \
[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" \
1169 "$(INTDIR)\pollset.obj" \
1405 "$(INTDIR)\pollset.obj" \
[all …]
H A DCHANGES137 *) Files and pipes on Windows: Don't create an unused pollset when
H A DNWGNUmakefile342 $(OBJDIR)/pollset.o \
/freebsd-12.1/usr.bin/svn/lib/libapr/
H A DMakefile15 otherchild.c pipe.c poll.c pollcb.c pollset.c port.c \
/freebsd-12.1/contrib/apr/network_io/unix/
H A Dsockets.c81 (void) apr_pollset_create(&(*new)->pollset, 1, p, 0); in alloc_socket()

12