/// pwrite operation. This is usefull for code that can mostly stream out data,
/// but needs to patch in a header that needs to know the output size.
class raw_pwrite_stream : public raw_ostream {
+ virtual void pwrite_impl(const char *Ptr, size_t Size, uint64_t Offset) = 0;
+
public:
explicit raw_pwrite_stream(bool Unbuffered = false)
: raw_ostream(Unbuffered) {}
- virtual void pwrite(const char *Ptr, size_t Size, uint64_t Offset) = 0;
+ void pwrite(const char *Ptr, size_t Size, uint64_t Offset) {
+ assert(Size + Offset <= tell() && "We don't support extending the stream");
+ pwrite_impl(Ptr, Size, Offset);
+ }
};
//===----------------------------------------------------------------------===//
/// See raw_ostream::write_impl.
void write_impl(const char *Ptr, size_t Size) override;
+ void pwrite_impl(const char *Ptr, size_t Size, uint64_t Offset) override;
+
/// Return the current position within the stream, not counting the bytes
/// currently in the buffer.
uint64_t current_pos() const override { return pos; }
/// to the offset specified from the beginning of the file.
uint64_t seek(uint64_t off);
- void pwrite(const char *Ptr, size_t Size, uint64_t Offset) override;
-
/// Set the stream to attempt to use atomic writes for individual output
/// routines where possible.
///
/// See raw_ostream::write_impl.
void write_impl(const char *Ptr, size_t Size) override;
+ void pwrite_impl(const char *Ptr, size_t Size, uint64_t Offset) override;
+
/// Return the current position within the stream, not counting the bytes
/// currently in the buffer.
uint64_t current_pos() const override;
explicit raw_svector_ostream(SmallVectorImpl<char> &O);
~raw_svector_ostream() override;
- void pwrite(const char *Ptr, size_t Size, uint64_t Offset) override;
/// This is called when the SmallVector we're appending to is changed outside
/// of the raw_svector_ostream's control. It is only safe to do this if the
class raw_null_ostream : public raw_pwrite_stream {
/// See raw_ostream::write_impl.
void write_impl(const char *Ptr, size_t size) override;
+ void pwrite_impl(const char *Ptr, size_t Size, uint64_t Offset) override;
/// Return the current position within the stream, not counting the bytes
/// currently in the buffer.
public:
explicit raw_null_ostream() {}
~raw_null_ostream() override;
- void pwrite(const char *Ptr, size_t Size, uint64_t Offset) override;
};
class buffer_ostream : public raw_svector_ostream {
return pos;
}
-void raw_fd_ostream::pwrite(const char *Ptr, size_t Size, uint64_t Offset) {
+void raw_fd_ostream::pwrite_impl(const char *Ptr, size_t Size,
+ uint64_t Offset) {
uint64_t Pos = tell();
seek(Offset);
write(Ptr, Size);
flush();
}
-void raw_svector_ostream::pwrite(const char *Ptr, size_t Size,
- uint64_t Offset) {
+void raw_svector_ostream::pwrite_impl(const char *Ptr, size_t Size,
+ uint64_t Offset) {
flush();
-
- uint64_t End = Offset + Size;
- if (End > OS.size())
- OS.resize(End);
-
memcpy(OS.begin() + Offset, Ptr, Size);
}
return 0;
}
-void raw_null_ostream::pwrite(const char *Ptr, size_t Size, uint64_t Offset) {}
+void raw_null_ostream::pwrite_impl(const char *Ptr, size_t Size,
+ uint64_t Offset) {}
namespace {
TEST(raw_pwrite_ostreamTest, TestSVector) {
- SmallString<64> Buffer;
+ SmallVector<char, 0> Buffer;
raw_svector_ostream OS(Buffer);
+ OS << "abcd";
StringRef Test = "test";
OS.pwrite(Test.data(), Test.size(), 0);
EXPECT_EQ(Test, OS.str());
+
+#ifdef GTEST_HAS_DEATH_TEST
+#ifndef NDEBUG
+ EXPECT_DEATH(OS.pwrite("12345", 5, 0),
+ "We don't support extending the stream");
+#endif
+#endif
}
}