| | |
| | | cache.getNo = q.capacity |
| | | cache.putNo = q.capacity |
| | | |
| | | fmt.Println("NewQueue EsCaches:", eqi.EsCaches) |
| | | //fmt.Println("NewQueue EsCaches:", eqi.EsCaches) |
| | | |
| | | eqi.ShmData = data |
| | | eqi.ShmID = shmid |
| | | eqi.ShmKey = key |
| | | eqi.Queue = q |
| | | time.Sleep(10 * time.Second) |
| | | |
| | | return &eqi |
| | | } |
| | |
| | | data, shmid := AttachRawShm(ctx, key) |
| | | shmdata := bytes2shmEsQueue(data) |
| | | eqi.EsCaches = ptr2esCache(unsafe.Pointer(&shmdata.cache), int(shmdata.capacity)) |
| | | fmt.Println("AttachQueue EsCaches:", eqi.EsCaches) |
| | | //fmt.Println("AttachQueue EsCaches:", eqi.EsCaches) |
| | | |
| | | eqi.Queue = shmdata |
| | | eqi.ShmKey = key |