| | |
|---|
| | | 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 |
|---|
