1 files changed, 107 insertions, 0 deletions
diff --git a/fnet/src/examples/frt/rpc/rpc_invoke.cpp b/fnet/src/examples/frt/rpc/rpc_invoke.cpp
new file mode 100644
index 00000000000..471fd9a879f
--- /dev/null
+++ b/fnet/src/examples/frt/rpc/rpc_invoke.cpp
@@ -0,0 +1,107 @@
+// Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
+#include <vespa/fastos/fastos.h>
+#include <vespa/log/log.h>
+LOG_SETUP("rpc_invoke");
+#include <vespa/fnet/frt/frt.h>
+
+class RPCClient : public FastOS_Application
+{
+private:
+    static bool addArg(FRT_RPCRequest *req, const char *param) {
+        int len = strlen(param);
+        if (len < 2 || param[1] != ':') {
+            return false;
+        }
+        const char *value = param + 2;
+        switch (param[0]) {
+        case 'b':
+            req->GetParams()->AddInt8(strtoll(value, NULL, 0));
+            break;
+        case 'h':
+            req->GetParams()->AddInt16(strtoll(value, NULL, 0));
+            break;
+        case 'i':
+            req->GetParams()->AddInt32(strtoll(value, NULL, 0));
+            break;
+        case 'l':
+            req->GetParams()->AddInt64(strtoll(value, NULL, 0));
+            break;
+        case 'f':
+            req->GetParams()->AddFloat(strtod(value, NULL));
+            break;
+        case 'd':
+            req->GetParams()->AddDouble(strtod(value, NULL));
+            break;
+        case 's':
+            req->GetParams()->AddString(value);
+            break;
+        default:
+            return false;
+        }
+        return true;
+    }
+
+public:
+    virtual int Main();
+};
+
+int
+RPCClient::Main()
+{
+    if (_argc < 3) {
+        fprintf(stderr, "usage: rpc_invoke [-t timeout] <connectspec> <method> [args]\n");
+        fprintf(stderr, "    -t timeout in seconds\n");
+        fprintf(stderr, "    Each arg must be on the form <type>:<value>\n");
+        fprintf(stderr, "    supported types: {'b','h','i','l','f','d','s'}\n");
+        return 1;
+    }
+    int retCode = 0;
+    FRT_Supervisor supervisor;
+    supervisor.Start();
+    int targetArg = 1;
+    int methNameArg = 2;
+    int startOfArgs = 3;
+    int timeOut = 10;
+    if (strcmp(_argv[1], "-t") == 0) {
+      timeOut = atoi(_argv[2]);
+      targetArg = 3;
+      methNameArg = 4;
+      startOfArgs = 5;
+    }
+    FRT_Target *target = supervisor.GetTarget(_argv[targetArg]);
+    FRT_RPCRequest *req = supervisor.AllocRPCRequest();
+    req->SetMethodName(_argv[methNameArg]);
+    for (int i = startOfArgs; i < _argc; ++i) {
+        if (!addArg(req, _argv[i])) {
+            fprintf(stderr, "could not parse parameter: '%s'\n", _argv[i]);
+            retCode = 2;
+            break;
+        }
+    }
+    if (retCode == 0) {
+        fprintf(stdout, "PARAMETERS:\n");
+        req->GetParams()->Print();
+        target->InvokeSync(req, (double)timeOut);
+        if (req->GetErrorCode() == FRTE_NO_ERROR) {
+            fprintf(stdout, "RETURN VALUES:\n");
+            req->GetReturn()->Print();
+        } else {
+            fprintf(stderr, "error(%d): %s\n",
+                    req->GetErrorCode(),
+                    req->GetErrorMessage());
+            retCode = 3;
+        }
+    }
+    req->SubRef();
+    target->SubRef();
+    supervisor.ShutDown(true);
+    return retCode;
+}
+
+
+int
+main(int argc, char **argv)
+{
+    RPCClient myapp;
+    return myapp.Entry(argc, argv);
+}