53245449fd
Bumps [github.com/onsi/ginkgo](https://github.com/onsi/ginkgo) from 1.14.0 to 1.16.5. - [Release notes](https://github.com/onsi/ginkgo/releases) - [Changelog](https://github.com/onsi/ginkgo/blob/master/CHANGELOG.md) - [Commits](https://github.com/onsi/ginkgo/compare/v1.14.0...v1.16.5) --- updated-dependencies: - dependency-name: github.com/onsi/ginkgo dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <support@github.com>
38 lines
1.0 KiB
Go
38 lines
1.0 KiB
Go
// Copyright (c) 2019 FOSS contributors of https://github.com/nxadm/tail
|
|
package watch
|
|
|
|
type FileChanges struct {
|
|
Modified chan bool // Channel to get notified of modifications
|
|
Truncated chan bool // Channel to get notified of truncations
|
|
Deleted chan bool // Channel to get notified of deletions/renames
|
|
}
|
|
|
|
func NewFileChanges() *FileChanges {
|
|
return &FileChanges{
|
|
make(chan bool, 1), make(chan bool, 1), make(chan bool, 1)}
|
|
}
|
|
|
|
func (fc *FileChanges) NotifyModified() {
|
|
sendOnlyIfEmpty(fc.Modified)
|
|
}
|
|
|
|
func (fc *FileChanges) NotifyTruncated() {
|
|
sendOnlyIfEmpty(fc.Truncated)
|
|
}
|
|
|
|
func (fc *FileChanges) NotifyDeleted() {
|
|
sendOnlyIfEmpty(fc.Deleted)
|
|
}
|
|
|
|
// sendOnlyIfEmpty sends on a bool channel only if the channel has no
|
|
// backlog to be read by other goroutines. This concurrency pattern
|
|
// can be used to notify other goroutines if and only if they are
|
|
// looking for it (i.e., subsequent notifications can be compressed
|
|
// into one).
|
|
func sendOnlyIfEmpty(ch chan bool) {
|
|
select {
|
|
case ch <- true:
|
|
default:
|
|
}
|
|
}
|