memleak bug fix

554325746@qq.com

2019-08-22 074c0c376a7b6c91bad7c45e050270a4a6856b6d

memleak bug fix

 shm.go

@@ -1,6 +1,7 @@
package deliver

import (
    "bytes"
    "errors"
    "fmt"
    "io"
@@ -12,10 +13,8 @@

// SHM share memory
type SHM struct {
    rw  *shm.ReadWriteCloser
    typ td

    data []byte
    rw      *shm.ReadWriteCloser
    typ     td
}

// Send impl interface Diliver
@@ -55,14 +54,12 @@

    ch := make(chan []byte)
    go func(){
        var data []byte
        n, err := s.rw.Read(s.data)
        buffer := new(bytes.Buffer)
        _, err := s.rw.WriteTo(buffer)
        if err == nil || err == io.EOF {
            data = make([]byte, n)
            copy(data, s.data)
            // s.data = s.data[:n:n]
            ch <- buffer.Bytes()
        }
        ch <- s.data
        ch <- nil
    }()
    select{
    case d := <-ch:
@@ -126,7 +123,6 @@
        return &SHM{
            rw,
            agent,
            make([]byte, maxRecvSize),
        }, nil
    }

@@ -143,7 +139,6 @@
        return &SHM{
            rw,
            coactee,
            make([]byte, maxRecvSize),
        }, nil
    }
    return nil, err