| Index: third_party/grpc/src/core/iomgr/pollset_multipoller_with_poll_posix.c
|
| diff --git a/third_party/grpc/src/core/iomgr/pollset_multipoller_with_poll_posix.c b/third_party/grpc/src/core/iomgr/pollset_multipoller_with_poll_posix.c
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..92d6fb724142a64f4b6553c3a2191e34db89991e
|
| --- /dev/null
|
| +++ b/third_party/grpc/src/core/iomgr/pollset_multipoller_with_poll_posix.c
|
| @@ -0,0 +1,234 @@
|
| +/*
|
| + *
|
| + * Copyright 2015-2016, Google Inc.
|
| + * All rights reserved.
|
| + *
|
| + * Redistribution and use in source and binary forms, with or without
|
| + * modification, are permitted provided that the following conditions are
|
| + * met:
|
| + *
|
| + * * Redistributions of source code must retain the above copyright
|
| + * notice, this list of conditions and the following disclaimer.
|
| + * * Redistributions in binary form must reproduce the above
|
| + * copyright notice, this list of conditions and the following disclaimer
|
| + * in the documentation and/or other materials provided with the
|
| + * distribution.
|
| + * * Neither the name of Google Inc. nor the names of its
|
| + * contributors may be used to endorse or promote products derived from
|
| + * this software without specific prior written permission.
|
| + *
|
| + * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
|
| + * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
|
| + * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
|
| + * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
|
| + * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
|
| + * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
|
| + * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
|
| + * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
|
| + * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
|
| + * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
|
| + * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
|
| + *
|
| + */
|
| +
|
| +#include <grpc/support/port_platform.h>
|
| +
|
| +#ifdef GPR_POSIX_SOCKET
|
| +
|
| +#include "src/core/iomgr/pollset_posix.h"
|
| +
|
| +#include <errno.h>
|
| +#include <poll.h>
|
| +#include <stdlib.h>
|
| +#include <string.h>
|
| +
|
| +#include <grpc/support/alloc.h>
|
| +#include <grpc/support/log.h>
|
| +#include <grpc/support/useful.h>
|
| +
|
| +#include "src/core/iomgr/fd_posix.h"
|
| +#include "src/core/iomgr/iomgr_internal.h"
|
| +#include "src/core/iomgr/pollset_posix.h"
|
| +#include "src/core/support/block_annotate.h"
|
| +
|
| +typedef struct {
|
| + /* all polled fds */
|
| + size_t fd_count;
|
| + size_t fd_capacity;
|
| + grpc_fd **fds;
|
| + /* fds that have been removed from the pollset explicitly */
|
| + size_t del_count;
|
| + size_t del_capacity;
|
| + grpc_fd **dels;
|
| +} pollset_hdr;
|
| +
|
| +static void multipoll_with_poll_pollset_add_fd(grpc_exec_ctx *exec_ctx,
|
| + grpc_pollset *pollset,
|
| + grpc_fd *fd,
|
| + int and_unlock_pollset) {
|
| + size_t i;
|
| + pollset_hdr *h = pollset->data.ptr;
|
| + /* TODO(ctiller): this is O(num_fds^2); maybe switch to a hash set here */
|
| + for (i = 0; i < h->fd_count; i++) {
|
| + if (h->fds[i] == fd) goto exit;
|
| + }
|
| + if (h->fd_count == h->fd_capacity) {
|
| + h->fd_capacity = GPR_MAX(h->fd_capacity + 8, h->fd_count * 3 / 2);
|
| + h->fds = gpr_realloc(h->fds, sizeof(grpc_fd *) * h->fd_capacity);
|
| + }
|
| + h->fds[h->fd_count++] = fd;
|
| + GRPC_FD_REF(fd, "multipoller");
|
| +exit:
|
| + if (and_unlock_pollset) {
|
| + gpr_mu_unlock(&pollset->mu);
|
| + }
|
| +}
|
| +
|
| +static void multipoll_with_poll_pollset_maybe_work_and_unlock(
|
| + grpc_exec_ctx *exec_ctx, grpc_pollset *pollset, grpc_pollset_worker *worker,
|
| + gpr_timespec deadline, gpr_timespec now) {
|
| +#define POLLOUT_CHECK (POLLOUT | POLLHUP | POLLERR)
|
| +#define POLLIN_CHECK (POLLIN | POLLHUP | POLLERR)
|
| +
|
| + int timeout;
|
| + int r;
|
| + size_t i, j, fd_count;
|
| + nfds_t pfd_count;
|
| + pollset_hdr *h;
|
| + /* TODO(ctiller): inline some elements to avoid an allocation */
|
| + grpc_fd_watcher *watchers;
|
| + struct pollfd *pfds;
|
| +
|
| + h = pollset->data.ptr;
|
| + timeout = grpc_poll_deadline_to_millis_timeout(deadline, now);
|
| + /* TODO(ctiller): perform just one malloc here if we exceed the inline case */
|
| + pfds = gpr_malloc(sizeof(*pfds) * (h->fd_count + 2));
|
| + watchers = gpr_malloc(sizeof(*watchers) * (h->fd_count + 2));
|
| + fd_count = 0;
|
| + pfd_count = 2;
|
| + pfds[0].fd = GRPC_WAKEUP_FD_GET_READ_FD(&grpc_global_wakeup_fd);
|
| + pfds[0].events = POLLIN;
|
| + pfds[0].revents = 0;
|
| + pfds[1].fd = GRPC_WAKEUP_FD_GET_READ_FD(&worker->wakeup_fd->fd);
|
| + pfds[1].events = POLLIN;
|
| + pfds[1].revents = 0;
|
| + for (i = 0; i < h->fd_count; i++) {
|
| + int remove = grpc_fd_is_orphaned(h->fds[i]);
|
| + for (j = 0; !remove && j < h->del_count; j++) {
|
| + if (h->fds[i] == h->dels[j]) remove = 1;
|
| + }
|
| + if (remove) {
|
| + GRPC_FD_UNREF(h->fds[i], "multipoller");
|
| + } else {
|
| + h->fds[fd_count++] = h->fds[i];
|
| + watchers[pfd_count].fd = h->fds[i];
|
| + GRPC_FD_REF(watchers[pfd_count].fd, "multipoller_start");
|
| + pfds[pfd_count].fd = h->fds[i]->fd;
|
| + pfds[pfd_count].revents = 0;
|
| + pfd_count++;
|
| + }
|
| + }
|
| + for (j = 0; j < h->del_count; j++) {
|
| + GRPC_FD_UNREF(h->dels[j], "multipoller_del");
|
| + }
|
| + h->del_count = 0;
|
| + h->fd_count = fd_count;
|
| + gpr_mu_unlock(&pollset->mu);
|
| +
|
| + for (i = 2; i < pfd_count; i++) {
|
| + grpc_fd *fd = watchers[i].fd;
|
| + pfds[i].events = (short)grpc_fd_begin_poll(fd, pollset, worker, POLLIN,
|
| + POLLOUT, &watchers[i]);
|
| + GRPC_FD_UNREF(fd, "multipoller_start");
|
| + }
|
| +
|
| + /* TODO(vpai): Consider first doing a 0 timeout poll here to avoid
|
| + even going into the blocking annotation if possible */
|
| + GRPC_SCHEDULING_START_BLOCKING_REGION;
|
| + r = grpc_poll_function(pfds, pfd_count, timeout);
|
| + GRPC_SCHEDULING_END_BLOCKING_REGION;
|
| +
|
| + if (r < 0) {
|
| + if (errno != EINTR) {
|
| + gpr_log(GPR_ERROR, "poll() failed: %s", strerror(errno));
|
| + }
|
| + for (i = 2; i < pfd_count; i++) {
|
| + grpc_fd_end_poll(exec_ctx, &watchers[i], 0, 0);
|
| + }
|
| + } else if (r == 0) {
|
| + for (i = 2; i < pfd_count; i++) {
|
| + grpc_fd_end_poll(exec_ctx, &watchers[i], 0, 0);
|
| + }
|
| + } else {
|
| + if (pfds[0].revents & POLLIN_CHECK) {
|
| + grpc_wakeup_fd_consume_wakeup(&grpc_global_wakeup_fd);
|
| + }
|
| + if (pfds[1].revents & POLLIN_CHECK) {
|
| + grpc_wakeup_fd_consume_wakeup(&worker->wakeup_fd->fd);
|
| + }
|
| + for (i = 2; i < pfd_count; i++) {
|
| + if (watchers[i].fd == NULL) {
|
| + grpc_fd_end_poll(exec_ctx, &watchers[i], 0, 0);
|
| + continue;
|
| + }
|
| + grpc_fd_end_poll(exec_ctx, &watchers[i], pfds[i].revents & POLLIN_CHECK,
|
| + pfds[i].revents & POLLOUT_CHECK);
|
| + }
|
| + }
|
| +
|
| + gpr_free(pfds);
|
| + gpr_free(watchers);
|
| +}
|
| +
|
| +static void multipoll_with_poll_pollset_finish_shutdown(grpc_pollset *pollset) {
|
| + size_t i;
|
| + pollset_hdr *h = pollset->data.ptr;
|
| + for (i = 0; i < h->fd_count; i++) {
|
| + GRPC_FD_UNREF(h->fds[i], "multipoller");
|
| + }
|
| + for (i = 0; i < h->del_count; i++) {
|
| + GRPC_FD_UNREF(h->dels[i], "multipoller_del");
|
| + }
|
| + h->fd_count = 0;
|
| + h->del_count = 0;
|
| +}
|
| +
|
| +static void multipoll_with_poll_pollset_destroy(grpc_pollset *pollset) {
|
| + pollset_hdr *h = pollset->data.ptr;
|
| + multipoll_with_poll_pollset_finish_shutdown(pollset);
|
| + gpr_free(h->fds);
|
| + gpr_free(h->dels);
|
| + gpr_free(h);
|
| +}
|
| +
|
| +static const grpc_pollset_vtable multipoll_with_poll_pollset = {
|
| + multipoll_with_poll_pollset_add_fd,
|
| + multipoll_with_poll_pollset_maybe_work_and_unlock,
|
| + multipoll_with_poll_pollset_finish_shutdown,
|
| + multipoll_with_poll_pollset_destroy};
|
| +
|
| +void grpc_poll_become_multipoller(grpc_exec_ctx *exec_ctx,
|
| + grpc_pollset *pollset, grpc_fd **fds,
|
| + size_t nfds) {
|
| + size_t i;
|
| + pollset_hdr *h = gpr_malloc(sizeof(pollset_hdr));
|
| + pollset->vtable = &multipoll_with_poll_pollset;
|
| + pollset->data.ptr = h;
|
| + h->fd_count = nfds;
|
| + h->fd_capacity = nfds;
|
| + h->fds = gpr_malloc(nfds * sizeof(grpc_fd *));
|
| + h->del_count = 0;
|
| + h->del_capacity = 0;
|
| + h->dels = NULL;
|
| + for (i = 0; i < nfds; i++) {
|
| + h->fds[i] = fds[i];
|
| + GRPC_FD_REF(fds[i], "multipoller");
|
| + }
|
| +}
|
| +
|
| +#endif /* GPR_POSIX_SOCKET */
|
| +
|
| +#ifdef GPR_POSIX_MULTIPOLL_WITH_POLL
|
| +grpc_platform_become_multipoller_type grpc_platform_become_multipoller =
|
| + grpc_poll_become_multipoller;
|
| +#endif
|
|
|