From 622b701e27351e28a6c3df579d4423120afe79fc Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期一, 20 五月 2019 12:55:54 +0800
Subject: [PATCH] update deliver
---
main.go | 11 ++++++++++-
1 files changed, 10 insertions(+), 1 deletions(-)
diff --git a/main.go b/main.go
index aed056c..24b9193 100644
--- a/main.go
+++ b/main.go
@@ -1,12 +1,15 @@
package main
import (
+ "context"
"demo/deliver"
"fmt"
"os"
)
const dLen = 12 * 1024 * 1024
+
+var ctx, cancel = context.WithCancel(context.Background())
func modeType(t string) deliver.Mode {
@@ -18,14 +21,18 @@
return deliver.Pair
} else if t == "reqrep" {
return deliver.ReqRep
+ } else if t == "shm" {
+ return deliver.Shm
}
- return deliver.Mode(-1)
+ return deliver.NONE
}
func senderMode(ipc string, m deliver.Mode) {
if m == deliver.ReqRep {
req(ipc, m)
+ } else if m == deliver.Shm {
+ shmSender(ipc, 2, 32*1024*1024)
}
sender(ipc, m)
}
@@ -33,6 +40,8 @@
func recvMode(ipc string, m deliver.Mode, strCount string) {
if m == deliver.ReqRep {
rep(ipc, m)
+ } else if m == deliver.Shm {
+ shmReciever(ipc, strCount)
}
reciever(ipc, m, strCount)
}
--
Gitblit v1.8.0