nanomsg

1 files changed, 53 insertions, 0 deletions

diff --git a/nanomsg/feed.cc b/nanomsg/feed.cc
new file mode 100644
index 0000000..f8923fc
--- /dev/null
+++ b/nanomsg/feed.cc
@@ -0,0 +1,53 @@
+#include <iostream>
+#include <string>
+#include <sstream>
+#include <stdio.h>
+#include <unistd.h>
+
+#include <nanomsg/nn.h>
+#include <nanomsg/pair.h>
+#include "nn.hpp"
+
+using namespace std;
+
+void
+recv(nn::socket& sock)
+{
+  char *buf = NULL;
+  size_t sz = sock.recv(&buf, NN_MSG, 0);
+  if (buf) {
+    string translation(buf, buf+sz);
+    cout << "got translation '" << translation << "'" << endl << endl;
+  }
+}
+
+void
+send(nn::socket& sock, const string& msg)
+{
+  cout << "sending source '" << msg << "'" << endl;
+  sock.send(msg.c_str(), msg.size()+1, 0);
+}
+
+void
+loop(nn::socket& sock)
+{
+  int to = 100;
+  sock.setsockopt(NN_SOL_SOCKET, NN_RCVTIMEO, &to, sizeof(to));
+  for (string line; getline(cin, line);) {
+    send(sock, line);
+    sleep(1);
+    recv(sock);
+  }
+}
+
+int main(int argc, char const* argv[])
+{
+  nn::socket sock(AF_SP, NN_PAIR);
+  //string url = "ipc:///tmp/network_decoder.ipc";
+  string url = "tcp://127.0.0.1:60666";
+  sock.connect(url.c_str());
+  loop(sock);
+
+  return 0;
+}
+