/freebsd-10.2-release/contrib/apr/poll/unix/ |
H A D | pollset.c | 38 static apr_status_t create_wakeup_pipe(apr_pollset_t *pollset) argument 42 if ((rv = apr_file_socket_pipe_create(&pollset->wakeup_pipe[0], 43 &pollset->wakeup_pipe[1], 44 pollset->pool)) != APR_SUCCESS) 47 pollset->wakeup_pfd.p = pollset->pool; 48 pollset->wakeup_pfd.reqevents = APR_POLLIN; 49 pollset->wakeup_pfd.desc_type = APR_POLL_FILE; 50 pollset->wakeup_pfd.desc.f = pollset 56 create_wakeup_pipe(apr_pollset_t *pollset) argument 71 create_wakeup_pipe(apr_pollset_t *pollset) argument 112 apr_pollset_drain_wakeup_pipe(apr_pollset_t *pollset) argument 130 apr_pollset_t *pollset = (apr_pollset_t *) p; local 219 apr_pollset_t *pollset; local 291 apr_pollset_method_name(apr_pollset_t *pollset) 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 | 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 | 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 135 impl_pollset_add(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument 191 impl_pollset_remove(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument 244 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 | 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 209 impl_pollset_add(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument 262 impl_pollset_remove(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument 343 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 | 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; 118 pollset->p = apr_palloc(p, sizeof(apr_pollset_private_t)); 122 ((rv = apr_thread_mutex_create(&pollset->p->ring_lock, 125 pollset->p = NULL; 130 pollset->p = NULL; 134 pollset 146 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 243 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 rv = msgctl(pollset->p->msg_q, IPC_RMID, NULL); 256 static apr_status_t asio_pollset_create(apr_pollset_t *pollset, argument 267 priv = pollset->p = apr_palloc(p, sizeof(*priv)); 275 pollset = NULL; 283 pollset = NULL; 287 DBG2(4, "pollset 329 posix_add(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument 364 asio_pollset_add(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument 438 posix_remove(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument 471 asio_pollset_remove(apr_pollset_t *pollset, const apr_pollfd_t *descriptor) argument 535 posix_poll(apr_pollset_t *pollset, apr_interval_time_t timeout, apr_int32_t *num, const apr_pollfd_t **descriptors) argument 575 process_msg(apr_pollset_t *pollset, struct asio_msgbuf_t *msg) argument 603 asio_pollset_poll(apr_pollset_t *pollset, apr_interval_time_t timeout, apr_int32_t *num, const apr_pollfd_t **descriptors) argument [all...] |
/freebsd-10.2-release/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-10.2-release/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-10.2-release/contrib/apr/include/arch/unix/ |
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); 153 apr_pollcb_pset pollset; member in struct:apr_pollcb_t 176 void apr_pollset_drain_wakeup_pipe(apr_pollset_t *pollset);
|
H A D | apr_arch_networkio.h | 121 /* if there is a timeout set, then this pollset is used */ 122 apr_pollset_t *pollset; member in struct:apr_socket_t
|
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
|
/freebsd-10.2-release/contrib/serf/ |
H A D | context.c | 86 return apr_pollset_add(s->pollset, pfd); 95 return apr_pollset_remove(s->pollset, pfd); 136 /* build the pollset with a (default) number of connections */ 141 ### Probably move creation of the pollset to later when we have 153 (void) apr_pollset_create_ex(&ps->pollset, MAX_CONN, pool, 0, 156 (void) apr_pollset_create(&ps->pollset, MAX_CONN, pool, 0); 208 * to remove it from the pollset again 277 if ((status = apr_pollset_poll(ps->pollset, duration, &num,
|
H A D | serf_private.h | 21 ### stop, rebuild a pollset, and repopulate it. what suckage. */ 115 apr_pollset_t *pollset; member in struct:serf_pollset_t 134 /* one of our connections has a dirty pollset state. */ 212 /* the events we've seen for this connection in our returned pollset */
|
/freebsd-10.2-release/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; 201 (*in)->pollset = NULL; 216 (*out)->pollset = NULL;
|
/freebsd-10.2-release/contrib/subversion/subversion/libsvn_subr/ |
H A D | prompt.c | 446 apr_pollfd_t pollset; 449 pollset.desc_type = APR_POLL_FILE; 450 pollset.desc.f = terminal->infd; 451 pollset.p = pool; 452 pollset.reqevents = APR_POLLIN; 454 status = apr_poll(&pollset, 1, &n, -1); 456 if (n == 1 && pollset.rtnevents & APR_POLLIN) 444 apr_pollfd_t pollset; local
|
/freebsd-10.2-release/usr.bin/svn/lib/libapr/ |
H A D | Makefile | 15 otherchild.c pipe.c poll.c pollcb.c pollset.c port.c \
|
/freebsd-10.2-release/contrib/apr-util/memcache/ |
H A D | apr_memcache.c | 1206 apr_pollset_t* pollset; local 1279 rv = apr_pollset_create(&pollset, apr_hash_count(server_queries), temp_pool, 0); 1326 apr_pollset_add (pollset, &pollfds[queries_sent]); 1332 rv = apr_pollset_poll(pollset, MULT_GET_TIMEOUT, &queries_recvd, &activefds); 1347 apr_pollset_remove (pollset, &activefds[i]); 1384 apr_pollset_remove (pollset, &activefds[i]); 1396 apr_pollset_remove (pollset, &activefds[i]); 1405 apr_pollset_remove (pollset, &activefds[i]); 1433 apr_pollset_remove (pollset, &activefds[i]); 1462 apr_pollset_destroy(pollset); [all...] |
/freebsd-10.2-release/contrib/apr/ |
H A D | apr.mak | 90 -@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" \
946 -@erase "$(INTDIR)\pollset.obj"
1073 "$(INTDIR)\pollset [all...] |
H A D | libapr.mak | 92 -@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" \
1036 -@erase "$(INTDIR)\pollset.obj"
1169 "$(INTDIR)\pollset [all...] |
H A D | build-outputs.mk | 83 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_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 88 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/z_asio.lo 215 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_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 217 OBJECTS_poll_os2 = poll/os2/poll.lo poll/os2/pollset.lo
|
/freebsd-10.2-release/contrib/apr/network_io/unix/ |
H A D | sockets.c | 79 /* Create a pollset with room for one descriptor. */ 81 (void) apr_pollset_create(&(*new)->pollset, 1, p, 0);
|