summaryrefslogtreecommitdiffstats
path: root/document/src/tests/documenttestcase.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'document/src/tests/documenttestcase.cpp')
-rw-r--r--document/src/tests/documenttestcase.cpp38
1 files changed, 27 insertions, 11 deletions
diff --git a/document/src/tests/documenttestcase.cpp b/document/src/tests/documenttestcase.cpp
index 475cf64128e..6ea15c6a581 100644
--- a/document/src/tests/documenttestcase.cpp
+++ b/document/src/tests/documenttestcase.cpp
@@ -597,8 +597,9 @@ void DocumentTest::testReadSerializedFile()
size_t len = lseek(fd,0,SEEK_END);
ByteBuffer buf(len);
lseek(fd,0,SEEK_SET);
- read(fd, buf.getBuffer(), len);
-
+ if (read(fd, buf.getBuffer(), len) != len) {
+ throw vespalib::Exception("read failed");
+ }
close(fd);
Document doc(repo, buf);
@@ -630,8 +631,9 @@ void DocumentTest::testReadSerializedFileCompressed()
int len = lseek(fd,0,SEEK_END);
ByteBuffer buf(len);
lseek(fd,0,SEEK_SET);
- read(fd, buf.getBuffer(), len);
-
+ if (read(fd, buf.getBuffer(), len) != len) {
+ throw vespalib::Exception("read failed");
+ }
close(fd);
Document doc(repo, buf);
@@ -782,7 +784,9 @@ void DocumentTest::testReadSerializedAllVersions()
int len = lseek(fd,0,SEEK_END);
ByteBuffer buf(len);
lseek(fd,0,SEEK_SET);
- read(fd, buf.getBuffer(), len);
+ if (read(fd, buf.getBuffer(), len) != len) {
+ throw vespalib::Exception("read failed");
+ }
close(fd);
Document doc(repo, buf);
@@ -905,21 +909,27 @@ void DocumentTest::testGenerateSerializedFile()
#define SERIALIZED_DIR "../../test/document/"
int fd = open(SERIALIZED_DIR "/serializecpp.dat",
O_WRONLY | O_TRUNC | O_CREAT, 0644);
- write(fd, buf->getBuffer(), buf->getPos());
+ if (write(fd, buf->getBuffer(), buf->getPos()) != buf->getPos()) {
+ throw vespalib::Exception("write failed");
+ }
close(fd);
ByteBuffer hBuf(getSerializedSizeHeader(doc));
doc.serializeHeader(hBuf);
fd = open(SERIALIZED_DIR "/serializecppsplit_header.dat",
O_WRONLY | O_TRUNC | O_CREAT, 0644);
- write(fd, hBuf.getBuffer(), hBuf.getPos());
+ if (write(fd, hBuf.getBuffer(), hBuf.getPos()) != hBuf.getPos()) {
+ throw vespalib::Exception("write failed");
+ }
close(fd);
ByteBuffer bBuf(getSerializedSizeBody(doc));
doc.serializeBody(bBuf);
fd = open(SERIALIZED_DIR "/serializecppsplit_body.dat",
O_WRONLY | O_TRUNC | O_CREAT, 0644);
- write(fd, bBuf.getBuffer(), bBuf.getPos());
+ if (write(fd, bBuf.getBuffer(), bBuf.getPos()) != bBuf.getPos()) {
+ throw vespalib::Exception("write failed");
+ }
close(fd);
@@ -933,7 +943,9 @@ void DocumentTest::testGenerateSerializedFile()
fd = open(SERIALIZED_DIR "/serializecpp-lz4-level9.dat",
O_WRONLY | O_TRUNC | O_CREAT, 0644);
- write(fd, lz4buf.getBufferAtPos(), lz4buf.getRemaining());
+ if (write(fd, lz4buf.getBufferAtPos(), lz4buf.getRemaining()) != lz4buf.getRemaining()) {
+ throw vespalib::Exception("write failed");
+ }
close(fd);
}
void DocumentTest::testGetURIFromSerialized()
@@ -1300,7 +1312,9 @@ DocumentTest::testUnknownEntries()
int len = lseek(fd,0,SEEK_END);
ByteBuffer buf(len);
lseek(fd,0,SEEK_SET);
- read(fd, buf.getBuffer(), len);
+ if (read(fd, buf.getBuffer(), len) != len) {
+ throw vespalib::Exception("read failed");
+ }
close(fd);
DocumenttypesConfigBuilderHelper builder;
@@ -1347,7 +1361,9 @@ void DocumentTest::testAnnotationDeserialization()
int len = lseek(fd,0,SEEK_END);
ByteBuffer buf(len);
lseek(fd,0,SEEK_SET);
- read(fd, buf.getBuffer(), len);
+ if (read(fd, buf.getBuffer(), len) != len) {
+ throw vespalib::Exception("read failed");
+ }
close(fd);
Document doc(repo, buf);