Method addNote

engine/sync.go:212–223

addNote adds a notification to the synchronisation session. If the notes channel is full the session is marked as desynchronised and the notification is discarded.

(note *SyncNote)

// channel is full the session is marked as desynchronised and the notification
// is discarded.
func (ss *syncSession) addNote(note *SyncNote) {
	select {
	case ss.notes <- note:
	default:
		ss.Lock()
		if !ss.desync {
			log.Warningf("Sync session with %v is desynchronised", ss.node)
			ss.desync = true
		}
		ss.Unlock()
	}
}

// syncServer encapsulates the data for a synchronisation server.
type syncServer struct {