mirror of https://github.com/k3s-io/k3s
watch/iowatcher should log non EOF errors encountered
parent
9a0add3c96
commit
6778a8d88d
|
@ -17,10 +17,12 @@ limitations under the License.
|
|||
package watch
|
||||
|
||||
import (
|
||||
"io"
|
||||
"sync"
|
||||
|
||||
"github.com/GoogleCloudPlatform/kubernetes/pkg/runtime"
|
||||
"github.com/GoogleCloudPlatform/kubernetes/pkg/util"
|
||||
"github.com/golang/glog"
|
||||
)
|
||||
|
||||
// Decoder allows StreamWatcher to watch any stream for which a Decoder can be written.
|
||||
|
@ -82,6 +84,9 @@ func (sw *StreamWatcher) receive() {
|
|||
for {
|
||||
action, obj, err := sw.source.Decode()
|
||||
if err != nil {
|
||||
if err != io.EOF {
|
||||
glog.Errorf("Unable to decode an event from the watch stream: %v", err)
|
||||
}
|
||||
return
|
||||
}
|
||||
sw.result <- Event{
|
||||
|
|
Loading…
Reference in New Issue