model.go 87 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893
  1. // Copyright (C) 2014 The Syncthing Authors.
  2. //
  3. // This Source Code Form is subject to the terms of the Mozilla Public
  4. // License, v. 2.0. If a copy of the MPL was not distributed with this file,
  5. // You can obtain one at https://mozilla.org/MPL/2.0/.
  6. package model
  7. import (
  8. "bytes"
  9. "context"
  10. "encoding/json"
  11. "fmt"
  12. "io"
  13. "net"
  14. "path/filepath"
  15. "reflect"
  16. "runtime"
  17. "strings"
  18. stdsync "sync"
  19. "time"
  20. "github.com/pkg/errors"
  21. "github.com/thejerf/suture/v4"
  22. "github.com/syncthing/syncthing/lib/config"
  23. "github.com/syncthing/syncthing/lib/connections"
  24. "github.com/syncthing/syncthing/lib/db"
  25. "github.com/syncthing/syncthing/lib/events"
  26. "github.com/syncthing/syncthing/lib/fs"
  27. "github.com/syncthing/syncthing/lib/ignore"
  28. "github.com/syncthing/syncthing/lib/osutil"
  29. "github.com/syncthing/syncthing/lib/protocol"
  30. "github.com/syncthing/syncthing/lib/scanner"
  31. "github.com/syncthing/syncthing/lib/stats"
  32. "github.com/syncthing/syncthing/lib/sync"
  33. "github.com/syncthing/syncthing/lib/ur/contract"
  34. "github.com/syncthing/syncthing/lib/util"
  35. "github.com/syncthing/syncthing/lib/versioner"
  36. )
  37. // How many files to send in each Index/IndexUpdate message.
  38. const (
  39. maxBatchSizeBytes = 250 * 1024 // Aim for making index messages no larger than 250 KiB (uncompressed)
  40. maxBatchSizeFiles = 1000 // Either way, don't include more files than this
  41. )
  42. type service interface {
  43. suture.Service
  44. BringToFront(string)
  45. Override()
  46. Revert()
  47. DelayScan(d time.Duration)
  48. SchedulePull() // something relevant changed, we should try a pull
  49. Jobs(page, perpage int) ([]string, []string, int) // In progress, Queued, skipped
  50. Scan(subs []string) error
  51. Errors() []FileError
  52. WatchError() error
  53. ScheduleForceRescan(path string)
  54. GetStatistics() (stats.FolderStatistics, error)
  55. getState() (folderState, time.Time, error)
  56. }
  57. type Availability struct {
  58. ID protocol.DeviceID `json:"id"`
  59. FromTemporary bool `json:"fromTemporary"`
  60. }
  61. type Model interface {
  62. suture.Service
  63. connections.Model
  64. ResetFolder(folder string)
  65. DelayScan(folder string, next time.Duration)
  66. ScanFolder(folder string) error
  67. ScanFolders() map[string]error
  68. ScanFolderSubdirs(folder string, subs []string) error
  69. State(folder string) (string, time.Time, error)
  70. FolderErrors(folder string) ([]FileError, error)
  71. WatchError(folder string) error
  72. Override(folder string)
  73. Revert(folder string)
  74. BringToFront(folder, file string)
  75. GetIgnores(folder string) ([]string, []string, error)
  76. SetIgnores(folder string, content []string) error
  77. GetFolderVersions(folder string) (map[string][]versioner.FileVersion, error)
  78. RestoreFolderVersions(folder string, versions map[string]time.Time) (map[string]string, error)
  79. DBSnapshot(folder string) (*db.Snapshot, error)
  80. NeedFolderFiles(folder string, page, perpage int) ([]db.FileInfoTruncated, []db.FileInfoTruncated, []db.FileInfoTruncated, error)
  81. RemoteNeedFolderFiles(folder string, device protocol.DeviceID, page, perpage int) ([]db.FileInfoTruncated, error)
  82. LocalChangedFolderFiles(folder string, page, perpage int) ([]db.FileInfoTruncated, error)
  83. FolderProgressBytesCompleted(folder string) int64
  84. CurrentFolderFile(folder string, file string) (protocol.FileInfo, bool)
  85. CurrentGlobalFile(folder string, file string) (protocol.FileInfo, bool)
  86. Availability(folder string, file protocol.FileInfo, block protocol.BlockInfo) []Availability
  87. Completion(device protocol.DeviceID, folder string) FolderCompletion
  88. ConnectionStats() map[string]interface{}
  89. DeviceStatistics() (map[string]stats.DeviceStatistics, error)
  90. FolderStatistics() (map[string]stats.FolderStatistics, error)
  91. UsageReportingStats(report *contract.Report, version int, preview bool)
  92. StartDeadlockDetector(timeout time.Duration)
  93. GlobalDirectoryTree(folder, prefix string, levels int, dirsonly bool) map[string]interface{}
  94. }
  95. type model struct {
  96. *suture.Supervisor
  97. // constructor parameters
  98. cfg config.Wrapper
  99. id protocol.DeviceID
  100. clientName string
  101. clientVersion string
  102. db *db.Lowlevel
  103. protectedFiles []string
  104. evLogger events.Logger
  105. // constant or concurrency safe fields
  106. finder *db.BlockFinder
  107. progressEmitter *ProgressEmitter
  108. shortID protocol.ShortID
  109. // globalRequestLimiter limits the amount of data in concurrent incoming
  110. // requests
  111. globalRequestLimiter *byteSemaphore
  112. // folderIOLimiter limits the number of concurrent I/O heavy operations,
  113. // such as scans and pulls.
  114. folderIOLimiter *byteSemaphore
  115. // fields protected by fmut
  116. fmut sync.RWMutex
  117. folderCfgs map[string]config.FolderConfiguration // folder -> cfg
  118. folderFiles map[string]*db.FileSet // folder -> files
  119. deviceStatRefs map[protocol.DeviceID]*stats.DeviceStatisticsReference // deviceID -> statsRef
  120. folderIgnores map[string]*ignore.Matcher // folder -> matcher object
  121. folderRunners map[string]service // folder -> puller or scanner
  122. folderRunnerToken map[string]suture.ServiceToken // folder -> token for folder runner
  123. folderRestartMuts syncMutexMap // folder -> restart mutex
  124. folderVersioners map[string]versioner.Versioner // folder -> versioner (may be nil)
  125. folderEncryptionPasswordTokens map[string][]byte // folder -> encryption token (may be missing, and only for encryption type folders)
  126. folderEncryptionFailures map[string]map[protocol.DeviceID]error // folder -> device -> error regarding encryption consistency (may be missing)
  127. // fields protected by pmut
  128. pmut sync.RWMutex
  129. conn map[protocol.DeviceID]connections.Connection
  130. connRequestLimiters map[protocol.DeviceID]*byteSemaphore
  131. closed map[protocol.DeviceID]chan struct{}
  132. helloMessages map[protocol.DeviceID]protocol.Hello
  133. deviceDownloads map[protocol.DeviceID]*deviceDownloadState
  134. remotePausedFolders map[protocol.DeviceID]map[string]struct{} // deviceID -> folders
  135. indexSenders map[protocol.DeviceID]*indexSenderRegistry
  136. // for testing only
  137. foldersRunning int32
  138. started chan struct{}
  139. }
  140. type folderFactory func(*model, *db.FileSet, *ignore.Matcher, config.FolderConfiguration, versioner.Versioner, fs.Filesystem, events.Logger, *byteSemaphore) service
  141. var (
  142. folderFactories = make(map[config.FolderType]folderFactory)
  143. )
  144. var (
  145. errDeviceUnknown = errors.New("unknown device")
  146. errDevicePaused = errors.New("device is paused")
  147. errDeviceIgnored = errors.New("device is ignored")
  148. errDeviceRemoved = errors.New("device has been removed")
  149. ErrFolderPaused = errors.New("folder is paused")
  150. errFolderNotRunning = errors.New("folder is not running")
  151. errFolderMissing = errors.New("no such folder")
  152. errNetworkNotAllowed = errors.New("network not allowed")
  153. errNoVersioner = errors.New("folder has no versioner")
  154. // errors about why a connection is closed
  155. errIgnoredFolderRemoved = errors.New("folder no longer ignored")
  156. errReplacingConnection = errors.New("replacing connection")
  157. errStopped = errors.New("Syncthing is being stopped")
  158. errEncryptionInvConfigLocal = errors.New("can't encrypt data for a device when the folder type is receiveEncrypted")
  159. errEncryptionInvConfigRemote = errors.New("remote has encrypted data and encrypts that data for us - this is impossible")
  160. errEncryptionNotEncryptedLocal = errors.New("folder is announced as encrypted, but not configured thus")
  161. errEncryptionNotEncryptedRemote = errors.New("folder is configured to be encrypted but not announced thus")
  162. errEncryptionNotEncryptedUntrusted = errors.New("device is untrusted, but configured to receive not encrypted data")
  163. errEncryptionPassword = errors.New("different encryption passwords used")
  164. errEncryptionReceivedToken = errors.New("resetting connection to send info on new encrypted folder (new cluster config)")
  165. errMissingRemoteInClusterConfig = errors.New("remote device missing in cluster config")
  166. errMissingLocalInClusterConfig = errors.New("local device missing in cluster config")
  167. )
  168. // NewModel creates and starts a new model. The model starts in read-only mode,
  169. // where it sends index information to connected peers and responds to requests
  170. // for file data without altering the local folder in any way.
  171. func NewModel(cfg config.Wrapper, id protocol.DeviceID, clientName, clientVersion string, ldb *db.Lowlevel, protectedFiles []string, evLogger events.Logger) Model {
  172. spec := util.Spec()
  173. spec.EventHook = func(e suture.Event) {
  174. l.Debugln(e)
  175. }
  176. m := &model{
  177. Supervisor: suture.New("model", spec),
  178. // constructor parameters
  179. cfg: cfg,
  180. id: id,
  181. clientName: clientName,
  182. clientVersion: clientVersion,
  183. db: ldb,
  184. protectedFiles: protectedFiles,
  185. evLogger: evLogger,
  186. // constant or concurrency safe fields
  187. finder: db.NewBlockFinder(ldb),
  188. progressEmitter: NewProgressEmitter(cfg, evLogger),
  189. shortID: id.Short(),
  190. globalRequestLimiter: newByteSemaphore(1024 * cfg.Options().MaxConcurrentIncomingRequestKiB()),
  191. folderIOLimiter: newByteSemaphore(cfg.Options().MaxFolderConcurrency()),
  192. // fields protected by fmut
  193. fmut: sync.NewRWMutex(),
  194. folderCfgs: make(map[string]config.FolderConfiguration),
  195. folderFiles: make(map[string]*db.FileSet),
  196. deviceStatRefs: make(map[protocol.DeviceID]*stats.DeviceStatisticsReference),
  197. folderIgnores: make(map[string]*ignore.Matcher),
  198. folderRunners: make(map[string]service),
  199. folderRunnerToken: make(map[string]suture.ServiceToken),
  200. folderVersioners: make(map[string]versioner.Versioner),
  201. folderEncryptionPasswordTokens: make(map[string][]byte),
  202. folderEncryptionFailures: make(map[string]map[protocol.DeviceID]error),
  203. // fields protected by pmut
  204. pmut: sync.NewRWMutex(),
  205. conn: make(map[protocol.DeviceID]connections.Connection),
  206. connRequestLimiters: make(map[protocol.DeviceID]*byteSemaphore),
  207. closed: make(map[protocol.DeviceID]chan struct{}),
  208. helloMessages: make(map[protocol.DeviceID]protocol.Hello),
  209. deviceDownloads: make(map[protocol.DeviceID]*deviceDownloadState),
  210. remotePausedFolders: make(map[protocol.DeviceID]map[string]struct{}),
  211. indexSenders: make(map[protocol.DeviceID]*indexSenderRegistry),
  212. // for testing only
  213. started: make(chan struct{}),
  214. }
  215. for devID := range cfg.Devices() {
  216. m.deviceStatRefs[devID] = stats.NewDeviceStatisticsReference(m.db, devID.String())
  217. }
  218. m.Add(m.progressEmitter)
  219. m.Add(util.AsService(m.serve, m.String()))
  220. return m
  221. }
  222. func (m *model) serve(ctx context.Context) error {
  223. // Add and start folders
  224. cacheIgnoredFiles := m.cfg.Options().CacheIgnoredFiles
  225. clusterConfigDevices := make(deviceIDSet, len(m.cfg.Devices()))
  226. for _, folderCfg := range m.cfg.Folders() {
  227. if folderCfg.Paused {
  228. folderCfg.CreateRoot()
  229. continue
  230. }
  231. m.newFolder(folderCfg, cacheIgnoredFiles)
  232. clusterConfigDevices.add(folderCfg.DeviceIDs())
  233. }
  234. m.resendClusterConfig(clusterConfigDevices.AsSlice())
  235. m.cfg.Subscribe(m)
  236. close(m.started)
  237. <-ctx.Done()
  238. m.cfg.Unsubscribe(m)
  239. m.pmut.RLock()
  240. closed := make([]chan struct{}, 0, len(m.conn))
  241. for id, conn := range m.conn {
  242. closed = append(closed, m.closed[id])
  243. go conn.Close(errStopped)
  244. }
  245. m.pmut.RUnlock()
  246. for _, c := range closed {
  247. <-c
  248. }
  249. return nil
  250. }
  251. // StartDeadlockDetector starts a deadlock detector on the models locks which
  252. // causes panics in case the locks cannot be acquired in the given timeout
  253. // period.
  254. func (m *model) StartDeadlockDetector(timeout time.Duration) {
  255. l.Infof("Starting deadlock detector with %v timeout", timeout)
  256. detector := newDeadlockDetector(timeout)
  257. detector.Watch("fmut", m.fmut)
  258. detector.Watch("pmut", m.pmut)
  259. }
  260. // Need to hold lock on m.fmut when calling this.
  261. func (m *model) addAndStartFolderLocked(cfg config.FolderConfiguration, fset *db.FileSet, cacheIgnoredFiles bool) {
  262. ignores := ignore.New(cfg.Filesystem(), ignore.WithCache(cacheIgnoredFiles))
  263. if err := ignores.Load(".stignore"); err != nil && !fs.IsNotExist(err) {
  264. l.Warnln("Loading ignores:", err)
  265. }
  266. m.addAndStartFolderLockedWithIgnores(cfg, fset, ignores)
  267. }
  268. // Only needed for testing, use addAndStartFolderLocked instead.
  269. func (m *model) addAndStartFolderLockedWithIgnores(cfg config.FolderConfiguration, fset *db.FileSet, ignores *ignore.Matcher) {
  270. m.folderCfgs[cfg.ID] = cfg
  271. m.folderFiles[cfg.ID] = fset
  272. m.folderIgnores[cfg.ID] = ignores
  273. _, ok := m.folderRunners[cfg.ID]
  274. if ok {
  275. l.Warnln("Cannot start already running folder", cfg.Description())
  276. panic("cannot start already running folder")
  277. }
  278. folderFactory, ok := folderFactories[cfg.Type]
  279. if !ok {
  280. panic(fmt.Sprintf("unknown folder type 0x%x", cfg.Type))
  281. }
  282. folder := cfg.ID
  283. // Find any devices for which we hold the index in the db, but the folder
  284. // is not shared, and drop it.
  285. expected := mapDevices(cfg.DeviceIDs())
  286. for _, available := range fset.ListDevices() {
  287. if _, ok := expected[available]; !ok {
  288. l.Debugln("dropping", folder, "state for", available)
  289. fset.Drop(available)
  290. }
  291. }
  292. v, ok := fset.Sequence(protocol.LocalDeviceID), true
  293. indexHasFiles := ok && v > 0
  294. if !indexHasFiles {
  295. // It's a blank folder, so this may the first time we're looking at
  296. // it. Attempt to create and tag with our marker as appropriate. We
  297. // don't really do anything with errors at this point except warn -
  298. // if these things don't work, we still want to start the folder and
  299. // it'll show up as errored later.
  300. if err := cfg.CreateRoot(); err != nil {
  301. l.Warnln("Failed to create folder root directory", err)
  302. } else if err = cfg.CreateMarker(); err != nil {
  303. l.Warnln("Failed to create folder marker:", err)
  304. }
  305. }
  306. ffs := fset.MtimeFS()
  307. if cfg.Type == config.FolderTypeReceiveEncrypted {
  308. if encryptionToken, err := readEncryptionToken(cfg); err == nil {
  309. m.folderEncryptionPasswordTokens[folder] = encryptionToken
  310. } else if !fs.IsNotExist(err) {
  311. l.Warnf("Failed to read encryption token: %v", err)
  312. }
  313. }
  314. // These are our metadata files, and they should always be hidden.
  315. _ = ffs.Hide(config.DefaultMarkerName)
  316. _ = ffs.Hide(".stversions")
  317. _ = ffs.Hide(".stignore")
  318. var ver versioner.Versioner
  319. if cfg.Versioning.Type != "" {
  320. var err error
  321. ver, err = versioner.New(cfg)
  322. if err != nil {
  323. panic(fmt.Errorf("creating versioner: %w", err))
  324. }
  325. }
  326. m.folderVersioners[folder] = ver
  327. p := folderFactory(m, fset, ignores, cfg, ver, ffs, m.evLogger, m.folderIOLimiter)
  328. m.folderRunners[folder] = p
  329. m.warnAboutOverwritingProtectedFiles(cfg, ignores)
  330. m.folderRunnerToken[folder] = m.Add(p)
  331. l.Infof("Ready to synchronize %s (%s)", cfg.Description(), cfg.Type)
  332. }
  333. func (m *model) warnAboutOverwritingProtectedFiles(cfg config.FolderConfiguration, ignores *ignore.Matcher) {
  334. if cfg.Type == config.FolderTypeSendOnly {
  335. return
  336. }
  337. // This is a bit of a hack.
  338. ffs := cfg.Filesystem()
  339. if ffs.Type() != fs.FilesystemTypeBasic {
  340. return
  341. }
  342. folderLocation := ffs.URI()
  343. var filesAtRisk []string
  344. for _, protectedFilePath := range m.protectedFiles {
  345. // check if file is synced in this folder
  346. if protectedFilePath != folderLocation && !fs.IsParent(protectedFilePath, folderLocation) {
  347. continue
  348. }
  349. // check if file is ignored
  350. relPath, _ := filepath.Rel(folderLocation, protectedFilePath)
  351. if ignores.Match(relPath).IsIgnored() {
  352. continue
  353. }
  354. filesAtRisk = append(filesAtRisk, protectedFilePath)
  355. }
  356. if len(filesAtRisk) > 0 {
  357. l.Warnln("Some protected files may be overwritten and cause issues. See https://docs.syncthing.net/users/config.html#syncing-configuration-files for more information. The at risk files are:", strings.Join(filesAtRisk, ", "))
  358. }
  359. }
  360. func (m *model) removeFolder(cfg config.FolderConfiguration) {
  361. m.fmut.RLock()
  362. token, ok := m.folderRunnerToken[cfg.ID]
  363. m.fmut.RUnlock()
  364. if ok {
  365. m.RemoveAndWait(token, 0)
  366. }
  367. // We need to hold both fmut and pmut and must acquire locks in the same
  368. // order always. (The locks can be *released* in any order.)
  369. m.fmut.Lock()
  370. m.pmut.RLock()
  371. isPathUnique := true
  372. for folderID, folderCfg := range m.folderCfgs {
  373. if folderID != cfg.ID && folderCfg.Path == cfg.Path {
  374. isPathUnique = false
  375. break
  376. }
  377. }
  378. if isPathUnique {
  379. // Delete syncthing specific files
  380. cfg.Filesystem().RemoveAll(config.DefaultMarkerName)
  381. }
  382. m.cleanupFolderLocked(cfg)
  383. for _, r := range m.indexSenders {
  384. r.remove(cfg.ID)
  385. }
  386. m.fmut.Unlock()
  387. m.pmut.RUnlock()
  388. // Remove it from the database
  389. db.DropFolder(m.db, cfg.ID)
  390. }
  391. // Need to hold lock on m.fmut when calling this.
  392. func (m *model) cleanupFolderLocked(cfg config.FolderConfiguration) {
  393. // clear up our config maps
  394. delete(m.folderCfgs, cfg.ID)
  395. delete(m.folderFiles, cfg.ID)
  396. delete(m.folderIgnores, cfg.ID)
  397. delete(m.folderRunners, cfg.ID)
  398. delete(m.folderRunnerToken, cfg.ID)
  399. delete(m.folderVersioners, cfg.ID)
  400. }
  401. func (m *model) restartFolder(from, to config.FolderConfiguration, cacheIgnoredFiles bool) {
  402. if len(to.ID) == 0 {
  403. panic("bug: cannot restart empty folder ID")
  404. }
  405. if to.ID != from.ID {
  406. l.Warnf("bug: folder restart cannot change ID %q -> %q", from.ID, to.ID)
  407. panic("bug: folder restart cannot change ID")
  408. }
  409. folder := to.ID
  410. // This mutex protects the entirety of the restart operation, preventing
  411. // there from being more than one folder restart operation in progress
  412. // at any given time. The usual fmut/pmut stuff doesn't cover this,
  413. // because those locks are released while we are waiting for the folder
  414. // to shut down (and must be so because the folder might need them as
  415. // part of its operations before shutting down).
  416. restartMut := m.folderRestartMuts.Get(folder)
  417. restartMut.Lock()
  418. defer restartMut.Unlock()
  419. m.fmut.RLock()
  420. token, ok := m.folderRunnerToken[from.ID]
  421. m.fmut.RUnlock()
  422. if ok {
  423. m.RemoveAndWait(token, 0)
  424. }
  425. m.fmut.Lock()
  426. defer m.fmut.Unlock()
  427. // Cache the (maybe) existing fset before it's removed by cleanupFolderLocked
  428. fset := m.folderFiles[folder]
  429. fsetNil := fset == nil
  430. m.cleanupFolderLocked(from)
  431. if !to.Paused {
  432. if fsetNil {
  433. // Create a new fset. Might take a while and we do it under
  434. // locking, but it's unsafe to create fset:s concurrently so
  435. // that's the price we pay.
  436. fset = db.NewFileSet(folder, to.Filesystem(), m.db)
  437. }
  438. m.addAndStartFolderLocked(to, fset, cacheIgnoredFiles)
  439. }
  440. // Care needs to be taken because we already hold fmut and the lock order
  441. // must be the same everywhere. As fmut is acquired first, this is fine.
  442. // toDeviceIDs := to.DeviceIDs()
  443. m.pmut.RLock()
  444. for _, id := range to.DeviceIDs() {
  445. indexSenders, ok := m.indexSenders[id]
  446. if !ok {
  447. continue
  448. }
  449. // In case the folder was newly shared with us we already got a
  450. // cluster config and wont necessarily get another soon - start
  451. // sending indexes if connected.
  452. if to.Paused {
  453. indexSenders.pause(to.ID)
  454. } else if !from.SharedWith(indexSenders.deviceID) || fsetNil || from.Paused {
  455. indexSenders.resume(to, fset)
  456. }
  457. }
  458. m.pmut.RUnlock()
  459. var infoMsg string
  460. switch {
  461. case to.Paused:
  462. infoMsg = "Paused"
  463. case from.Paused:
  464. infoMsg = "Unpaused"
  465. default:
  466. infoMsg = "Restarted"
  467. }
  468. l.Infof("%v folder %v (%v)", infoMsg, to.Description(), to.Type)
  469. }
  470. func (m *model) newFolder(cfg config.FolderConfiguration, cacheIgnoredFiles bool) {
  471. // Creating the fileset can take a long time (metadata calculation) so
  472. // we do it outside of the lock.
  473. fset := db.NewFileSet(cfg.ID, cfg.Filesystem(), m.db)
  474. m.fmut.Lock()
  475. defer m.fmut.Unlock()
  476. // Cluster configs might be received and processed before reaching this
  477. // point, i.e. before the folder is started. If that's the case, start
  478. // index senders here.
  479. m.pmut.RLock()
  480. for _, id := range cfg.DeviceIDs() {
  481. if is, ok := m.indexSenders[id]; ok {
  482. is.resume(cfg, fset)
  483. }
  484. }
  485. m.pmut.RUnlock()
  486. m.addAndStartFolderLocked(cfg, fset, cacheIgnoredFiles)
  487. }
  488. func (m *model) UsageReportingStats(report *contract.Report, version int, preview bool) {
  489. if version >= 3 {
  490. // Block stats
  491. blockStatsMut.Lock()
  492. for k, v := range blockStats {
  493. switch k {
  494. case "total":
  495. report.BlockStats.Total = v
  496. case "renamed":
  497. report.BlockStats.Renamed = v
  498. case "reused":
  499. report.BlockStats.Reused = v
  500. case "pulled":
  501. report.BlockStats.Pulled = v
  502. case "copyOrigin":
  503. report.BlockStats.CopyOrigin = v
  504. case "copyOriginShifted":
  505. report.BlockStats.CopyOriginShifted = v
  506. case "copyElsewhere":
  507. report.BlockStats.CopyElsewhere = v
  508. }
  509. // Reset counts, as these are incremental
  510. if !preview {
  511. blockStats[k] = 0
  512. }
  513. }
  514. blockStatsMut.Unlock()
  515. // Transport stats
  516. m.pmut.RLock()
  517. for _, conn := range m.conn {
  518. report.TransportStats[conn.Transport()]++
  519. }
  520. m.pmut.RUnlock()
  521. // Ignore stats
  522. var seenPrefix [3]bool
  523. for folder := range m.cfg.Folders() {
  524. lines, _, err := m.GetIgnores(folder)
  525. if err != nil {
  526. continue
  527. }
  528. report.IgnoreStats.Lines += len(lines)
  529. for _, line := range lines {
  530. // Allow prefixes to be specified in any order, but only once.
  531. for {
  532. if strings.HasPrefix(line, "!") && !seenPrefix[0] {
  533. seenPrefix[0] = true
  534. line = line[1:]
  535. report.IgnoreStats.Inverts++
  536. } else if strings.HasPrefix(line, "(?i)") && !seenPrefix[1] {
  537. seenPrefix[1] = true
  538. line = line[4:]
  539. report.IgnoreStats.Folded++
  540. } else if strings.HasPrefix(line, "(?d)") && !seenPrefix[2] {
  541. seenPrefix[2] = true
  542. line = line[4:]
  543. report.IgnoreStats.Deletable++
  544. } else {
  545. seenPrefix[0] = false
  546. seenPrefix[1] = false
  547. seenPrefix[2] = false
  548. break
  549. }
  550. }
  551. // Noops, remove
  552. line = strings.TrimSuffix(line, "**")
  553. line = strings.TrimPrefix(line, "**/")
  554. if strings.HasPrefix(line, "/") {
  555. report.IgnoreStats.Rooted++
  556. } else if strings.HasPrefix(line, "#include ") {
  557. report.IgnoreStats.Includes++
  558. if strings.Contains(line, "..") {
  559. report.IgnoreStats.EscapedIncludes++
  560. }
  561. }
  562. if strings.Contains(line, "**") {
  563. report.IgnoreStats.DoubleStars++
  564. // Remove not to trip up star checks.
  565. line = strings.Replace(line, "**", "", -1)
  566. }
  567. if strings.Contains(line, "*") {
  568. report.IgnoreStats.Stars++
  569. }
  570. }
  571. }
  572. }
  573. }
  574. type ConnectionInfo struct {
  575. protocol.Statistics
  576. Connected bool
  577. Paused bool
  578. Address string
  579. ClientVersion string
  580. Type string
  581. Crypto string
  582. }
  583. func (info ConnectionInfo) MarshalJSON() ([]byte, error) {
  584. return json.Marshal(map[string]interface{}{
  585. "at": info.At,
  586. "inBytesTotal": info.InBytesTotal,
  587. "outBytesTotal": info.OutBytesTotal,
  588. "connected": info.Connected,
  589. "paused": info.Paused,
  590. "address": info.Address,
  591. "clientVersion": info.ClientVersion,
  592. "type": info.Type,
  593. "crypto": info.Crypto,
  594. })
  595. }
  596. // ConnectionStats returns a map with connection statistics for each device.
  597. func (m *model) ConnectionStats() map[string]interface{} {
  598. m.pmut.RLock()
  599. defer m.pmut.RUnlock()
  600. res := make(map[string]interface{})
  601. devs := m.cfg.Devices()
  602. conns := make(map[string]ConnectionInfo, len(devs))
  603. for device, deviceCfg := range devs {
  604. hello := m.helloMessages[device]
  605. versionString := hello.ClientVersion
  606. if hello.ClientName != "syncthing" {
  607. versionString = hello.ClientName + " " + hello.ClientVersion
  608. }
  609. ci := ConnectionInfo{
  610. ClientVersion: strings.TrimSpace(versionString),
  611. Paused: deviceCfg.Paused,
  612. }
  613. if conn, ok := m.conn[device]; ok {
  614. ci.Type = conn.Type()
  615. ci.Crypto = conn.Crypto()
  616. ci.Connected = ok
  617. ci.Statistics = conn.Statistics()
  618. if addr := conn.RemoteAddr(); addr != nil {
  619. ci.Address = addr.String()
  620. }
  621. }
  622. conns[device.String()] = ci
  623. }
  624. res["connections"] = conns
  625. in, out := protocol.TotalInOut()
  626. res["total"] = ConnectionInfo{
  627. Statistics: protocol.Statistics{
  628. At: time.Now(),
  629. InBytesTotal: in,
  630. OutBytesTotal: out,
  631. },
  632. }
  633. return res
  634. }
  635. // DeviceStatistics returns statistics about each device
  636. func (m *model) DeviceStatistics() (map[string]stats.DeviceStatistics, error) {
  637. m.fmut.RLock()
  638. defer m.fmut.RUnlock()
  639. res := make(map[string]stats.DeviceStatistics, len(m.deviceStatRefs))
  640. for id, sr := range m.deviceStatRefs {
  641. stats, err := sr.GetStatistics()
  642. if err != nil {
  643. return nil, err
  644. }
  645. res[id.String()] = stats
  646. }
  647. return res, nil
  648. }
  649. // FolderStatistics returns statistics about each folder
  650. func (m *model) FolderStatistics() (map[string]stats.FolderStatistics, error) {
  651. res := make(map[string]stats.FolderStatistics)
  652. m.fmut.RLock()
  653. defer m.fmut.RUnlock()
  654. for id, runner := range m.folderRunners {
  655. stats, err := runner.GetStatistics()
  656. if err != nil {
  657. return nil, err
  658. }
  659. res[id] = stats
  660. }
  661. return res, nil
  662. }
  663. type FolderCompletion struct {
  664. CompletionPct float64
  665. GlobalBytes int64
  666. NeedBytes int64
  667. GlobalItems int
  668. NeedItems int
  669. NeedDeletes int
  670. Sequence int64
  671. }
  672. func newFolderCompletion(global, need db.Counts, sequence int64) FolderCompletion {
  673. comp := FolderCompletion{
  674. GlobalBytes: global.Bytes,
  675. NeedBytes: need.Bytes,
  676. GlobalItems: global.Files + global.Directories + global.Symlinks,
  677. NeedItems: need.Files + need.Directories + need.Symlinks,
  678. NeedDeletes: need.Deleted,
  679. Sequence: sequence,
  680. }
  681. comp.setComplectionPct()
  682. return comp
  683. }
  684. func (comp *FolderCompletion) add(other FolderCompletion) {
  685. comp.GlobalBytes += other.GlobalBytes
  686. comp.NeedBytes += other.NeedBytes
  687. comp.GlobalItems += other.GlobalItems
  688. comp.NeedItems += other.NeedItems
  689. comp.NeedDeletes += other.NeedDeletes
  690. comp.setComplectionPct()
  691. }
  692. func (comp *FolderCompletion) setComplectionPct() {
  693. if comp.GlobalBytes == 0 {
  694. comp.CompletionPct = 100
  695. } else {
  696. needRatio := float64(comp.NeedBytes) / float64(comp.GlobalBytes)
  697. comp.CompletionPct = 100 * (1 - needRatio)
  698. }
  699. // If the completion is 100% but there are deletes we need to handle,
  700. // drop it down a notch. Hack for consumers that look only at the
  701. // percentage (our own GUI does the same calculation as here on its own
  702. // and needs the same fixup).
  703. if comp.NeedBytes == 0 && comp.NeedDeletes > 0 {
  704. comp.CompletionPct = 95 // chosen by fair dice roll
  705. }
  706. }
  707. // Map returns the members as a map, e.g. used in api to serialize as Json.
  708. func (comp FolderCompletion) Map() map[string]interface{} {
  709. return map[string]interface{}{
  710. "completion": comp.CompletionPct,
  711. "globalBytes": comp.GlobalBytes,
  712. "needBytes": comp.NeedBytes,
  713. "globalItems": comp.GlobalItems,
  714. "needItems": comp.NeedItems,
  715. "needDeletes": comp.NeedDeletes,
  716. "sequence": comp.Sequence,
  717. }
  718. }
  719. // Completion returns the completion status, in percent with some counters,
  720. // for the given device and folder. The device can be any known device ID
  721. // (including the local device) or explicitly protocol.LocalDeviceID. An
  722. // empty folder string means the aggregate of all folders shared with the
  723. // given device.
  724. func (m *model) Completion(device protocol.DeviceID, folder string) FolderCompletion {
  725. // The user specifically asked for our own device ID. Internally that is
  726. // known as protocol.LocalDeviceID so translate.
  727. if device == m.id {
  728. device = protocol.LocalDeviceID
  729. }
  730. if folder != "" {
  731. // We want completion for a specific folder.
  732. return m.folderCompletion(device, folder)
  733. }
  734. // We want completion for all (shared) folders as an aggregate.
  735. var comp FolderCompletion
  736. for _, fcfg := range m.cfg.FolderList() {
  737. if device == protocol.LocalDeviceID || fcfg.SharedWith(device) {
  738. comp.add(m.folderCompletion(device, fcfg.ID))
  739. }
  740. }
  741. return comp
  742. }
  743. func (m *model) folderCompletion(device protocol.DeviceID, folder string) FolderCompletion {
  744. m.fmut.RLock()
  745. rf, ok := m.folderFiles[folder]
  746. m.fmut.RUnlock()
  747. if !ok {
  748. return FolderCompletion{} // Folder doesn't exist, so we hardly have any of it
  749. }
  750. snap := rf.Snapshot()
  751. defer snap.Release()
  752. m.pmut.RLock()
  753. downloaded := m.deviceDownloads[device].BytesDownloaded(folder)
  754. m.pmut.RUnlock()
  755. need := snap.NeedSize(device)
  756. need.Bytes -= downloaded
  757. // This might might be more than it really is, because some blocks can be of a smaller size.
  758. if need.Bytes < 0 {
  759. need.Bytes = 0
  760. }
  761. comp := newFolderCompletion(snap.GlobalSize(), need, snap.Sequence(device))
  762. l.Debugf("%v Completion(%s, %q): %v", m, device, folder, comp.Map())
  763. return comp
  764. }
  765. // DBSnapshot returns a snapshot of the database content relevant to the given folder.
  766. func (m *model) DBSnapshot(folder string) (*db.Snapshot, error) {
  767. m.fmut.RLock()
  768. err := m.checkFolderRunningLocked(folder)
  769. rf := m.folderFiles[folder]
  770. m.fmut.RUnlock()
  771. if err != nil {
  772. return nil, err
  773. }
  774. return rf.Snapshot(), nil
  775. }
  776. func (m *model) FolderProgressBytesCompleted(folder string) int64 {
  777. return m.progressEmitter.BytesCompleted(folder)
  778. }
  779. // NeedFolderFiles returns paginated list of currently needed files in
  780. // progress, queued, and to be queued on next puller iteration.
  781. func (m *model) NeedFolderFiles(folder string, page, perpage int) ([]db.FileInfoTruncated, []db.FileInfoTruncated, []db.FileInfoTruncated, error) {
  782. m.fmut.RLock()
  783. rf, rfOk := m.folderFiles[folder]
  784. runner, runnerOk := m.folderRunners[folder]
  785. cfg := m.folderCfgs[folder]
  786. m.fmut.RUnlock()
  787. if !rfOk {
  788. return nil, nil, nil, errFolderMissing
  789. }
  790. snap := rf.Snapshot()
  791. defer snap.Release()
  792. var progress, queued, rest []db.FileInfoTruncated
  793. var seen map[string]struct{}
  794. p := newPager(page, perpage)
  795. if runnerOk {
  796. progressNames, queuedNames, skipped := runner.Jobs(page, perpage)
  797. progress = make([]db.FileInfoTruncated, len(progressNames))
  798. queued = make([]db.FileInfoTruncated, len(queuedNames))
  799. seen = make(map[string]struct{}, len(progressNames)+len(queuedNames))
  800. for i, name := range progressNames {
  801. if f, ok := snap.GetGlobalTruncated(name); ok {
  802. progress[i] = f
  803. seen[name] = struct{}{}
  804. }
  805. }
  806. for i, name := range queuedNames {
  807. if f, ok := snap.GetGlobalTruncated(name); ok {
  808. queued[i] = f
  809. seen[name] = struct{}{}
  810. }
  811. }
  812. p.get -= len(seen)
  813. if p.get == 0 {
  814. return progress, queued, nil, nil
  815. }
  816. p.toSkip -= skipped
  817. }
  818. rest = make([]db.FileInfoTruncated, 0, perpage)
  819. snap.WithNeedTruncated(protocol.LocalDeviceID, func(f protocol.FileIntf) bool {
  820. if cfg.IgnoreDelete && f.IsDeleted() {
  821. return true
  822. }
  823. if p.skip() {
  824. return true
  825. }
  826. ft := f.(db.FileInfoTruncated)
  827. if _, ok := seen[ft.Name]; !ok {
  828. rest = append(rest, ft)
  829. p.get--
  830. }
  831. return p.get > 0
  832. })
  833. return progress, queued, rest, nil
  834. }
  835. // RemoteNeedFolderFiles returns paginated list of currently needed files in
  836. // progress, queued, and to be queued on next puller iteration, as well as the
  837. // total number of files currently needed.
  838. func (m *model) RemoteNeedFolderFiles(folder string, device protocol.DeviceID, page, perpage int) ([]db.FileInfoTruncated, error) {
  839. m.fmut.RLock()
  840. rf, ok := m.folderFiles[folder]
  841. m.fmut.RUnlock()
  842. if !ok {
  843. return nil, errFolderMissing
  844. }
  845. snap := rf.Snapshot()
  846. defer snap.Release()
  847. files := make([]db.FileInfoTruncated, 0, perpage)
  848. p := newPager(page, perpage)
  849. snap.WithNeedTruncated(device, func(f protocol.FileIntf) bool {
  850. if p.skip() {
  851. return true
  852. }
  853. files = append(files, f.(db.FileInfoTruncated))
  854. return !p.done()
  855. })
  856. return files, nil
  857. }
  858. func (m *model) LocalChangedFolderFiles(folder string, page, perpage int) ([]db.FileInfoTruncated, error) {
  859. m.fmut.RLock()
  860. rf, ok := m.folderFiles[folder]
  861. cfg := m.folderCfgs[folder]
  862. m.fmut.RUnlock()
  863. if !ok {
  864. return nil, errFolderMissing
  865. }
  866. snap := rf.Snapshot()
  867. defer snap.Release()
  868. if snap.ReceiveOnlyChangedSize().TotalItems() == 0 {
  869. return nil, nil
  870. }
  871. p := newPager(page, perpage)
  872. recvEnc := cfg.Type == config.FolderTypeReceiveEncrypted
  873. files := make([]db.FileInfoTruncated, 0, perpage)
  874. snap.WithHaveTruncated(protocol.LocalDeviceID, func(f protocol.FileIntf) bool {
  875. if !f.IsReceiveOnlyChanged() || (recvEnc && f.IsDeleted()) {
  876. return true
  877. }
  878. if p.skip() {
  879. return true
  880. }
  881. ft := f.(db.FileInfoTruncated)
  882. files = append(files, ft)
  883. return !p.done()
  884. })
  885. return files, nil
  886. }
  887. type pager struct {
  888. toSkip, get int
  889. }
  890. func newPager(page, perpage int) *pager {
  891. return &pager{
  892. toSkip: (page - 1) * perpage,
  893. get: perpage,
  894. }
  895. }
  896. func (p *pager) skip() bool {
  897. if p.toSkip == 0 {
  898. return false
  899. }
  900. p.toSkip--
  901. return true
  902. }
  903. func (p *pager) done() bool {
  904. if p.get > 0 {
  905. p.get--
  906. }
  907. return p.get == 0
  908. }
  909. // Index is called when a new device is connected and we receive their full index.
  910. // Implements the protocol.Model interface.
  911. func (m *model) Index(deviceID protocol.DeviceID, folder string, fs []protocol.FileInfo) error {
  912. return m.handleIndex(deviceID, folder, fs, false)
  913. }
  914. // IndexUpdate is called for incremental updates to connected devices' indexes.
  915. // Implements the protocol.Model interface.
  916. func (m *model) IndexUpdate(deviceID protocol.DeviceID, folder string, fs []protocol.FileInfo) error {
  917. return m.handleIndex(deviceID, folder, fs, true)
  918. }
  919. func (m *model) handleIndex(deviceID protocol.DeviceID, folder string, fs []protocol.FileInfo, update bool) error {
  920. op := "Index"
  921. if update {
  922. op += " update"
  923. }
  924. l.Debugf("%v (in): %s / %q: %d files", op, deviceID, folder, len(fs))
  925. if cfg, ok := m.cfg.Folder(folder); !ok || !cfg.SharedWith(deviceID) {
  926. l.Infof("%v for unexpected folder ID %q sent from device %q; ensure that the folder exists and that this device is selected under \"Share With\" in the folder configuration.", op, folder, deviceID)
  927. return errors.Wrap(errFolderMissing, folder)
  928. } else if cfg.Paused {
  929. l.Debugf("%v for paused folder (ID %q) sent from device %q.", op, folder, deviceID)
  930. return errors.Wrap(ErrFolderPaused, folder)
  931. }
  932. m.fmut.RLock()
  933. files, existing := m.folderFiles[folder]
  934. runner, running := m.folderRunners[folder]
  935. m.fmut.RUnlock()
  936. if !existing {
  937. l.Infof("%v for nonexistent folder %q", op, folder)
  938. return errors.Wrap(errFolderMissing, folder)
  939. }
  940. if running {
  941. defer runner.SchedulePull()
  942. }
  943. m.pmut.RLock()
  944. downloads := m.deviceDownloads[deviceID]
  945. m.pmut.RUnlock()
  946. downloads.Update(folder, makeForgetUpdate(fs))
  947. if !update {
  948. files.Drop(deviceID)
  949. }
  950. for i := range fs {
  951. // The local attributes should never be transmitted over the wire.
  952. // Make sure they look like they weren't.
  953. fs[i].LocalFlags = 0
  954. fs[i].VersionHash = nil
  955. }
  956. files.Update(deviceID, fs)
  957. seq := files.Sequence(deviceID)
  958. m.evLogger.Log(events.RemoteIndexUpdated, map[string]interface{}{
  959. "device": deviceID.String(),
  960. "folder": folder,
  961. "items": len(fs),
  962. "sequence": seq,
  963. "version": seq, // legacy for sequence
  964. })
  965. return nil
  966. }
  967. func (m *model) ClusterConfig(deviceID protocol.DeviceID, cm protocol.ClusterConfig) error {
  968. // Check the peer device's announced folders against our own. Emits events
  969. // for folders that we don't expect (unknown or not shared).
  970. // Also, collect a list of folders we do share, and if he's interested in
  971. // temporary indexes, subscribe the connection.
  972. m.pmut.RLock()
  973. indexSenderRegistry, ok := m.indexSenders[deviceID]
  974. m.pmut.RUnlock()
  975. if !ok {
  976. panic("bug: ClusterConfig called on closed or nonexistent connection")
  977. }
  978. changed := false
  979. deviceCfg, ok := m.cfg.Device(deviceID)
  980. if !ok {
  981. l.Debugln("Device disappeared from config while processing cluster-config")
  982. return errDeviceUnknown
  983. }
  984. // Assemble the device information from the connected device about
  985. // themselves and us for all folders.
  986. ccDeviceInfos := make(map[string]*indexSenderStartInfo, len(cm.Folders))
  987. for _, folder := range cm.Folders {
  988. info := &indexSenderStartInfo{}
  989. for _, dev := range folder.Devices {
  990. if dev.ID == m.id {
  991. info.local = dev
  992. } else if dev.ID == deviceID {
  993. info.remote = dev
  994. }
  995. if info.local.ID != protocol.EmptyDeviceID && info.remote.ID != protocol.EmptyDeviceID {
  996. break
  997. }
  998. }
  999. if info.remote.ID == protocol.EmptyDeviceID {
  1000. l.Infof("Device %v sent cluster-config without the device info for the remote on folder %v", deviceID, folder.Description())
  1001. return errMissingRemoteInClusterConfig
  1002. }
  1003. if info.local.ID == protocol.EmptyDeviceID {
  1004. l.Infof("Device %v sent cluster-config without the device info for us locally on folder %v", deviceID, folder.Description())
  1005. return errMissingLocalInClusterConfig
  1006. }
  1007. ccDeviceInfos[folder.ID] = info
  1008. }
  1009. // Needs to happen outside of the fmut, as can cause CommitConfiguration
  1010. if deviceCfg.AutoAcceptFolders {
  1011. changedFolders := make([]config.FolderConfiguration, 0, len(cm.Folders))
  1012. for _, folder := range cm.Folders {
  1013. if fcfg, fchanged := m.handleAutoAccepts(deviceID, folder, ccDeviceInfos[folder.ID]); fchanged {
  1014. changedFolders = append(changedFolders, fcfg)
  1015. }
  1016. }
  1017. if len(changedFolders) > 0 {
  1018. // Need to wait for the waiter, as this calls CommitConfiguration,
  1019. // which sets up the folder and as we return from this call,
  1020. // ClusterConfig starts poking at m.folderFiles and other things
  1021. // that might not exist until the config is committed.
  1022. w, _ := m.cfg.SetFolders(changedFolders)
  1023. w.Wait()
  1024. changed = true
  1025. }
  1026. }
  1027. changedHere, tempIndexFolders, paused, err := m.ccHandleFolders(cm.Folders, deviceCfg, ccDeviceInfos, indexSenderRegistry)
  1028. if err != nil {
  1029. return err
  1030. }
  1031. changed = changed || changedHere
  1032. m.pmut.Lock()
  1033. m.remotePausedFolders[deviceID] = paused
  1034. m.pmut.Unlock()
  1035. if len(tempIndexFolders) > 0 {
  1036. m.pmut.RLock()
  1037. conn, ok := m.conn[deviceID]
  1038. m.pmut.RUnlock()
  1039. // In case we've got ClusterConfig, and the connection disappeared
  1040. // from infront of our nose.
  1041. if ok {
  1042. m.progressEmitter.temporaryIndexSubscribe(conn, tempIndexFolders)
  1043. }
  1044. }
  1045. if deviceCfg.Introducer {
  1046. folders, devices, foldersDevices, introduced := m.handleIntroductions(deviceCfg, cm)
  1047. folders, devices, deintroduced := m.handleDeintroductions(deviceCfg, foldersDevices, folders, devices)
  1048. if introduced || deintroduced {
  1049. changed = true
  1050. cfg := m.cfg.RawCopy()
  1051. cfg.Folders = make([]config.FolderConfiguration, 0, len(folders))
  1052. for _, fcfg := range folders {
  1053. cfg.Folders = append(cfg.Folders, fcfg)
  1054. }
  1055. cfg.Devices = make([]config.DeviceConfiguration, len(devices))
  1056. for _, dcfg := range devices {
  1057. cfg.Devices = append(cfg.Devices, dcfg)
  1058. }
  1059. m.cfg.Replace(cfg)
  1060. }
  1061. }
  1062. if changed {
  1063. if err := m.cfg.Save(); err != nil {
  1064. l.Warnln("Failed to save config", err)
  1065. }
  1066. }
  1067. return nil
  1068. }
  1069. func (m *model) ccHandleFolders(folders []protocol.Folder, deviceCfg config.DeviceConfiguration, ccDeviceInfos map[string]*indexSenderStartInfo, indexSenders *indexSenderRegistry) (bool, []string, map[string]struct{}, error) {
  1070. var changed bool
  1071. var folderDevice config.FolderDeviceConfiguration
  1072. tempIndexFolders := make([]string, 0, len(folders))
  1073. paused := make(map[string]struct{}, len(folders))
  1074. seenFolders := make(map[string]struct{}, len(folders))
  1075. deviceID := deviceCfg.DeviceID
  1076. for _, folder := range folders {
  1077. seenFolders[folder.ID] = struct{}{}
  1078. cfg, ok := m.cfg.Folder(folder.ID)
  1079. if ok {
  1080. folderDevice, ok = cfg.Device(deviceID)
  1081. }
  1082. if !ok {
  1083. indexSenders.remove(folder.ID)
  1084. if deviceCfg.IgnoredFolder(folder.ID) {
  1085. l.Infof("Ignoring folder %s from device %s since we are configured to", folder.Description(), deviceID)
  1086. continue
  1087. }
  1088. m.cfg.AddOrUpdatePendingFolder(folder.ID, folder.Label, deviceID)
  1089. indexSenders.addPending(cfg, ccDeviceInfos[folder.ID])
  1090. changed = true
  1091. m.evLogger.Log(events.FolderRejected, map[string]string{
  1092. "folder": folder.ID,
  1093. "folderLabel": folder.Label,
  1094. "device": deviceID.String(),
  1095. })
  1096. l.Infof("Unexpected folder %s sent from device %q; ensure that the folder exists and that this device is selected under \"Share With\" in the folder configuration.", folder.Description(), deviceID)
  1097. continue
  1098. }
  1099. if folder.Paused {
  1100. indexSenders.remove(folder.ID)
  1101. paused[cfg.ID] = struct{}{}
  1102. continue
  1103. }
  1104. if cfg.Paused {
  1105. indexSenders.addPending(cfg, ccDeviceInfos[folder.ID])
  1106. continue
  1107. }
  1108. if err := m.ccCheckEncryption(cfg, folderDevice, ccDeviceInfos[folder.ID], deviceCfg.Untrusted); err != nil {
  1109. sameError := false
  1110. if devs, ok := m.folderEncryptionFailures[folder.ID]; ok {
  1111. sameError = devs[deviceID] == err
  1112. } else {
  1113. m.folderEncryptionFailures[folder.ID] = make(map[protocol.DeviceID]error)
  1114. }
  1115. m.folderEncryptionFailures[folder.ID][deviceID] = err
  1116. msg := fmt.Sprintf("Failure checking encryption consistency with device %v for folder %v: %v", deviceID, cfg.Description(), err)
  1117. if sameError || err == errEncryptionReceivedToken {
  1118. l.Debugln(msg)
  1119. } else {
  1120. l.Warnln(msg)
  1121. }
  1122. return changed, tempIndexFolders, paused, err
  1123. }
  1124. if devErrs, ok := m.folderEncryptionFailures[folder.ID]; ok {
  1125. if len(devErrs) == 1 {
  1126. delete(m.folderEncryptionFailures, folder.ID)
  1127. } else {
  1128. delete(m.folderEncryptionFailures[folder.ID], deviceID)
  1129. }
  1130. }
  1131. // Handle indexes
  1132. if !folder.DisableTempIndexes {
  1133. tempIndexFolders = append(tempIndexFolders, folder.ID)
  1134. }
  1135. m.fmut.RLock()
  1136. fs, ok := m.folderFiles[folder.ID]
  1137. m.fmut.RUnlock()
  1138. if !ok {
  1139. // Shouldn't happen because !cfg.Paused, but might happen
  1140. // if the folder is about to be unpaused, but not yet.
  1141. l.Debugln("ccH: no fset", folder.ID)
  1142. indexSenders.addPending(cfg, ccDeviceInfos[folder.ID])
  1143. continue
  1144. }
  1145. indexSenders.add(cfg, fs, ccDeviceInfos[folder.ID])
  1146. // We might already have files that we need to pull so let the
  1147. // folder runner know that it should recheck the index data.
  1148. m.fmut.RLock()
  1149. if runner := m.folderRunners[folder.ID]; runner != nil {
  1150. defer runner.SchedulePull()
  1151. }
  1152. m.fmut.RUnlock()
  1153. }
  1154. indexSenders.removeAllExcept(seenFolders)
  1155. return changed, tempIndexFolders, paused, nil
  1156. }
  1157. func (m *model) ccCheckEncryption(fcfg config.FolderConfiguration, folderDevice config.FolderDeviceConfiguration, ccDeviceInfos *indexSenderStartInfo, deviceUntrusted bool) error {
  1158. hasTokenRemote := len(ccDeviceInfos.remote.EncryptionPasswordToken) > 0
  1159. hasTokenLocal := len(ccDeviceInfos.local.EncryptionPasswordToken) > 0
  1160. isEncryptedRemote := folderDevice.EncryptionPassword != ""
  1161. isEncryptedLocal := fcfg.Type == config.FolderTypeReceiveEncrypted
  1162. if !isEncryptedRemote && !isEncryptedLocal && deviceUntrusted {
  1163. return errEncryptionNotEncryptedUntrusted
  1164. }
  1165. if !(hasTokenRemote || hasTokenLocal || isEncryptedRemote || isEncryptedLocal) {
  1166. // Noone cares about encryption here
  1167. return nil
  1168. }
  1169. if isEncryptedRemote && isEncryptedLocal {
  1170. // Should never happen, but config racyness and be safe.
  1171. return errEncryptionInvConfigLocal
  1172. }
  1173. if hasTokenRemote && hasTokenLocal {
  1174. return errEncryptionInvConfigRemote
  1175. }
  1176. if !(hasTokenRemote || hasTokenLocal) {
  1177. return errEncryptionNotEncryptedRemote
  1178. }
  1179. if !(isEncryptedRemote || isEncryptedLocal) {
  1180. return errEncryptionNotEncryptedLocal
  1181. }
  1182. if isEncryptedRemote {
  1183. passwordToken := protocol.PasswordToken(fcfg.ID, folderDevice.EncryptionPassword)
  1184. match := false
  1185. if hasTokenLocal {
  1186. match = bytes.Equal(passwordToken, ccDeviceInfos.local.EncryptionPasswordToken)
  1187. } else {
  1188. // hasTokenRemote == true
  1189. match = bytes.Equal(passwordToken, ccDeviceInfos.remote.EncryptionPasswordToken)
  1190. }
  1191. if !match {
  1192. return errEncryptionPassword
  1193. }
  1194. return nil
  1195. }
  1196. // isEncryptedLocal == true
  1197. var ccToken []byte
  1198. if hasTokenLocal {
  1199. ccToken = ccDeviceInfos.local.EncryptionPasswordToken
  1200. } else {
  1201. // hasTokenRemote == true
  1202. ccToken = ccDeviceInfos.remote.EncryptionPasswordToken
  1203. }
  1204. m.fmut.RLock()
  1205. token, ok := m.folderEncryptionPasswordTokens[fcfg.ID]
  1206. m.fmut.RUnlock()
  1207. if !ok {
  1208. var err error
  1209. token, err = readEncryptionToken(fcfg)
  1210. if err != nil && !fs.IsNotExist(err) {
  1211. return err
  1212. }
  1213. if err == nil {
  1214. m.fmut.Lock()
  1215. m.folderEncryptionPasswordTokens[fcfg.ID] = token
  1216. m.fmut.Unlock()
  1217. } else {
  1218. if err := writeEncryptionToken(ccToken, fcfg); err != nil {
  1219. return err
  1220. }
  1221. m.fmut.Lock()
  1222. m.folderEncryptionPasswordTokens[fcfg.ID] = ccToken
  1223. m.fmut.Unlock()
  1224. // We can only announce ourselfs once we have the token,
  1225. // thus we need to resend CCs now that we have it.
  1226. m.resendClusterConfig(fcfg.DeviceIDs())
  1227. return nil
  1228. }
  1229. }
  1230. if !bytes.Equal(token, ccToken) {
  1231. return errEncryptionPassword
  1232. }
  1233. return nil
  1234. }
  1235. func (m *model) resendClusterConfig(ids []protocol.DeviceID) {
  1236. if len(ids) == 0 {
  1237. return
  1238. }
  1239. ccConns := make([]protocol.Connection, 0, len(ids))
  1240. m.pmut.RLock()
  1241. for _, id := range ids {
  1242. if conn, ok := m.conn[id]; ok {
  1243. ccConns = append(ccConns, conn)
  1244. }
  1245. }
  1246. m.pmut.RUnlock()
  1247. // Generating cluster-configs acquires fmut -> must happen outside of pmut.
  1248. for _, conn := range ccConns {
  1249. cm := m.generateClusterConfig(conn.ID())
  1250. go conn.ClusterConfig(cm)
  1251. }
  1252. }
  1253. // handleIntroductions handles adding devices/folders that are shared by an introducer device
  1254. func (m *model) handleIntroductions(introducerCfg config.DeviceConfiguration, cm protocol.ClusterConfig) (map[string]config.FolderConfiguration, map[protocol.DeviceID]config.DeviceConfiguration, folderDeviceSet, bool) {
  1255. changed := false
  1256. folders := m.cfg.Folders()
  1257. devices := m.cfg.Devices()
  1258. foldersDevices := make(folderDeviceSet)
  1259. for _, folder := range cm.Folders {
  1260. // Adds devices which we do not have, but the introducer has
  1261. // for the folders that we have in common. Also, shares folders
  1262. // with devices that we have in common, yet are currently not sharing
  1263. // the folder.
  1264. fcfg, ok := folders[folder.ID]
  1265. if !ok {
  1266. // Don't have this folder, carry on.
  1267. continue
  1268. }
  1269. folderChanged := false
  1270. for _, device := range folder.Devices {
  1271. // No need to share with self.
  1272. if device.ID == m.id {
  1273. continue
  1274. }
  1275. foldersDevices.set(device.ID, folder.ID)
  1276. if _, ok := m.cfg.Device(device.ID); !ok {
  1277. // The device is currently unknown. Add it to the config.
  1278. devices[device.ID] = m.introduceDevice(device, introducerCfg)
  1279. } else if fcfg.SharedWith(device.ID) {
  1280. // We already share the folder with this device, so
  1281. // nothing to do.
  1282. continue
  1283. }
  1284. // We don't yet share this folder with this device. Add the device
  1285. // to sharing list of the folder.
  1286. l.Infof("Sharing folder %s with %v (vouched for by introducer %v)", folder.Description(), device.ID, introducerCfg.DeviceID)
  1287. fcfg.Devices = append(fcfg.Devices, config.FolderDeviceConfiguration{
  1288. DeviceID: device.ID,
  1289. IntroducedBy: introducerCfg.DeviceID,
  1290. })
  1291. folderChanged = true
  1292. }
  1293. if folderChanged {
  1294. folders[fcfg.ID] = fcfg
  1295. changed = true
  1296. }
  1297. }
  1298. return folders, devices, foldersDevices, changed
  1299. }
  1300. // handleDeintroductions handles removals of devices/shares that are removed by an introducer device
  1301. func (m *model) handleDeintroductions(introducerCfg config.DeviceConfiguration, foldersDevices folderDeviceSet, folders map[string]config.FolderConfiguration, devices map[protocol.DeviceID]config.DeviceConfiguration) (map[string]config.FolderConfiguration, map[protocol.DeviceID]config.DeviceConfiguration, bool) {
  1302. if introducerCfg.SkipIntroductionRemovals {
  1303. return folders, devices, false
  1304. }
  1305. changed := false
  1306. devicesNotIntroduced := make(map[protocol.DeviceID]struct{})
  1307. // Check if we should unshare some folders, if the introducer has unshared them.
  1308. for folderID, folderCfg := range folders {
  1309. for k := 0; k < len(folderCfg.Devices); k++ {
  1310. if folderCfg.Devices[k].IntroducedBy != introducerCfg.DeviceID {
  1311. devicesNotIntroduced[folderCfg.Devices[k].DeviceID] = struct{}{}
  1312. continue
  1313. }
  1314. if !foldersDevices.has(folderCfg.Devices[k].DeviceID, folderCfg.ID) {
  1315. // We could not find that folder shared on the
  1316. // introducer with the device that was introduced to us.
  1317. // We should follow and unshare as well.
  1318. l.Infof("Unsharing folder %s with %v as introducer %v no longer shares the folder with that device", folderCfg.Description(), folderCfg.Devices[k].DeviceID, folderCfg.Devices[k].IntroducedBy)
  1319. folderCfg.Devices = append(folderCfg.Devices[:k], folderCfg.Devices[k+1:]...)
  1320. folders[folderID] = folderCfg
  1321. k--
  1322. changed = true
  1323. }
  1324. }
  1325. }
  1326. // Check if we should remove some devices, if the introducer no longer
  1327. // shares any folder with them. Yet do not remove if we share other
  1328. // folders that haven't been introduced by the introducer.
  1329. for deviceID, device := range devices {
  1330. if device.IntroducedBy == introducerCfg.DeviceID {
  1331. if !foldersDevices.hasDevice(deviceID) {
  1332. if _, ok := devicesNotIntroduced[deviceID]; !ok {
  1333. // The introducer no longer shares any folder with the
  1334. // device, remove the device.
  1335. l.Infof("Removing device %v as introducer %v no longer shares any folders with that device", deviceID, device.IntroducedBy)
  1336. changed = true
  1337. delete(devices, deviceID)
  1338. continue
  1339. }
  1340. l.Infof("Would have removed %v as %v no longer shares any folders, yet there are other folders that are shared with this device that haven't been introduced by this introducer.", deviceID, device.IntroducedBy)
  1341. }
  1342. }
  1343. }
  1344. return folders, devices, changed
  1345. }
  1346. // handleAutoAccepts handles adding and sharing folders for devices that have
  1347. // AutoAcceptFolders set to true.
  1348. func (m *model) handleAutoAccepts(deviceID protocol.DeviceID, folder protocol.Folder, ccDeviceInfos *indexSenderStartInfo) (config.FolderConfiguration, bool) {
  1349. if cfg, ok := m.cfg.Folder(folder.ID); !ok {
  1350. defaultPath := m.cfg.Options().DefaultFolderPath
  1351. defaultPathFs := fs.NewFilesystem(fs.FilesystemTypeBasic, defaultPath)
  1352. pathAlternatives := []string{
  1353. fs.SanitizePath(folder.Label),
  1354. fs.SanitizePath(folder.ID),
  1355. }
  1356. for _, path := range pathAlternatives {
  1357. if _, err := defaultPathFs.Lstat(path); !fs.IsNotExist(err) {
  1358. continue
  1359. }
  1360. fcfg := config.NewFolderConfiguration(m.id, folder.ID, folder.Label, fs.FilesystemTypeBasic, filepath.Join(defaultPath, path))
  1361. fcfg.Devices = append(fcfg.Devices, config.FolderDeviceConfiguration{
  1362. DeviceID: deviceID,
  1363. })
  1364. if len(ccDeviceInfos.remote.EncryptionPasswordToken) > 0 || len(ccDeviceInfos.local.EncryptionPasswordToken) > 0 {
  1365. fcfg.Type = config.FolderTypeReceiveEncrypted
  1366. }
  1367. l.Infof("Auto-accepted %s folder %s at path %s", deviceID, folder.Description(), fcfg.Path)
  1368. return fcfg, true
  1369. }
  1370. l.Infof("Failed to auto-accept folder %s from %s due to path conflict", folder.Description(), deviceID)
  1371. return config.FolderConfiguration{}, false
  1372. } else {
  1373. for _, device := range cfg.DeviceIDs() {
  1374. if device == deviceID {
  1375. // Already shared nothing todo.
  1376. return config.FolderConfiguration{}, false
  1377. }
  1378. }
  1379. if cfg.Type == config.FolderTypeReceiveEncrypted {
  1380. if len(ccDeviceInfos.remote.EncryptionPasswordToken) == 0 && len(ccDeviceInfos.local.EncryptionPasswordToken) == 0 {
  1381. l.Infof("Failed to auto-accept device %s on existing folder %s as the remote wants to send us unencrypted data, but the folder type is receive-encrypted", folder.Description(), deviceID)
  1382. return config.FolderConfiguration{}, false
  1383. }
  1384. } else {
  1385. if len(ccDeviceInfos.remote.EncryptionPasswordToken) > 0 || len(ccDeviceInfos.local.EncryptionPasswordToken) > 0 {
  1386. l.Infof("Failed to auto-accept device %s on existing folder %s as the remote wants to send us encrypted data, but the folder type is not receive-encrypted", folder.Description(), deviceID)
  1387. return config.FolderConfiguration{}, false
  1388. }
  1389. }
  1390. cfg.Devices = append(cfg.Devices, config.FolderDeviceConfiguration{
  1391. DeviceID: deviceID,
  1392. })
  1393. l.Infof("Shared %s with %s due to auto-accept", folder.ID, deviceID)
  1394. return cfg, true
  1395. }
  1396. }
  1397. func (m *model) introduceDevice(device protocol.Device, introducerCfg config.DeviceConfiguration) config.DeviceConfiguration {
  1398. addresses := []string{"dynamic"}
  1399. for _, addr := range device.Addresses {
  1400. if addr != "dynamic" {
  1401. addresses = append(addresses, addr)
  1402. }
  1403. }
  1404. l.Infof("Adding device %v to config (vouched for by introducer %v)", device.ID, introducerCfg.DeviceID)
  1405. newDeviceCfg := config.DeviceConfiguration{
  1406. DeviceID: device.ID,
  1407. Name: device.Name,
  1408. Compression: introducerCfg.Compression,
  1409. Addresses: addresses,
  1410. CertName: device.CertName,
  1411. IntroducedBy: introducerCfg.DeviceID,
  1412. }
  1413. // The introducers' introducers are also our introducers.
  1414. if device.Introducer {
  1415. l.Infof("Device %v is now also an introducer", device.ID)
  1416. newDeviceCfg.Introducer = true
  1417. newDeviceCfg.SkipIntroductionRemovals = device.SkipIntroductionRemovals
  1418. }
  1419. return newDeviceCfg
  1420. }
  1421. // Closed is called when a connection has been closed
  1422. func (m *model) Closed(conn protocol.Connection, err error) {
  1423. device := conn.ID()
  1424. m.pmut.Lock()
  1425. conn, ok := m.conn[device]
  1426. if !ok {
  1427. m.pmut.Unlock()
  1428. return
  1429. }
  1430. delete(m.conn, device)
  1431. delete(m.connRequestLimiters, device)
  1432. delete(m.helloMessages, device)
  1433. delete(m.deviceDownloads, device)
  1434. delete(m.remotePausedFolders, device)
  1435. closed := m.closed[device]
  1436. delete(m.closed, device)
  1437. delete(m.indexSenders, device)
  1438. m.pmut.Unlock()
  1439. m.progressEmitter.temporaryIndexUnsubscribe(conn)
  1440. l.Infof("Connection to %s at %s closed: %v", device, conn.Name(), err)
  1441. m.evLogger.Log(events.DeviceDisconnected, map[string]string{
  1442. "id": device.String(),
  1443. "error": err.Error(),
  1444. })
  1445. close(closed)
  1446. }
  1447. // Implements protocol.RequestResponse
  1448. type requestResponse struct {
  1449. data []byte
  1450. closed chan struct{}
  1451. once stdsync.Once
  1452. }
  1453. func newRequestResponse(size int) *requestResponse {
  1454. return &requestResponse{
  1455. data: protocol.BufferPool.Get(size),
  1456. closed: make(chan struct{}),
  1457. }
  1458. }
  1459. func (r *requestResponse) Data() []byte {
  1460. return r.data
  1461. }
  1462. func (r *requestResponse) Close() {
  1463. r.once.Do(func() {
  1464. protocol.BufferPool.Put(r.data)
  1465. close(r.closed)
  1466. })
  1467. }
  1468. func (r *requestResponse) Wait() {
  1469. <-r.closed
  1470. }
  1471. // Request returns the specified data segment by reading it from local disk.
  1472. // Implements the protocol.Model interface.
  1473. func (m *model) Request(deviceID protocol.DeviceID, folder, name string, blockNo, size int32, offset int64, hash []byte, weakHash uint32, fromTemporary bool) (out protocol.RequestResponse, err error) {
  1474. if size < 0 || offset < 0 {
  1475. return nil, protocol.ErrInvalid
  1476. }
  1477. m.fmut.RLock()
  1478. folderCfg, ok := m.folderCfgs[folder]
  1479. folderIgnores := m.folderIgnores[folder]
  1480. m.fmut.RUnlock()
  1481. if !ok {
  1482. // The folder might be already unpaused in the config, but not yet
  1483. // in the model.
  1484. l.Debugf("Request from %s for file %s in unstarted folder %q", deviceID, name, folder)
  1485. return nil, protocol.ErrGeneric
  1486. }
  1487. if !folderCfg.SharedWith(deviceID) {
  1488. l.Warnf("Request from %s for file %s in unshared folder %q", deviceID, name, folder)
  1489. return nil, protocol.ErrGeneric
  1490. }
  1491. if folderCfg.Paused {
  1492. l.Debugf("Request from %s for file %s in paused folder %q", deviceID, name, folder)
  1493. return nil, protocol.ErrGeneric
  1494. }
  1495. // Make sure the path is valid and in canonical form
  1496. if name, err = fs.Canonicalize(name); err != nil {
  1497. l.Debugf("Request from %s in folder %q for invalid filename %s", deviceID, folder, name)
  1498. return nil, protocol.ErrGeneric
  1499. }
  1500. if deviceID != protocol.LocalDeviceID {
  1501. l.Debugf("%v REQ(in): %s: %q / %q o=%d s=%d t=%v", m, deviceID, folder, name, offset, size, fromTemporary)
  1502. }
  1503. if fs.IsInternal(name) {
  1504. l.Debugf("%v REQ(in) for internal file: %s: %q / %q o=%d s=%d", m, deviceID, folder, name, offset, size)
  1505. return nil, protocol.ErrInvalid
  1506. }
  1507. if folderIgnores.Match(name).IsIgnored() {
  1508. l.Debugf("%v REQ(in) for ignored file: %s: %q / %q o=%d s=%d", m, deviceID, folder, name, offset, size)
  1509. return nil, protocol.ErrInvalid
  1510. }
  1511. folderFs := folderCfg.Filesystem()
  1512. if err := osutil.TraversesSymlink(folderFs, filepath.Dir(name)); err != nil {
  1513. l.Debugf("%v REQ(in) traversal check: %s - %s: %q / %q o=%d s=%d", m, err, deviceID, folder, name, offset, size)
  1514. return nil, protocol.ErrNoSuchFile
  1515. }
  1516. // Restrict parallel requests by connection/device
  1517. m.pmut.RLock()
  1518. limiter := m.connRequestLimiters[deviceID]
  1519. m.pmut.RUnlock()
  1520. // The requestResponse releases the bytes to the buffer pool and the
  1521. // limiters when its Close method is called.
  1522. res := newLimitedRequestResponse(int(size), limiter, m.globalRequestLimiter)
  1523. defer func() {
  1524. // Close it ourselves if it isn't returned due to an error
  1525. if err != nil {
  1526. res.Close()
  1527. }
  1528. }()
  1529. // Only check temp files if the flag is set, and if we are set to advertise
  1530. // the temp indexes.
  1531. if fromTemporary && !folderCfg.DisableTempIndexes {
  1532. tempFn := fs.TempName(name)
  1533. if info, err := folderFs.Lstat(tempFn); err != nil || !info.IsRegular() {
  1534. // Reject reads for anything that doesn't exist or is something
  1535. // other than a regular file.
  1536. l.Debugf("%v REQ(in) failed stating temp file (%v): %s: %q / %q o=%d s=%d", m, err, deviceID, folder, name, offset, size)
  1537. return nil, protocol.ErrNoSuchFile
  1538. }
  1539. err := readOffsetIntoBuf(folderFs, tempFn, offset, res.data)
  1540. if err == nil && scanner.Validate(res.data, hash, weakHash) {
  1541. return res, nil
  1542. }
  1543. // Fall through to reading from a non-temp file, just incase the temp
  1544. // file has finished downloading.
  1545. }
  1546. if info, err := folderFs.Lstat(name); err != nil || !info.IsRegular() {
  1547. // Reject reads for anything that doesn't exist or is something
  1548. // other than a regular file.
  1549. l.Debugf("%v REQ(in) failed stating file (%v): %s: %q / %q o=%d s=%d", m, err, deviceID, folder, name, offset, size)
  1550. return nil, protocol.ErrNoSuchFile
  1551. }
  1552. if err := readOffsetIntoBuf(folderFs, name, offset, res.data); fs.IsNotExist(err) {
  1553. l.Debugf("%v REQ(in) file doesn't exist: %s: %q / %q o=%d s=%d", m, deviceID, folder, name, offset, size)
  1554. return nil, protocol.ErrNoSuchFile
  1555. } else if err == io.EOF && len(hash) == 0 {
  1556. // Read beyond end of file when we can't verify the hash -- this is
  1557. // a padded read for an encrypted file. It's fine.
  1558. } else if err != nil {
  1559. l.Debugf("%v REQ(in) failed reading file (%v): %s: %q / %q o=%d s=%d", m, err, deviceID, folder, name, offset, size)
  1560. return nil, protocol.ErrGeneric
  1561. }
  1562. if len(hash) > 0 && !scanner.Validate(res.data, hash, weakHash) {
  1563. m.recheckFile(deviceID, folder, name, offset, hash, weakHash)
  1564. l.Debugf("%v REQ(in) failed validating data: %s: %q / %q o=%d s=%d", m, deviceID, folder, name, offset, size)
  1565. return nil, protocol.ErrNoSuchFile
  1566. }
  1567. return res, nil
  1568. }
  1569. // newLimitedRequestResponse takes size bytes from the limiters in order,
  1570. // skipping nil limiters, then returns a requestResponse of the given size.
  1571. // When the requestResponse is closed the limiters are given back the bytes,
  1572. // in reverse order.
  1573. func newLimitedRequestResponse(size int, limiters ...*byteSemaphore) *requestResponse {
  1574. for _, limiter := range limiters {
  1575. if limiter != nil {
  1576. limiter.take(size)
  1577. }
  1578. }
  1579. res := newRequestResponse(size)
  1580. go func() {
  1581. res.Wait()
  1582. for i := range limiters {
  1583. limiter := limiters[len(limiters)-1-i]
  1584. if limiter != nil {
  1585. limiter.give(size)
  1586. }
  1587. }
  1588. }()
  1589. return res
  1590. }
  1591. func (m *model) recheckFile(deviceID protocol.DeviceID, folder, name string, offset int64, hash []byte, weakHash uint32) {
  1592. cf, ok := m.CurrentFolderFile(folder, name)
  1593. if !ok {
  1594. l.Debugf("%v recheckFile: %s: %q / %q: no current file", m, deviceID, folder, name)
  1595. return
  1596. }
  1597. if cf.IsDeleted() || cf.IsInvalid() || cf.IsSymlink() || cf.IsDirectory() {
  1598. l.Debugf("%v recheckFile: %s: %q / %q: not a regular file", m, deviceID, folder, name)
  1599. return
  1600. }
  1601. blockIndex := int(offset / int64(cf.BlockSize()))
  1602. if blockIndex >= len(cf.Blocks) {
  1603. l.Debugf("%v recheckFile: %s: %q / %q i=%d: block index too far", m, deviceID, folder, name, blockIndex)
  1604. return
  1605. }
  1606. block := cf.Blocks[blockIndex]
  1607. // Seems to want a different version of the file, whatever.
  1608. if !bytes.Equal(block.Hash, hash) {
  1609. l.Debugf("%v recheckFile: %s: %q / %q i=%d: hash mismatch %x != %x", m, deviceID, folder, name, blockIndex, block.Hash, hash)
  1610. return
  1611. }
  1612. if weakHash != 0 && block.WeakHash != weakHash {
  1613. l.Debugf("%v recheckFile: %s: %q / %q i=%d: weak hash mismatch %v != %v", m, deviceID, folder, name, blockIndex, block.WeakHash, weakHash)
  1614. return
  1615. }
  1616. // The hashes provided part of the request match what we expect to find according
  1617. // to what we have in the database, yet the content we've read off the filesystem doesn't
  1618. // Something is fishy, invalidate the file and rescan it.
  1619. // The file will temporarily become invalid, which is ok as the content is messed up.
  1620. m.fmut.RLock()
  1621. runner, ok := m.folderRunners[folder]
  1622. m.fmut.RUnlock()
  1623. if !ok {
  1624. l.Debugf("%v recheckFile: %s: %q / %q: Folder stopped before rescan could be scheduled", m, deviceID, folder, name)
  1625. return
  1626. }
  1627. runner.ScheduleForceRescan(name)
  1628. l.Debugf("%v recheckFile: %s: %q / %q", m, deviceID, folder, name)
  1629. }
  1630. func (m *model) CurrentFolderFile(folder string, file string) (protocol.FileInfo, bool) {
  1631. m.fmut.RLock()
  1632. fs, ok := m.folderFiles[folder]
  1633. m.fmut.RUnlock()
  1634. if !ok {
  1635. return protocol.FileInfo{}, false
  1636. }
  1637. snap := fs.Snapshot()
  1638. defer snap.Release()
  1639. return snap.Get(protocol.LocalDeviceID, file)
  1640. }
  1641. func (m *model) CurrentGlobalFile(folder string, file string) (protocol.FileInfo, bool) {
  1642. m.fmut.RLock()
  1643. fs, ok := m.folderFiles[folder]
  1644. m.fmut.RUnlock()
  1645. if !ok {
  1646. return protocol.FileInfo{}, false
  1647. }
  1648. snap := fs.Snapshot()
  1649. defer snap.Release()
  1650. return snap.GetGlobal(file)
  1651. }
  1652. // Connection returns the current connection for device, and a boolean whether a connection was found.
  1653. func (m *model) Connection(deviceID protocol.DeviceID) (connections.Connection, bool) {
  1654. m.pmut.RLock()
  1655. cn, ok := m.conn[deviceID]
  1656. m.pmut.RUnlock()
  1657. if ok {
  1658. m.deviceWasSeen(deviceID)
  1659. }
  1660. return cn, ok
  1661. }
  1662. func (m *model) GetIgnores(folder string) ([]string, []string, error) {
  1663. m.fmut.RLock()
  1664. cfg, cfgOk := m.folderCfgs[folder]
  1665. ignores, ignoresOk := m.folderIgnores[folder]
  1666. m.fmut.RUnlock()
  1667. if !cfgOk {
  1668. cfg, cfgOk = m.cfg.Folder(folder)
  1669. if !cfgOk {
  1670. return nil, nil, fmt.Errorf("folder %s does not exist", folder)
  1671. }
  1672. }
  1673. // On creation a new folder with ignore patterns validly has no marker yet.
  1674. if err := cfg.CheckPath(); err != nil && err != config.ErrMarkerMissing {
  1675. return nil, nil, err
  1676. }
  1677. if !ignoresOk {
  1678. ignores = ignore.New(fs.NewFilesystem(cfg.FilesystemType, cfg.Path))
  1679. }
  1680. err := ignores.Load(".stignore")
  1681. if fs.IsNotExist(err) {
  1682. // Having no ignores is not an error.
  1683. return nil, nil, nil
  1684. }
  1685. // Return lines and patterns, which may have some meaning even when err
  1686. // != nil, depending on the specific error.
  1687. return ignores.Lines(), ignores.Patterns(), err
  1688. }
  1689. func (m *model) SetIgnores(folder string, content []string) error {
  1690. cfg, ok := m.cfg.Folder(folder)
  1691. if !ok {
  1692. return fmt.Errorf("folder %s does not exist", cfg.Description())
  1693. }
  1694. err := cfg.CheckPath()
  1695. if err == config.ErrPathMissing {
  1696. if err = cfg.CreateRoot(); err != nil {
  1697. return errors.Wrap(err, "failed to create folder root")
  1698. }
  1699. err = cfg.CheckPath()
  1700. }
  1701. if err != nil && err != config.ErrMarkerMissing {
  1702. return err
  1703. }
  1704. if err := ignore.WriteIgnores(cfg.Filesystem(), ".stignore", content); err != nil {
  1705. l.Warnln("Saving .stignore:", err)
  1706. return err
  1707. }
  1708. m.fmut.RLock()
  1709. runner, ok := m.folderRunners[folder]
  1710. m.fmut.RUnlock()
  1711. if ok {
  1712. return runner.Scan(nil)
  1713. }
  1714. return nil
  1715. }
  1716. // OnHello is called when an device connects to us.
  1717. // This allows us to extract some information from the Hello message
  1718. // and add it to a list of known devices ahead of any checks.
  1719. func (m *model) OnHello(remoteID protocol.DeviceID, addr net.Addr, hello protocol.Hello) error {
  1720. if m.cfg.IgnoredDevice(remoteID) {
  1721. return errDeviceIgnored
  1722. }
  1723. cfg, ok := m.cfg.Device(remoteID)
  1724. if !ok {
  1725. m.cfg.AddOrUpdatePendingDevice(remoteID, hello.DeviceName, addr.String())
  1726. _ = m.cfg.Save() // best effort
  1727. m.evLogger.Log(events.DeviceRejected, map[string]string{
  1728. "name": hello.DeviceName,
  1729. "device": remoteID.String(),
  1730. "address": addr.String(),
  1731. })
  1732. return errDeviceUnknown
  1733. }
  1734. if cfg.Paused {
  1735. return errDevicePaused
  1736. }
  1737. if len(cfg.AllowedNetworks) > 0 {
  1738. if !connections.IsAllowedNetwork(addr.String(), cfg.AllowedNetworks) {
  1739. return errNetworkNotAllowed
  1740. }
  1741. }
  1742. return nil
  1743. }
  1744. // GetHello is called when we are about to connect to some remote device.
  1745. func (m *model) GetHello(id protocol.DeviceID) protocol.HelloIntf {
  1746. name := ""
  1747. if _, ok := m.cfg.Device(id); ok {
  1748. // Set our name (from the config of our device ID) only if we already know about the other side device ID.
  1749. if myCfg, ok := m.cfg.Device(m.id); ok {
  1750. name = myCfg.Name
  1751. }
  1752. }
  1753. return &protocol.Hello{
  1754. DeviceName: name,
  1755. ClientName: m.clientName,
  1756. ClientVersion: m.clientVersion,
  1757. }
  1758. }
  1759. // AddConnection adds a new peer connection to the model. An initial index will
  1760. // be sent to the connected peer, thereafter index updates whenever the local
  1761. // folder changes.
  1762. func (m *model) AddConnection(conn connections.Connection, hello protocol.Hello) {
  1763. deviceID := conn.ID()
  1764. device, ok := m.cfg.Device(deviceID)
  1765. if !ok {
  1766. l.Infoln("Trying to add connection to unknown device")
  1767. return
  1768. }
  1769. m.pmut.Lock()
  1770. if oldConn, ok := m.conn[deviceID]; ok {
  1771. l.Infoln("Replacing old connection", oldConn, "with", conn, "for", deviceID)
  1772. // There is an existing connection to this device that we are
  1773. // replacing. We must close the existing connection and wait for the
  1774. // close to complete before adding the new connection. We do the
  1775. // actual close without holding pmut as the connection will call
  1776. // back into Closed() for the cleanup.
  1777. closed := m.closed[deviceID]
  1778. m.pmut.Unlock()
  1779. oldConn.Close(errReplacingConnection)
  1780. <-closed
  1781. m.pmut.Lock()
  1782. }
  1783. m.conn[deviceID] = conn
  1784. closed := make(chan struct{})
  1785. m.closed[deviceID] = closed
  1786. m.deviceDownloads[deviceID] = newDeviceDownloadState()
  1787. m.indexSenders[deviceID] = newIndexSenderRegistry(conn, closed, m.Supervisor, m.evLogger)
  1788. // 0: default, <0: no limiting
  1789. switch {
  1790. case device.MaxRequestKiB > 0:
  1791. m.connRequestLimiters[deviceID] = newByteSemaphore(1024 * device.MaxRequestKiB)
  1792. case device.MaxRequestKiB == 0:
  1793. m.connRequestLimiters[deviceID] = newByteSemaphore(1024 * defaultPullerPendingKiB)
  1794. }
  1795. m.helloMessages[deviceID] = hello
  1796. event := map[string]string{
  1797. "id": deviceID.String(),
  1798. "deviceName": hello.DeviceName,
  1799. "clientName": hello.ClientName,
  1800. "clientVersion": hello.ClientVersion,
  1801. "type": conn.Type(),
  1802. }
  1803. addr := conn.RemoteAddr()
  1804. if addr != nil {
  1805. event["addr"] = addr.String()
  1806. }
  1807. m.evLogger.Log(events.DeviceConnected, event)
  1808. l.Infof(`Device %s client is "%s %s" named "%s" at %s`, deviceID, hello.ClientName, hello.ClientVersion, hello.DeviceName, conn)
  1809. conn.Start()
  1810. m.pmut.Unlock()
  1811. // Acquires fmut, so has to be done outside of pmut.
  1812. cm := m.generateClusterConfig(deviceID)
  1813. conn.ClusterConfig(cm)
  1814. if (device.Name == "" || m.cfg.Options().OverwriteRemoteDevNames) && hello.DeviceName != "" {
  1815. device.Name = hello.DeviceName
  1816. m.cfg.SetDevice(device)
  1817. m.cfg.Save()
  1818. }
  1819. m.deviceWasSeen(deviceID)
  1820. }
  1821. func (m *model) DownloadProgress(device protocol.DeviceID, folder string, updates []protocol.FileDownloadProgressUpdate) error {
  1822. m.fmut.RLock()
  1823. cfg, ok := m.folderCfgs[folder]
  1824. m.fmut.RUnlock()
  1825. if !ok || cfg.DisableTempIndexes || !cfg.SharedWith(device) {
  1826. return nil
  1827. }
  1828. m.pmut.RLock()
  1829. downloads := m.deviceDownloads[device]
  1830. m.pmut.RUnlock()
  1831. downloads.Update(folder, updates)
  1832. state := downloads.GetBlockCounts(folder)
  1833. m.evLogger.Log(events.RemoteDownloadProgress, map[string]interface{}{
  1834. "device": device.String(),
  1835. "folder": folder,
  1836. "state": state,
  1837. })
  1838. return nil
  1839. }
  1840. func (m *model) deviceWasSeen(deviceID protocol.DeviceID) {
  1841. m.fmut.RLock()
  1842. sr, ok := m.deviceStatRefs[deviceID]
  1843. m.fmut.RUnlock()
  1844. if ok {
  1845. sr.WasSeen()
  1846. }
  1847. }
  1848. func (m *model) requestGlobal(ctx context.Context, deviceID protocol.DeviceID, folder, name string, blockNo int, offset int64, size int, hash []byte, weakHash uint32, fromTemporary bool) ([]byte, error) {
  1849. m.pmut.RLock()
  1850. nc, ok := m.conn[deviceID]
  1851. m.pmut.RUnlock()
  1852. if !ok {
  1853. return nil, fmt.Errorf("requestGlobal: no such device: %s", deviceID)
  1854. }
  1855. l.Debugf("%v REQ(out): %s: %q / %q b=%d o=%d s=%d h=%x wh=%x ft=%t", m, deviceID, folder, name, blockNo, offset, size, hash, weakHash, fromTemporary)
  1856. return nc.Request(ctx, folder, name, blockNo, offset, size, hash, weakHash, fromTemporary)
  1857. }
  1858. func (m *model) ScanFolders() map[string]error {
  1859. m.fmut.RLock()
  1860. folders := make([]string, 0, len(m.folderCfgs))
  1861. for folder := range m.folderCfgs {
  1862. folders = append(folders, folder)
  1863. }
  1864. m.fmut.RUnlock()
  1865. errors := make(map[string]error, len(m.folderCfgs))
  1866. errorsMut := sync.NewMutex()
  1867. wg := sync.NewWaitGroup()
  1868. wg.Add(len(folders))
  1869. for _, folder := range folders {
  1870. folder := folder
  1871. go func() {
  1872. err := m.ScanFolder(folder)
  1873. if err != nil {
  1874. errorsMut.Lock()
  1875. errors[folder] = err
  1876. errorsMut.Unlock()
  1877. }
  1878. wg.Done()
  1879. }()
  1880. }
  1881. wg.Wait()
  1882. return errors
  1883. }
  1884. func (m *model) ScanFolder(folder string) error {
  1885. return m.ScanFolderSubdirs(folder, nil)
  1886. }
  1887. func (m *model) ScanFolderSubdirs(folder string, subs []string) error {
  1888. m.fmut.RLock()
  1889. err := m.checkFolderRunningLocked(folder)
  1890. runner := m.folderRunners[folder]
  1891. m.fmut.RUnlock()
  1892. if err != nil {
  1893. return err
  1894. }
  1895. return runner.Scan(subs)
  1896. }
  1897. func (m *model) DelayScan(folder string, next time.Duration) {
  1898. m.fmut.RLock()
  1899. runner, ok := m.folderRunners[folder]
  1900. m.fmut.RUnlock()
  1901. if !ok {
  1902. return
  1903. }
  1904. runner.DelayScan(next)
  1905. }
  1906. // numHashers returns the number of hasher routines to use for a given folder,
  1907. // taking into account configuration and available CPU cores.
  1908. func (m *model) numHashers(folder string) int {
  1909. m.fmut.RLock()
  1910. folderCfg := m.folderCfgs[folder]
  1911. numFolders := len(m.folderCfgs)
  1912. m.fmut.RUnlock()
  1913. if folderCfg.Hashers > 0 {
  1914. // Specific value set in the config, use that.
  1915. return folderCfg.Hashers
  1916. }
  1917. if runtime.GOOS == "windows" || runtime.GOOS == "darwin" {
  1918. // Interactive operating systems; don't load the system too heavily by
  1919. // default.
  1920. return 1
  1921. }
  1922. // For other operating systems and architectures, lets try to get some
  1923. // work done... Divide the available CPU cores among the configured
  1924. // folders.
  1925. if perFolder := runtime.GOMAXPROCS(-1) / numFolders; perFolder > 0 {
  1926. return perFolder
  1927. }
  1928. return 1
  1929. }
  1930. // generateClusterConfig returns a ClusterConfigMessage that is correct for
  1931. // the given peer device
  1932. func (m *model) generateClusterConfig(device protocol.DeviceID) protocol.ClusterConfig {
  1933. var message protocol.ClusterConfig
  1934. m.fmut.RLock()
  1935. defer m.fmut.RUnlock()
  1936. for _, folderCfg := range m.cfg.FolderList() {
  1937. if !folderCfg.SharedWith(device) {
  1938. continue
  1939. }
  1940. var encryptionToken []byte
  1941. var hasEncryptionToken bool
  1942. if folderCfg.Type == config.FolderTypeReceiveEncrypted {
  1943. if encryptionToken, hasEncryptionToken = m.folderEncryptionPasswordTokens[folderCfg.ID]; !hasEncryptionToken {
  1944. // We haven't gotten a token for us yet and without
  1945. // one the other side can't validate us - pretend
  1946. // we don't have the folder yet.
  1947. continue
  1948. }
  1949. }
  1950. protocolFolder := protocol.Folder{
  1951. ID: folderCfg.ID,
  1952. Label: folderCfg.Label,
  1953. ReadOnly: folderCfg.Type == config.FolderTypeSendOnly,
  1954. IgnorePermissions: folderCfg.IgnorePerms,
  1955. IgnoreDelete: folderCfg.IgnoreDelete,
  1956. DisableTempIndexes: folderCfg.DisableTempIndexes,
  1957. }
  1958. fs := m.folderFiles[folderCfg.ID]
  1959. // Even if we aren't paused, if we haven't started the folder yet
  1960. // pretend we are. Otherwise the remote might get confused about
  1961. // the missing index info (and drop all the info). We will send
  1962. // another cluster config once the folder is started.
  1963. protocolFolder.Paused = folderCfg.Paused || fs == nil
  1964. for _, device := range folderCfg.Devices {
  1965. deviceCfg, _ := m.cfg.Device(device.DeviceID)
  1966. protocolDevice := protocol.Device{
  1967. ID: deviceCfg.DeviceID,
  1968. Name: deviceCfg.Name,
  1969. Addresses: deviceCfg.Addresses,
  1970. Compression: deviceCfg.Compression,
  1971. CertName: deviceCfg.CertName,
  1972. Introducer: deviceCfg.Introducer,
  1973. }
  1974. if deviceCfg.DeviceID == m.id && hasEncryptionToken {
  1975. protocolDevice.EncryptionPasswordToken = encryptionToken
  1976. } else if device.EncryptionPassword != "" {
  1977. protocolDevice.EncryptionPasswordToken = protocol.PasswordToken(folderCfg.ID, device.EncryptionPassword)
  1978. }
  1979. if fs != nil {
  1980. if deviceCfg.DeviceID == m.id {
  1981. protocolDevice.IndexID = fs.IndexID(protocol.LocalDeviceID)
  1982. protocolDevice.MaxSequence = fs.Sequence(protocol.LocalDeviceID)
  1983. } else {
  1984. protocolDevice.IndexID = fs.IndexID(deviceCfg.DeviceID)
  1985. protocolDevice.MaxSequence = fs.Sequence(deviceCfg.DeviceID)
  1986. }
  1987. }
  1988. protocolFolder.Devices = append(protocolFolder.Devices, protocolDevice)
  1989. }
  1990. message.Folders = append(message.Folders, protocolFolder)
  1991. }
  1992. return message
  1993. }
  1994. func (m *model) State(folder string) (string, time.Time, error) {
  1995. m.fmut.RLock()
  1996. runner, ok := m.folderRunners[folder]
  1997. m.fmut.RUnlock()
  1998. if !ok {
  1999. // The returned error should be an actual folder error, so returning
  2000. // errors.New("does not exist") or similar here would be
  2001. // inappropriate.
  2002. return "", time.Time{}, nil
  2003. }
  2004. state, changed, err := runner.getState()
  2005. return state.String(), changed, err
  2006. }
  2007. func (m *model) FolderErrors(folder string) ([]FileError, error) {
  2008. m.fmut.RLock()
  2009. err := m.checkFolderRunningLocked(folder)
  2010. runner := m.folderRunners[folder]
  2011. m.fmut.RUnlock()
  2012. if err != nil {
  2013. return nil, err
  2014. }
  2015. return runner.Errors(), nil
  2016. }
  2017. func (m *model) WatchError(folder string) error {
  2018. m.fmut.RLock()
  2019. err := m.checkFolderRunningLocked(folder)
  2020. runner := m.folderRunners[folder]
  2021. m.fmut.RUnlock()
  2022. if err != nil {
  2023. return nil // If the folder isn't running, there's no error to report.
  2024. }
  2025. return runner.WatchError()
  2026. }
  2027. func (m *model) Override(folder string) {
  2028. // Grab the runner and the file set.
  2029. m.fmut.RLock()
  2030. runner, ok := m.folderRunners[folder]
  2031. m.fmut.RUnlock()
  2032. if !ok {
  2033. return
  2034. }
  2035. // Run the override, taking updates as if they came from scanning.
  2036. runner.Override()
  2037. }
  2038. func (m *model) Revert(folder string) {
  2039. // Grab the runner and the file set.
  2040. m.fmut.RLock()
  2041. runner, ok := m.folderRunners[folder]
  2042. m.fmut.RUnlock()
  2043. if !ok {
  2044. return
  2045. }
  2046. // Run the revert, taking updates as if they came from scanning.
  2047. runner.Revert()
  2048. }
  2049. func (m *model) GlobalDirectoryTree(folder, prefix string, levels int, dirsonly bool) map[string]interface{} {
  2050. m.fmut.RLock()
  2051. files, ok := m.folderFiles[folder]
  2052. m.fmut.RUnlock()
  2053. if !ok {
  2054. return nil
  2055. }
  2056. output := make(map[string]interface{})
  2057. sep := string(filepath.Separator)
  2058. prefix = osutil.NativeFilename(prefix)
  2059. if prefix != "" && !strings.HasSuffix(prefix, sep) {
  2060. prefix = prefix + sep
  2061. }
  2062. snap := files.Snapshot()
  2063. defer snap.Release()
  2064. snap.WithPrefixedGlobalTruncated(prefix, func(fi protocol.FileIntf) bool {
  2065. f := fi.(db.FileInfoTruncated)
  2066. // Don't include the prefix itself.
  2067. if f.IsInvalid() || f.IsDeleted() || strings.HasPrefix(prefix, f.Name) {
  2068. return true
  2069. }
  2070. f.Name = strings.Replace(f.Name, prefix, "", 1)
  2071. var dir, base string
  2072. if f.IsDirectory() && !f.IsSymlink() {
  2073. dir = f.Name
  2074. } else {
  2075. dir = filepath.Dir(f.Name)
  2076. base = filepath.Base(f.Name)
  2077. }
  2078. if levels > -1 && strings.Count(f.Name, sep) > levels {
  2079. return true
  2080. }
  2081. last := output
  2082. if dir != "." {
  2083. for _, path := range strings.Split(dir, sep) {
  2084. directory, ok := last[path]
  2085. if !ok {
  2086. newdir := make(map[string]interface{})
  2087. last[path] = newdir
  2088. last = newdir
  2089. } else {
  2090. last = directory.(map[string]interface{})
  2091. }
  2092. }
  2093. }
  2094. if !dirsonly && base != "" {
  2095. last[base] = []interface{}{
  2096. f.ModTime(), f.FileSize(),
  2097. }
  2098. }
  2099. return true
  2100. })
  2101. return output
  2102. }
  2103. func (m *model) GetFolderVersions(folder string) (map[string][]versioner.FileVersion, error) {
  2104. m.fmut.RLock()
  2105. err := m.checkFolderRunningLocked(folder)
  2106. ver := m.folderVersioners[folder]
  2107. m.fmut.RUnlock()
  2108. if err != nil {
  2109. return nil, err
  2110. }
  2111. if ver == nil {
  2112. return nil, errNoVersioner
  2113. }
  2114. return ver.GetVersions()
  2115. }
  2116. func (m *model) RestoreFolderVersions(folder string, versions map[string]time.Time) (map[string]string, error) {
  2117. m.fmut.RLock()
  2118. err := m.checkFolderRunningLocked(folder)
  2119. fcfg := m.folderCfgs[folder]
  2120. ver := m.folderVersioners[folder]
  2121. m.fmut.RUnlock()
  2122. if err != nil {
  2123. return nil, err
  2124. }
  2125. if ver == nil {
  2126. return nil, errNoVersioner
  2127. }
  2128. restoreErrors := make(map[string]string)
  2129. for file, version := range versions {
  2130. if err := ver.Restore(file, version); err != nil {
  2131. restoreErrors[file] = err.Error()
  2132. }
  2133. }
  2134. // Trigger scan
  2135. if !fcfg.FSWatcherEnabled {
  2136. go func() { _ = m.ScanFolder(folder) }()
  2137. }
  2138. return restoreErrors, nil
  2139. }
  2140. func (m *model) Availability(folder string, file protocol.FileInfo, block protocol.BlockInfo) []Availability {
  2141. // The slightly unusual locking sequence here is because we need to hold
  2142. // pmut for the duration (as the value returned from foldersFiles can
  2143. // get heavily modified on Close()), but also must acquire fmut before
  2144. // pmut. (The locks can be *released* in any order.)
  2145. m.fmut.RLock()
  2146. m.pmut.RLock()
  2147. defer m.pmut.RUnlock()
  2148. fs, ok := m.folderFiles[folder]
  2149. cfg := m.folderCfgs[folder]
  2150. m.fmut.RUnlock()
  2151. if !ok {
  2152. return nil
  2153. }
  2154. var availabilities []Availability
  2155. snap := fs.Snapshot()
  2156. defer snap.Release()
  2157. for _, device := range snap.Availability(file.Name) {
  2158. if _, ok := m.remotePausedFolders[device]; !ok {
  2159. continue
  2160. }
  2161. if _, ok := m.remotePausedFolders[device][folder]; ok {
  2162. continue
  2163. }
  2164. _, ok := m.conn[device]
  2165. if ok {
  2166. availabilities = append(availabilities, Availability{ID: device, FromTemporary: false})
  2167. }
  2168. }
  2169. for _, device := range cfg.Devices {
  2170. if m.deviceDownloads[device.DeviceID].Has(folder, file.Name, file.Version, int(block.Offset/int64(file.BlockSize()))) {
  2171. availabilities = append(availabilities, Availability{ID: device.DeviceID, FromTemporary: true})
  2172. }
  2173. }
  2174. return availabilities
  2175. }
  2176. // BringToFront bumps the given files priority in the job queue.
  2177. func (m *model) BringToFront(folder, file string) {
  2178. m.fmut.RLock()
  2179. runner, ok := m.folderRunners[folder]
  2180. m.fmut.RUnlock()
  2181. if ok {
  2182. runner.BringToFront(file)
  2183. }
  2184. }
  2185. func (m *model) ResetFolder(folder string) {
  2186. l.Infof("Cleaning data for folder %q", folder)
  2187. db.DropFolder(m.db, folder)
  2188. }
  2189. func (m *model) String() string {
  2190. return fmt.Sprintf("model@%p", m)
  2191. }
  2192. func (m *model) VerifyConfiguration(from, to config.Configuration) error {
  2193. return nil
  2194. }
  2195. func (m *model) CommitConfiguration(from, to config.Configuration) bool {
  2196. // TODO: This should not use reflect, and should take more care to try to handle stuff without restart.
  2197. // Go through the folder configs and figure out if we need to restart or not.
  2198. // Tracks devices affected by any configuration change to resend ClusterConfig.
  2199. clusterConfigDevices := make(deviceIDSet, len(from.Devices)+len(to.Devices))
  2200. fromFolders := mapFolders(from.Folders)
  2201. toFolders := mapFolders(to.Folders)
  2202. for folderID, cfg := range toFolders {
  2203. if _, ok := fromFolders[folderID]; !ok {
  2204. // A folder was added.
  2205. if cfg.Paused {
  2206. l.Infoln("Paused folder", cfg.Description())
  2207. } else {
  2208. l.Infoln("Adding folder", cfg.Description())
  2209. m.newFolder(cfg, to.Options.CacheIgnoredFiles)
  2210. }
  2211. clusterConfigDevices.add(cfg.DeviceIDs())
  2212. }
  2213. }
  2214. for folderID, fromCfg := range fromFolders {
  2215. toCfg, ok := toFolders[folderID]
  2216. if !ok {
  2217. // The folder was removed.
  2218. m.removeFolder(fromCfg)
  2219. clusterConfigDevices.add(fromCfg.DeviceIDs())
  2220. continue
  2221. }
  2222. if fromCfg.Paused && toCfg.Paused {
  2223. continue
  2224. }
  2225. // This folder exists on both sides. Settings might have changed.
  2226. // Check if anything differs that requires a restart.
  2227. if !reflect.DeepEqual(fromCfg.RequiresRestartOnly(), toCfg.RequiresRestartOnly()) || from.Options.CacheIgnoredFiles != to.Options.CacheIgnoredFiles {
  2228. m.restartFolder(fromCfg, toCfg, to.Options.CacheIgnoredFiles)
  2229. clusterConfigDevices.add(fromCfg.DeviceIDs())
  2230. clusterConfigDevices.add(toCfg.DeviceIDs())
  2231. }
  2232. // Emit the folder pause/resume event
  2233. if fromCfg.Paused != toCfg.Paused {
  2234. eventType := events.FolderResumed
  2235. if toCfg.Paused {
  2236. eventType = events.FolderPaused
  2237. }
  2238. m.evLogger.Log(eventType, map[string]string{"id": toCfg.ID, "label": toCfg.Label})
  2239. }
  2240. }
  2241. // Removing a device. We actually don't need to do anything.
  2242. // Because folder config has changed (since the device lists do not match)
  2243. // Folders for that had device got "restarted", which involves killing
  2244. // connections to all devices that we were sharing the folder with.
  2245. // At some point model.Close() will get called for that device which will
  2246. // clean residue device state that is not part of any folder.
  2247. // Pausing a device, unpausing is handled by the connection service.
  2248. fromDevices := from.DeviceMap()
  2249. toDevices := to.DeviceMap()
  2250. closeDevices := make([]protocol.DeviceID, 0, len(to.Devices))
  2251. for deviceID, toCfg := range toDevices {
  2252. fromCfg, ok := fromDevices[deviceID]
  2253. if !ok {
  2254. sr := stats.NewDeviceStatisticsReference(m.db, deviceID.String())
  2255. m.fmut.Lock()
  2256. m.deviceStatRefs[deviceID] = sr
  2257. m.fmut.Unlock()
  2258. continue
  2259. }
  2260. delete(fromDevices, deviceID)
  2261. if fromCfg.Paused == toCfg.Paused {
  2262. continue
  2263. }
  2264. // Ignored folder was removed, reconnect to retrigger the prompt.
  2265. if !toCfg.Paused && len(fromCfg.IgnoredFolders) > len(toCfg.IgnoredFolders) {
  2266. closeDevices = append(closeDevices, deviceID)
  2267. }
  2268. if toCfg.Paused {
  2269. l.Infoln("Pausing", deviceID)
  2270. closeDevices = append(closeDevices, deviceID)
  2271. delete(clusterConfigDevices, deviceID)
  2272. m.evLogger.Log(events.DevicePaused, map[string]string{"device": deviceID.String()})
  2273. } else {
  2274. m.evLogger.Log(events.DeviceResumed, map[string]string{"device": deviceID.String()})
  2275. }
  2276. }
  2277. removedDevices := make([]protocol.DeviceID, 0, len(fromDevices))
  2278. m.fmut.Lock()
  2279. for deviceID := range fromDevices {
  2280. delete(m.deviceStatRefs, deviceID)
  2281. removedDevices = append(removedDevices, deviceID)
  2282. delete(clusterConfigDevices, deviceID)
  2283. }
  2284. m.fmut.Unlock()
  2285. m.pmut.RLock()
  2286. for _, id := range closeDevices {
  2287. if conn, ok := m.conn[id]; ok {
  2288. go conn.Close(errDevicePaused)
  2289. }
  2290. }
  2291. for _, id := range removedDevices {
  2292. if conn, ok := m.conn[id]; ok {
  2293. go conn.Close(errDeviceRemoved)
  2294. }
  2295. }
  2296. m.pmut.RUnlock()
  2297. // Generating cluster-configs acquires fmut -> must happen outside of pmut.
  2298. m.resendClusterConfig(clusterConfigDevices.AsSlice())
  2299. m.globalRequestLimiter.setCapacity(1024 * to.Options.MaxConcurrentIncomingRequestKiB())
  2300. m.folderIOLimiter.setCapacity(to.Options.MaxFolderConcurrency())
  2301. // Some options don't require restart as those components handle it fine
  2302. // by themselves. Compare the options structs containing only the
  2303. // attributes that require restart and act apprioriately.
  2304. if !reflect.DeepEqual(from.Options.RequiresRestartOnly(), to.Options.RequiresRestartOnly()) {
  2305. l.Debugln(m, "requires restart, options differ")
  2306. return false
  2307. }
  2308. return true
  2309. }
  2310. // checkFolderRunningLocked returns nil if the folder is up and running and a
  2311. // descriptive error if not.
  2312. // Need to hold (read) lock on m.fmut when calling this.
  2313. func (m *model) checkFolderRunningLocked(folder string) error {
  2314. _, ok := m.folderRunners[folder]
  2315. if ok {
  2316. return nil
  2317. }
  2318. if cfg, ok := m.cfg.Folder(folder); !ok {
  2319. return errFolderMissing
  2320. } else if cfg.Paused {
  2321. return ErrFolderPaused
  2322. }
  2323. return errFolderNotRunning
  2324. }
  2325. // mapFolders returns a map of folder ID to folder configuration for the given
  2326. // slice of folder configurations.
  2327. func mapFolders(folders []config.FolderConfiguration) map[string]config.FolderConfiguration {
  2328. m := make(map[string]config.FolderConfiguration, len(folders))
  2329. for _, cfg := range folders {
  2330. m[cfg.ID] = cfg
  2331. }
  2332. return m
  2333. }
  2334. // mapDevices returns a map of device ID to nothing for the given slice of
  2335. // device IDs.
  2336. func mapDevices(devices []protocol.DeviceID) map[protocol.DeviceID]struct{} {
  2337. m := make(map[protocol.DeviceID]struct{}, len(devices))
  2338. for _, dev := range devices {
  2339. m[dev] = struct{}{}
  2340. }
  2341. return m
  2342. }
  2343. func readOffsetIntoBuf(fs fs.Filesystem, file string, offset int64, buf []byte) error {
  2344. fd, err := fs.Open(file)
  2345. if err != nil {
  2346. l.Debugln("readOffsetIntoBuf.Open", file, err)
  2347. return err
  2348. }
  2349. defer fd.Close()
  2350. _, err = fd.ReadAt(buf, offset)
  2351. if err != nil {
  2352. l.Debugln("readOffsetIntoBuf.ReadAt", file, err)
  2353. }
  2354. return err
  2355. }
  2356. // makeForgetUpdate takes an index update and constructs a download progress update
  2357. // causing to forget any progress for files which we've just been sent.
  2358. func makeForgetUpdate(files []protocol.FileInfo) []protocol.FileDownloadProgressUpdate {
  2359. updates := make([]protocol.FileDownloadProgressUpdate, 0, len(files))
  2360. for _, file := range files {
  2361. if file.IsSymlink() || file.IsDirectory() || file.IsDeleted() {
  2362. continue
  2363. }
  2364. updates = append(updates, protocol.FileDownloadProgressUpdate{
  2365. Name: file.Name,
  2366. Version: file.Version,
  2367. UpdateType: protocol.FileDownloadProgressUpdateTypeForget,
  2368. })
  2369. }
  2370. return updates
  2371. }
  2372. // folderDeviceSet is a set of (folder, deviceID) pairs
  2373. type folderDeviceSet map[string]map[protocol.DeviceID]struct{}
  2374. // set adds the (dev, folder) pair to the set
  2375. func (s folderDeviceSet) set(dev protocol.DeviceID, folder string) {
  2376. devs, ok := s[folder]
  2377. if !ok {
  2378. devs = make(map[protocol.DeviceID]struct{})
  2379. s[folder] = devs
  2380. }
  2381. devs[dev] = struct{}{}
  2382. }
  2383. // has returns true if the (dev, folder) pair is in the set
  2384. func (s folderDeviceSet) has(dev protocol.DeviceID, folder string) bool {
  2385. _, ok := s[folder][dev]
  2386. return ok
  2387. }
  2388. // hasDevice returns true if the device is set on any folder
  2389. func (s folderDeviceSet) hasDevice(dev protocol.DeviceID) bool {
  2390. for _, devices := range s {
  2391. if _, ok := devices[dev]; ok {
  2392. return true
  2393. }
  2394. }
  2395. return false
  2396. }
  2397. type fileInfoBatch struct {
  2398. infos []protocol.FileInfo
  2399. size int
  2400. flushFn func([]protocol.FileInfo) error
  2401. }
  2402. func newFileInfoBatch(fn func([]protocol.FileInfo) error) *fileInfoBatch {
  2403. return &fileInfoBatch{
  2404. infos: make([]protocol.FileInfo, 0, maxBatchSizeFiles),
  2405. flushFn: fn,
  2406. }
  2407. }
  2408. func (b *fileInfoBatch) append(f protocol.FileInfo) {
  2409. b.infos = append(b.infos, f)
  2410. b.size += f.ProtoSize()
  2411. }
  2412. func (b *fileInfoBatch) full() bool {
  2413. return len(b.infos) >= maxBatchSizeFiles || b.size >= maxBatchSizeBytes
  2414. }
  2415. func (b *fileInfoBatch) flushIfFull() error {
  2416. if b.full() {
  2417. return b.flush()
  2418. }
  2419. return nil
  2420. }
  2421. func (b *fileInfoBatch) flush() error {
  2422. if len(b.infos) == 0 {
  2423. return nil
  2424. }
  2425. if err := b.flushFn(b.infos); err != nil {
  2426. return err
  2427. }
  2428. b.reset()
  2429. return nil
  2430. }
  2431. func (b *fileInfoBatch) reset() {
  2432. b.infos = b.infos[:0]
  2433. b.size = 0
  2434. }
  2435. // syncMutexMap is a type safe wrapper for a sync.Map that holds mutexes
  2436. type syncMutexMap struct {
  2437. inner stdsync.Map
  2438. }
  2439. func (m *syncMutexMap) Get(key string) sync.Mutex {
  2440. v, _ := m.inner.LoadOrStore(key, sync.NewMutex())
  2441. return v.(sync.Mutex)
  2442. }
  2443. type deviceIDSet map[protocol.DeviceID]struct{}
  2444. func (s deviceIDSet) add(ids []protocol.DeviceID) {
  2445. for _, id := range ids {
  2446. if _, ok := s[id]; !ok {
  2447. s[id] = struct{}{}
  2448. }
  2449. }
  2450. }
  2451. func (s deviceIDSet) AsSlice() []protocol.DeviceID {
  2452. ids := make([]protocol.DeviceID, 0, len(s))
  2453. for id := range s {
  2454. ids = append(ids, id)
  2455. }
  2456. return ids
  2457. }
  2458. func encryptionTokenPath(cfg config.FolderConfiguration) string {
  2459. return filepath.Join(cfg.MarkerName, "syncthing-encryption_password_token")
  2460. }
  2461. type storedEncryptionToken struct {
  2462. FolderID string
  2463. Token []byte
  2464. }
  2465. func readEncryptionToken(cfg config.FolderConfiguration) ([]byte, error) {
  2466. fd, err := cfg.Filesystem().Open(encryptionTokenPath(cfg))
  2467. if err != nil {
  2468. return nil, err
  2469. }
  2470. defer fd.Close()
  2471. var stored storedEncryptionToken
  2472. if err := json.NewDecoder(fd).Decode(&stored); err != nil {
  2473. return nil, err
  2474. }
  2475. return stored.Token, nil
  2476. }
  2477. func writeEncryptionToken(token []byte, cfg config.FolderConfiguration) error {
  2478. tokenName := encryptionTokenPath(cfg)
  2479. fd, err := cfg.Filesystem().OpenFile(tokenName, fs.OptReadWrite|fs.OptCreate, 0666)
  2480. if err != nil {
  2481. return err
  2482. }
  2483. defer fd.Close()
  2484. return json.NewEncoder(fd).Encode(storedEncryptionToken{
  2485. FolderID: cfg.ID,
  2486. Token: token,
  2487. })
  2488. }