From f62f2cd8fee44ecf7bc54f2635172e48dc348321 Mon Sep 17 00:00:00 2001
From: 554325746@qq.com <554325746@qq.com>
Date: 星期五, 23 八月 2019 10:34:14 +0800
Subject: [PATCH] add shm
---
sdk/sdk.go | 34 +++++++++++++++++++++++++++-------
1 files changed, 27 insertions(+), 7 deletions(-)
diff --git a/sdk/sdk.go b/sdk/sdk.go
index 0998b97..8fdbc9c 100644
--- a/sdk/sdk.go
+++ b/sdk/sdk.go
@@ -2,6 +2,7 @@
import (
"fmt"
+ // "golang.org/x/sys/unix"
"github.com/gogo/protobuf/proto"
"taskpubsub/tasktag"
@@ -13,12 +14,14 @@
)
const (
- postPush = "_1.ipc"
- postPull = "_2.ipc"
+ postPush = "_1"
+ postPull = "_2"
)
var SocketManage = make(map[string]util.SocketContext)
var SdkMap = make(map[string]chan protomsg.SdkMessage)
+
+var shm bool = false
var innerRecvTopic = []string{
"facedetect-sdk-no-track", //to sdk-no-track 浠ュ浘鎼滃浘
@@ -39,7 +42,9 @@
}
}
-func Init() {
+func Init(useShm bool) {
+
+ shm = useShm
logger.Info("============= init sdk info =====================")
for _, sdkid := range util.Sdklist { // 鍒涘缓sdk server
@@ -83,8 +88,14 @@
logger.Info("create", id)
}
- url := fmt.Sprintf("ipc:///tmp/%s%s", id, postPush)
- socket, err := util.NewSocketListen(int(deliver.PushPull), url)
+ url := fmt.Sprintf("ipc:///tmp/%s%s.ipc", id, postPush)
+ m := deliver.PushPull
+ if shm{
+ m = deliver.Shm
+ url = id + postPush
+ // unix.Unlink("/dev/shm/" + url)
+ }
+ socket, err := util.NewSocketListen(int(m), url, shm)
if err != nil {
delete(SdkMap, id)
logger.Error(id, "create socket error!")
@@ -101,8 +112,17 @@
logger.Info("create", id)
}
- url := fmt.Sprintf("ipc:///tmp/%s%s", id, postPull)
- socket, err := util.NewSocketListen(int(deliver.PushPull), url)
+ url := fmt.Sprintf("ipc:///tmp/%s%s.ipc", id, postPull)
+ m := deliver.PushPull
+ if shm{
+ m = deliver.Shm
+ url = id + postPull
+
+ // unix.Unlink("/dev/shm/" + url)
+ }
+
+ socket, err := util.NewSocketListen(int(m), url, shm)
+
if err != nil {
delete(SdkMap, id)
logger.Error(id, "create socket error!")
--
Gitblit v1.8.0