zhangmeng
2019-05-21 93ff14f01eb200848336c95ea75658282e14947a
change memory usage, lower performance but safer
1个文件已修改
14 ■■■■■ 已修改文件
shm.go 14 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史
shm.go
@@ -10,9 +10,8 @@
// SHM share memory
type SHM struct {
    rw   *shm.ReadWriteCloser
    typ  td
    data []byte
    rw  *shm.ReadWriteCloser
    typ td
}
// 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")