(userWaiter *ChangeWaiter)
| 167 | } |
| 168 | |
| 169 | func WaitForUserWaiterChange(userWaiter *ChangeWaiter) bool { |
| 170 | var isChanged bool |
| 171 | for i := 0; i < 100; i++ { |
| 172 | isChanged = userWaiter.RefreshUserCount() |
| 173 | if isChanged { |
| 174 | break |
| 175 | } |
| 176 | time.Sleep(10 * time.Millisecond) |
| 177 | } |
| 178 | return isChanged |
| 179 | } |
| 180 | |
| 181 | // purgeWithDCPFeed purges all documents seen on a DCP feed with system xattrs, including tombstones. |
| 182 | func purgeWithDCPFeed(ctx context.Context, bucket base.Bucket, tbp *base.TestBucketPool) error { |