aboutsummaryrefslogtreecommitdiff
path: root/test/unit/test_network.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'test/unit/test_network.cpp')
-rw-r--r--test/unit/test_network.cpp59
1 files changed, 35 insertions, 24 deletions
diff --git a/test/unit/test_network.cpp b/test/unit/test_network.cpp
index db3e987f..8edb7c8c 100644
--- a/test/unit/test_network.cpp
+++ b/test/unit/test_network.cpp
@@ -275,8 +275,9 @@ static PROJ_NETWORK_HANDLE *open_cbk(PJ_CONTEXT *ctx, const char *url,
auto openEvent =
dynamic_cast<OpenEvent *>(exchange->events[exchange->nextEvent].get());
if (!openEvent) {
- fprintf(stderr, "unexpected call to open(%s, %ld, %ld). "
- "Was expecting a %s event\n",
+ fprintf(stderr,
+ "unexpected call to open(%s, %ld, %ld). "
+ "Was expecting a %s event\n",
url, (long)offset, (long)size_to_read,
exchange->events[exchange->nextEvent]->type.c_str());
exchange->error = true;
@@ -286,8 +287,9 @@ static PROJ_NETWORK_HANDLE *open_cbk(PJ_CONTEXT *ctx, const char *url,
if (openEvent->ctx != ctx || openEvent->url != url ||
openEvent->offset != offset ||
openEvent->size_to_read != size_to_read) {
- fprintf(stderr, "wrong call to open(%s, %ld, %ld). Was expecting "
- "open(%s, %ld, %ld)\n",
+ fprintf(stderr,
+ "wrong call to open(%s, %ld, %ld). Was expecting "
+ "open(%s, %ld, %ld)\n",
url, (long)offset, (long)size_to_read, openEvent->url.c_str(),
(long)openEvent->offset, (long)openEvent->size_to_read);
exchange->error = true;
@@ -319,8 +321,9 @@ static void close_cbk(PJ_CONTEXT *ctx, PROJ_NETWORK_HANDLE *handle,
auto closeEvent =
dynamic_cast<CloseEvent *>(exchange->events[exchange->nextEvent].get());
if (!closeEvent) {
- fprintf(stderr, "unexpected call to close(). "
- "Was expecting a %s event\n",
+ fprintf(stderr,
+ "unexpected call to close(). "
+ "Was expecting a %s event\n",
exchange->events[exchange->nextEvent]->type.c_str());
exchange->error = true;
return;
@@ -354,8 +357,9 @@ static const char *get_header_value_cbk(PJ_CONTEXT *ctx,
auto getHeaderValueEvent = dynamic_cast<GetHeaderValueEvent *>(
exchange->events[exchange->nextEvent].get());
if (!getHeaderValueEvent) {
- fprintf(stderr, "unexpected call to get_header_value(). "
- "Was expecting a %s event\n",
+ fprintf(stderr,
+ "unexpected call to get_header_value(). "
+ "Was expecting a %s event\n",
exchange->events[exchange->nextEvent]->type.c_str());
exchange->error = true;
return nullptr;
@@ -366,8 +370,9 @@ static const char *get_header_value_cbk(PJ_CONTEXT *ctx,
return nullptr;
}
if (getHeaderValueEvent->key != header_name) {
- fprintf(stderr, "wrong call to get_header_value(%s). Was expecting "
- "get_header_value(%s)\n",
+ fprintf(stderr,
+ "wrong call to get_header_value(%s). Was expecting "
+ "get_header_value(%s)\n",
header_name, getHeaderValueEvent->key.c_str());
exchange->error = true;
return nullptr;
@@ -397,8 +402,9 @@ static size_t read_range_cbk(PJ_CONTEXT *ctx, PROJ_NETWORK_HANDLE *handle,
auto readRangeEvent = dynamic_cast<ReadRangeEvent *>(
exchange->events[exchange->nextEvent].get());
if (!readRangeEvent) {
- fprintf(stderr, "unexpected call to read_range(). "
- "Was expecting a %s event\n",
+ fprintf(stderr,
+ "unexpected call to read_range(). "
+ "Was expecting a %s event\n",
exchange->events[exchange->nextEvent]->type.c_str());
exchange->error = true;
return 0;
@@ -410,8 +416,9 @@ static size_t read_range_cbk(PJ_CONTEXT *ctx, PROJ_NETWORK_HANDLE *handle,
}
if (readRangeEvent->ctx != ctx || readRangeEvent->offset != offset ||
readRangeEvent->size_to_read != size_to_read) {
- fprintf(stderr, "wrong call to read_range(%ld, %ld). Was expecting "
- "read_range(%ld, %ld)\n",
+ fprintf(stderr,
+ "wrong call to read_range(%ld, %ld). Was expecting "
+ "read_range(%ld, %ld)\n",
(long)offset, (long)size_to_read, (long)readRangeEvent->offset,
(long)readRangeEvent->size_to_read);
exchange->error = true;
@@ -1308,9 +1315,10 @@ TEST(networking, cache_basic) {
SQLITE_OPEN_READONLY, nullptr);
ASSERT_NE(hDB, nullptr);
sqlite3_stmt *hStmt = nullptr;
- sqlite3_prepare_v2(hDB, "SELECT url, offset FROM chunks WHERE id = ("
- "SELECT chunk_id FROM linked_chunks WHERE id = ("
- "SELECT head FROM linked_chunks_head_tail))",
+ sqlite3_prepare_v2(hDB,
+ "SELECT url, offset FROM chunks WHERE id = ("
+ "SELECT chunk_id FROM linked_chunks WHERE id = ("
+ "SELECT head FROM linked_chunks_head_tail))",
-1, &hStmt, nullptr);
ASSERT_NE(hStmt, nullptr);
ASSERT_EQ(sqlite3_step(hStmt), SQLITE_ROW);
@@ -1429,9 +1437,10 @@ TEST(networking, cache_saturation) {
ASSERT_NE(hDB, nullptr);
sqlite3_stmt *hStmt = nullptr;
- sqlite3_prepare_v2(hDB, "SELECT COUNT(*) FROM chunk_data UNION ALL "
- "SELECT COUNT(*) FROM chunks UNION ALL "
- "SELECT COUNT(*) FROM linked_chunks",
+ sqlite3_prepare_v2(hDB,
+ "SELECT COUNT(*) FROM chunk_data UNION ALL "
+ "SELECT COUNT(*) FROM chunks UNION ALL "
+ "SELECT COUNT(*) FROM linked_chunks",
-1, &hStmt, nullptr);
ASSERT_NE(hStmt, nullptr);
ASSERT_EQ(sqlite3_step(hStmt), SQLITE_ROW);
@@ -1487,8 +1496,9 @@ TEST(networking, cache_ttl) {
// Force lastChecked to the Epoch so that data is expired.
sqlite3_stmt *hStmt = nullptr;
- sqlite3_prepare_v2(hDB, "UPDATE properties SET lastChecked = 0, "
- "lastModified = 'foo', etag = 'bar'",
+ sqlite3_prepare_v2(hDB,
+ "UPDATE properties SET lastChecked = 0, "
+ "lastModified = 'foo', etag = 'bar'",
-1, &hStmt, nullptr);
ASSERT_NE(hStmt, nullptr);
ASSERT_EQ(sqlite3_step(hStmt), SQLITE_DONE);
@@ -1724,8 +1734,9 @@ TEST(networking, download_whole_files) {
// Now invalid lastModified. This should trigger a new download
sqlite3_prepare_v2(
- hDB, "UPDATE downloaded_file_properties SET lastChecked = 0, "
- "lastModified = 'foo'",
+ hDB,
+ "UPDATE downloaded_file_properties SET lastChecked = 0, "
+ "lastModified = 'foo'",
-1, &hStmt, nullptr);
ASSERT_NE(hStmt, nullptr);
ASSERT_EQ(sqlite3_step(hStmt), SQLITE_DONE);