mirror of https://github.com/grpc/grpc.git
Sree Kuchibhotla
9 years ago
parent
812c66ba1b
commit
2e12db9c31
9 changed files with 366 additions and 2 deletions
@ -0,0 +1,222 @@ |
||||
/*
|
||||
* |
||||
* Copyright 2015, 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 "src/core/lib/iomgr/ev_epoll_linux.h" |
||||
#include "src/core/lib/iomgr/ev_posix.h" |
||||
|
||||
#include <poll.h> |
||||
#include <string.h> |
||||
#include <sys/eventfd.h> |
||||
#include <unistd.h> |
||||
|
||||
#include <grpc/support/alloc.h> |
||||
#include <grpc/support/log.h> |
||||
|
||||
#include "src/core/lib/iomgr/iomgr.h" |
||||
#include "test/core/util/test_config.h" |
||||
|
||||
typedef struct test_pollset { |
||||
grpc_pollset *pollset; |
||||
gpr_mu *mu; |
||||
} test_pollset; |
||||
|
||||
typedef struct test_fd { |
||||
int inner_fd; |
||||
grpc_fd *fd; |
||||
} test_fd; |
||||
|
||||
static void test_fd_init(test_fd *fds, int num_fds) { |
||||
int i; |
||||
for (i = 0; i < num_fds; i++) { |
||||
fds[i].inner_fd = eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC); |
||||
fds[i].fd = grpc_fd_create(fds[i].inner_fd, "test_fd"); |
||||
} |
||||
} |
||||
|
||||
static void test_fd_cleanup(grpc_exec_ctx *exec_ctx, test_fd *fds, |
||||
int num_fds) { |
||||
int release_fd; |
||||
int i; |
||||
|
||||
for (i = 0; i < num_fds; i++) { |
||||
grpc_fd_shutdown(exec_ctx, fds[i].fd); |
||||
grpc_exec_ctx_flush(exec_ctx); |
||||
|
||||
grpc_fd_orphan(exec_ctx, fds[i].fd, NULL, &release_fd, "test_fd_cleanup"); |
||||
grpc_exec_ctx_flush(exec_ctx); |
||||
|
||||
GPR_ASSERT(release_fd == fds[i].inner_fd); |
||||
close(fds[i].inner_fd); |
||||
} |
||||
} |
||||
|
||||
static void test_pollset_init(test_pollset *pollsets, int num_pollsets) { |
||||
int i; |
||||
for (i = 0; i < num_pollsets; i++) { |
||||
pollsets[i].pollset = gpr_malloc(grpc_pollset_size()); |
||||
grpc_pollset_init(pollsets[i].pollset, &pollsets[i].mu); |
||||
} |
||||
} |
||||
|
||||
static void destroy_pollset(grpc_exec_ctx *exec_ctx, void *p, bool success) { |
||||
grpc_pollset_destroy(p); |
||||
} |
||||
|
||||
static void test_pollset_cleanup(grpc_exec_ctx *exec_ctx, |
||||
test_pollset *pollsets, int num_pollsets) { |
||||
grpc_closure destroyed; |
||||
int i; |
||||
|
||||
for (i = 0; i < num_pollsets; i++) { |
||||
grpc_closure_init(&destroyed, destroy_pollset, pollsets[i].pollset); |
||||
grpc_pollset_shutdown(exec_ctx, pollsets[i].pollset, &destroyed); |
||||
|
||||
grpc_exec_ctx_flush(exec_ctx); |
||||
gpr_free(pollsets[i].pollset); |
||||
} |
||||
} |
||||
|
||||
#define NUM_FDS 8 |
||||
#define NUM_POLLSETS 4 |
||||
/*
|
||||
* Cases to test: |
||||
* case 1) Polling islands of both fd and pollset are NULL |
||||
* case 2) Polling island of fd is NULL but that of pollset is not-NULL |
||||
* case 3) Polling island of fd is not-NULL but that of pollset is NULL |
||||
* case 4) Polling islands of both fd and pollset are not-NULL and: |
||||
* case 4.1) Polling islands of fd and pollset are equal |
||||
* case 4.2) Polling islands of fd and pollset are NOT-equal (This results |
||||
* in a merge) |
||||
* */ |
||||
static void test_add_fd_to_pollset() { |
||||
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT; |
||||
test_fd fds[NUM_FDS]; |
||||
test_pollset pollsets[NUM_POLLSETS]; |
||||
void *expected_pi = NULL; |
||||
int i; |
||||
|
||||
test_fd_init(fds, NUM_FDS); |
||||
test_pollset_init(pollsets, NUM_POLLSETS); |
||||
|
||||
/*Step 1.
|
||||
* Create three polling islands (This will exercise test case 1 and 2) with |
||||
* the following configuration: |
||||
* polling island 0 = { fds:0,1,2, pollsets:0} |
||||
* polling island 1 = { fds:3,4, pollsets:1} |
||||
* polling island 2 = { fds:5,6,7 pollsets:2} |
||||
* |
||||
*Step 2. |
||||
* Add pollset 3 to polling island 0 (by adding fds 0 and 1 to pollset 3) |
||||
* (This will exercise test cases 3 and 4.1). The configuration becomes: |
||||
* polling island 0 = { fds:0,1,2, pollsets:0,3} <<< pollset 3 added here |
||||
* polling island 1 = { fds:3,4, pollsets:1} |
||||
* polling island 2 = { fds:5,6,7 pollsets:2} |
||||
* |
||||
*Step 3. |
||||
* Merge polling islands 0 and 1 by adding fd 0 to pollset 1 (This will |
||||
* exercise test case 4.2). The configuration becomes: |
||||
* polling island (merged) = {fds: 0,1,2,3,4, pollsets: 0,1,3} |
||||
* polling island 2 = {fds: 5,6,7 pollsets: 2} |
||||
* |
||||
*Step 4. |
||||
* Finally do one more merge by adding fd 3 to pollset 2. |
||||
* polling island (merged) = {fds: 0,1,2,3,4,5,6,7, pollsets: 0,1,2,3} |
||||
*/ |
||||
|
||||
/* == Step 1 == */ |
||||
for (i = 0; i <= 2; i++) { |
||||
grpc_pollset_add_fd(&exec_ctx, pollsets[0].pollset, fds[i].fd); |
||||
grpc_exec_ctx_flush(&exec_ctx); |
||||
} |
||||
|
||||
for (i = 3; i <= 4; i++) { |
||||
grpc_pollset_add_fd(&exec_ctx, pollsets[1].pollset, fds[i].fd); |
||||
grpc_exec_ctx_flush(&exec_ctx); |
||||
} |
||||
|
||||
for (i = 5; i <= 7; i++) { |
||||
grpc_pollset_add_fd(&exec_ctx, pollsets[2].pollset, fds[i].fd); |
||||
grpc_exec_ctx_flush(&exec_ctx); |
||||
} |
||||
|
||||
/* == Step 2 == */ |
||||
for (i = 0; i <= 1; i++) { |
||||
grpc_pollset_add_fd(&exec_ctx, pollsets[3].pollset, fds[i].fd); |
||||
grpc_exec_ctx_flush(&exec_ctx); |
||||
} |
||||
|
||||
/* == Step 3 == */ |
||||
grpc_pollset_add_fd(&exec_ctx, pollsets[1].pollset, fds[0].fd); |
||||
grpc_exec_ctx_flush(&exec_ctx); |
||||
|
||||
/* == Step 4 == */ |
||||
grpc_pollset_add_fd(&exec_ctx, pollsets[2].pollset, fds[3].fd); |
||||
grpc_exec_ctx_flush(&exec_ctx); |
||||
|
||||
/* All polling islands are merged at this point */ |
||||
|
||||
/* Compare Fd:0's polling island with that of all other Fds */ |
||||
expected_pi = grpc_fd_get_polling_island(fds[0].fd); |
||||
for (i = 1; i < NUM_FDS; i++) { |
||||
GPR_ASSERT(grpc_are_polling_islands_equal( |
||||
expected_pi, grpc_fd_get_polling_island(fds[i].fd))); |
||||
} |
||||
|
||||
/* Compare Fd:0's polling island with that of all other pollsets */ |
||||
for (i = 0; i < NUM_POLLSETS; i++) { |
||||
GPR_ASSERT(grpc_are_polling_islands_equal( |
||||
expected_pi, grpc_pollset_get_polling_island(pollsets[i].pollset))); |
||||
} |
||||
|
||||
test_fd_cleanup(&exec_ctx, fds, NUM_FDS); |
||||
test_pollset_cleanup(&exec_ctx, pollsets, NUM_POLLSETS); |
||||
grpc_exec_ctx_finish(&exec_ctx); |
||||
} |
||||
|
||||
int main(int argc, char **argv) { |
||||
const char *poll_strategy = NULL; |
||||
grpc_test_init(argc, argv); |
||||
grpc_iomgr_init(); |
||||
|
||||
poll_strategy = grpc_get_poll_strategy_name(); |
||||
if (poll_strategy != NULL && strcmp(poll_strategy, "epoll") == 0) { |
||||
test_add_fd_to_pollset(); |
||||
} else { |
||||
gpr_log(GPR_INFO, |
||||
"Skipping the test. The test is only relevant for 'epoll' " |
||||
"strategy. and the current strategy is: '%s'", |
||||
poll_strategy); |
||||
} |
||||
grpc_iomgr_shutdown(); |
||||
return 0; |
||||
} |
||||
Loading…
Reference in new issue