Home
last modified time | relevance | path

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

12

/freebsd-13.1/contrib/apr/poll/unix/
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()
258 ret = WSAPoll(pollset->p->pollset, pollset->nelts, (int)timeout); in impl_pollset_poll()
263 ret = poll(pollset->p->pollset, pollset->nelts, timeout); in impl_pollset_poll()
[all …]
H A Dpollset.c37 (*pollset->provider->cleanup)(pollset); in pollset_cleanup()
108 apr_pollset_t *pollset; in apr_pollset_create_ex() local
141 pollset = apr_palloc(p, sizeof(*pollset)); in apr_pollset_create_ex()
142 pollset->nelts = 0; in apr_pollset_create_ex()
144 pollset->pool = p; in apr_pollset_create_ex()
168 if ((rv = apr_poll_create_wakeup_pipe(pollset->pool, &pollset->wakeup_pfd, in apr_pollset_create_ex()
174 if ((rv = apr_pollset_add(pollset, &pollset->wakeup_pfd)) != APR_SUCCESS) { in apr_pollset_create_ex()
215 return apr_pool_cleanup_run(pollset->pool, pollset, in apr_pollset_destroy()
232 return (*pollset->provider->add)(pollset, descriptor); in apr_pollset_add()
238 return (*pollset->provider->remove)(pollset, descriptor); in apr_pollset_remove()
[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()
272 ret = kevent(pollset->p->kqueue_fd, NULL, 0, pollset->p->ke_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()
267 ret = epoll_wait(pollset->p->epoll_fd, pollset->p->pollset, pollset->nalloc, in impl_pollset_poll()
281 fdptr = (apr_pollfd_t *)(pollset->p->pollset[i].data.ptr); in impl_pollset_poll()
284 fdptr = &(((pfd_elem_t *) (pollset->p->pollset[i].data.ptr))->pfd); 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()
400 rv = call_port_getn(pollset->p->port_fd, pollset->p->port_set, in impl_pollset_poll()
[all …]
H A Dz_asio.c297 pollset->p = NULL; in asio_pollset_create()
314 pollset->nelts = 0; in asio_pollset_create()
316 pollset->pool = p; in asio_pollset_create()
323 pollset->p = NULL; in asio_pollset_create()
328 pollset, in asio_pollset_create()
358 priv->pollset[pollset->nelts].fd = fd; in posix_add()
360 priv->pollset[pollset->nelts].events = in posix_add()
363 pollset->nelts++; in posix_add()
464 priv->pollset[dst] = priv->pollset[i]; in posix_remove()
559 rv = poll(priv->pollset, pollset->nelts, timeout); in posix_poll()
[all …]
/freebsd-13.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-13.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-13.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);
157 apr_pollcb_pset pollset; member
H A Dapr_arch_networkio.h125 apr_pollset_t *pollset; member
H A Dapr_arch_file_io.h106 apr_pollset_t *pollset; member
/freebsd-13.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-13.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-13.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()
202 (*in)->pollset = NULL; in file_pipe_create()
217 (*out)->pollset = NULL; in file_pipe_create()
H A Dfiledup.c123 (*new_file)->pollset = NULL; in file_dup()
178 (*new_file)->pollset = NULL; in apr_file_setaside()
/freebsd-13.1/contrib/apr-util/memcache/
H A Dapr_memcache.c1223 apr_pollset_t* pollset; in apr_memcache_multgetp() local
1296 rv = apr_pollset_create(&pollset, apr_hash_count(server_queries), temp_pool, 0); in apr_memcache_multgetp()
1343 apr_pollset_add (pollset, &pollfds[queries_sent]); in apr_memcache_multgetp()
1349 rv = apr_pollset_poll(pollset, MULT_GET_TIMEOUT, &queries_recvd, &activefds); in apr_memcache_multgetp()
1364 apr_pollset_remove (pollset, &activefds[i]); in apr_memcache_multgetp()
1393 apr_pollset_remove (pollset, &activefds[i]); in apr_memcache_multgetp()
1408 apr_pollset_remove (pollset, &activefds[i]); in apr_memcache_multgetp()
1417 apr_pollset_remove (pollset, &activefds[i]); in apr_memcache_multgetp()
1444 apr_pollset_remove (pollset, &activefds[i]); in apr_memcache_multgetp()
1454 apr_pollset_remove (pollset, &activefds[i]); in apr_memcache_multgetp()
[all …]
/freebsd-13.1/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.obj" : $(SOURCE) "$(INTDIR)"
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.obj" : $(SOURCE) "$(INTDIR)" ".\include\apr.h"
H A DNWGNUmakefile342 $(OBJDIR)/pollset.o \
H A Dbuild-outputs.mk85 poll/unix/pollset.lo: poll/unix/pollset.c .make.dirs include/apr_allocator.h include/apr_dso.h incl…
91 …l.lo poll/unix/kqueue.lo poll/unix/poll.lo poll/unix/pollcb.lo poll/unix/pollset.lo poll/unix/port…
220 poll/os2/pollset.lo: poll/os2/pollset.c .make.dirs include/apr_allocator.h include/apr_errno.h incl…
222 OBJECTS_poll_os2 = poll/os2/poll.lo poll/os2/pollset.lo
/freebsd-13.1/usr.bin/svn/lib/libapr/
H A DMakefile55 pollset.c \
/freebsd-13.1/contrib/apr/network_io/unix/
H A Dsockets.c106 (void) apr_pollset_create(&(*new)->pollset, 1, p, 0); in alloc_socket()

12