zhangmeng
2019-08-30 f8dadae1c1254ec79dcaff16257d9c54c2ee2e43
test one data
1个文件已修改
11 ■■■■ 已修改文件
shm.go 11 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
shm.go
@@ -16,7 +16,8 @@
    rw  *shm.ReadWriteCloser
    typ td
    recvData []byte
    recvData        []byte
    recvSliceHeader *reflect.SliceHeader
}
// Send impl interface Diliver
@@ -60,14 +61,14 @@
    if s.recvData == nil {
        s.recvData = make([]byte, maxRecvSize)
        s.recvSliceHeader = (*reflect.SliceHeader)(unsafe.Pointer(&s.recvData))
    }
    sliceHeader := (*reflect.SliceHeader)(unsafe.Pointer(&s.recvData))
    sliceHeader.Cap = maxRecvSize
    sliceHeader.Len = 0
    // sliceHeader.Cap = maxRecvSize
    s.recvSliceHeader.Len = maxRecvSize
    n, err := s.rw.Read(s.recvData)
    if err == nil || err == io.EOF {
        sliceHeader.Len = n
        s.recvSliceHeader.Len = n
        return s.recvData, nil
    }