add symlink

weed/mount/weedfs_symlink.go

@@ -0,0 +1,77 @@
+package mount
+
+import (
+	"context"
+	"fmt"
+	"github.com/chrislusf/seaweedfs/weed/filer"
+	"github.com/chrislusf/seaweedfs/weed/glog"
+	"github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
+	"github.com/hanwen/go-fuse/v2/fuse"
+	"os"
+	"time"
+)
+
+func (wfs *WFS) Symlink(cancel <-chan struct{}, header *fuse.InHeader, target string, name string, out *fuse.EntryOut) (code fuse.Status) {
+
+	if s := checkName(name); s != fuse.OK {
+		return s
+	}
+
+	dirPath := wfs.inodeToPath.GetPath(header.NodeId)
+	entryFullPath := dirPath.Child(name)
+
+	request := &filer_pb.CreateEntryRequest{
+		Directory: string(dirPath),
+		Entry: &filer_pb.Entry{
+			Name:        name,
+			IsDirectory: false,
+			Attributes: &filer_pb.FuseAttributes{
+				Mtime:         time.Now().Unix(),
+				Crtime:        time.Now().Unix(),
+				FileMode:      uint32((os.FileMode(0777) | os.ModeSymlink) &^ wfs.option.Umask),
+				Uid:           header.Uid,
+				Gid:           header.Gid,
+				SymlinkTarget: target,
+			},
+		},
+		Signatures: []int32{wfs.signature},
+	}
+
+	err := wfs.WithFilerClient(false, func(client filer_pb.SeaweedFilerClient) error {
+
+		wfs.mapPbIdFromLocalToFiler(request.Entry)
+		defer wfs.mapPbIdFromFilerToLocal(request.Entry)
+
+		if err := filer_pb.CreateEntry(client, request); err != nil {
+			return fmt.Errorf("symlink %s: %v", entryFullPath, err)
+		}
+
+		wfs.metaCache.InsertEntry(context.Background(), filer.FromPbEntry(request.Directory, request.Entry))
+
+		return nil
+	})
+	if err != nil {
+		glog.V(0).Infof("Symlink %s => %s: %v", entryFullPath, target, err)
+		return fuse.EIO
+	}
+
+	inode := wfs.inodeToPath.GetInode(entryFullPath)
+
+	wfs.outputPbEntry(out, inode, request.Entry)
+
+	return fuse.OK
+}
+
+func (wfs *WFS) Readlink(cancel <-chan struct{}, header *fuse.InHeader) (out []byte, code fuse.Status) {
+	entryFullPath := wfs.inodeToPath.GetPath(header.NodeId)
+
+	entry, status := wfs.maybeLoadEntry(entryFullPath)
+	if status != fuse.OK {
+		return nil, status
+	}
+	if os.FileMode(entry.Attributes.FileMode)&os.ModeSymlink == 0 {
+		return nil, fuse.EINVAL
+	}
+
+	return []byte(entry.Attributes.SymlinkTarget), fuse.OK
+}