Merge pull request #16 from leapmotion/file-endpoint

File endpoint

Author: yeswalrus

src/leapipc/CMakeLists.txt

@@ -5,6 +5,8 @@ set(IPC_SRCS
   IPCClientConnector.cpp
   IPCEndpoint.h
   IPCEndpoint.cpp
+  IPCFileEndpoint.h
+  IPCFileEndpoint.cpp
   IPCListener.h
   IPCListener.cpp
   MessageBuffers.h

src/leapipc/IPCFileEndpoint.cpp

@@ -0,0 +1,50 @@
+// Copyright (C) 2012-2016 Leap Motion, Inc. All rights reserved.
+#include "stdafx.h"
+#include "IPCFileEndpoint.h"
+#include <system_error>
+
+using namespace leap::ipc;
+
+IPCFileEndpoint::IPCFileEndpoint(const std::string & fileName, bool read, bool write)
+{
+  std::ios_base::openmode mode = std::ios::binary;
+  if (read) mode |= std::ios::in;
+  if (write) mode |= std::ios::out;
+  m_file.open(fileName, mode);
+  if (!m_file.is_open())
+    throw std::runtime_error("Failed to open file");
+}
+
+IPCFileEndpoint::~IPCFileEndpoint(void)
+{
+  if (m_file.is_open())
+    m_file.close();
+}
+
+std::streamsize IPCFileEndpoint::ReadRaw(void* buffer, std::streamsize size) {
+  if (m_file.eof())
+    return Done(Reason::UserClosed);
+
+  m_file.read((char*)buffer, size);
+  return m_file.gcount();
+}
+
+bool IPCFileEndpoint::WriteRaw(const void* pBuf, std::streamsize nBytes) {
+  m_file.write((char*)pBuf, nBytes);
+  if (m_file.bad())
+    return false;
+  return true;
+}
+
+bool IPCFileEndpoint::Abort(Reason reason) {
+  if (m_file.is_open()) {
+    m_file.close();
+    return true;
+  }
+  return false;
+}
+
+// On the first call, return 0 (EOF). Subsequent calls, return -1 (error).
+int IPCFileEndpoint::Done(Reason reason) {
+  return Abort(reason) ? 0 : -1;
+}

src/leapipc/IPCFileEndpoint.h

@@ -0,0 +1,31 @@
+// Copyright (C) 2012-2016 Leap Motion, Inc. All rights reserved.
+#pragma once
+#include "IPCEndpoint.h"
+#include <fstream>
+
+namespace leap {
+namespace ipc {
+
+class IPCFileEndpoint:
+  public IPCEndpoint
+{
+public:
+  IPCFileEndpoint(const std::string & fileName, bool read, bool write);
+  ~IPCFileEndpoint(void);
+
+private:
+  std::fstream m_file;
+
+  /// <summary>
+  /// Simulate EOF behavior when we are done.
+  /// </summary>
+  int Done(Reason reason);
+
+public:
+  // IPCEndpoint overrides:
+  std::streamsize ReadRaw(void* buffer, std::streamsize size) override;
+  bool WriteRaw(const void* pBuf, std::streamsize nBytes) override;
+  bool Abort(Reason reason) override;
+};
+
+}}

src/leapipc/testing/CMakeLists.txt

@@ -5,6 +5,7 @@ set(LeapIPCTest_SRCS
   IPCListenerTest.cpp
   IPCMessagingTest.cpp
   IPCShutdownTest.cpp
+  IPCFileEndpointTest.cpp
   IPCTestUtils.h
   IPCTestUtils.cpp
 )

src/leapipc/testing/IPCFileEndpointTest.cpp

@@ -0,0 +1,43 @@
+// Copyright (C) 2012-2016 Leap Motion, Inc. All rights reserved.
+#include "stdafx.h"
+#include "IPCTestUtils.h"
+#include <leapipc/IPCFileEndpoint.h>
+#include <autowiring/autowiring.h>
+#include <autowiring/CoreThread.h>
+#include <cstdio>
+#include <gtest/gtest.h>
+
+using namespace leap::ipc;
+
+class IPCFileEndpointTest :
+  public testing::Test
+{};
+
+TEST_F(IPCFileEndpointTest, RawWriteToReadFromFile)
+{
+  std::string testMessage = "0123456789abcdef";
+  const char* testFile = "IPCFileEndpoint_TestFile";
+
+  // Write test message to file
+  {
+    std::shared_ptr<IPCFileEndpoint> ep = std::make_shared<IPCFileEndpoint>(testFile, false, true);
+    ep->WriteRaw((void*)testMessage.c_str(), testMessage.size());
+  }
+
+  // Read test message from file
+  {
+    std::shared_ptr<IPCFileEndpoint> ep = std::make_shared<IPCFileEndpoint>(testFile, true, false);
+
+    size_t bufsize = testMessage.size()+1;
+    char* buf = new char[bufsize];
+    buf[bufsize - 1] = 0;
+
+    ep->ReadRaw((void*)buf, bufsize-1);
+
+    ASSERT_EQ(strcmp(buf, testMessage.c_str()), 0);
+
+    delete[] buf;
+  }
+
+  remove(testFile);
+}

version.cmake

@@ -1 +1 @@
-set(LeapIPC_VERSION 0.1.2)
+set(LeapIPC_VERSION 0.1.3)