diff options
Diffstat (limited to 'test/storage/http_error.cpp')
-rw-r--r-- | test/storage/http_error.cpp | 87 |
1 files changed, 50 insertions, 37 deletions
diff --git a/test/storage/http_error.cpp b/test/storage/http_error.cpp index 85bc70e546..00deeb063a 100644 --- a/test/storage/http_error.cpp +++ b/test/storage/http_error.cpp @@ -19,67 +19,80 @@ TEST_F(Storage, HTTPError) { using namespace mbgl; - uv_timer_t statusChange; - uv_timer_init(uv_default_loop(), &statusChange); - uv_timer_start(&statusChange, [](UV_TIMER_PARAMS) { - NetworkStatus::Reachable(); - }, 500, 500); - uv_unref((uv_handle_t *)&statusChange); - DefaultFileSource fs(nullptr); - auto start = uv_hrtime(); + const auto start = uv_hrtime(); Request* req1 = fs.request({ Resource::Unknown, "http://127.0.0.1:3000/temporary-error" }, uv_default_loop(), [&](const Response &res) { - fs.cancel(req1); - const auto duration = double(uv_hrtime() - start) / 1e9; - EXPECT_LT(1, duration) << "Backoff timer didn't wait 1 second"; - EXPECT_GT(1.2, duration) << "Backoff timer fired too late"; - EXPECT_EQ(Response::Successful, res.status); - EXPECT_EQ(false, res.stale); - ASSERT_TRUE(res.data.get()); - EXPECT_EQ("Hello World!", *res.data); - EXPECT_EQ(0, res.expires); - EXPECT_EQ(0, res.modified); - EXPECT_EQ("", res.etag); - EXPECT_EQ("", res.message); - - HTTPTemporaryError.finish(); + static int counter = 0; + switch (counter++) { + case 0: { + const auto duration = double(uv_hrtime() - start) / 1e9; + EXPECT_GT(0.2, duration) << "Initial error request took too long"; + ASSERT_NE(nullptr, res.error); + EXPECT_EQ(Response::Error::Reason::Server, res.error->reason); + EXPECT_EQ("HTTP status code 500", res.error->message); + EXPECT_EQ(false, res.stale); + ASSERT_TRUE(res.data.get()); + EXPECT_EQ("", *res.data); + EXPECT_EQ(0, res.expires); + EXPECT_EQ(0, res.modified); + EXPECT_EQ("", res.etag); + } break; + case 1: { + fs.cancel(req1); + const auto duration = double(uv_hrtime() - start) / 1e9; + EXPECT_LT(0.99, duration) << "Backoff timer didn't wait 1 second"; + EXPECT_GT(1.2, duration) << "Backoff timer fired too late"; + EXPECT_EQ(nullptr, res.error); + EXPECT_EQ(false, res.stale); + ASSERT_TRUE(res.data.get()); + EXPECT_EQ("Hello World!", *res.data); + EXPECT_EQ(0, res.expires); + EXPECT_EQ(0, res.modified); + EXPECT_EQ("", res.etag); + HTTPTemporaryError.finish(); + } break; + } }); Request* req2 = fs.request({ Resource::Unknown, "http://127.0.0.1:3001/" }, uv_default_loop(), [&](const Response &res) { - fs.cancel(req2); + static int counter = 0; + static int wait = 0; const auto duration = double(uv_hrtime() - start) / 1e9; - // 1.5 seconds == 4 retries, with a 500ms timeout (see above). - EXPECT_LT(1.4, duration) << "Resource wasn't retried the correct number of times"; - EXPECT_GT(1.7, duration) << "Resource wasn't retried the correct number of times"; - EXPECT_EQ(Response::Error, res.status); - EXPECT_EQ(false, res.stale); + EXPECT_LT(wait - 0.01, duration) << "Backoff timer didn't wait 1 second"; + EXPECT_GT(wait + 0.2, duration) << "Backoff timer fired too late"; + ASSERT_NE(nullptr, res.error); + EXPECT_EQ(Response::Error::Reason::Connection, res.error->reason); #ifdef MBGL_HTTP_NSURL - EXPECT_TRUE(res.message == - "The operation couldn’t be completed. (NSURLErrorDomain error -1004.)" || - res.message == "Could not connect to the server.") - << "Full message is: \"" << res.message << "\""; + EXPECT_TRUE(res.error->message == + "The operation couldn’t be completed. (NSURLErrorDomain error -1004.)" || + res.error->message == "Could not connect to the server.") + << "Full message is: \"" << res.error->message << "\""; #elif MBGL_HTTP_CURL const std::string prefix { "Couldn't connect to server: " }; - EXPECT_STREQ(prefix.c_str(), res.message.substr(0, prefix.size()).c_str()) << "Full message is: \"" << res.message << "\""; + EXPECT_STREQ(prefix.c_str(), res.error->message.substr(0, prefix.size()).c_str()) << "Full message is: \"" << res.error->message << "\""; #else FAIL(); #endif + EXPECT_EQ(false, res.stale); ASSERT_FALSE(res.data.get()); EXPECT_EQ(0, res.expires); EXPECT_EQ(0, res.modified); EXPECT_EQ("", res.etag); - HTTPConnectionError.finish(); + + if (counter == 2) { + fs.cancel(req2); + HTTPConnectionError.finish(); + } + wait += (1 << counter); + counter++; }); uv_run(uv_default_loop(), UV_RUN_DEFAULT); - uv_timer_stop(&statusChange); - uv_close(reinterpret_cast<uv_handle_t *>(&statusChange), nullptr); - // Run again so that the timer handle can be properly closed. uv_run(uv_default_loop(), UV_RUN_DEFAULT); } |