Replace ZeroMQ (pytorch#41)

Author: 0mp

torch/lib/THD/README.md

@@ -0,0 +1,9 @@
+# Dependecies
+
+- Asio C++ Library
+
+## macOS
+
+```
+brew install asio
+```

torch/lib/THD/master_worker/common/ByteArray.cpp

@@ -69,6 +69,10 @@ std::size_t ByteArray::length() const {
  return _length;
 }
 
+std::string ByteArray::to_string() {
+ return std::string(_data, _length);
+}
+
 ByteArray ByteArray::fromData(const char* arr, std::size_t size) {
  char* new_arr = static_cast<char*>(std::malloc(size));
  if (new_arr == nullptr) {

torch/lib/THD/master_worker/common/ByteArray.hpp

@@ -1,10 +1,12 @@
 #pragma once
 
 #include <cstddef>
+#include <string>
 
 namespace thd { namespace rpc {
 
 struct ByteArray {
+ using size_type = std::size_t;
  ByteArray();
  ByteArray(std::size_t size);
  ByteArray(char* arr, std::size_t size);
@@ -14,14 +16,16 @@ struct ByteArray {
 
  ByteArray& append(const char* arr, std::size_t size);
  char* data() const;
- std::size_t length() const;
+ size_type length() const;
+
+ std::string to_string();
 
  static ByteArray fromData(const char* arr, std::size_t size);
 
 private:
  char* _data;
- std::size_t _length; // The length of the data.
- std::size_t _size; // The size of the allocated memory.
+ size_type _length; // The length of the data.
+ size_type _size; // The size of the allocated memory.
 
  void _realloc(std::size_t new_size);
  void _resize(std::size_t desired_size);