adding iris benchmark

[c11concurrency-benchmarks.git] / iris / src / file_writer.cpp

diff --git a/iris/src/file_writer.cpp b/iris/src/file_writer.cpp
new file mode 100644 (file)
index 0000000..b322d5c
--- /dev/null
+++ b/iris/src/file_writer.cpp
@@ -0,0 +1,43 @@
+#include <file_writer.h>
+#include <errno.h>
+#include <string.h>
+#include <unistd.h>
+
+
+using namespace iris;
+
+file_writer::file_writer(const char * filename): stream_writer(nullptr) {
+    FILE *fp = fopen(filename, "a");
+    if (fp == nullptr) {
+        std::string error_string = "[iris] failed to open log file <";
+        error_string += filename;
+        error_string += ">, reason: ";
+        error_string += strerror(errno);
+        throw error_string;
+    }
+    m_stream = fp;
+    m_fd = fileno(m_stream);
+}
+
+file_writer::~file_writer() {
+    if (m_stream == nullptr)
+        return;
+    fclose(m_stream);
+    m_stream = nullptr;
+    m_fd = -1;
+}
+
+void file_writer::write(const char * buffer, size_t len) {
+    size_t offset = 0;
+    while (len) {
+        size_t written = ::write(m_fd, buffer + offset, len);
+        if (written <= 0) {
+            if (errno == EINTR)
+                continue;
+            fprintf(stderr, "[iris] error, should write %lu byts, only %lu bytes written, reason: %s.\n", len, written, strerror(errno));
+            break;
+        }   
+        len -= written;
+        offset += written;
+    }   
+}