From 4403997708025d6c82122f4b15dcfb109dd3e6c6 Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期一, 29 七月 2019 13:52:59 +0800
Subject: [PATCH] update
---
main.go | 15 +++++++++++++++
1 files changed, 15 insertions(+), 0 deletions(-)
diff --git a/main.go b/main.go
index 751bfb7..fb8204a 100644
--- a/main.go
+++ b/main.go
@@ -48,6 +48,8 @@
mode string
ipc string
oneSendnRecv bool
+
+ tmm string
)
const (
@@ -64,6 +66,8 @@
flag.StringVar(&ipc, "i", "ipc:///tmp/pic.ipc", "ipc label")
flag.BoolVar(&oneSendnRecv, "n", true, "one send n recv")
+
+ flag.StringVar(&tmm, "t", "server", "")
}
func modeType(t string) deliver.Mode {
@@ -86,6 +90,17 @@
func main() {
flag.Parse()
+ if tmm == "server" {
+ c, _ := deliver.NewServerWithTimeout(deliver.PushPull, ipc, 1000)
+ // c := deliver.NewServer(deliver.PushPull, ipc)
+ nSenderImpl(c, 0)
+ } else if tmm == "client" {
+ s, _ := deliver.NewServerWithTimeout(deliver.PushPull, ipc, 100)
+
+ oneRecvImpl(s, 0)
+
+ }
+ return
m := modeType(mode)
if m > deliver.ModeStart {
if proc == act {
--
Gitblit v1.8.0