shmqueue的get和put,增加超次数退出

chenshijun

2020-04-15 b45e986f51e4545a9f42e6f387829a75d589c69a

 shmData.go

@@ -37,10 +37,10 @@
      return err
   }
   sdi := shmData2Info(shmData)
   if len(data) <= len(shmData) {
   if len(data) <= len(shmData)-SHMSLICEOFFSET {
      sdi.Len = uint32(len(data))
   } else {
      sdi.Len = uint32(len(shmData))
      sdi.Len = uint32(len(shmData)-SHMSLICEOFFSET)
   }

   tmpData := ptr2Slice(unsafe.Pointer(&sdi.Cache), int(sdi.Len), len(shmData)-SHMSLICEOFFSET)
@@ -74,10 +74,10 @@
// 适合解码使用
func DeepCopyDataToShm(memData,shmData []byte) {
   sdi := shmData2Info(shmData)
   if len(memData) <= len(shmData) {
   if len(memData) <= len(shmData)-SHMSLICEOFFSET {
      sdi.Len = uint32(len(memData))
   } else {
      sdi.Len = uint32(len(shmData))
      sdi.Len = uint32(len(shmData)-SHMSLICEOFFSET)
   }

   tmpData := ptr2Slice(unsafe.Pointer(&sdi.Cache), int(sdi.Len), len(shmData)-SHMSLICEOFFSET)