()
| 120 | } |
| 121 | |
| 122 | func (u *upstream) IsBusy() bool { |
| 123 | u.isBusyMutex.Lock() |
| 124 | defer u.isBusyMutex.Unlock() |
| 125 | |
| 126 | return len(u.events) > 0 || u.isBusy |
| 127 | } |
| 128 | |
| 129 | func (u *upstream) IsInitialSyncing() bool { |
| 130 | u.initialSyncCompletedMutex.Lock() |
no test coverage detected