Skip to content

Commit

Permalink
use as many goroutines for ForgetInode op
Browse files Browse the repository at this point in the history
in #30 forgetinode was changed into inline ServerOps, this may solove
memory oom, but the performance of rm op will be very slow, and it will
also hang other ops, so i think limit the max num of forgetinode
goroutines, this can avoid oom but not affect performance
  • Loading branch information
kungf committed Mar 18, 2020
1 parent 7d791d2 commit 4b07f0d
Showing 1 changed file with 11 additions and 7 deletions.
18 changes: 11 additions & 7 deletions fuseutil/file_system.go
Original file line number Diff line number Diff line change
Expand Up @@ -84,13 +84,15 @@ type FileSystem interface {
// requests").
func NewFileSystemServer(fs FileSystem) fuse.Server {
return &fileSystemServer{
fs: fs,
fs: fs,
opsForgetInode: make(chan int, 100000),
}
}

type fileSystemServer struct {
fs FileSystem
opsInFlight sync.WaitGroup
fs FileSystem
opsInFlight sync.WaitGroup
opsForgetInode chan int
}

func (s *fileSystemServer) ServeOps(c *fuse.Connection) {
Expand All @@ -113,11 +115,12 @@ func (s *fileSystemServer) ServeOps(c *fuse.Connection) {

s.opsInFlight.Add(1)
if _, ok := op.(*fuseops.ForgetInodeOp); ok {
// Special case: call in this goroutine for
// forget inode ops, which may come in a
// flurry from the kernel and are generally
// cheap for the file system to handle
s.handleOp(c, ctx, op)
// flurry from the kernel and we should
// to limit the number of goroutines
// one goroutine 2KB, 10w goroutine max 200MB
s.opsForgetInode <- 1
go s.handleOp(c, ctx, op)
} else {
go s.handleOp(c, ctx, op)
}
Expand Down Expand Up @@ -150,6 +153,7 @@ func (s *fileSystemServer) handleOp(

case *fuseops.ForgetInodeOp:
err = s.fs.ForgetInode(ctx, typed)
<-s.opsForgetInode

case *fuseops.MkDirOp:
err = s.fs.MkDir(ctx, typed)
Expand Down

0 comments on commit 4b07f0d

Please sign in to comment.