diff --git a/websocket.go b/websocket.go index 70837bd..8073467 100644 --- a/websocket.go +++ b/websocket.go @@ -119,9 +119,10 @@ func queueHandler(w http.ResponseWriter, r *http.Request) { return } - countPutPop.Use(func(item *CountPutPop) { - item.PopCount++ - item.SelfCount[raddr.String()]++ + countPutPop.Use(func(citem *CountPutPop) { + citem.PopCount++ + citem.SelfCount[raddr.String()]++ + log.Printf("all put %d, all pop %d source[%s] -> self[%s] pop %d\n", citem.PutCount, citem.PopCount, item.Source, raddr.String(), citem.SelfCount[raddr.String()]) }) logIntervalTimeHandler.Notify(countPutPop) // 打印消息