model.go 101 KB

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