| | |
| | | "errors" |
| | | "fmt" |
| | | "io" |
| | | "time" |
| | | |
| | | "github.com/tmthrgd/shm-go" |
| | | "basic.com/valib/shm.git" |
| | | ) |
| | | |
| | | // SHM share memory |
| | |
| | | |
| | | // Send impl interface Diliver |
| | | func (s *SHM) Send(data []byte) error { |
| | | if s.rw == nil { |
| | | if s == nil || s.rw == nil { |
| | | return errors.New("please init shm producer first") |
| | | } |
| | | |
| | |
| | | // Recv impl interface Diliver |
| | | func (s *SHM) Recv() ([]byte, error) { |
| | | |
| | | if s.rw == nil { |
| | | if s == nil || s.rw == nil { |
| | | return nil, errors.New("please open shm consumer first") |
| | | } |
| | | |
| | | data := make([]byte, maxRecvSize) |
| | | n, err := s.rw.Read(data) |
| | | // data := make([]byte, maxRecvSize) |
| | | // n, err := s.rw.Read(data) |
| | | // if err == nil || err == io.EOF { |
| | | // data := make([]byte, maxRecvSize) |
| | | // copy(data, s.recvData) |
| | | // return data, nil |
| | | // } |
| | | |
| | | data, err := s.rw.DirectRead() |
| | | if err == nil || err == io.EOF { |
| | | data = data[:n:n] |
| | | return data, nil |
| | | } |
| | | |
| | | return nil, err |
| | | } |
| | | |
| | | // Close impl interface Deliver |
| | | func (s *SHM) Close() { |
| | | if s == nil { |
| | | return |
| | | } |
| | | if s.rw != nil { |
| | | s.rw.Close() |
| | | } |
| | |
| | | } |
| | | } |
| | | |
| | | func shmServer(m Mode, url string, args ...interface{}) *SHM { |
| | | func shmServer(m Mode, url string, args ...interface{}) (*SHM, error) { |
| | | if m != Shm { |
| | | fmt.Println("this is not a shm mode: ", m) |
| | | return nil |
| | | return nil, errors.New("please use deliver.Shm mode") |
| | | } |
| | | |
| | | var param []int |
| | | for _, v := range args { |
| | | fmt.Println(v) |
| | | switch v.(type) { |
| | | case int: |
| | | param = append(param, v.(int)) |
| | | default: |
| | | fmt.Println("shmProducer recv error parameters") |
| | | |
| | | return nil |
| | | return nil, errors.New("shmServer created recv error parameters") |
| | | } |
| | | } |
| | | if len(param) != 2 { |
| | | fmt.Println("shmProducer recv too much parameter: ", len(param)) |
| | | return nil |
| | | |
| | | blocks, size := 2, maxRecvSize |
| | | if len(param) == 2 { |
| | | blocks, size = param[0], param[1] |
| | | // return nil, errors.New("shmServer created recv too much parameters") |
| | | } |
| | | if rw, err := shm.CreateSimplex(url, 0644, param[0], param[1]); err == nil { |
| | | |
| | | time.Sleep(time.Millisecond) |
| | | shm.Unlink(url) |
| | | |
| | | rw, err := shm.CreateSimplex(url, 0644, blocks, size) |
| | | if err == nil { |
| | | fmt.Println(rw.Name()) |
| | | return &SHM{ |
| | | rw, |
| | | agent, |
| | | } |
| | | rw: rw, |
| | | typ: agent, |
| | | }, nil |
| | | } |
| | | |
| | | fmt.Println("create simple shm error") |
| | | return nil |
| | | return nil, err |
| | | } |
| | | |
| | | func shmClient(m Mode, url string, args ...interface{}) *SHM { |
| | | |
| | | func shmClient(m Mode, url string, args ...interface{}) (*SHM, error) { |
| | | if m != Shm { |
| | | fmt.Println("this is not a shm mode: ", m) |
| | | return nil |
| | | return nil, errors.New("please use deliver.Shm mode") |
| | | } |
| | | |
| | | if rw, err := shm.OpenSimplex(url); err == nil { |
| | | rw, err := shm.OpenSimplex(url) |
| | | if err == nil { |
| | | return &SHM{ |
| | | rw, |
| | | coactee, |
| | | } |
| | | rw: rw, |
| | | typ: coactee, |
| | | }, nil |
| | | } |
| | | fmt.Println("shmConsumer open error") |
| | | return nil |
| | | return nil, err |
| | | } |