X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fcommon%2Ffile-descriptor.hpp;h=b467e2e382d5bc293380ed880b779a2b02bc591b;hb=HEAD;hp=0ddc2b91c8f30a8d689a5be1b9fe26b8b0b412b9;hpb=b37c485170fc29ed99e21a1c9e8a3bb3b24c184b;p=lttng-tools.git

diff --git a/src/common/file-descriptor.hpp b/src/common/file-descriptor.hpp
index 0ddc2b91c..b467e2e38 100644
--- a/src/common/file-descriptor.hpp
+++ b/src/common/file-descriptor.hpp
@@ -5,76 +5,52 @@
  *
  */
 
-#include <common/error.hpp>
-#include <common/format.hpp>
+#ifndef LTTNG_FILE_DESCRIPTOR_HPP
+#define LTTNG_FILE_DESCRIPTOR_HPP
 
-#include <algorithm>
-
-#include <unistd.h>
+#include <cstddef>
 
 namespace lttng {
 
-/*
- * RAII wrapper around a UNIX file descriptor. A file_descriptor's underlying
- * file descriptor.
- */
+/* RAII wrapper around a UNIX file descriptor. */
 class file_descriptor {
 public:
-	file_descriptor()
-	{
-	}
-
-	explicit file_descriptor(int raw_fd) noexcept : _raw_fd{ raw_fd }
-	{
-		LTTNG_ASSERT(_is_valid_fd(_raw_fd));
-	}
+	file_descriptor() noexcept = default;
 
+	explicit file_descriptor(int raw_fd) noexcept;
 	file_descriptor(const file_descriptor&) = delete;
 	file_descriptor& operator=(const file_descriptor&) = delete;
-	file_descriptor& operator=(file_descriptor&& other)
-	{
-		_cleanup();
-		std::swap(_raw_fd, other._raw_fd);
-		return *this;
-	}
 
-	file_descriptor(file_descriptor&& other) noexcept
-	{
-		std::swap(_raw_fd, other._raw_fd);
-	}
+	file_descriptor(file_descriptor&& other) noexcept;
 
-	~file_descriptor()
-	{
-		_cleanup();
-	}
+	file_descriptor& operator=(file_descriptor&& other) noexcept;
 
-	int fd() const noexcept
-	{
-		LTTNG_ASSERT(_is_valid_fd(_raw_fd));
-		return _raw_fd;
-	}
+	~file_descriptor() noexcept;
 
-private:
-	static bool _is_valid_fd(int fd)
-	{
-		return fd >= 0;
-	}
-
-	void _cleanup()
-	{
-		if (!_is_valid_fd(_raw_fd)) {
-			return;
-		}
+	/*
+	 * Read `size` bytes from the underlying file descriptor, assuming
+	 * raw_fd behaves as a blocking device.
+	 *
+	 * Throws an exception if the requested amount of bytes couldn't be read.
+	 */
+	void read(void *buffer, std::size_t size);
+	/*
+	 * Write `size` bytes to the underlying file descriptor, assuming
+	 * raw_fd behaves as a blocking device.
+	 *
+	 * Throws an exception if the requested amount of bytes couldn't be written.
+	 */
+	void write(const void *buffer, std::size_t size);
 
-		const auto ret = ::close(_raw_fd);
+	int fd() const noexcept;
 
-		_raw_fd = -1;
-		if (ret) {
-			PERROR("Failed to close file descriptor: fd=%i", _raw_fd);
-		}
-	}
+protected:
+	void _cleanup() noexcept;
 
+private:
 	int _raw_fd = -1;
 };
 
 } /* namespace lttng */
+
+#endif /* LTTNG_FILE_DESCRIPTOR_HPP */