summaryrefslogtreecommitdiff
path: root/test/storage/http_error.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'test/storage/http_error.cpp')
-rw-r--r--test/storage/http_error.cpp87
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);
}