(n int)
| 123 | func (s *daemonState) pushM(data float64) { |
| 124 | s.Lock() |
| 125 | defer s.Unlock() |
| 126 | s.mmms.Value = data |
| 127 | s.mmms = s.mmms.Next() |
| 128 | } |
| 129 | |
| 130 | func (s *daemonState) takeM(n int) []float64 { |
| 131 | s.Lock() |
| 132 | defer s.Unlock() |
| 133 | result := []float64{} |
| 134 | r := s.mmms.Prev() |
| 135 | for range n { |
| 136 | if r.Value == nil { |
| 137 | continue |
| 138 | } |
| 139 | result = append(result, r.Value.(float64)) |
| 140 | r = r.Prev() |
| 141 | } |