From 2d390df9ede39c9d7c34bd8190b9329cfc371325 Mon Sep 17 00:00:00 2001
From: zhangmeng <775834166@qq.com>
Date: 星期五, 27 九月 2019 16:19:05 +0800
Subject: [PATCH] remove exist ipc
---
shm.go | 35 ++++++++++++++++-------------------
1 files changed, 16 insertions(+), 19 deletions(-)
diff --git a/shm.go b/shm.go
index 0c35931..534fc83 100644
--- a/shm.go
+++ b/shm.go
@@ -4,9 +4,7 @@
"errors"
"fmt"
"io"
- "reflect"
"time"
- "unsafe"
"basic.com/valib/shm.git"
)
@@ -16,8 +14,7 @@
rw *shm.ReadWriteCloser
typ td
- recvData []byte
- recvSliceHeader *reflect.SliceHeader
+ // recvData []byte
}
// Send impl interface Diliver
@@ -52,25 +49,25 @@
// cur
- // data, err := s.rw.DirectRead()
- // if err == nil || err == io.EOF {
- // return data, nil
- // }
+ data, err := s.rw.DirectRead()
+ if err == nil || err == io.EOF {
+ return data, nil
+ }
// new
- if s.recvData == nil {
- s.recvData = make([]byte, maxRecvSize)
- s.recvSliceHeader = (*reflect.SliceHeader)(unsafe.Pointer(&s.recvData))
- }
- // sliceHeader.Cap = maxRecvSize
- s.recvSliceHeader.Len = maxRecvSize
+ // if s.recvData == nil {
+ // s.recvData = make([]byte, maxRecvSize)
+ // }
+ // sliceHeader := (*reflect.SliceHeader)(unsafe.Pointer(&s.recvData))
+ // // sliceHeader.Cap = maxRecvSize
+ // sliceHeader.Len = maxRecvSize
- n, err := s.rw.Read(s.recvData)
- if err == nil || err == io.EOF {
- s.recvSliceHeader.Len = n
- return s.recvData, nil
- }
+ // n, err := s.rw.Read(s.recvData)
+ // if err == nil || err == io.EOF {
+ // sliceHeader.Len = n
+ // return s.recvData, nil
+ // }
return nil, err
}
--
Gitblit v1.8.0