chenshijun
2020-03-30 47099312089389a553e8a49f5e2c0739f061b839
添加注释
1个文件已修改
14 ■■■■ 已修改文件
shmData.go 14 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
shmData.go
@@ -5,7 +5,7 @@
    "unsafe"
)
// lock free queue struct
// []byte struct
type ShmDataInfo struct {
    Capacity uint32
    Cache    []byte
@@ -29,15 +29,15 @@
//WriteShmData   data待写入的数据;   shmId:共享内存id,只attach,不create
func WriteShmData(data []byte, shmId int) error {
    shmdata,err := Attach(shmId)
    shmData,err := Attach(shmId)
    if err != nil {
        return err
    }
    sdi := shmData2Info(shmdata)
    if len(data) <= len(shmdata) {
    sdi := shmData2Info(shmData)
    if len(data) <= len(shmData) {
        sdi.Capacity = uint32(len(data))
    } else {
        sdi.Capacity = uint32(len(shmdata))
        sdi.Capacity = uint32(len(shmData))
    }
    tmpData := ptr2Slice(unsafe.Pointer(&sdi.Cache), int(sdi.Capacity))
@@ -48,12 +48,12 @@
//ReadShmData attach到shmId对应的共享内存,并读出数据[]byte
func ReadShmData(shmId int) ([]byte,error) {
    shmdata,err := Attach(shmId)
    shmData,err := Attach(shmId)
    if err != nil {
        return nil,err
    }
    sdi := shmData2Info(shmdata)
    sdi := shmData2Info(shmData)
    tmpData := ptr2Slice(unsafe.Pointer(&sdi.Cache), int(sdi.Capacity))
    return tmpData, nil