Support opening files in server.

geesefs-0-30-9
Aaron Jacobs 2015-02-27 15:49:29 +11:00
parent 1f94acef2a
commit 4e5dbbe38f
1 changed files with 42 additions and 24 deletions

View File

@ -147,34 +147,52 @@ func (s *server) handleFuseRequest(fuseReq bazilfuse.Request) {
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
}
// File or directory?
if typed.Dir {
// Convert the request.
req := &OpenDirRequest{
Inode: InodeID(typed.Header.Node),
Flags: typed.Flags,
}
// 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
}
// 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),
}
// Convert the response.
fuseResp := &bazilfuse.OpenResponse{
Handle: bazilfuse.HandleID(resp.Handle),
}
s.logger.Print("Responding:", fuseResp)
typed.Respond(fuseResp)
} else {
// Convert the request.
req := &OpenFileRequest{
Inode: InodeID(typed.Header.Node),
Flags: typed.Flags,
}
s.logger.Print("Responding:", fuseResp)
typed.Respond(fuseResp)
// Call the file system.
resp, err := s.fs.OpenFile(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)
}
case *bazilfuse.ReadRequest:
// We support only directories at this point.