aboutsummaryrefslogtreecommitdiff
path: root/weed/shell
diff options
context:
space:
mode:
authorhilimd <68371223+hilimd@users.noreply.github.com>2021-10-23 19:52:48 +0800
committerGitHub <noreply@github.com>2021-10-23 19:52:48 +0800
commitee90edd0e3746ae0f6046dd9e7362aeec821456c (patch)
treeaf291d9afde8e3be8ba9061e14edad75a34d0c6b /weed/shell
parent0548ed3a1b5aa15b035b452519568bc017c065a3 (diff)
parent07dd4873db996c4f4a94ee3b0975052d0ec7595b (diff)
downloadseaweedfs-ee90edd0e3746ae0f6046dd9e7362aeec821456c.tar.xz
seaweedfs-ee90edd0e3746ae0f6046dd9e7362aeec821456c.zip
Merge pull request #83 from chrislusf/master
sync
Diffstat (limited to 'weed/shell')
-rw-r--r--weed/shell/command_fs_configure.go19
-rw-r--r--weed/shell/command_volume_fsck.go9
2 files changed, 5 insertions, 23 deletions
diff --git a/weed/shell/command_fs_configure.go b/weed/shell/command_fs_configure.go
index 0aae51d74..25761d580 100644
--- a/weed/shell/command_fs_configure.go
+++ b/weed/shell/command_fs_configure.go
@@ -62,7 +62,7 @@ func (c *commandFsConfigure) Do(args []string, commandEnv *CommandEnv, writer io
return nil
}
- fc, err := readFilerConf(commandEnv)
+ fc, err := filer.ReadFilerConf(commandEnv.option.FilerAddress, commandEnv.option.GrpcDialOption, commandEnv.MasterClient)
if err != nil {
return err
}
@@ -122,20 +122,3 @@ func (c *commandFsConfigure) Do(args []string, commandEnv *CommandEnv, writer io
return nil
}
-
-func readFilerConf(commandEnv *CommandEnv) (*filer.FilerConf, error) {
- var buf bytes.Buffer
- if err := commandEnv.WithFilerClient(func(client filer_pb.SeaweedFilerClient) error {
- return filer.ReadEntry(commandEnv.MasterClient, client, filer.DirectoryEtcSeaweedFS, filer.FilerConfName, &buf)
- }); err != nil && err != filer_pb.ErrNotFound {
- return nil, fmt.Errorf("read %s/%s: %v", filer.DirectoryEtcSeaweedFS, filer.FilerConfName, err)
- }
-
- fc := filer.NewFilerConf()
- if buf.Len() > 0 {
- if err := fc.LoadFromBytes(buf.Bytes()); err != nil {
- return nil, fmt.Errorf("parse %s/%s: %v", filer.DirectoryEtcSeaweedFS, filer.FilerConfName, err)
- }
- }
- return fc, nil
-}
diff --git a/weed/shell/command_volume_fsck.go b/weed/shell/command_volume_fsck.go
index ce5ea66bf..119973a5b 100644
--- a/weed/shell/command_volume_fsck.go
+++ b/weed/shell/command_volume_fsck.go
@@ -5,10 +5,7 @@ import (
"context"
"flag"
"fmt"
- "github.com/chrislusf/seaweedfs/weed/pb"
- "github.com/chrislusf/seaweedfs/weed/storage/needle"
"io"
- "io/ioutil"
"math"
"os"
"path/filepath"
@@ -16,9 +13,11 @@ import (
"github.com/chrislusf/seaweedfs/weed/filer"
"github.com/chrislusf/seaweedfs/weed/operation"
+ "github.com/chrislusf/seaweedfs/weed/pb"
"github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
"github.com/chrislusf/seaweedfs/weed/pb/master_pb"
"github.com/chrislusf/seaweedfs/weed/pb/volume_server_pb"
+ "github.com/chrislusf/seaweedfs/weed/storage/needle"
"github.com/chrislusf/seaweedfs/weed/storage/needle_map"
"github.com/chrislusf/seaweedfs/weed/storage/types"
"github.com/chrislusf/seaweedfs/weed/util"
@@ -74,7 +73,7 @@ func (c *commandVolumeFsck) Do(args []string, commandEnv *CommandEnv, writer io.
c.env = commandEnv
// create a temp folder
- tempFolder, err := ioutil.TempDir("", "sw_fsck")
+ tempFolder, err := os.MkdirTemp("", "sw_fsck")
if err != nil {
return fmt.Errorf("failed to create temp folder: %v", err)
}
@@ -402,7 +401,7 @@ func (c *commandVolumeFsck) oneVolumeFileIdsSubtractFilerFileIds(tempFolder stri
return
}
- filerFileIdsData, err := ioutil.ReadFile(getFilerFileIdFile(tempFolder, volumeId))
+ filerFileIdsData, err := os.ReadFile(getFilerFileIdFile(tempFolder, volumeId))
if err != nil {
return
}