add shm interface 2

zhangmeng

2019-08-27 020e17cc5311d091d713eb4fabae2a3d50944916

 shm.go

@@ -39,8 +39,7 @@
   // data := make([]byte, maxRecvSize)
   // n, err := s.rw.Read(data)
   // if err == nil || err == io.EOF {
   //    data := make([]byte, maxRecvSize)
   //    copy(data, s.recvData)
   //    data := data[:n:n]
   //    return data, nil
   // }

@@ -51,6 +50,21 @@
   return nil, err
}

// Recv2 impl interface
func (s *SHM) Recv2(data []byte) error {
   if s == nil || s.rw == nil {
      return errors.New("please open shm consumer first")
   }

   n, err := s.rw.Read(data)
   if err == nil || err == io.EOF {
      data = data[:n:n]
      return nil
   }

   return err
}

// Close impl interface Deliver
func (s *SHM) Close() {
   if s == nil {