Lines Matching refs:syncer
57 syncer := &cniNetConfSyncer{
64 if err := syncer.netPlugin.Load(syncer.loadOpts...); err != nil {
66 syncer.updateLastStatus(err)
68 return syncer, nil
73 func (syncer *cniNetConfSyncer) syncLoop() error {
76 case event := <-syncer.watcher.Events:
88 lerr := syncer.netPlugin.Load(syncer.loadOpts...)
93 syncer.updateLastStatus(lerr)
95 case err := <-syncer.watcher.Errors:
105 func (syncer *cniNetConfSyncer) lastStatus() error {
106 syncer.RLock()
107 defer syncer.RUnlock()
108 return syncer.lastSyncStatus
112 func (syncer *cniNetConfSyncer) updateLastStatus(err error) {
113 syncer.Lock()
114 defer syncer.Unlock()
115 syncer.lastSyncStatus = err
119 func (syncer *cniNetConfSyncer) stop() error {
120 return syncer.watcher.Close()