Commitbc0d1e3

committed

set generous timeouts on session requests

1 parentba8bd98 commitbc0d1e3Copy full SHA for bc0d1e3

File tree

-4

lines changed

-4

lines changed

Lines changed: 3 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -43,6 +43,9 @@ public class MutagenDaemon: FileSyncDaemon {`
`43`	`43`	`privateletmutagenDataDirectory:URL`
`44`	`44`	`privateletmutagenDaemonSocket:URL`
`45`	`45`
	`46`	`+ // Managing sync sessions can take a while, especially with prompting`
	`47`	`+letsessionMgmtReqTimeout:TimeAmount=.seconds(5)`
	`48`	`+`
`46`	`49`	`// Non-nil when the daemon is running`
`47`	`50`	`varclient:DaemonClient?`
`48`	`51`	`privatevargroup:MultiThreadedEventLoopGroup?`

Lines changed: 6 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -1,3 +1,5 @@`
	`1`	`+import NIOCore`
	`2`	`+`
`1`	`3`	`publicextensionMutagenDaemon{`
`2`	`4`	`func refreshSessions()async{`
`3`	`5`	`guard case.running= stateelse{return}`
`@@ -49,7 +51,7 @@ public extension MutagenDaemon {`
`49`	`51`	`}`
`50`	`52`	`}`
`51`	`53`	`do{`
`52`		`- _=tryawait client!.sync.create(req)`
	`54`	`+ _=tryawait client!.sync.create(req, callOptions:.init(timeLimit:.timeout(sessionMgmtReqTimeout)))`
`53`	`55`	`}catch{`
`54`	`56`	`throw.grpcFailure(error)`
`55`	`57`	`}`
`@@ -68,7 +70,7 @@ public extension MutagenDaemon {`
`68`	`70`	`req.selection=.with{ selectionin`
`69`	`71`	`selection.specifications= ids`
`70`	`72`	`}`
`71`		`-})`
	`73`	`+}, callOptions:.init(timeLimit:.timeout(sessionMgmtReqTimeout)))`
`72`	`74`	`}catch{`
`73`	`75`	`throw.grpcFailure(error)`
`74`	`76`	`}`
`@@ -87,7 +89,7 @@ public extension MutagenDaemon {`
`87`	`89`	`req.selection=.with{ selectionin`
`88`	`90`	`selection.specifications= ids`
`89`	`91`	`}`
`90`		`-})`
	`92`	`+}, callOptions:.init(timeLimit:.timeout(sessionMgmtReqTimeout)))`
`91`	`93`	`}catch{`
`92`	`94`	`throw.grpcFailure(error)`
`93`	`95`	`}`
`@@ -106,7 +108,7 @@ public extension MutagenDaemon {`
`106`	`108`	`req.selection=.with{ selectionin`
`107`	`109`	`selection.specifications= ids`
`108`	`110`	`}`
`109`		`-})`
	`111`	`+}, callOptions:.init(timeLimit:.timeout(sessionMgmtReqTimeout)))`
`110`	`112`	`}catch{`
`111`	`113`	`throw.grpcFailure(error)`
`112`	`114`	`}`

Comments

(0)