From 91f7d13bdf60a2df6bedff6467f550c7c643f3fc Mon Sep 17 00:00:00 2001
From: chenshijun <csj_sky@126.com>
Date: 星期六, 28 三月 2020 09:03:52 +0800
Subject: [PATCH] 给强制写入和读取增加context资源管理
---
shmwrap.go | 11 ++++-------
1 files changed, 4 insertions(+), 7 deletions(-)
diff --git a/shmwrap.go b/shmwrap.go
index 12dba41..73aefc0 100644
--- a/shmwrap.go
+++ b/shmwrap.go
@@ -10,13 +10,14 @@
// NewBlock shm block with size
func NewBlock(size int, key int) ([]byte, int, error) {
id, err := shm.Get(key, size, shm.IPC_CREAT|0666)
- fmt.Println("Get:", id, err)
if err != nil || id == -1 {
+ fmt.Println("NewBlock Get:", key, err)
return nil, -1, err
}
data, err2 := shm.At(id, 0, 0)
if err2 != nil {
+ fmt.Println("NewBlock At:", key, err2)
return nil, -1, err2
}
@@ -26,13 +27,14 @@
// AttachBlock attach exist shm
func AttachBlock(key int) ([]byte, int, error) {
id, err := shm.Get(key, 0, 0)
- fmt.Println("Get:", id, err)
if err != nil || id == -1 { //no exist
+ fmt.Println("AttachBlock Get:", key, err)
return nil, -1, err
}
data, err2 := shm.At(id, 0, 0)
if err2 != nil {
+ fmt.Println("AttachBlock At:", key, err2)
return nil, -1, err2
}
@@ -50,7 +52,6 @@
// context for quit
func CreateRawShm(ctx context.Context, size int, key int) ([]byte, int) {
data, id, err := AttachBlock(key)
- fmt.Println("err:", err)
if err != nil {
loopB:
for {
@@ -60,8 +61,6 @@
default:
if err == nil {
break loopB
- } else {
- fmt.Println("createShm error:", err)
}
time.Sleep(time.Millisecond)
data, id, err = NewBlock(size, key)
@@ -83,8 +82,6 @@
default:
if err == nil {
break loopB
- } else {
- fmt.Println("createShm error:", err)
}
time.Sleep(time.Millisecond)
data, id, err = AttachBlock(key)
--
Gitblit v1.8.0