delete debug print

chenshijun

2020-03-18 7283c4bc94a98a63bd34501eea659955c84d0c9b

 shmqueue.go

@@ -72,59 +72,24 @@
   shmLen = shmblocks*uint32(unsafe.Sizeof(datainfo)) + uint32(unsafe.Sizeof(shmstruct))

   data, shmid := CreateRawShm(ctx, int(shmLen), key)
   fmt.Println("shmid:", shmid)
   fmt.Printf("data:%p\n", data)
   q := bytes2shmEsQueue(data)
   fmt.Printf("q:%p\n", q)
   fmt.Println("esqueue:", q)
   fmt.Printf("q.capacity:%p\n", &q.capacity)
   fmt.Printf("q.capMod:%p\n", &q.capMod)
   fmt.Printf("q.putPos:%p\n", &q.putPos)
   fmt.Printf("q.getPos:%p\n", &q.getPos)
   fmt.Printf("q.cache:%p\n", &q.cache)
   //init parameters
   q.capacity = shmblocks
   q.capMod = q.capacity - 1
   q.putPos = 0
   q.getPos = 0

   fmt.Println("int(q.capacity)", int(q.capacity))
   eqi.EsCaches = ptr2esCache(unsafe.Pointer(&q.cache), int(q.capacity))
   fmt.Printf("EsCaches:%p\n", &eqi.EsCaches)
   fmt.Printf("EsCaches[0]:%p\n", &(eqi.EsCaches[0]))
   fmt.Printf("EsCaches[1]:%p\n", &(eqi.EsCaches[1]))

   fmt.Println("int(q.capacity)", int(q.capacity))
   for i := 0; i < int(q.capacity); i++ {
      fmt.Println("i", i)
      fmt.Printf("EsCaches[%d]:%p\n", i, &(eqi.EsCaches[i]))
      fmt.Printf("EsCaches[%d].getNo:%p\n", i, &(eqi.EsCaches[i].getNo))
      fmt.Printf("EsCaches[%d].putNo:%p\n", i, &(eqi.EsCaches[i].putNo))

      eqi.EsCaches[i].getNo = uint32(i)
      eqi.EsCaches[i].putNo = uint32(i)
      fmt.Printf("cache.putNo:%p\n", &(eqi.EsCaches[i].putNo))
      fmt.Printf("cache.putNo:%p\n", &(eqi.EsCaches[i].putNo))
      fmt.Println("cache:", eqi.EsCaches[i])
   }
   cache := &eqi.EsCaches[0]
   cache.getNo = q.capacity
   cache.putNo = q.capacity
   fmt.Println("cache:", cache)

   cache0 := eqi.EsCaches[0]
   fmt.Printf("cache0:%p\n", &(cache0))
   fmt.Printf("cache0.getNo:%p\n", &(cache0.getNo))
   fmt.Printf("cache0.putNo:%p\n", &(cache0.putNo))
   fmt.Println("cache0:", cache0)

   cache1 := eqi.EsCaches[1]
   fmt.Printf("cache1:%p\n", &(cache1))
   fmt.Printf("cache1.getNo:%p\n", &(cache1.getNo))
   fmt.Printf("cache1.putNo:%p\n", &(cache1.putNo))
   fmt.Println("cache1:", cache1)

   fmt.Println("EsCaches:", eqi.EsCaches)
   fmt.Println("NewQueue EsCaches:", eqi.EsCaches)

   eqi.ShmData = data
   eqi.ShmID = shmid
@@ -140,11 +105,9 @@

   var eqi EsQueueInfo
   data, shmid := AttachRawShm(ctx, key)
   fmt.Println("shmid:", shmid)
   shmdata := bytes2shmEsQueue(data)
   fmt.Println("shmdata:", shmdata)
   eqi.EsCaches = ptr2esCache(unsafe.Pointer(&shmdata.cache), int(shmdata.capacity))
   fmt.Println("EsCaches:", eqi.EsCaches)
   fmt.Println("AttachQueue EsCaches:", eqi.EsCaches)

   eqi.Queue = shmdata
   eqi.ShmKey = key
@@ -371,6 +334,9 @@

// round 到最近的2的倍数
func minQuantity(v uint32) uint32 {
   if v < 2 {
      return 2
   }
   v--
   v |= v >> 1
   v |= v >> 2