14 "github.com/docker/go-p9p"
20 refs map[p9p.Fid]*FileRef
23 func NewSession(ctx context.Context, root string) (p9p.Session, error) {
25 rootRef: &FileRef{Path: root},
26 refs: make(map[p9p.Fid]*FileRef),
30 func (sess *session) getRef(fid p9p.Fid) (*FileRef, error) {
35 return nil, p9p.ErrUnknownfid
38 ref, found := sess.refs[fid]
40 return nil, p9p.ErrUnknownfid
43 if err := ref.Stat(); err != nil {
50 func (sess *session) newRef(fid p9p.Fid, path string) (*FileRef, error) {
55 return nil, p9p.ErrUnknownfid
58 _, found := sess.refs[fid]
60 return nil, p9p.ErrDupfid
63 ref := &FileRef{Path: path}
64 if err := ref.Stat(); err != nil {
72 func (sess *session) Auth(ctx context.Context, afid p9p.Fid, uname, aname string) (p9p.Qid, error) {
74 return p9p.Qid{}, nil //p9p.MessageRerror{Ename: "no auth"}
77 func (sess *session) Attach(ctx context.Context, fid, afid p9p.Fid, uname, aname string) (p9p.Qid, error) {
79 return p9p.Qid{}, p9p.MessageRerror{Ename: "no user"}
85 // return p9p.Qid{}, p9p.MessageRerror{Ename: "attach: no auth"}
89 aname = sess.rootRef.Path
92 ref, err := sess.newRef(fid, aname)
97 return ref.Info.Qid, nil
100 func (sess *session) Clunk(ctx context.Context, fid p9p.Fid) error {
101 ref, err := sess.getRef(fid)
114 delete(sess.refs, fid)
119 func (sess *session) Remove(ctx context.Context, fid p9p.Fid) error {
120 defer sess.Clunk(ctx, fid)
122 ref, err := sess.getRef(fid)
127 // TODO: check write perms on parent
129 return os.Remove(ref.Path)
132 func (sess *session) Walk(ctx context.Context, fid p9p.Fid, newfid p9p.Fid, names ...string) ([]p9p.Qid, error) {
135 ref, err := sess.getRef(fid)
140 newref, err := sess.newRef(newfid, ref.Path)
146 for _, name := range names {
147 newpath := filepath.Join(path, name)
148 r := &FileRef{Path: newpath}
149 if err := r.Stat(); err != nil {
152 qids = append(qids, r.Info.Qid)
160 func (sess *session) Read(ctx context.Context, fid p9p.Fid, p []byte, offset int64) (n int, err error) {
161 ref, err := sess.getRef(fid)
170 if offset == 0 && ref.Readdir == nil {
171 files, err := ioutil.ReadDir(ref.Path)
176 for _, info := range files {
177 dirs = append(dirs, dirFromInfo(info))
179 ref.Readdir = p9p.NewFixedReaddir(p9p.NewCodec(), dirs)
181 if ref.Readdir == nil {
182 return 0, p9p.ErrBadoffset
184 return ref.Readdir.Read(ctx, p, offset)
188 return 0, p9p.MessageRerror{Ename: "no file open"} //p9p.ErrClosed
191 n, err = ref.File.ReadAt(p, offset)
192 if err != nil && err != io.EOF {
198 func (sess *session) Write(ctx context.Context, fid p9p.Fid, p []byte, offset int64) (n int, err error) {
199 ref, err := sess.getRef(fid)
207 return 0, p9p.ErrClosed
210 return ref.File.WriteAt(p, offset)
213 func (sess *session) Open(ctx context.Context, fid p9p.Fid, mode p9p.Flag) (p9p.Qid, uint32, error) {
214 ref, err := sess.getRef(fid)
216 return p9p.Qid{}, 0, err
221 f, err := os.OpenFile(ref.Path, oflags(mode), 0)
223 return p9p.Qid{}, 0, err
226 return ref.Info.Qid, 0, nil
229 func (sess *session) Create(ctx context.Context, parent p9p.Fid, name string, perm uint32, mode p9p.Flag) (p9p.Qid, uint32, error) {
230 ref, err := sess.getRef(parent)
232 return p9p.Qid{}, 0, err
235 newpath := filepath.Join(ref.Path, name)
239 case perm&p9p.DMDIR != 0:
240 err = os.Mkdir(newpath, os.FileMode(perm&0777))
242 case perm&p9p.DMSYMLINK != 0:
243 case perm&p9p.DMNAMEDPIPE != 0:
244 case perm&p9p.DMDEVICE != 0:
245 err = p9p.MessageRerror{Ename: "not implemented"}
248 file, err = os.OpenFile(newpath, oflags(mode)|os.O_CREATE, os.FileMode(perm&0777))
251 if file == nil && err == nil {
252 file, err = os.OpenFile(newpath, oflags(mode), 0)
256 return p9p.Qid{}, 0, err
263 if err := ref.statLocked(); err != nil {
264 return p9p.Qid{}, 0, err
266 return ref.Info.Qid, 0, err
269 func (sess *session) Stat(ctx context.Context, fid p9p.Fid) (p9p.Dir, error) {
270 ref, err := sess.getRef(fid)
272 return p9p.Dir{}, err
277 func (sess *session) WStat(ctx context.Context, fid p9p.Fid, dir p9p.Dir) error {
278 ref, err := sess.getRef(fid)
283 if dir.Mode != ^uint32(0) {
284 // TODO: 9P2000.u: DMSETUID DMSETGID
285 err := os.Chmod(ref.Path, os.FileMode(dir.Mode&0777))
291 if dir.UID != "" || dir.GID != "" {
292 usr, err := user.Lookup(dir.UID)
296 uid, err := strconv.Atoi(usr.Uid)
300 grp, err := user.LookupGroup(dir.GID)
304 gid, err := strconv.Atoi(grp.Gid)
308 if err := os.Chown(ref.Path, uid, gid); err != nil {
314 newpath := filepath.Join(filepath.Dir(ref.Path), dir.Name)
315 if err := syscall.Rename(ref.Path, newpath); err != nil {
323 if dir.Length != ^uint64(0) {
324 if err := os.Truncate(ref.Path, int64(dir.Length)); err != nil {
329 // If either mtime or atime need to be changed, then
330 // we must change both.
331 //if dir.ModTime != time.Time{} || dir.AccessTime != ^uint32(0) {
332 // mt, at := time.Unix(int64(dir.Mtime), 0), time.Unix(int64(dir.Atime), 0)
333 // if cmt, cat := (dir.Mtime == ^uint32(0)), (dir.Atime == ^uint32(0)); cmt || cat {
334 // st, e := os.Stat(fid.path)
336 // req.RespondError(toError(e))
343 // at = atime(st.Sys().(*syscall.Stat_t))
346 // e := os.Chtimes(fid.path, at, mt)
348 // req.RespondError(toError(e))
355 func (sess *session) Version() (msize int, version string) {
356 return p9p.DefaultMSize, p9p.DefaultVersion