summaryrefslogtreecommitdiff
path: root/decoder/feed.cc
diff options
context:
space:
mode:
Diffstat (limited to 'decoder/feed.cc')
-rw-r--r--decoder/feed.cc53
1 files changed, 0 insertions, 53 deletions
diff --git a/decoder/feed.cc b/decoder/feed.cc
deleted file mode 100644
index f8923fc4..00000000
--- a/decoder/feed.cc
+++ /dev/null
@@ -1,53 +0,0 @@
-#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;
-}
-