github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-22 19:31:44 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #91174 from jqmichael/updateHasSyncDoc

Browse Source 
Polished up comments around HasSynced()
This commit is contained in:
Kubernetes Prow Robot 2020-05-19 15:22:48 -07:00 committed by GitHub
commit e5ead81bb0
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
staging/src/k8s.io/client-go/tools/cache/fifo.go vendored
View File

@ -71,8 +71,8 @@ type Queue interface {
// HasSynced returns true if the first batch of keys have all been // HasSynced returns true if the first batch of keys have all been
// popped. The first batch of keys are those of the first Replace // popped. The first batch of keys are those of the first Replace
// operation if that happened before any Add, Update, or Delete; // operation if that happened before any Add, AddIfNotPresent,
// otherwise the first batch is empty. // Update, or Delete; otherwise the first batch is empty.
HasSynced() bool HasSynced() bool
// Close the queue // Close the queue
@ -145,7 +145,7 @@ func (f *FIFO) Close() {
} }
// HasSynced returns true if an Add/Update/Delete/AddIfNotPresent are called first, // HasSynced returns true if an Add/Update/Delete/AddIfNotPresent are called first,
// or an Update called first but the first batch of items inserted by Replace() has been popped // or the first batch of items inserted by Replace() has been popped.
func (f *FIFO) HasSynced() bool { func (f *FIFO) HasSynced() bool {
f.lock.Lock() f.lock.Lock()
defer f.lock.Unlock() defer f.lock.Unlock()