diff --git a/heap_manager.go b/heap_manager.go index 6d8169b..d4e39e0 100644 --- a/heap_manager.go +++ b/heap_manager.go @@ -43,7 +43,7 @@ for req := range m { switch req.cmd { case h_push: - data := req.data.(*pushData) + data := req.data.(pushData) heap.Push(&bHeap, data.bar) if !sync { sync = data.sync @@ -67,7 +67,7 @@ syncWidth(pMatrix) syncWidth(aMatrix) case h_iter: - data := req.data.(*iterData) + data := req.data.(iterData) for _, b := range bHeap { select { case data.iter <- b: @@ -76,7 +76,7 @@ } close(data.iter) case h_drain: - data := req.data.(*iterData) + data := req.data.(iterData) for bHeap.Len() != 0 { select { case data.iter <- heap.Pop(&bHeap).(*Bar): @@ -103,17 +103,17 @@ } func (m heapManager) push(b *Bar, sync bool) { - data := &pushData{b, sync} + data := pushData{b, sync} m <- heapRequest{cmd: h_push, data: data} } func (m heapManager) iter(iter chan *Bar, drop chan struct{}) { - data := &iterData{iter, drop} + data := iterData{iter, drop} m <- heapRequest{cmd: h_iter, data: data} } func (m heapManager) drain(iter chan *Bar, drop chan struct{}) { - data := &iterData{iter, drop} + data := iterData{iter, drop} m <- heapRequest{cmd: h_drain, data: data} }