mirror of
https://github.com/kubernetes/client-go.git
synced 2025-06-29 08:29:23 +00:00
Polished up HasSync comment
Kubernetes-commit: 168d0848299a625b9d4d2b85923efc60ed7de734
This commit is contained in:
parent
455d6109ca
commit
aea2fc6906
6
tools/cache/fifo.go
vendored
6
tools/cache/fifo.go
vendored
@ -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()
|
||||||
|
Loading…
Reference in New Issue
Block a user