@@ -247,7 +247,7 @@ func daemonExecute(ctx context.Context, options ...daemonOption) error {
247
247
serviceWg , errs ,
248
248
)
249
249
idleCheckInterval := settings .exitInterval
250
- setupExtraStopWriters (idleCheckInterval , fsys ,
250
+ setupExtraStopWriters (idleCheckInterval , & fsys ,
251
251
stopSend , errs ,
252
252
log ,
253
253
)
@@ -404,7 +404,7 @@ func setupIPCHandler(ctx context.Context, procExitCh <-chan bool,
404
404
}
405
405
406
406
func setupExtraStopWriters (
407
- idleCheck time.Duration , fsys fileSystem ,
407
+ idleCheck time.Duration , fsys * fileSystem ,
408
408
stopper wgShutdown ,
409
409
errs wgErrs , log ulog.Logger ,
410
410
) {
@@ -510,7 +510,7 @@ func newFileSystem(ctx context.Context, uid p9.UID, gid p9.GID) (fileSystem, err
510
510
listen : listen ,
511
511
control : control ,
512
512
}
513
- return system , linkSystems (system )
513
+ return system , linkSystems (& system )
514
514
}
515
515
516
516
func newListener (ctx context.Context , parent p9.File , path ninePath ,
@@ -583,7 +583,7 @@ func newControl(ctx context.Context,
583
583
}, nil
584
584
}
585
585
586
- func linkSystems (system fileSystem ) error {
586
+ func linkSystems (system * fileSystem ) error {
587
587
root := system .root
588
588
for _ , file := range []struct {
589
589
p9.File
@@ -854,7 +854,7 @@ func stopOnDone(ctx context.Context, stopCh wgShutdown) {
854
854
}
855
855
}
856
856
857
- func stopOnUnreachable (fsys fileSystem , stopper wgShutdown ,
857
+ func stopOnUnreachable (fsys * fileSystem , stopper wgShutdown ,
858
858
errs wgErrs , log ulog.Logger ,
859
859
) {
860
860
const (
@@ -1033,7 +1033,7 @@ func stopWhen(checkFn checkFunc, interval time.Duration,
1033
1033
1034
1034
// makeIdleChecker prevents the process from lingering around
1035
1035
// if a client closes all services, then disconnects.
1036
- func makeIdleChecker (fsys fileSystem , interval time.Duration , log ulog.Logger ) checkFunc {
1036
+ func makeIdleChecker (fsys * fileSystem , interval time.Duration , log ulog.Logger ) checkFunc {
1037
1037
var (
1038
1038
mounts = fsys .mount .MountFile
1039
1039
listeners = fsys .listen .Listener
@@ -1072,15 +1072,15 @@ func hasActiveClients(listeners p9.File, threshold time.Duration) (bool, error)
1072
1072
return false , err
1073
1073
}
1074
1074
for _ , info := range infos {
1075
- lastActive := lastActive (info )
1075
+ lastActive := lastActive (& info )
1076
1076
if time .Since (lastActive ) <= threshold {
1077
1077
return true , nil
1078
1078
}
1079
1079
}
1080
1080
return false , nil
1081
1081
}
1082
1082
1083
- func lastActive (info p9fs.ConnInfo ) time.Time {
1083
+ func lastActive (info * p9fs.ConnInfo ) time.Time {
1084
1084
var (
1085
1085
read = info .LastRead
1086
1086
write = info .LastWrite
0 commit comments