mirror of https://github.com/grpc/grpc.git
Craig Tiller
8 years ago
parent
565d4c1e88
commit
c0df1c0f9a
57 changed files with 662 additions and 693 deletions
@ -0,0 +1,34 @@ |
||||
# Copyright 2016 gRPC authors. |
||||
# |
||||
# Licensed under the Apache License, Version 2.0 (the "License"); |
||||
# you may not use this file except in compliance with the License. |
||||
# You may obtain a copy of the License at |
||||
# |
||||
# http://www.apache.org/licenses/LICENSE-2.0 |
||||
# |
||||
# Unless required by applicable law or agreed to in writing, software |
||||
# distributed under the License is distributed on an "AS IS" BASIS, |
||||
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
# See the License for the specific language governing permissions and |
||||
# limitations under the License. |
||||
|
||||
load("//bazel:grpc_build_system.bzl", "grpc_cc_library", "grpc_cc_test", "grpc_cc_binary") |
||||
|
||||
licenses(["notice"]) # Apache v2 |
||||
|
||||
package( |
||||
features = [ |
||||
"-layering_check", |
||||
"-parse_headers", |
||||
], |
||||
) |
||||
|
||||
grpc_cc_test( |
||||
name = "backoff_test", |
||||
srcs = ["backoff_test.c"], |
||||
language = "C", |
||||
deps = [ |
||||
"//:gpr", |
||||
"//test/core/util:gpr_test_util", |
||||
], |
||||
) |
||||
@ -0,0 +1,147 @@ |
||||
/*
|
||||
* |
||||
* Copyright 2016 gRPC authors. |
||||
* |
||||
* Licensed under the Apache License, Version 2.0 (the "License"); |
||||
* you may not use this file except in compliance with the License. |
||||
* You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software |
||||
* distributed under the License is distributed on an "AS IS" BASIS, |
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
* See the License for the specific language governing permissions and |
||||
* limitations under the License. |
||||
* |
||||
*/ |
||||
|
||||
#include "src/core/lib/backoff/backoff.h" |
||||
|
||||
#include <grpc/support/log.h> |
||||
|
||||
#include "test/core/util/test_config.h" |
||||
|
||||
static void test_constant_backoff(void) { |
||||
grpc_backoff backoff; |
||||
grpc_backoff_init(&backoff, 200 /* initial timeout */, 1.0 /* multiplier */, |
||||
0.0 /* jitter */, 100 /* min timeout */, |
||||
1000 /* max timeout */); |
||||
|
||||
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT; |
||||
grpc_millis next = grpc_backoff_begin(&exec_ctx, &backoff); |
||||
GPR_ASSERT(next - grpc_exec_ctx_now(&exec_ctx) == 200); |
||||
for (int i = 0; i < 10000; i++) { |
||||
next = grpc_backoff_step(&exec_ctx, &backoff); |
||||
GPR_ASSERT(next - grpc_exec_ctx_now(&exec_ctx) == 200); |
||||
exec_ctx.now = next; |
||||
} |
||||
grpc_exec_ctx_finish(&exec_ctx); |
||||
} |
||||
|
||||
static void test_min_connect(void) { |
||||
grpc_backoff backoff; |
||||
grpc_backoff_init(&backoff, 100 /* initial timeout */, 1.0 /* multiplier */, |
||||
0.0 /* jitter */, 200 /* min timeout */, |
||||
1000 /* max timeout */); |
||||
|
||||
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT; |
||||
grpc_millis next = grpc_backoff_begin(&exec_ctx, &backoff); |
||||
GPR_ASSERT(next - grpc_exec_ctx_now(&exec_ctx) == 200); |
||||
grpc_exec_ctx_finish(&exec_ctx); |
||||
} |
||||
|
||||
static void test_no_jitter_backoff(void) { |
||||
grpc_backoff backoff; |
||||
grpc_backoff_init(&backoff, 2 /* initial timeout */, 2.0 /* multiplier */, |
||||
0.0 /* jitter */, 1 /* min timeout */, |
||||
513 /* max timeout */); |
||||
// x_1 = 2
|
||||
// x_n = 2**i + x_{i-1} ( = 2**(n+1) - 2 )
|
||||
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT; |
||||
grpc_millis next = grpc_backoff_begin(&exec_ctx, &backoff); |
||||
GPR_ASSERT(next - grpc_exec_ctx_now(&exec_ctx) == 2); |
||||
exec_ctx.now = next; |
||||
next = grpc_backoff_step(&exec_ctx, &backoff); |
||||
GPR_ASSERT(next - grpc_exec_ctx_now(&exec_ctx) == 6); |
||||
exec_ctx.now = next; |
||||
next = grpc_backoff_step(&exec_ctx, &backoff); |
||||
GPR_ASSERT(next - grpc_exec_ctx_now(&exec_ctx) == 14); |
||||
exec_ctx.now = next; |
||||
next = grpc_backoff_step(&exec_ctx, &backoff); |
||||
GPR_ASSERT(next - grpc_exec_ctx_now(&exec_ctx) == 30); |
||||
exec_ctx.now = next; |
||||
next = grpc_backoff_step(&exec_ctx, &backoff); |
||||
GPR_ASSERT(next - grpc_exec_ctx_now(&exec_ctx) == 62); |
||||
exec_ctx.now = next; |
||||
next = grpc_backoff_step(&exec_ctx, &backoff); |
||||
GPR_ASSERT(next - grpc_exec_ctx_now(&exec_ctx) == 126); |
||||
exec_ctx.now = next; |
||||
next = grpc_backoff_step(&exec_ctx, &backoff); |
||||
GPR_ASSERT(next - grpc_exec_ctx_now(&exec_ctx) == 254); |
||||
exec_ctx.now = next; |
||||
next = grpc_backoff_step(&exec_ctx, &backoff); |
||||
GPR_ASSERT(next - grpc_exec_ctx_now(&exec_ctx) == 510); |
||||
exec_ctx.now = next; |
||||
next = grpc_backoff_step(&exec_ctx, &backoff); |
||||
GPR_ASSERT(next - grpc_exec_ctx_now(&exec_ctx) == 1022); |
||||
exec_ctx.now = next; |
||||
next = grpc_backoff_step(&exec_ctx, &backoff); |
||||
// Hit the maximum timeout. From this point onwards, retries will increase
|
||||
// only by max timeout.
|
||||
GPR_ASSERT(next - grpc_exec_ctx_now(&exec_ctx) == 1535); |
||||
exec_ctx.now = next; |
||||
next = grpc_backoff_step(&exec_ctx, &backoff); |
||||
GPR_ASSERT(next - grpc_exec_ctx_now(&exec_ctx) == 2048); |
||||
exec_ctx.now = next; |
||||
next = grpc_backoff_step(&exec_ctx, &backoff); |
||||
GPR_ASSERT(next - grpc_exec_ctx_now(&exec_ctx) == 2561); |
||||
grpc_exec_ctx_finish(&exec_ctx); |
||||
} |
||||
|
||||
static void test_jitter_backoff(void) { |
||||
const int64_t initial_timeout = 500; |
||||
const double jitter = 0.1; |
||||
grpc_backoff backoff; |
||||
grpc_backoff_init(&backoff, initial_timeout, 1.0 /* multiplier */, jitter, |
||||
100 /* min timeout */, 1000 /* max timeout */); |
||||
|
||||
backoff.rng_state = 0; // force consistent PRNG
|
||||
|
||||
grpc_exec_ctx exec_ctx = GRPC_EXEC_CTX_INIT; |
||||
grpc_millis next = grpc_backoff_begin(&exec_ctx, &backoff); |
||||
GPR_ASSERT(next - grpc_exec_ctx_now(&exec_ctx) == 500); |
||||
|
||||
int64_t expected_next_lower_bound = |
||||
(int64_t)((double)initial_timeout * (1 - jitter)); |
||||
int64_t expected_next_upper_bound = |
||||
(int64_t)((double)initial_timeout * (1 + jitter)); |
||||
|
||||
for (int i = 0; i < 10000; i++) { |
||||
next = grpc_backoff_step(&exec_ctx, &backoff); |
||||
|
||||
// next-now must be within (jitter*100)% of the previous timeout.
|
||||
const int64_t timeout_millis = next - grpc_exec_ctx_now(&exec_ctx); |
||||
GPR_ASSERT(timeout_millis >= expected_next_lower_bound); |
||||
GPR_ASSERT(timeout_millis <= expected_next_upper_bound); |
||||
|
||||
expected_next_lower_bound = |
||||
(int64_t)((double)timeout_millis * (1 - jitter)); |
||||
expected_next_upper_bound = |
||||
(int64_t)((double)timeout_millis * (1 + jitter)); |
||||
exec_ctx.now = next; |
||||
} |
||||
grpc_exec_ctx_finish(&exec_ctx); |
||||
} |
||||
|
||||
int main(int argc, char **argv) { |
||||
grpc_test_init(argc, argv); |
||||
gpr_time_init(); |
||||
|
||||
test_constant_backoff(); |
||||
test_min_connect(); |
||||
test_no_jitter_backoff(); |
||||
test_jitter_backoff(); |
||||
|
||||
return 0; |
||||
} |
||||
@ -1,143 +0,0 @@ |
||||
/*
|
||||
* |
||||
* Copyright 2016 gRPC authors. |
||||
* |
||||
* Licensed under the Apache License, Version 2.0 (the "License"); |
||||
* you may not use this file except in compliance with the License. |
||||
* You may obtain a copy of the License at |
||||
* |
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
* |
||||
* Unless required by applicable law or agreed to in writing, software |
||||
* distributed under the License is distributed on an "AS IS" BASIS, |
||||
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
* See the License for the specific language governing permissions and |
||||
* limitations under the License. |
||||
* |
||||
*/ |
||||
|
||||
#include "src/core/lib/support/backoff.h" |
||||
|
||||
#include <grpc/support/log.h> |
||||
|
||||
#include "test/core/util/test_config.h" |
||||
|
||||
static void test_constant_backoff(void) { |
||||
gpr_backoff backoff; |
||||
gpr_backoff_init(&backoff, 200 /* initial timeout */, 1.0 /* multiplier */, |
||||
0.0 /* jitter */, 100 /* min timeout */, |
||||
1000 /* max timeout */); |
||||
|
||||
gpr_timespec now = gpr_time_0(GPR_TIMESPAN); |
||||
gpr_timespec next = gpr_backoff_begin(&backoff, now); |
||||
GPR_ASSERT(gpr_time_to_millis(gpr_time_sub(next, now)) == 200); |
||||
for (int i = 0; i < 10000; i++) { |
||||
next = gpr_backoff_step(&backoff, now); |
||||
GPR_ASSERT(gpr_time_to_millis(gpr_time_sub(next, now)) == 200); |
||||
now = next; |
||||
} |
||||
} |
||||
|
||||
static void test_min_connect(void) { |
||||
gpr_backoff backoff; |
||||
gpr_backoff_init(&backoff, 100 /* initial timeout */, 1.0 /* multiplier */, |
||||
0.0 /* jitter */, 200 /* min timeout */, |
||||
1000 /* max timeout */); |
||||
|
||||
gpr_timespec now = gpr_time_0(GPR_TIMESPAN); |
||||
gpr_timespec next = gpr_backoff_begin(&backoff, now); |
||||
GPR_ASSERT(gpr_time_to_millis(gpr_time_sub(next, now)) == 200); |
||||
} |
||||
|
||||
static void test_no_jitter_backoff(void) { |
||||
gpr_backoff backoff; |
||||
gpr_backoff_init(&backoff, 2 /* initial timeout */, 2.0 /* multiplier */, |
||||
0.0 /* jitter */, 1 /* min timeout */, |
||||
513 /* max timeout */); |
||||
// x_1 = 2
|
||||
// x_n = 2**i + x_{i-1} ( = 2**(n+1) - 2 )
|
||||
gpr_timespec now = gpr_time_0(GPR_TIMESPAN); |
||||
gpr_timespec next = gpr_backoff_begin(&backoff, now); |
||||
GPR_ASSERT(gpr_time_cmp(gpr_time_from_millis(2, GPR_TIMESPAN), next) == 0); |
||||
now = next; |
||||
next = gpr_backoff_step(&backoff, now); |
||||
GPR_ASSERT(gpr_time_cmp(gpr_time_from_millis(6, GPR_TIMESPAN), next) == 0); |
||||
now = next; |
||||
next = gpr_backoff_step(&backoff, now); |
||||
GPR_ASSERT(gpr_time_cmp(gpr_time_from_millis(14, GPR_TIMESPAN), next) == 0); |
||||
now = next; |
||||
next = gpr_backoff_step(&backoff, now); |
||||
GPR_ASSERT(gpr_time_cmp(gpr_time_from_millis(30, GPR_TIMESPAN), next) == 0); |
||||
now = next; |
||||
next = gpr_backoff_step(&backoff, now); |
||||
GPR_ASSERT(gpr_time_cmp(gpr_time_from_millis(62, GPR_TIMESPAN), next) == 0); |
||||
now = next; |
||||
next = gpr_backoff_step(&backoff, now); |
||||
GPR_ASSERT(gpr_time_cmp(gpr_time_from_millis(126, GPR_TIMESPAN), next) == 0); |
||||
now = next; |
||||
next = gpr_backoff_step(&backoff, now); |
||||
GPR_ASSERT(gpr_time_cmp(gpr_time_from_millis(254, GPR_TIMESPAN), next) == 0); |
||||
now = next; |
||||
next = gpr_backoff_step(&backoff, now); |
||||
GPR_ASSERT(gpr_time_cmp(gpr_time_from_millis(510, GPR_TIMESPAN), next) == 0); |
||||
now = next; |
||||
next = gpr_backoff_step(&backoff, now); |
||||
GPR_ASSERT(gpr_time_cmp(gpr_time_from_millis(1022, GPR_TIMESPAN), next) == 0); |
||||
now = next; |
||||
next = gpr_backoff_step(&backoff, now); |
||||
// Hit the maximum timeout. From this point onwards, retries will increase
|
||||
// only by max timeout.
|
||||
GPR_ASSERT(gpr_time_cmp(gpr_time_from_millis(1535, GPR_TIMESPAN), next) == 0); |
||||
now = next; |
||||
next = gpr_backoff_step(&backoff, now); |
||||
GPR_ASSERT(gpr_time_cmp(gpr_time_from_millis(2048, GPR_TIMESPAN), next) == 0); |
||||
now = next; |
||||
next = gpr_backoff_step(&backoff, now); |
||||
GPR_ASSERT(gpr_time_cmp(gpr_time_from_millis(2561, GPR_TIMESPAN), next) == 0); |
||||
} |
||||
|
||||
static void test_jitter_backoff(void) { |
||||
const int64_t initial_timeout = 500; |
||||
const double jitter = 0.1; |
||||
gpr_backoff backoff; |
||||
gpr_backoff_init(&backoff, initial_timeout, 1.0 /* multiplier */, jitter, |
||||
100 /* min timeout */, 1000 /* max timeout */); |
||||
|
||||
backoff.rng_state = 0; // force consistent PRNG
|
||||
|
||||
gpr_timespec now = gpr_time_0(GPR_TIMESPAN); |
||||
gpr_timespec next = gpr_backoff_begin(&backoff, now); |
||||
GPR_ASSERT(gpr_time_to_millis(gpr_time_sub(next, now)) == 500); |
||||
|
||||
int64_t expected_next_lower_bound = |
||||
(int64_t)((double)initial_timeout * (1 - jitter)); |
||||
int64_t expected_next_upper_bound = |
||||
(int64_t)((double)initial_timeout * (1 + jitter)); |
||||
|
||||
for (int i = 0; i < 10000; i++) { |
||||
next = gpr_backoff_step(&backoff, now); |
||||
|
||||
// next-now must be within (jitter*100)% of the previous timeout.
|
||||
const int64_t timeout_millis = gpr_time_to_millis(gpr_time_sub(next, now)); |
||||
GPR_ASSERT(timeout_millis >= expected_next_lower_bound); |
||||
GPR_ASSERT(timeout_millis <= expected_next_upper_bound); |
||||
|
||||
expected_next_lower_bound = |
||||
(int64_t)((double)timeout_millis * (1 - jitter)); |
||||
expected_next_upper_bound = |
||||
(int64_t)((double)timeout_millis * (1 + jitter)); |
||||
now = next; |
||||
} |
||||
} |
||||
|
||||
int main(int argc, char **argv) { |
||||
grpc_test_init(argc, argv); |
||||
gpr_time_init(); |
||||
|
||||
test_constant_backoff(); |
||||
test_min_connect(); |
||||
test_no_jitter_backoff(); |
||||
test_jitter_backoff(); |
||||
|
||||
return 0; |
||||
} |
||||
@ -1,20 +1,20 @@ |
||||
<?xml version="1.0" encoding="utf-8"?> |
||||
<Project ToolsVersion="4.0" xmlns="http://schemas.microsoft.com/developer/msbuild/2003"> |
||||
<ItemGroup> |
||||
<ClCompile Include="$(SolutionDir)\..\test\core\support\backoff_test.c"> |
||||
<Filter>test\core\support</Filter> |
||||
<ClCompile Include="$(SolutionDir)\..\test\core\backoff\backoff_test.c"> |
||||
<Filter>test\core\backoff</Filter> |
||||
</ClCompile> |
||||
</ItemGroup> |
||||
|
||||
<ItemGroup> |
||||
<Filter Include="test"> |
||||
<UniqueIdentifier>{4b7f1d25-d344-0bcb-63d8-2ba959874ea8}</UniqueIdentifier> |
||||
<UniqueIdentifier>{05e21e2a-bc8e-8c99-d00c-486e055f3b4a}</UniqueIdentifier> |
||||
</Filter> |
||||
<Filter Include="test\core"> |
||||
<UniqueIdentifier>{2bd2fba5-8799-2c78-469f-ec3ba6b01da8}</UniqueIdentifier> |
||||
<UniqueIdentifier>{42a371ec-543d-205f-0fbc-7ba3d2b2deca}</UniqueIdentifier> |
||||
</Filter> |
||||
<Filter Include="test\core\support"> |
||||
<UniqueIdentifier>{2ef0cfa7-fe3d-2b82-7d0e-f9e293e8f98c}</UniqueIdentifier> |
||||
<Filter Include="test\core\backoff"> |
||||
<UniqueIdentifier>{467ad11c-0245-020b-4558-5b324ac725be}</UniqueIdentifier> |
||||
</Filter> |
||||
</ItemGroup> |
||||
</Project> |
||||
Loading…
Reference in new issue