From 877eba6c21febeafd1122b60768c5ca5f4a69945 Mon Sep 17 00:00:00 2001 From: imarom Date: Wed, 12 Aug 2015 17:50:34 +0300 Subject: just a checkpoint - not stable --- src/gtest/rpc_test.cpp | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) (limited to 'src/gtest/rpc_test.cpp') diff --git a/src/gtest/rpc_test.cpp b/src/gtest/rpc_test.cpp index 7f78efd0..59b4b189 100644 --- a/src/gtest/rpc_test.cpp +++ b/src/gtest/rpc_test.cpp @@ -47,19 +47,19 @@ TEST_F(RpcTest, basic_rpc_test) { zmq_connect (requester, "tcp://localhost:5050"); - char buffer[50]; + char buffer[250]; Json::Value request; int id = 1; request["jsonrpc"] = "2.0"; - request["method"] = "test_func"; + //request["method"] = "test_func"; Json::Value ¶ms = request["params"]; params["num"] = 12; params["msg"] = "hello, method test_func"; - for (int request_nbr = 0; request_nbr != 10; request_nbr++) { - request["id"] = id++; + for (int request_nbr = 0; request_nbr != 1; request_nbr++) { + //request["id"] = "itay_id"; std::stringstream ss; ss << request; @@ -68,8 +68,9 @@ TEST_F(RpcTest, basic_rpc_test) { zmq_send (requester, ss.str().c_str(), ss.str().size(), 0); - zmq_recv (requester, buffer, 50, 0); - printf ("Received ACK\n"); + int len = zmq_recv (requester, buffer, 250, 0); + std::string resp(buffer, buffer + len); + std::cout << "Got: " << resp << "\n"; } zmq_close (requester); zmq_ctx_destroy (context); -- cgit 1.2.3-korg