2 files changed, 38 insertions, 0 deletions
diff --git a/tests/modules/pipe/echo_client.lua b/tests/modules/pipe/echo_client.lua
new file mode 100644
index 000000000..4061b08b6
--- /dev/null
+++ b/tests/modules/pipe/echo_client.lua
@@ -0,0 +1,15 @@
+import("core.base.pipe")
+
+function main(name)
+    local pipefile = pipe.open(name or "test", 'w')
+    local count = 0
+    while count < 10000 do
+        local write = pipefile:write("hello world..", {block = true})
+        if write <= 0 then
+            break
+        end
+        count = count + 1
+    end
+    print("%s: write ok, count: %d!", pipefile, count)
+    pipefile:close()
+end
diff --git a/tests/modules/pipe/echo_server.lua b/tests/modules/pipe/echo_server.lua
new file mode 100644
index 000000000..15f15291b
--- /dev/null
+++ b/tests/modules/pipe/echo_server.lua
@@ -0,0 +1,23 @@
+import("core.base.pipe")
+
+function main(name)
+
+    local pipefile = pipe.open(name or "test", 'r')
+    if pipefile:connect() > 0 then
+        print("%s: connected", pipefile) 
+        local count = 0
+        local result = nil
+        while count < 10000 do
+            local read, data = pipefile:read(13, {block = true})
+            if read > 0 then
+                result = data
+                count = count + 1
+            else
+                break
+            end
+        end
+        print("%s: read: %d, count: %d", pipefile, result and result:size() or 0, count)
+        result:dump()
+    end
+    pipefile:close()
+end