mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-21 10:51:29 +00:00
Merge pull request #514 from brendandburns/fix
Insert a couple of sleeps to slow things down.
This commit is contained in:
commit
7d0b8e0c1c
@ -76,14 +76,17 @@ func (s ConfigSourceFile) Run() {
|
|||||||
var lastServices []api.Service
|
var lastServices []api.Service
|
||||||
var lastEndpoints []api.Endpoints
|
var lastEndpoints []api.Endpoints
|
||||||
|
|
||||||
|
sleep := 5 * time.Second
|
||||||
for {
|
for {
|
||||||
data, err := ioutil.ReadFile(s.filename)
|
data, err := ioutil.ReadFile(s.filename)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
glog.Errorf("Couldn't read file: %s : %v", s.filename, err)
|
glog.Errorf("Couldn't read file: %s : %v", s.filename, err)
|
||||||
|
time.Sleep(sleep)
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
if bytes.Equal(lastData, data) {
|
if bytes.Equal(lastData, data) {
|
||||||
|
time.Sleep(sleep)
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
lastData = data
|
lastData = data
|
||||||
@ -112,6 +115,6 @@ func (s ConfigSourceFile) Run() {
|
|||||||
lastEndpoints = newEndpoints
|
lastEndpoints = newEndpoints
|
||||||
}
|
}
|
||||||
|
|
||||||
time.Sleep(5 * time.Second)
|
time.Sleep(sleep)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user