()
| 185 | } |
| 186 | |
| 187 | func (u *upstream) getEvents() []notify.EventInfo { |
| 188 | var eventsRef []notify.EventInfo |
| 189 | u.eventBufferMutex.Lock() |
| 190 | defer u.eventBufferMutex.Unlock() |
| 191 | |
| 192 | // exchange buffer if we got events |
| 193 | if len(u.eventBuffer) > 0 { |
| 194 | eventsRef = u.eventBuffer |
| 195 | u.eventBuffer = make([]notify.EventInfo, 0, 64) |
| 196 | } |
| 197 | |
| 198 | return eventsRef |
| 199 | } |
| 200 | |
| 201 | func (u *upstream) mainLoop() error { |
| 202 | doneChan := make(chan struct{}) |