| /dports/devel/apr1/apr-1.7.0/poll/os2/ |
| H A D | pollset.c | 54 *pollset = apr_palloc(p, sizeof(**pollset)); in apr_pollset_create()
121 if (pollset->nelts == pollset->nalloc) { in apr_pollset_add()
125 pollset->query_set[pollset->nelts] = *descriptor; in apr_pollset_add()
155 pollset->pollset[dst] = pollset->pollset[i]; in apr_pollset_remove()
182 pollset->pollset[pos++] = pollset->query_set[i].desc.s->socketdes; in make_pollset()
189 pollset->pollset[pos++] = pollset->query_set[i].desc.s->socketdes; in make_pollset()
196 pollset->pollset[pos++] = pollset->query_set[i].desc.s->socketdes; in make_pollset()
201 pollset->num_total = pollset->num_read + pollset->num_write + pollset->num_except; in make_pollset()
222 memcpy(pollresult, pollset->pollset, sizeof(int) * pollset->num_total); in apr_pollset_poll()
229 rv = select(pollresult, pollset->num_read, pollset->num_write, pollset->num_except, timeout); in apr_pollset_poll()
[all …]
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/libs/apr/poll/os2/ |
| H A D | pollset.c | 43 *pollset = apr_palloc(p, sizeof(**pollset)); in apr_pollset_create()
69 if (pollset->nelts == pollset->nalloc) { in apr_pollset_add()
73 pollset->query_set[pollset->nelts] = *descriptor; in apr_pollset_add()
103 pollset->pollset[dst] = pollset->pollset[i]; in apr_pollset_remove()
130 pollset->pollset[pos++] = pollset->query_set[i].desc.s->socketdes; in make_pollset()
137 pollset->pollset[pos++] = pollset->query_set[i].desc.s->socketdes; in make_pollset()
144 pollset->pollset[pos++] = pollset->query_set[i].desc.s->socketdes; in make_pollset()
149 pollset->num_total = pollset->num_read + pollset->num_write + pollset->num_except; in make_pollset()
169 memcpy(pollresult, pollset->pollset, sizeof(int) * pollset->num_total); in apr_pollset_poll()
176 rv = select(pollresult, pollset->num_read, pollset->num_write, pollset->num_except, timeout); in apr_pollset_poll()
[all …]
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/libs/apr/poll/unix/ |
| H A D | poll.c | 170 *pollset = apr_palloc(p, sizeof(**pollset)); in apr_pollset_create()
188 if (pollset->nelts == pollset->nalloc) { in apr_pollset_add()
192 pollset->query_set[pollset->nelts] = *descriptor; in apr_pollset_add()
195 pollset->pollset[pollset->nelts].fd = descriptor->desc.s->socketdes; in apr_pollset_add()
198 pollset->pollset[pollset->nelts].fd = descriptor->desc.f->filedes; in apr_pollset_add()
201 pollset->pollset[pollset->nelts].events = in apr_pollset_add()
224 pollset->pollset[dst] = pollset->pollset[i]; in apr_pollset_remove()
247 rv = poll(pollset->pollset, pollset->nelts, timeout); in apr_pollset_poll()
257 if (pollset->pollset[i].revents != 0) { in apr_pollset_poll()
258 pollset->result_set[j] = pollset->query_set[i]; in apr_pollset_poll()
[all …]
|
| H A D | kqueue.c | 73 *pollset = apr_palloc(p, sizeof(**pollset)); in apr_pollset_create()
79 *pollset = NULL; in apr_pollset_create()
84 *pollset = NULL; in apr_pollset_create()
91 (*pollset)->pool = p; in apr_pollset_create()
93 (*pollset)->ke_set = in apr_pollset_create()
118 return apr_pool_cleanup_run(pollset->pool, pollset, backend_cleanup); in apr_pollset_destroy()
150 if (kevent(pollset->kqueue_fd, &pollset->kevent, 1, NULL, 0, in apr_pollset_add()
159 if (kevent(pollset->kqueue_fd, &pollset->kevent, 1, NULL, 0, in apr_pollset_add()
197 if (kevent(pollset->kqueue_fd, &pollset->kevent, 1, NULL, 0, in apr_pollset_remove()
206 if (kevent(pollset->kqueue_fd, &pollset->kevent, 1, NULL, 0, in apr_pollset_remove()
[all …]
|
| H A D | epoll.c | 98 *pollset = NULL; in apr_pollset_create()
102 *pollset = apr_palloc(p, sizeof(**pollset)); in apr_pollset_create()
108 *pollset = NULL; in apr_pollset_create()
113 *pollset = NULL; in apr_pollset_create()
120 (*pollset)->pool = p; in apr_pollset_create()
122 (*pollset)->pollset = apr_palloc(p, size * sizeof(struct epoll_event)); in apr_pollset_create()
135 return apr_pool_cleanup_run(pollset->pool, pollset, backend_cleanup); in apr_pollset_destroy()
174 pollset->nelts++; in apr_pollset_add()
239 ret = epoll_wait(pollset->epoll_fd, pollset->pollset, pollset->nalloc, in apr_pollset_poll()
252 (((pfd_elem_t *) (pollset->pollset[i].data.ptr))->pfd); in apr_pollset_poll()
[all …]
|
| H A D | port.c | 88 close(pollset->port_fd); in backend_cleanup()
98 *pollset = apr_palloc(p, sizeof(**pollset)); in apr_pollset_create()
104 *pollset = NULL; in apr_pollset_create()
109 *pollset = NULL; in apr_pollset_create()
113 (*pollset)->nelts = 0; in apr_pollset_create()
114 (*pollset)->nalloc = size; in apr_pollset_create()
116 (*pollset)->pool = p; in apr_pollset_create()
141 return apr_pool_cleanup_run(pollset->pool, pollset, backend_cleanup); in apr_pollset_destroy()
179 pollset->nelts++; in apr_pollset_add()
291 ret = port_getn(pollset->port_fd, pollset->port_set, pollset->nalloc, in apr_pollset_poll()
[all …]
|
| H A D | select.c | 193 *pollset = NULL; in apr_pollset_create()
198 *pollset = NULL; in apr_pollset_create()
202 *pollset = apr_palloc(p, sizeof(**pollset)); in apr_pollset_create()
203 (*pollset)->nelts = 0; in apr_pollset_create()
205 (*pollset)->pool = p; in apr_pollset_create()
229 if (pollset->nelts == pollset->nalloc) { in apr_pollset_add()
233 pollset->query_set[pollset->nelts] = *descriptor; in apr_pollset_add()
284 pollset->nelts++; in apr_pollset_add()
316 pollset->query_set[dst] = pollset->query_set[i]; in apr_pollset_remove()
323 if (((int) fd == pollset->maxfd) && (pollset->maxfd > 0)) { in apr_pollset_remove()
[all …]
|
| /dports/devel/apr1/apr-1.7.0/poll/unix/ |
| H A D | poll.c | 81 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 D | pollset.c | 37 (*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 D | select.c | 203 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 D | kqueue.c | 103 pollset->p = NULL; in impl_pollset_create()
108 pollset->p = NULL; in impl_pollset_create()
122 pollset->p->ke_set = in impl_pollset_create()
125 memset(pollset->p->ke_set, 0, pollset->p->setsize * sizeof(struct kevent)); in impl_pollset_create()
130 pollset->p = NULL; in impl_pollset_create()
191 if (kevent(pollset->p->kqueue_fd, &pollset->p->kevent, 1, NULL, 0, in impl_pollset_add()
200 if (kevent(pollset->p->kqueue_fd, &pollset->p->kevent, 1, NULL, 0, in impl_pollset_add()
238 if (kevent(pollset->p->kqueue_fd, &pollset->p->kevent, 1, NULL, 0, in impl_pollset_remove()
247 if (kevent(pollset->p->kqueue_fd, &pollset->p->kevent, 1, NULL, 0, in impl_pollset_remove()
291 ret = kevent(pollset->p->kqueue_fd, NULL, 0, pollset->p->ke_set, in impl_pollset_poll()
[all …]
|
| H A D | epoll.c | 101 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 D | port.c | 152 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 …]
|
| /dports/net/freeswitch/freeswitch-1.10.3.-release/libs/unimrcp/libs/apr-toolkit/src/ |
| H A D | apt_pollset.c | 47 pollset->pool = pool; in apt_pollset_create()
48 memset(&pollset->wakeup_pfd,0,sizeof(pollset->wakeup_pfd)); in apt_pollset_create()
63 if(apr_pollset_add(pollset->base,&pollset->wakeup_pfd) != APR_SUCCESS) { in apt_pollset_create()
68 return pollset; in apt_pollset_create()
75 apr_pollset_remove(pollset->base,&pollset->wakeup_pfd); in apt_pollset_destroy()
97 apt_pollset_t *pollset, in apt_pollset_poll() argument
270 pollset->wakeup_pipe[0] = rd; in apt_wakeup_pipe_create()
271 pollset->wakeup_pipe[1] = wr; in apt_wakeup_pipe_create()
279 if(pollset->wakeup_pipe[0]) { in apt_wakeup_pipe_destroy()
283 if(pollset->wakeup_pipe[1]) { in apt_wakeup_pipe_destroy()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/util/src/ |
| H A D | util_poll.c | 43 struct util_poll *pollset; in util_poll_add() local
52 if (!pollset->domain) in util_poll_add()
61 return fid_list_insert(&pollset->fid_list, &pollset->lock, event_fid); in util_poll_add()
67 struct util_poll *pollset; in util_poll_del() local
70 fid_list_remove(&pollset->fid_list, &pollset->lock, event_fid); in util_poll_del()
76 struct util_poll *pollset; in util_poll_run() local
142 if (pollset->domain) in util_poll_close()
147 free(pollset); in util_poll_close()
187 pollset = calloc(1, sizeof(*pollset)); in fi_poll_create_()
188 if (!pollset) in fi_poll_create_()
[all …]
|
| /dports/www/chromium-legacy/chromium-88.0.4324.182/third_party/grpc/src/src/core/lib/iomgr/ |
| H A D | ev_epoll1_linux.cc | 548 *mu = &pollset->mu; in pollset_init()
557 pollset->next = pollset->prev = nullptr; in pollset_init()
575 pollset->prev->next = pollset->next; in pollset_destroy()
576 pollset->next->prev = pollset->prev; in pollset_destroy()
577 if (pollset == pollset->neighborhood->active_root) { in pollset_destroy()
579 pollset->next == pollset ? nullptr : pollset->next; in pollset_destroy()
752 pollset->begin_refs++; in begin_worker()
798 neighborhood->active_root = pollset->next = pollset->prev = pollset; in begin_worker()
806 pollset->prev = pollset->next->prev; in begin_worker()
807 pollset->next->prev = pollset->prev->next = pollset; in begin_worker()
[all …]
|
| /dports/devel/grpc130/grpc-1.30.2/src/core/lib/iomgr/ |
| H A D | ev_epoll1_linux.cc | 553 *mu = &pollset->mu; in pollset_init()
562 pollset->next = pollset->prev = nullptr; in pollset_init()
580 pollset->prev->next = pollset->next; in pollset_destroy()
581 pollset->next->prev = pollset->prev; in pollset_destroy()
582 if (pollset == pollset->neighborhood->active_root) { in pollset_destroy()
584 pollset->next == pollset ? nullptr : pollset->next; in pollset_destroy()
758 pollset->begin_refs++; in begin_worker()
804 neighborhood->active_root = pollset->next = pollset->prev = pollset; in begin_worker()
812 pollset->prev = pollset->next->prev; in begin_worker()
813 pollset->next->prev = pollset->prev->next = pollset; in begin_worker()
[all …]
|
| H A D | ev_poll_posix.cc | 57 grpc_pollset* pollset; member
642 watcher->pollset = pollset;
848 *mu = &pollset->mu;
849 pollset->root_worker.next = pollset->root_worker.prev = &pollset->root_worker;
881 if (pollset->fd_count == pollset->fd_capacity) {
883 GPR_MAX(pollset->fd_capacity + 8, pollset->fd_count * 3 / 2);
887 pollset->fds[pollset->fd_count++] = fd;
1002 pollset->fds[fd_count++] = pollset->fds[i];
1146 if (!pollset->called_shutdown && !pollset_has_observers(pollset)) {
1183 if (pollset->shutting_down && !pollset->called_shutdown &&
[all …]
|
| /dports/devel/grpc134/grpc-1.34.1/src/core/lib/iomgr/ |
| H A D | ev_epoll1_linux.cc | 552 *mu = &pollset->mu; in pollset_init()
561 pollset->next = pollset->prev = nullptr; in pollset_init()
579 pollset->prev->next = pollset->next; in pollset_destroy()
580 pollset->next->prev = pollset->prev; in pollset_destroy()
581 if (pollset == pollset->neighborhood->active_root) { in pollset_destroy()
583 pollset->next == pollset ? nullptr : pollset->next; in pollset_destroy()
757 pollset->begin_refs++; in begin_worker()
803 neighborhood->active_root = pollset->next = pollset->prev = pollset; in begin_worker()
811 pollset->prev = pollset->next->prev; in begin_worker()
812 pollset->next->prev = pollset->prev->next = pollset; in begin_worker()
[all …]
|
| H A D | ev_poll_posix.cc | 60 grpc_pollset* pollset; member
643 watcher->pollset = pollset;
849 *mu = &pollset->mu;
850 pollset->root_worker.next = pollset->root_worker.prev = &pollset->root_worker;
882 if (pollset->fd_count == pollset->fd_capacity) {
884 GPR_MAX(pollset->fd_capacity + 8, pollset->fd_count * 3 / 2);
888 pollset->fds[pollset->fd_count++] = fd;
1003 pollset->fds[fd_count++] = pollset->fds[i];
1147 if (!pollset->called_shutdown && !pollset_has_observers(pollset)) {
1184 if (pollset->shutting_down && !pollset->called_shutdown &&
[all …]
|
| /dports/devel/grpc/grpc-1.42.0/src/core/lib/iomgr/ |
| H A D | ev_epoll1_linux.cc | 548 *mu = &pollset->mu; in pollset_init()
557 pollset->next = pollset->prev = nullptr; in pollset_init()
575 pollset->prev->next = pollset->next; in pollset_destroy()
576 pollset->next->prev = pollset->prev; in pollset_destroy()
577 if (pollset == pollset->neighborhood->active_root) { in pollset_destroy()
579 pollset->next == pollset ? nullptr : pollset->next; in pollset_destroy()
753 pollset->begin_refs++; in begin_worker()
799 neighborhood->active_root = pollset->next = pollset->prev = pollset; in begin_worker()
808 pollset->prev = pollset->next->prev; in begin_worker()
809 pollset->next->prev = pollset->prev->next = pollset; in begin_worker()
[all …]
|
| /dports/devel/pecl-grpc/grpc-1.42.0/src/core/lib/iomgr/ |
| H A D | ev_epoll1_linux.cc | 548 *mu = &pollset->mu;
557 pollset->next = pollset->prev = nullptr;
575 pollset->prev->next = pollset->next;
576 pollset->next->prev = pollset->prev;
577 if (pollset == pollset->neighborhood->active_root) {
579 pollset->next == pollset ? nullptr : pollset->next;
753 pollset->begin_refs++;
799 neighborhood->active_root = pollset->next = pollset->prev = pollset;
808 pollset->prev = pollset->next->prev;
809 pollset->next->prev = pollset->prev->next = pollset;
[all …]
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/core/lib/iomgr/ |
| H A D | ev_epoll1_linux.cc | 548 *mu = &pollset->mu; in pollset_init()
557 pollset->next = pollset->prev = nullptr; in pollset_init()
575 pollset->prev->next = pollset->next; in pollset_destroy()
576 pollset->next->prev = pollset->prev; in pollset_destroy()
577 if (pollset == pollset->neighborhood->active_root) { in pollset_destroy()
579 pollset->next == pollset ? nullptr : pollset->next; in pollset_destroy()
753 pollset->begin_refs++; in begin_worker()
799 neighborhood->active_root = pollset->next = pollset->prev = pollset; in begin_worker()
808 pollset->prev = pollset->next->prev; in begin_worker()
809 pollset->next->prev = pollset->prev->next = pollset; in begin_worker()
[all …]
|
| /dports/devel/libxs/libxs-1.2.0/src/ |
| H A D | poll.cpp | 56 pollset.push_back (pfd); in add_fd()
59 fd_table [fd_].index = pollset.size() - 1; in add_fd()
74 pollset [index].fd = retired_fd; in rm_fd()
85 pollset [index].events |= POLLIN; in set_pollin()
97 pollset [index].events |= POLLOUT; in set_pollout()
124 int rc = poll (&pollset [0], pollset.size (), timeout ? timeout : -1); in loop()
141 fd_table [pollset [i].fd].events->in_event (pollset [i].fd); in loop()
145 fd_table [pollset [i].fd].events->out_event (pollset [i].fd); in loop()
149 fd_table [pollset [i].fd].events->in_event (pollset [i].fd); in loop()
155 while (i < pollset.size ()) { in loop()
[all …]
|
| /dports/net/pecl-zmq/zmq-1.1.3/php5/ |
| H A D | zmq_pollset.c | 157 assert(pollset->num_php_items == pollset->num_items); in php_zmq_pollset_add()
179 resize = (pollset->num_items >= pollset->alloc_size); in php_zmq_pollset_add()
200 …pollset->items = erealloc(pollset->items, (pollset->alloc_size + PHP_ZMQ_ALLOC_SIZE) * sizeof(zmq_… in php_zmq_pollset_add()
205 pollset->items[pollset->num_items].fd = fd; in php_zmq_pollset_add()
206 pollset->items[pollset->num_items].events = events; in php_zmq_pollset_add()
217 pollset->items[pollset->num_items].events = events; in php_zmq_pollset_add()
228 pollset->php_items[pollset->num_php_items].events = events; in php_zmq_pollset_add()
229 pollset->php_items[pollset->num_php_items].entry = entry; in php_zmq_pollset_add()
230 pollset->php_items[pollset->num_php_items].key_len = key_len; in php_zmq_pollset_add()
233 pollset->php_items[pollset->num_php_items].fd = pollset->items[pollset->num_items].fd; in php_zmq_pollset_add()
[all …]
|