Function NewModel

lib/model/model.go:215–266

NewModel creates and starts a new model. The model starts in read-only mode, where it sends index information to connected peers and responds to requests for file data without altering the local folder in any way.

(cfg config.Wrapper, id protocol.DeviceID, sdb db.DB, protectedFiles []string, evLogger events.Logger, keyGen *protocol.KeyGenerator)

// where it sends index information to connected peers and responds to requests
// for file data without altering the local folder in any way.
func NewModel(cfg config.Wrapper, id protocol.DeviceID, sdb db.DB, protectedFiles []string, evLogger events.Logger, keyGen *protocol.KeyGenerator) Model {
	spec := svcutil.SpecWithDebugLogger()
	m := &model{
		Supervisor: suture.New("model", spec),

		// constructor parameters
		cfg:            cfg,
		id:             id,
		sdb:            sdb,
		protectedFiles: protectedFiles,
		evLogger:       evLogger,

		// constant or concurrency safe fields
		progressEmitter:      NewProgressEmitter(cfg, evLogger),
		shortID:              id.Short(),
		globalRequestLimiter: semaphore.New(1024 * cfg.Options().MaxConcurrentIncomingRequestKiB()),
		folderIOLimiter:      semaphore.New(cfg.Options().MaxFolderConcurrency()),
		fatalChan:            make(chan error),
		started:              make(chan struct{}),
		keyGen:               keyGen,
		promotionTimer:       time.NewTimer(0),
		observed:             db.NewObservedDB(sdb),

		// fields protected by mut
		folderCfgs:                     make(map[string]config.FolderConfiguration),
		deviceStatRefs:                 make(map[protocol.DeviceID]*stats.DeviceStatisticsReference),
		folderIgnores:                  make(map[string]*ignore.Matcher),
		folderRunners:                  newServiceMap[string, service](evLogger),
		folderVersioners:               make(map[string]versioner.Versioner),
		folderEncryptionPasswordTokens: make(map[string][]byte),
		folderEncryptionFailures:       make(map[string]map[protocol.DeviceID]error),
		connections:                    make(map[string]protocol.Connection),
		deviceConnIDs:                  make(map[protocol.DeviceID][]string),
		promotedConnID:                 make(map[protocol.DeviceID]string),
		connRequestLimiters:            make(map[protocol.DeviceID]*semaphore.Semaphore),
		closed:                         make(map[string]chan struct{}),
		helloMessages:                  make(map[protocol.DeviceID]protocol.Hello),
		deviceDownloads:                make(map[protocol.DeviceID]*deviceDownloadState),
		remoteFolderStates:             make(map[protocol.DeviceID]map[string]remoteFolderState),
		indexHandlers:                  newServiceMap[protocol.DeviceID, *indexHandlerRegistry](evLogger),
	}
	for devID, cfg := range cfg.Devices() {
		m.deviceStatRefs[devID] = stats.NewDeviceStatisticsReference(db.NewTyped(sdb, "devicestats/"+devID.String()))
		m.setConnRequestLimitersLocked(cfg)
	}
	m.Add(m.folderRunners)
	m.Add(m.progressEmitter)
	m.Add(m.indexHandlers)
	m.Add(svcutil.AsService(m.serve, m.String()))

	return m
}

func (m *model) serve(ctx context.Context) error {
	defer m.closeAllConnectionsAndWait()