| | |
|---|
| | | 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 |
|---|
| | |
|---|
| | | // ReleaseQueue detach an exist shm queue |
|---|
| | | func (eqi *EsQueueInfo) ReleaseQueue() { |
|---|
| | | fmt.Printf("ReleaseQueue: key=%x\n", eqi.ShmKey) |
|---|
| | | DestroyShm(eqi.ShmData) |
|---|
| | | DetachShm(eqi.ShmData) |
|---|
| | | } |
|---|
| | | |
|---|
| | | // RemoveShmId remove an exist shm queue (ipcrm -m shmid) |
|---|
