shm.go
@@ -12,7 +12,6 @@ type SHM struct { rw *shm.ReadWriteCloser typ td data []byte } // Send impl interface Diliver @@ -36,10 +35,11 @@ return nil, errors.New("please open shm consumer first") } n, err := s.rw.Read(s.data) data := make([]byte, maxRecvSize) n, err := s.rw.Read(data) if err == nil || err == io.EOF { s.data = s.data[:n:n] return s.data, nil data = data[:n:n] return data, nil } return nil, err @@ -83,7 +83,6 @@ return &SHM{ rw, agent, nil, } } @@ -102,7 +101,6 @@ return &SHM{ rw, coactee, make([]byte, maxRecvSize), } } fmt.Println("shmConsumer open error")