diff options
Diffstat (limited to 'document/src/tests/documenttestcase.cpp')
-rw-r--r-- | document/src/tests/documenttestcase.cpp | 38 |
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); |