zhangmeng
2019-08-30 f8dadae1c1254ec79dcaff16257d9c54c2ee2e43
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
   }