(event EventMsg)
| 28 | } |
| 29 | |
| 30 | func (this *EventQueue) Push(event EventMsg) { |
| 31 | this.ev_queue.Push(event) |
| 32 | atomic.AddInt32(&this.q, 1) |
| 33 | |
| 34 | if this.notify_one() == true { |
| 35 | select { |
| 36 | case this.ev_cond <- true: |
| 37 | default: |
| 38 | } |
| 39 | } |
| 40 | } |
| 41 | |
| 42 | func (this *EventQueue) Get(event_list []interface{}, count uint32) uint32 { |
| 43 | if atomic.LoadInt32(&this.q) < 0 { |
nothing calls this directly
no test coverage detected