| /freebsd-12-stable/contrib/apr/poll/unix/ |
| D | poll.c | 78 struct pollfd pollset[num]; in apr_poll() local
80 struct pollfd *pollset = alloca(sizeof(struct pollfd) * num); in apr_poll() local
81 if (!pollset) in apr_poll()
85 struct pollfd *pollset; in apr_poll() local
88 pollset = tmp_pollset; in apr_poll()
94 pollset = malloc(sizeof(struct pollfd) * num); in apr_poll()
98 if (!pollset) in apr_poll()
104 pollset[i].fd = aprset[i].desc.s->socketdes; in apr_poll()
107 pollset[i].fd = aprset[i].desc.f->filedes; in apr_poll()
112 pollset[i].events = get_event(aprset[i].reqevents); in apr_poll()
[all …]
|
| D | pollset.c | 35 apr_pollset_t *pollset = (apr_pollset_t *) p; in pollset_cleanup() local
36 if (pollset->provider->cleanup) { in pollset_cleanup()
37 (*pollset->provider->cleanup)(pollset); in pollset_cleanup()
39 if (pollset->flags & APR_POLLSET_WAKEABLE) { in pollset_cleanup()
40 apr_poll_close_wakeup_pipe(pollset->wakeup_pipe); 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()
143 pollset->nalloc = size; in apr_pollset_create_ex()
144 pollset->pool = p; in apr_pollset_create_ex()
[all …]
|
| D | select.c | 197 static apr_status_t impl_pollset_create(apr_pollset_t *pollset, in impl_pollset_create() argument
203 pollset->p = NULL; in impl_pollset_create()
208 pollset->p = NULL; in impl_pollset_create()
212 pollset->p = apr_palloc(p, sizeof(apr_pollset_private_t)); in impl_pollset_create()
213 FD_ZERO(&(pollset->p->readset)); in impl_pollset_create()
214 FD_ZERO(&(pollset->p->writeset)); in impl_pollset_create()
215 FD_ZERO(&(pollset->p->exceptset)); in impl_pollset_create()
216 pollset->p->maxfd = 0; in impl_pollset_create()
218 pollset->p->set_type = APR_NO_DESC; in impl_pollset_create()
220 pollset->p->query_set = apr_palloc(p, size * sizeof(apr_pollfd_t)); in impl_pollset_create()
[all …]
|
| D | kqueue.c | 66 static apr_status_t impl_pollset_cleanup(apr_pollset_t *pollset) in impl_pollset_cleanup() argument
68 close(pollset->p->kqueue_fd); in impl_pollset_cleanup()
72 static apr_status_t impl_pollset_create(apr_pollset_t *pollset, in impl_pollset_create() argument
78 pollset->p = apr_palloc(p, sizeof(apr_pollset_private_t)); in impl_pollset_create()
81 ((rv = apr_thread_mutex_create(&pollset->p->ring_lock, in impl_pollset_create()
84 pollset->p = NULL; in impl_pollset_create()
89 pollset->p = NULL; in impl_pollset_create()
101 pollset->p->setsize = 2 * size; in impl_pollset_create()
103 pollset->p->ke_set = in impl_pollset_create()
104 (struct kevent *) apr_palloc(p, pollset->p->setsize * sizeof(struct kevent)); in impl_pollset_create()
[all …]
|
| D | epoll.c | 65 struct epoll_event *pollset; member
80 static apr_status_t impl_pollset_cleanup(apr_pollset_t *pollset) in impl_pollset_cleanup() argument
82 close(pollset->p->epoll_fd); in impl_pollset_cleanup()
87 static apr_status_t impl_pollset_create(apr_pollset_t *pollset, in impl_pollset_create() argument
101 pollset->p = NULL; in impl_pollset_create()
112 pollset->p = NULL; in impl_pollset_create()
120 pollset->p = NULL; in impl_pollset_create()
126 pollset->p = apr_palloc(p, sizeof(apr_pollset_private_t)); in impl_pollset_create()
130 ((rv = apr_thread_mutex_create(&pollset->p->ring_lock, in impl_pollset_create()
134 pollset->p = NULL; in impl_pollset_create()
[all …]
|
| D | port.c | 150 static apr_status_t impl_pollset_cleanup(apr_pollset_t *pollset) in impl_pollset_cleanup() argument
152 close(pollset->p->port_fd); in impl_pollset_cleanup()
156 static apr_status_t impl_pollset_create(apr_pollset_t *pollset, in impl_pollset_create() argument
162 pollset->p = apr_palloc(p, sizeof(apr_pollset_private_t)); in impl_pollset_create()
165 ((rv = apr_thread_mutex_create(&pollset->p->ring_lock, in impl_pollset_create()
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()
179 pollset->p->port_set = apr_palloc(p, size * sizeof(port_event_t)); in impl_pollset_create()
181 pollset->p->port_fd = port_create(); in impl_pollset_create()
[all …]
|
| D | z_asio.c | 74 struct pollfd *pollset; member
244 static apr_status_t asio_pollset_cleanup(apr_pollset_t *pollset) in asio_pollset_cleanup() argument
250 if (pollset->flags & APR_POLLSET_THREADSAFE) { in asio_pollset_cleanup()
251 rv = msgctl(pollset->p->msg_q, IPC_RMID, NULL); in asio_pollset_cleanup()
258 static apr_status_t asio_pollset_create(apr_pollset_t *pollset, in asio_pollset_create() argument
269 priv = pollset->p = apr_pcalloc(p, sizeof(*priv)); in asio_pollset_create()
277 pollset->p = NULL; in asio_pollset_create()
285 pollset->p = NULL; in asio_pollset_create()
289 DBG2(4, "pollset %p msgget was OK, rv=%d\n", pollset, rv); in asio_pollset_create()
297 pollset->p = NULL; in asio_pollset_create()
[all …]
|
| /freebsd-12-stable/contrib/apr/support/unix/ |
| D | waitio.c | 72 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-stable/contrib/apr/include/ |
| D | apr_poll.h | 154 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-stable/contrib/apr/include/arch/unix/ |
| D | apr_arch_poll_private.h | 93 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
|
| D | apr_arch_networkio.h | 125 apr_pollset_t *pollset; member
|
| D | apr_arch_file_io.h | 106 apr_pollset_t *pollset; member
|
| /freebsd-12-stable/contrib/serf/ |
| D | context.c | 91 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()
|
| D | serf_private.h | 120 apr_pollset_t *pollset; member
|
| /freebsd-12-stable/contrib/subversion/subversion/libsvn_subr/ |
| D | prompt.c | 440 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-stable/contrib/apr/file_io/unix/ |
| D | open.c | 58 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()
|
| D | pipe.c | 167 (*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()
|
| D | filedup.c | 123 (*new_file)->pollset = NULL; in file_dup()
178 (*new_file)->pollset = NULL; in apr_file_setaside()
|
| /freebsd-12-stable/contrib/apr-util/memcache/ |
| D | apr_memcache.c | 1223 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-12-stable/contrib/apr/ |
| D | apr.mak | 94 -@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)"
|
| D | libapr.mak | 93 -@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"
|
| D | NWGNUmakefile | 342 $(OBJDIR)/pollset.o \
|
| D | build-outputs.mk | 85 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-12-stable/usr.bin/svn/lib/libapr/ |
| D | Makefile | 55 pollset.c \
|
| /freebsd-12-stable/contrib/apr/network_io/unix/ |
| D | sockets.c | 106 (void) apr_pollset_create(&(*new)->pollset, 1, p, 0); in alloc_socket()
|