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, ok := <-syncer.watcher.Events:
92 lerr := syncer.netPlugin.Load(syncer.loadOpts...)
97 syncer.updateLastStatus(lerr)
99 case err := <-syncer.watcher.Errors:
109 func (syncer *cniNetConfSyncer) lastStatus() error {
110 syncer.RLock()
111 defer syncer.RUnlock()
112 return syncer.lastSyncStatus
116 func (syncer *cniNetConfSyncer) updateLastStatus(err error) {
117 syncer.Lock()
118 defer syncer.Unlock()
119 syncer.lastSyncStatus = err
123 func (syncer *cniNetConfSyncer) stop() error {
124 return syncer.watcher.Close()