diff options
Diffstat (limited to 'weed/shell')
| -rw-r--r-- | weed/shell/command_mount_configure.go | 5 | ||||
| -rw-r--r-- | weed/shell/command_volume_fsck.go | 3 |
2 files changed, 4 insertions, 4 deletions
diff --git a/weed/shell/command_mount_configure.go b/weed/shell/command_mount_configure.go index 5b224c39e..185857b9a 100644 --- a/weed/shell/command_mount_configure.go +++ b/weed/shell/command_mount_configure.go @@ -4,12 +4,13 @@ import ( "context" "flag" "fmt" + "io" + "github.com/seaweedfs/seaweedfs/weed/pb/mount_pb" "github.com/seaweedfs/seaweedfs/weed/util" "google.golang.org/grpc" "google.golang.org/grpc/credentials/insecure" _ "google.golang.org/grpc/resolver/passthrough" - "io" ) func init() { @@ -53,7 +54,7 @@ func (c *commandMountConfigure) Do(args []string, commandEnv *CommandEnv, writer } localSocket := fmt.Sprintf("/tmp/seaweedfs-mount-%d.sock", mountDirHash) - clientConn, err := grpc.Dial("passthrough:///unix://"+localSocket, grpc.WithTransportCredentials(insecure.NewCredentials())) + clientConn, err := grpc.NewClient("passthrough:///unix://"+localSocket, grpc.WithTransportCredentials(insecure.NewCredentials())) if err != nil { return } diff --git a/weed/shell/command_volume_fsck.go b/weed/shell/command_volume_fsck.go index e8140d3aa..2ee4309e4 100644 --- a/weed/shell/command_volume_fsck.go +++ b/weed/shell/command_volume_fsck.go @@ -152,8 +152,7 @@ func (c *commandVolumeFsck) Do(args []string, commandEnv *CommandEnv, writer io. collectModifyFromAtNs = time.Now().Add(-*modifyTimeAgo).UnixNano() } // collect each volume file ids - eg, gCtx := errgroup.WithContext(context.Background()) - _ = gCtx + eg, _ := errgroup.WithContext(context.Background()) for _dataNodeId, _volumeIdToVInfo := range dataNodeVolumeIdToVInfo { dataNodeId, volumeIdToVInfo := _dataNodeId, _volumeIdToVInfo eg.Go(func() error { |