121 lines
3.0 KiB
Go
121 lines
3.0 KiB
Go
// Copyright 2015 Google Inc. All Rights Reserved.
|
|
// Author: jacobsa@google.com (Aaron Jacobs)
|
|
|
|
package fuse
|
|
|
|
import (
|
|
"fmt"
|
|
"io"
|
|
"log"
|
|
|
|
"golang.org/x/net/context"
|
|
|
|
bazilfuse "bazil.org/fuse"
|
|
)
|
|
|
|
// An object that terminates one end of the userspace <-> FUSE VFS connection.
|
|
type server struct {
|
|
logger *log.Logger
|
|
fs FileSystem
|
|
}
|
|
|
|
// Create a server that relays requests to the supplied file system.
|
|
func newServer(fs FileSystem) (s *server, err error) {
|
|
s = &server{
|
|
logger: getLogger(),
|
|
fs: fs,
|
|
}
|
|
|
|
return
|
|
}
|
|
|
|
// Serve the fuse connection by repeatedly reading requests from the supplied
|
|
// FUSE connection, responding as dictated by the file system. Return when the
|
|
// connection is closed or an unexpected error occurs.
|
|
func (s *server) Serve(c *bazilfuse.Conn) (err error) {
|
|
// Read a message at a time, dispatching to goroutines doing the actual
|
|
// processing.
|
|
for {
|
|
var fuseReq bazilfuse.Request
|
|
fuseReq, err = c.ReadRequest()
|
|
|
|
// ReadRequest returns EOF when the connection has been closed.
|
|
//
|
|
// TODO(jacobsa): Remove this and verify it's actually needed.
|
|
if err == io.EOF {
|
|
err = nil
|
|
return
|
|
}
|
|
|
|
// Otherwise, forward on errors.
|
|
if err != nil {
|
|
err = fmt.Errorf("Conn.ReadRequest: %v", err)
|
|
return
|
|
}
|
|
|
|
go s.handleFuseRequest(fuseReq)
|
|
}
|
|
}
|
|
|
|
func (s *server) handleFuseRequest(fuseReq bazilfuse.Request) {
|
|
// Log the request.
|
|
s.logger.Println("Received:", fuseReq)
|
|
|
|
// TODO(jacobsa): Support cancellation when interrupted, if we can coax the
|
|
// system into reproducing such requests.
|
|
ctx := context.Background()
|
|
|
|
// Attempt to handle it.
|
|
switch typed := fuseReq.(type) {
|
|
case *bazilfuse.InitRequest:
|
|
// Responding to this is required to make mounting work, at least on OS X.
|
|
// We don't currently expose the capability for the file system to
|
|
// intercept this.
|
|
fuseResp := &bazilfuse.InitResponse{}
|
|
s.logger.Println("Responding:", fuseResp)
|
|
typed.Respond(fuseResp)
|
|
|
|
case *bazilfuse.StatfsRequest:
|
|
// Responding to this is required to make mounting work, at least on OS X.
|
|
// We don't currently expose the capability for the file system to
|
|
// intercept this.
|
|
fuseResp := &bazilfuse.StatfsResponse{}
|
|
s.logger.Println("Responding:", fuseResp)
|
|
typed.Respond(fuseResp)
|
|
|
|
case *bazilfuse.OpenRequest:
|
|
// We support only directories at this point.
|
|
if !typed.Dir {
|
|
s.logger.Println("We don't yet support files. Returning ENOSYS.")
|
|
typed.RespondError(ENOSYS)
|
|
return
|
|
}
|
|
|
|
// Convert the request.
|
|
req := &OpenDirRequest{
|
|
Inode: InodeID(typed.Header.Node),
|
|
Flags: typed.Flags,
|
|
}
|
|
|
|
// Call the file system.
|
|
resp, err := s.fs.OpenDir(ctx, req)
|
|
if err != nil {
|
|
s.logger.Print("Responding:", err)
|
|
typed.RespondError(err)
|
|
return
|
|
}
|
|
|
|
// Convert the response.
|
|
fuseResp := &bazilfuse.OpenResponse{
|
|
Handle: bazilfuse.HandleID(resp.Handle),
|
|
}
|
|
|
|
s.logger.Print("Responding:", fuseResp)
|
|
typed.Respond(fuseResp)
|
|
|
|
default:
|
|
s.logger.Println("Unhandled type. Returning ENOSYS.")
|
|
typed.RespondError(ENOSYS)
|
|
}
|
|
}
|