1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
|
#include "catch.hpp"
#include "utils.hpp"
#include <osmium/io/compression.hpp>
#include <string>
#include <system_error>
TEST_CASE("Invalid file descriptor of uncompressed file") {
osmium::io::NoDecompressor decomp{-1};
REQUIRE_THROWS_AS(decomp.read(), std::system_error);
}
TEST_CASE("Non-open file descriptor of uncompressed file") {
// 12345 is just a random file descriptor that should not be open
osmium::io::NoDecompressor decomp{12345};
REQUIRE_THROWS_AS(decomp.read(), std::system_error);
}
TEST_CASE("Empty uncompressed file") {
const int count = count_fds();
const std::string input_file = with_data_dir("t/io/empty_file");
const int fd = osmium::io::detail::open_for_reading(input_file);
REQUIRE(fd > 0);
osmium::io::NoDecompressor decomp{fd};
REQUIRE(decomp.read().empty());
decomp.close();
REQUIRE(count == count_fds());
}
TEST_CASE("Read uncompressed file") {
const int count = count_fds();
const std::string input_file = with_data_dir("t/io/data.txt");
const int fd = osmium::io::detail::open_for_reading(input_file);
REQUIRE(fd > 0);
size_t size = 0;
std::string all;
{
osmium::io::NoDecompressor decomp{fd};
for (std::string data = decomp.read(); !data.empty(); data = decomp.read()) {
size += data.size();
all += data;
}
decomp.close();
}
REQUIRE(size >= 9);
all.resize(8);
REQUIRE("TESTDATA" == all);
REQUIRE(count == count_fds());
}
TEST_CASE("Read uncompressed file without explicit close") {
const int count = count_fds();
const std::string input_file = with_data_dir("t/io/data.txt");
const int fd = osmium::io::detail::open_for_reading(input_file);
REQUIRE(fd > 0);
size_t size = 0;
std::string all;
{
osmium::io::NoDecompressor decomp{fd};
for (std::string data = decomp.read(); !data.empty(); data = decomp.read()) {
size += data.size();
all += data;
}
}
REQUIRE(size >= 9);
all.resize(8);
REQUIRE("TESTDATA" == all);
REQUIRE(count == count_fds());
}
TEST_CASE("Compressor: Invalid file descriptor for uncompressed file") {
osmium::io::NoCompressor comp{-1, osmium::io::fsync::yes};
REQUIRE_THROWS_AS(comp.write("foo"), std::system_error);
}
TEST_CASE("Compressor: Non-open file descriptor for uncompressed file") {
// 12345 is just a random file descriptor that should not be open
osmium::io::NoCompressor comp{12345, osmium::io::fsync::yes};
REQUIRE_THROWS_AS(comp.write("foo"), std::system_error);
}
TEST_CASE("Write uncompressed file with explicit close") {
const int count = count_fds();
const std::string output_file = "test_uncompressed_out.txt";
const int fd = osmium::io::detail::open_for_writing(output_file, osmium::io::overwrite::allow);
REQUIRE(fd > 0);
osmium::io::NoCompressor comp{fd, osmium::io::fsync::yes};
comp.write("foo");
comp.close();
REQUIRE(count == count_fds());
REQUIRE(osmium::file_size(output_file) == 3);
}
TEST_CASE("Write uncompressed file with implicit close") {
const int count = count_fds();
const std::string output_file = "test_uncompressed_out.txt";
const int fd = osmium::io::detail::open_for_writing(output_file, osmium::io::overwrite::allow);
REQUIRE(fd > 0);
{
osmium::io::NoCompressor comp{fd, osmium::io::fsync::yes};
comp.write("foo");
}
REQUIRE(count == count_fds());
REQUIRE(osmium::file_size(output_file) == 3);
}
|
