/freebsd-11-stable/contrib/apr/file_io/unix/ |
H A D | filedup.c | 120 /* 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 D | open.c | 58 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 D | pipe.c | 164 /* 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 D | apr_arch_file_io.h | 105 /* if there is a timeout set, then this pollset is used */ 106 apr_pollset_t *pollset; member in struct:apr_file_t
|
H A D | apr_arch_networkio.h | 124 /* if there is a timeout set, then this pollset is used */ 125 apr_pollset_t *pollset; member in struct:apr_socket_t
|
H A 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 in struct:apr_pollcb_t
|
/freebsd-11-stable/contrib/apr/support/unix/ |
H A D | waitio.c | 72 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 D | apr_memcache.c | 1223 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 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 [all...] |
H A D | build-outputs.mk | 85 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 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 [all...] |
/freebsd-11-stable/contrib/apr/include/ |
H A D | apr_poll.h | 122 /** 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 D | sockets.c | 104 /* 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 D | epoll.c | 65 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 D | kqueue.c | 66 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 D | poll.c | 78 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 D | pollset.c | 35 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 D | port.c | 150 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 D | select.c | 197 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 D | z_asio.c | 21 * 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 D | context.c | 91 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 D | serf_private.h | 26 ### 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 D | prompt.c | 442 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 D | Makefile | 55 pollset.c \
|