change memory usage, lower performance but safer
| | |
| | | |
| | | // SHM share memory |
| | | type SHM struct { |
| | | rw *shm.ReadWriteCloser |
| | | typ td |
| | | data []byte |
| | | rw *shm.ReadWriteCloser |
| | | typ td |
| | | } |
| | | |
| | | // Send impl interface Diliver |
| | |
| | | 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 |
| | |
| | | return &SHM{ |
| | | rw, |
| | | agent, |
| | | nil, |
| | | } |
| | | } |
| | | |
| | |
| | | return &SHM{ |
| | | rw, |
| | | coactee, |
| | | make([]byte, maxRecvSize), |
| | | } |
| | | } |
| | | fmt.Println("shmConsumer open error") |