From 1b6b5b8d9f84259fb5392af855f24f489f67bbf1 Mon Sep 17 00:00:00 2001
From: Shuai Lin <linshuai2012@gmail.com>
Date: Thu, 19 May 2016 11:31:11 +0800
Subject: [PATCH] named pipe transport: Added tests.

---
 .gitignore     |  7 ++++---
 tests/searpc.c | 36 ++++++++++++++++++++++++++++++++++--
 2 files changed, 38 insertions(+), 5 deletions(-)

diff --git a/.gitignore b/.gitignore
index 47f60de..2740b46 100644
--- a/.gitignore
+++ b/.gitignore
@@ -8,6 +8,7 @@
 .deps
 *.db
 *.gz
+compile
 config.*
 autom4te.cache/*
 aclocal.m4
@@ -51,6 +52,6 @@ tests/searpc-signature.h
 tests/rpc_table.stamp
 tests/rpc_table.tmp
 tests/clar.suite
-
-
-
+tests/.clarcache
+tests/*.trs
+test-driver
diff --git a/tests/searpc.c b/tests/searpc.c
index ff5c94d..b8b462d 100644
--- a/tests/searpc.c
+++ b/tests/searpc.c
@@ -139,17 +139,19 @@ maman_bar_class_init (MamanBarClass *klass)
 static void
 maman_bar_init (MamanBar *self)
 {
-    
+
 }
 
 /* sample client */
 static SearpcClient *client;
+/* sample client with named pipe as transport */
+static SearpcClient *client_with_pipe_transport;
 
 char *
 sample_send(void *arg, const gchar *fcall_str,
             size_t fcall_len, size_t *ret_len)
 {
-    cl_assert (strcmp(arg, "test") == 0);
+    cl_assert_ (strcmp(arg, "test") == 0, arg);
 
     char *ret;
     /* directly call in memory, instead of send via network */
@@ -321,6 +323,26 @@ test_searpc__simple_call_async (void)
                                       2, "string", "hello", "int", 10);
 }
 
+void
+test_searpc__pipe_simple_call (void)
+{
+    gchar* result;
+    GError *error = NULL;
+
+    result = searpc_client_call__string (client_with_pipe_transport, "get_substring", &error,
+                                         2, "string", "hello", "int", 2);
+    cl_assert_ (error == NULL, error ? error->message : "");
+    cl_assert (strcmp(result, "he") == 0);
+    g_free (result);
+
+    /* error should return */
+    result = NULL;
+    result = searpc_client_call__string (client_with_pipe_transport, "get_substring", &error,
+                                         2, "string", "hello", "int", 10);
+    cl_assert (error->message);
+    g_free (result);
+}
+
 #include "searpc-signature.h"
 #include "searpc-marshal.h"
 
@@ -346,6 +368,16 @@ test_searpc__initialize (void)
 
     client->async_send = sample_async_send;
     client->async_arg = "test_async";
+
+    const char *pipe_path = "/tmp/.searpc-test";
+
+    SearpcNamedPipeServer *pipe_server = searpc_create_named_pipe_server(pipe_path);
+    SearpcNamedPipeClient *pipe_client = searpc_create_named_pipe_client(pipe_path);
+
+    cl_must_pass_(searpc_named_pipe_server_start(pipe_server), "named pipe server failed to start");
+    cl_must_pass_(searpc_named_pipe_client_connect(pipe_client), "named pipe client failed to connect");
+
+    client_with_pipe_transport = searpc_client_with_named_pipe_transport(pipe_client, "test");
 }
 
 void