diff options
Diffstat (limited to 'pkg')
| -rw-r--r-- | pkg/driver/mounter_seaweedfs.go | 10 | ||||
| -rw-r--r-- | pkg/driver/nodeserver.go | 4 |
2 files changed, 12 insertions, 2 deletions
diff --git a/pkg/driver/mounter_seaweedfs.go b/pkg/driver/mounter_seaweedfs.go index 4d448de..85eb716 100644 --- a/pkg/driver/mounter_seaweedfs.go +++ b/pkg/driver/mounter_seaweedfs.go @@ -2,6 +2,8 @@ package driver import ( "fmt" + + "github.com/golang/glog" ) // Implements Mounter @@ -22,6 +24,8 @@ func newSeaweedFsMounter(bucketName string, filer string) (Mounter, error) { } func (seaweedFs *seaweedFsMounter) Mount(target string) error { + glog.V(4).Infof("mounting %s%s to %s", seaweedFs.filerUrl, seaweedFs.bucketName, target) + args := []string{ "mount", fmt.Sprintf("-dir=%s", target), @@ -29,5 +33,9 @@ func (seaweedFs *seaweedFsMounter) Mount(target string) error { fmt.Sprintf("-filer=%s", seaweedFs.filerUrl), fmt.Sprintf("-filer.path=/buckets/%s", seaweedFs.bucketName), } - return fuseMount(target, seaweedFsCmd, args) + err := fuseMount(target, seaweedFsCmd, args) + if err != nil { + glog.Errorf("mount %s%s to %s: %s", seaweedFs.filerUrl, seaweedFs.bucketName, target, err) + } + return err } diff --git a/pkg/driver/nodeserver.go b/pkg/driver/nodeserver.go index b281da9..57acd5f 100644 --- a/pkg/driver/nodeserver.go +++ b/pkg/driver/nodeserver.go @@ -25,6 +25,8 @@ func (ns *NodeServer) NodePublishVolume(ctx context.Context, req *csi.NodePublis // mount the fs here targetPath := req.GetTargetPath() + glog.V(4).Infof("NodePublishVolume volume %s to %s", volumeID, targetPath) + // Check arguments if req.GetVolumeCapability() == nil { return nil, status.Error(codes.InvalidArgument, "Volume capability missing in request") @@ -93,7 +95,7 @@ func (ns *NodeServer) NodeUnpublishVolume(ctx context.Context, req *csi.NodeUnpu } func (ns *NodeServer) NodeGetInfo(ctx context.Context, req *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error) { - glog.V(5).Infof("Using default NodeGetInfo") + glog.V(5).Infof("Using default NodeGetInfo: nodeID %s", ns.Driver.nodeID) return &csi.NodeGetInfoResponse{ NodeId: ns.Driver.nodeID, |