aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2021-09-01 02:45:42 -0700
committerChris Lu <chris.lu@gmail.com>2021-09-01 02:45:42 -0700
commit7ce97b59d828b3f6d7bcdab323209740280da3f3 (patch)
treeb4f50634e183c2bc8ba897baefbf3d62731bf9f8
parentd1a4e19a3f0aeaabcf87aba3c99880f82bde87a3 (diff)
downloadseaweedfs-7ce97b59d828b3f6d7bcdab323209740280da3f3.tar.xz
seaweedfs-7ce97b59d828b3f6d7bcdab323209740280da3f3.zip
go fmt
-rw-r--r--weed/command/filer_remote_sync.go2
-rw-r--r--weed/command/filer_sync_std.go1
-rw-r--r--weed/command/mount_notsupported.go5
-rw-r--r--weed/command/mount_std.go1
-rw-r--r--weed/filer/read_remote.go2
-rw-r--r--weed/filer/sqlite/sqlite_store.go1
-rw-r--r--weed/filer/sqlite/sqlite_store_unsupported.go1
-rw-r--r--weed/filer/stream.go20
-rw-r--r--weed/filer/tikv/tikv_store.go1
-rw-r--r--weed/filer/tikv/tikv_store_kv.go1
-rw-r--r--weed/remote_storage/gcs/gcs_storage_client.go6
-rw-r--r--weed/remote_storage/s3/aliyun.go6
-rw-r--r--weed/remote_storage/s3/backblaze.go6
-rw-r--r--weed/remote_storage/s3/baidu.go6
-rw-r--r--weed/remote_storage/s3/filebase.go6
-rw-r--r--weed/remote_storage/s3/storj.go6
-rw-r--r--weed/remote_storage/s3/tencent.go6
-rw-r--r--weed/remote_storage/traverse_bfs.go2
-rw-r--r--weed/replication/sink/s3sink/s3_sink.go6
-rw-r--r--weed/replication/sub/notification_aws_sqs.go2
-rw-r--r--weed/server/filer_grpc_server_remote.go10
-rw-r--r--weed/server/filer_grpc_server_sub_meta.go2
-rw-r--r--weed/server/filer_server_rocksdb.go1
-rw-r--r--weed/server/volume_grpc_copy.go8
-rw-r--r--weed/shell/command_remote_cache.go2
-rw-r--r--weed/shell/command_remote_configure.go1
-rw-r--r--weed/stats/disk_notsupported.go1
-rw-r--r--weed/stats/disk_supported.go1
-rw-r--r--weed/stats/memory_notsupported.go1
-rw-r--r--weed/stats/memory_supported.go1
-rw-r--r--weed/storage/backend/memory_map/memory_map_other.go1
-rw-r--r--weed/storage/backend/memory_map/memory_map_windows.go1
-rw-r--r--weed/storage/backend/s3_backend/s3_sessions.go6
-rw-r--r--weed/storage/backend/volume_create.go1
-rw-r--r--weed/storage/backend/volume_create_linux.go1
-rw-r--r--weed/storage/backend/volume_create_windows.go1
-rw-r--r--weed/storage/needle_map/compact_map_cases_test.go1
-rw-r--r--weed/storage/types/offset_4bytes.go1
-rw-r--r--weed/storage/types/offset_5bytes.go1
-rw-r--r--weed/util/constants_4bytes.go1
-rw-r--r--weed/util/constants_5bytes.go1
-rw-r--r--weed/util/file_util_non_posix.go1
-rw-r--r--weed/util/file_util_posix.go1
-rw-r--r--weed/util/grace/signal_handling.go1
-rw-r--r--weed/util/grace/signal_handling_notsupported.go1
45 files changed, 79 insertions, 56 deletions
diff --git a/weed/command/filer_remote_sync.go b/weed/command/filer_remote_sync.go
index b751d30b6..fb88652c1 100644
--- a/weed/command/filer_remote_sync.go
+++ b/weed/command/filer_remote_sync.go
@@ -154,7 +154,7 @@ func followUpdatesAndUploadToRemote(option *RemoteSyncOptions, filerSource *sour
os.Exit(0)
}
}
- if message.NewEntry.Name == remoteStorage.Name + filer.REMOTE_STORAGE_CONF_SUFFIX {
+ if message.NewEntry.Name == remoteStorage.Name+filer.REMOTE_STORAGE_CONF_SUFFIX {
conf := &remote_pb.RemoteConf{}
if err := proto.Unmarshal(message.NewEntry.Content, conf); err != nil {
return fmt.Errorf("unmarshal %s/%s: %v", filer.DirectoryEtcRemote, message.NewEntry.Name, err)
diff --git a/weed/command/filer_sync_std.go b/weed/command/filer_sync_std.go
index 63851eaf8..1f9b6fa14 100644
--- a/weed/command/filer_sync_std.go
+++ b/weed/command/filer_sync_std.go
@@ -1,3 +1,4 @@
+//go:build !windows
// +build !windows
package command
diff --git a/weed/command/mount_notsupported.go b/weed/command/mount_notsupported.go
index f3c0de3d6..1e5c9f53d 100644
--- a/weed/command/mount_notsupported.go
+++ b/weed/command/mount_notsupported.go
@@ -1,6 +1,5 @@
-// +build !linux
-// +build !darwin
-// +build !freebsd
+//go:build !linux && !darwin && !freebsd
+// +build !linux,!darwin,!freebsd
package command
diff --git a/weed/command/mount_std.go b/weed/command/mount_std.go
index cdf340067..e393e5894 100644
--- a/weed/command/mount_std.go
+++ b/weed/command/mount_std.go
@@ -1,3 +1,4 @@
+//go:build linux || darwin || freebsd
// +build linux darwin freebsd
package command
diff --git a/weed/filer/read_remote.go b/weed/filer/read_remote.go
index 3406246a9..58639024b 100644
--- a/weed/filer/read_remote.go
+++ b/weed/filer/read_remote.go
@@ -21,7 +21,7 @@ func MapFullPathToRemoteStorageLocation(localMountedDir util.FullPath, remoteMou
return remoteLocation
}
-func MapRemoteStorageLocationPathToFullPath(localMountedDir util.FullPath, remoteMountedLocation *remote_pb.RemoteStorageLocation, remoteLocationPath string)(fp util.FullPath) {
+func MapRemoteStorageLocationPathToFullPath(localMountedDir util.FullPath, remoteMountedLocation *remote_pb.RemoteStorageLocation, remoteLocationPath string) (fp util.FullPath) {
return localMountedDir.Child(remoteLocationPath[len(remoteMountedLocation.Path):])
}
diff --git a/weed/filer/sqlite/sqlite_store.go b/weed/filer/sqlite/sqlite_store.go
index 6b055e53c..ca9d38786 100644
--- a/weed/filer/sqlite/sqlite_store.go
+++ b/weed/filer/sqlite/sqlite_store.go
@@ -1,3 +1,4 @@
+//go:build linux || darwin || windows
// +build linux darwin windows
// limited GOOS due to modernc.org/libc/unistd
diff --git a/weed/filer/sqlite/sqlite_store_unsupported.go b/weed/filer/sqlite/sqlite_store_unsupported.go
index 803c71afa..0fba1ea33 100644
--- a/weed/filer/sqlite/sqlite_store_unsupported.go
+++ b/weed/filer/sqlite/sqlite_store_unsupported.go
@@ -1,3 +1,4 @@
+//go:build !linux && !darwin && !windows && !s390 && !ppc64le && !mips64
// +build !linux,!darwin,!windows,!s390,!ppc64le,!mips64
// limited GOOS due to modernc.org/libc/unistd
diff --git a/weed/filer/stream.go b/weed/filer/stream.go
index ce0264cd3..4a70d118e 100644
--- a/weed/filer/stream.go
+++ b/weed/filer/stream.go
@@ -127,14 +127,14 @@ func ReadAll(masterClient *wdclient.MasterClient, chunks []*filer_pb.FileChunk)
// ---------------- ChunkStreamReader ----------------------------------
type ChunkStreamReader struct {
- chunkViews []*ChunkView
- totalSize int64
- logicOffset int64
- buffer []byte
- bufferOffset int64
- bufferLock sync.Mutex
- chunk string
- lookupFileId wdclient.LookupFileIdFunctionType
+ chunkViews []*ChunkView
+ totalSize int64
+ logicOffset int64
+ buffer []byte
+ bufferOffset int64
+ bufferLock sync.Mutex
+ chunk string
+ lookupFileId wdclient.LookupFileIdFunctionType
}
var _ = io.ReadSeeker(&ChunkStreamReader{})
@@ -206,7 +206,7 @@ func (c *ChunkStreamReader) doRead(p []byte) (n int, err error) {
}
func (c *ChunkStreamReader) isBufferEmpty() bool {
- return len(c.buffer) <= int(c.logicOffset - c.bufferOffset)
+ return len(c.buffer) <= int(c.logicOffset-c.bufferOffset)
}
func (c *ChunkStreamReader) Seek(offset int64, whence int) (int64, error) {
@@ -261,7 +261,7 @@ func (c *ChunkStreamReader) prepareBufferFor(offset int64) (err error) {
} else if currentChunkIndex > 0 {
if insideChunk(offset, c.chunkViews[currentChunkIndex]) {
// good hit
- } else if insideChunk(offset, c.chunkViews[currentChunkIndex-1]){
+ } else if insideChunk(offset, c.chunkViews[currentChunkIndex-1]) {
currentChunkIndex -= 1
// fmt.Printf("select -1 chunk %d %s\n", currentChunkIndex, c.chunkViews[currentChunkIndex].FileId)
} else {
diff --git a/weed/filer/tikv/tikv_store.go b/weed/filer/tikv/tikv_store.go
index 4a8e8784d..561f23910 100644
--- a/weed/filer/tikv/tikv_store.go
+++ b/weed/filer/tikv/tikv_store.go
@@ -1,3 +1,4 @@
+//go:build tikv
// +build tikv
package tikv
diff --git a/weed/filer/tikv/tikv_store_kv.go b/weed/filer/tikv/tikv_store_kv.go
index 3fed7e045..1d9428c69 100644
--- a/weed/filer/tikv/tikv_store_kv.go
+++ b/weed/filer/tikv/tikv_store_kv.go
@@ -1,3 +1,4 @@
+//go:build tikv
// +build tikv
package tikv
diff --git a/weed/remote_storage/gcs/gcs_storage_client.go b/weed/remote_storage/gcs/gcs_storage_client.go
index 683b90086..997bf2c20 100644
--- a/weed/remote_storage/gcs/gcs_storage_client.go
+++ b/weed/remote_storage/gcs/gcs_storage_client.go
@@ -53,8 +53,8 @@ func (s gcsRemoteStorageMaker) Make(conf *remote_pb.RemoteConf) (remote_storage.
}
type gcsRemoteStorageClient struct {
- conf *remote_pb.RemoteConf
- client *storage.Client
+ conf *remote_pb.RemoteConf
+ client *storage.Client
}
var _ = remote_storage.RemoteStorageClient(&gcsRemoteStorageClient{})
@@ -169,7 +169,7 @@ func (gcs *gcsRemoteStorageClient) UpdateFileMetadata(loc *remote_pb.RemoteStora
if len(metadata) > 0 {
_, err = gcs.client.Bucket(loc.Bucket).Object(key).Update(context.Background(), storage.ObjectAttrsToUpdate{
- Metadata: metadata,
+ Metadata: metadata,
})
} else {
// no way to delete the metadata yet
diff --git a/weed/remote_storage/s3/aliyun.go b/weed/remote_storage/s3/aliyun.go
index 567c74299..864e4d5d0 100644
--- a/weed/remote_storage/s3/aliyun.go
+++ b/weed/remote_storage/s3/aliyun.go
@@ -30,9 +30,9 @@ func (s AliyunRemoteStorageMaker) Make(conf *remote_pb.RemoteConf) (remote_stora
secretKey := util.Nvl(conf.AliyunSecretKey, os.Getenv("ALICLOUD_ACCESS_KEY_SECRET"))
config := &aws.Config{
- Endpoint: aws.String(conf.AliyunEndpoint),
- Region: aws.String(conf.AliyunRegion),
- S3ForcePathStyle: aws.Bool(false),
+ Endpoint: aws.String(conf.AliyunEndpoint),
+ Region: aws.String(conf.AliyunRegion),
+ S3ForcePathStyle: aws.Bool(false),
S3DisableContentMD5Validation: aws.Bool(true),
}
if accessKey != "" && secretKey != "" {
diff --git a/weed/remote_storage/s3/backblaze.go b/weed/remote_storage/s3/backblaze.go
index 914f0ca44..ca24e85d2 100644
--- a/weed/remote_storage/s3/backblaze.go
+++ b/weed/remote_storage/s3/backblaze.go
@@ -25,9 +25,9 @@ func (s BackBlazeRemoteStorageMaker) Make(conf *remote_pb.RemoteConf) (remote_st
conf: conf,
}
config := &aws.Config{
- Endpoint: aws.String(conf.BackblazeEndpoint),
- Region: aws.String("us-west-002"),
- S3ForcePathStyle: aws.Bool(true),
+ Endpoint: aws.String(conf.BackblazeEndpoint),
+ Region: aws.String("us-west-002"),
+ S3ForcePathStyle: aws.Bool(true),
S3DisableContentMD5Validation: aws.Bool(true),
}
if conf.BackblazeKeyId != "" && conf.BackblazeApplicationKey != "" {
diff --git a/weed/remote_storage/s3/baidu.go b/weed/remote_storage/s3/baidu.go
index dfcf32512..6021c9330 100644
--- a/weed/remote_storage/s3/baidu.go
+++ b/weed/remote_storage/s3/baidu.go
@@ -30,9 +30,9 @@ func (s BaiduRemoteStorageMaker) Make(conf *remote_pb.RemoteConf) (remote_storag
secretKey := util.Nvl(conf.BaiduSecretKey, os.Getenv("BDCLOUD_SECRET_KEY"))
config := &aws.Config{
- Endpoint: aws.String(conf.BaiduEndpoint),
- Region: aws.String(conf.BaiduRegion),
- S3ForcePathStyle: aws.Bool(true),
+ Endpoint: aws.String(conf.BaiduEndpoint),
+ Region: aws.String(conf.BaiduRegion),
+ S3ForcePathStyle: aws.Bool(true),
S3DisableContentMD5Validation: aws.Bool(true),
}
if accessKey != "" && secretKey != "" {
diff --git a/weed/remote_storage/s3/filebase.go b/weed/remote_storage/s3/filebase.go
index e52c0be6e..fd5200f1a 100644
--- a/weed/remote_storage/s3/filebase.go
+++ b/weed/remote_storage/s3/filebase.go
@@ -31,9 +31,9 @@ func (s FilebaseRemoteStorageMaker) Make(conf *remote_pb.RemoteConf) (remote_sto
secretKey := util.Nvl(conf.FilebaseSecretKey, os.Getenv("AWS_SECRET_ACCESS_KEY"))
config := &aws.Config{
- Endpoint: aws.String(conf.FilebaseEndpoint),
- Region: aws.String("us-east-1"),
- S3ForcePathStyle: aws.Bool(true),
+ Endpoint: aws.String(conf.FilebaseEndpoint),
+ Region: aws.String("us-east-1"),
+ S3ForcePathStyle: aws.Bool(true),
S3DisableContentMD5Validation: aws.Bool(true),
}
if accessKey != "" && secretKey != "" {
diff --git a/weed/remote_storage/s3/storj.go b/weed/remote_storage/s3/storj.go
index 058009729..9e902515a 100644
--- a/weed/remote_storage/s3/storj.go
+++ b/weed/remote_storage/s3/storj.go
@@ -30,9 +30,9 @@ func (s StorjRemoteStorageMaker) Make(conf *remote_pb.RemoteConf) (remote_storag
secretKey := util.Nvl(conf.StorjSecretKey, os.Getenv("AWS_SECRET_ACCESS_KEY"))
config := &aws.Config{
- Endpoint: aws.String(conf.StorjEndpoint),
- Region: aws.String("us-west-2"),
- S3ForcePathStyle: aws.Bool(true),
+ Endpoint: aws.String(conf.StorjEndpoint),
+ Region: aws.String("us-west-2"),
+ S3ForcePathStyle: aws.Bool(true),
S3DisableContentMD5Validation: aws.Bool(true),
}
if accessKey != "" && secretKey != "" {
diff --git a/weed/remote_storage/s3/tencent.go b/weed/remote_storage/s3/tencent.go
index 9df72a7e2..b7711b956 100644
--- a/weed/remote_storage/s3/tencent.go
+++ b/weed/remote_storage/s3/tencent.go
@@ -30,9 +30,9 @@ func (s TencentRemoteStorageMaker) Make(conf *remote_pb.RemoteConf) (remote_stor
secretKey := util.Nvl(conf.TencentSecretKey, os.Getenv("COS_SECRETKEY"))
config := &aws.Config{
- Endpoint: aws.String(conf.TencentEndpoint),
- Region: aws.String("us-west-2"),
- S3ForcePathStyle: aws.Bool(true),
+ Endpoint: aws.String(conf.TencentEndpoint),
+ Region: aws.String("us-west-2"),
+ S3ForcePathStyle: aws.Bool(true),
S3DisableContentMD5Validation: aws.Bool(true),
}
if accessKey != "" && secretKey != "" {
diff --git a/weed/remote_storage/traverse_bfs.go b/weed/remote_storage/traverse_bfs.go
index 4056f8715..a73a1d5fd 100644
--- a/weed/remote_storage/traverse_bfs.go
+++ b/weed/remote_storage/traverse_bfs.go
@@ -45,7 +45,7 @@ func TraverseBfs(listDirFn ListDirectoryFunc, parentPath util.FullPath, visitFn
}
-func processOneDirectory(listDirFn ListDirectoryFunc, parentPath util.FullPath, visitFn VisitFunc, dirQueue *util.Queue, dirQueueWg *sync.WaitGroup) (error) {
+func processOneDirectory(listDirFn ListDirectoryFunc, parentPath util.FullPath, visitFn VisitFunc, dirQueue *util.Queue, dirQueueWg *sync.WaitGroup) error {
return listDirFn(parentPath, func(dir string, name string, isDirectory bool, remoteEntry *filer_pb.RemoteEntry) error {
if err := visitFn(dir, name, isDirectory, remoteEntry); err != nil {
diff --git a/weed/replication/sink/s3sink/s3_sink.go b/weed/replication/sink/s3sink/s3_sink.go
index 81cb87a18..c3da1ee3f 100644
--- a/weed/replication/sink/s3sink/s3_sink.go
+++ b/weed/replication/sink/s3sink/s3_sink.go
@@ -74,9 +74,9 @@ func (s3sink *S3Sink) initialize(awsAccessKeyId, awsSecretAccessKey, region, buc
s3sink.endpoint = endpoint
config := &aws.Config{
- Region: aws.String(s3sink.region),
- Endpoint: aws.String(s3sink.endpoint),
- S3ForcePathStyle: aws.Bool(true),
+ Region: aws.String(s3sink.region),
+ Endpoint: aws.String(s3sink.endpoint),
+ S3ForcePathStyle: aws.Bool(true),
S3DisableContentMD5Validation: aws.Bool(true),
}
if awsAccessKeyId != "" && awsSecretAccessKey != "" {
diff --git a/weed/replication/sub/notification_aws_sqs.go b/weed/replication/sub/notification_aws_sqs.go
index 844aa023d..08133533f 100644
--- a/weed/replication/sub/notification_aws_sqs.go
+++ b/weed/replication/sub/notification_aws_sqs.go
@@ -41,7 +41,7 @@ func (k *AwsSqsInput) Initialize(configuration util.Configuration, prefix string
func (k *AwsSqsInput) initialize(awsAccessKeyId, awsSecretAccessKey, region, queueName string) (err error) {
config := &aws.Config{
- Region: aws.String(region),
+ Region: aws.String(region),
S3DisableContentMD5Validation: aws.Bool(true),
}
if awsAccessKeyId != "" && awsSecretAccessKey != "" {
diff --git a/weed/server/filer_grpc_server_remote.go b/weed/server/filer_grpc_server_remote.go
index 8064431c5..509e95b03 100644
--- a/weed/server/filer_grpc_server_remote.go
+++ b/weed/server/filer_grpc_server_remote.go
@@ -114,11 +114,11 @@ func (fs *FilerServer) DownloadToLocal(ctx context.Context, req *filer_pb.Downlo
// tell filer to tell volume server to download into needles
err = operation.WithVolumeServerClient(assignResult.Url, fs.grpcDialOption, func(volumeServerClient volume_server_pb.VolumeServerClient) error {
_, fetchAndWriteErr := volumeServerClient.FetchAndWriteNeedle(context.Background(), &volume_server_pb.FetchAndWriteNeedleRequest{
- VolumeId: uint32(fileId.VolumeId),
- NeedleId: uint64(fileId.Key),
- Cookie: uint32(fileId.Cookie),
- Offset: localOffset,
- Size: size,
+ VolumeId: uint32(fileId.VolumeId),
+ NeedleId: uint64(fileId.Key),
+ Cookie: uint32(fileId.Cookie),
+ Offset: localOffset,
+ Size: size,
RemoteConf: storageConf,
RemoteLocation: &remote_pb.RemoteStorageLocation{
Name: remoteStorageMountedLocation.Name,
diff --git a/weed/server/filer_grpc_server_sub_meta.go b/weed/server/filer_grpc_server_sub_meta.go
index c7ba71e1c..a900275b9 100644
--- a/weed/server/filer_grpc_server_sub_meta.go
+++ b/weed/server/filer_grpc_server_sub_meta.go
@@ -203,7 +203,7 @@ func (fs *FilerServer) eachEventNotificationFn(req *filer_pb.SubscribeMetadataRe
if hasPrefixIn(fullpath, req.PathPrefixes) {
// good
- }else {
+ } else {
if !strings.HasPrefix(fullpath, req.PathPrefix) {
if eventNotification.NewParentPath != "" {
newFullPath := util.Join(eventNotification.NewParentPath, entryName)
diff --git a/weed/server/filer_server_rocksdb.go b/weed/server/filer_server_rocksdb.go
index 5fcc7e88f..75965e761 100644
--- a/weed/server/filer_server_rocksdb.go
+++ b/weed/server/filer_server_rocksdb.go
@@ -1,3 +1,4 @@
+//go:build rocksdb
// +build rocksdb
package weed_server
diff --git a/weed/server/volume_grpc_copy.go b/weed/server/volume_grpc_copy.go
index 20b81c422..53ee3df0a 100644
--- a/weed/server/volume_grpc_copy.go
+++ b/weed/server/volume_grpc_copy.go
@@ -84,21 +84,21 @@ func (vs *VolumeServer) VolumeCopy(ctx context.Context, req *volume_server_pb.Vo
return err
}
if modifiedTsNs > 0 {
- os.Chtimes(dataBaseFileName + ".dat", time.Unix(0, modifiedTsNs), time.Unix(0, modifiedTsNs))
+ os.Chtimes(dataBaseFileName+".dat", time.Unix(0, modifiedTsNs), time.Unix(0, modifiedTsNs))
}
if modifiedTsNs, err = vs.doCopyFile(client, false, req.Collection, req.VolumeId, volFileInfoResp.CompactionRevision, volFileInfoResp.IdxFileSize, indexBaseFileName, ".idx", false, false); err != nil {
return err
}
if modifiedTsNs > 0 {
- os.Chtimes(indexBaseFileName + ".idx", time.Unix(0, modifiedTsNs), time.Unix(0, modifiedTsNs))
+ os.Chtimes(indexBaseFileName+".idx", time.Unix(0, modifiedTsNs), time.Unix(0, modifiedTsNs))
}
if modifiedTsNs, err = vs.doCopyFile(client, false, req.Collection, req.VolumeId, volFileInfoResp.CompactionRevision, volFileInfoResp.DatFileSize, dataBaseFileName, ".vif", false, true); err != nil {
return err
}
if modifiedTsNs > 0 {
- os.Chtimes(dataBaseFileName + ".vif", time.Unix(0, modifiedTsNs), time.Unix(0, modifiedTsNs))
+ os.Chtimes(dataBaseFileName+".vif", time.Unix(0, modifiedTsNs), time.Unix(0, modifiedTsNs))
}
os.Remove(dataBaseFileName + ".note")
@@ -167,7 +167,7 @@ func (vs *VolumeServer) doCopyFile(client volume_server_pb.VolumeServerClient, i
only check the the differ of the file size
todo: maybe should check the received count and deleted count of the volume
*/
-func checkCopyFiles(originFileInf *volume_server_pb.ReadVolumeFileStatusResponse, idxFileName, datFileName string) (error) {
+func checkCopyFiles(originFileInf *volume_server_pb.ReadVolumeFileStatusResponse, idxFileName, datFileName string) error {
stat, err := os.Stat(idxFileName)
if err != nil {
return fmt.Errorf("stat idx file %s failed: %v", idxFileName, err)
diff --git a/weed/shell/command_remote_cache.go b/weed/shell/command_remote_cache.go
index 2888ec979..488fea7ea 100644
--- a/weed/shell/command_remote_cache.go
+++ b/weed/shell/command_remote_cache.go
@@ -59,7 +59,7 @@ func (c *commandRemoteCache) Do(args []string, commandEnv *CommandEnv, writer io
}
mappings, localMountedDir, remoteStorageMountedLocation, remoteStorageConf, detectErr := detectMountInfo(commandEnv, writer, *dir)
- if detectErr != nil{
+ if detectErr != nil {
jsonPrintln(writer, mappings)
return detectErr
}
diff --git a/weed/shell/command_remote_configure.go b/weed/shell/command_remote_configure.go
index 4990e81db..c6e55ae69 100644
--- a/weed/shell/command_remote_configure.go
+++ b/weed/shell/command_remote_configure.go
@@ -116,7 +116,6 @@ Namenode running as service 'hdfs' with FQDN 'namenode.hadoop.docker'.
`)
remoteConfigureCommand.StringVar(&conf.HdfsDataTransferProtection, "hdfs.dataTransferProtection", "", "[authentication|integrity|privacy] Kerberos data transfer protection")
-
if err = remoteConfigureCommand.Parse(args); err != nil {
return nil
}
diff --git a/weed/stats/disk_notsupported.go b/weed/stats/disk_notsupported.go
index 3d99e6ce7..2bc24a2f0 100644
--- a/weed/stats/disk_notsupported.go
+++ b/weed/stats/disk_notsupported.go
@@ -1,3 +1,4 @@
+//go:build openbsd || netbsd || plan9 || solaris
// +build openbsd netbsd plan9 solaris
package stats
diff --git a/weed/stats/disk_supported.go b/weed/stats/disk_supported.go
index dff580b5b..e698b0095 100644
--- a/weed/stats/disk_supported.go
+++ b/weed/stats/disk_supported.go
@@ -1,3 +1,4 @@
+//go:build !windows && !openbsd && !netbsd && !plan9 && !solaris
// +build !windows,!openbsd,!netbsd,!plan9,!solaris
package stats
diff --git a/weed/stats/memory_notsupported.go b/weed/stats/memory_notsupported.go
index 2bed95266..2508b561b 100644
--- a/weed/stats/memory_notsupported.go
+++ b/weed/stats/memory_notsupported.go
@@ -1,3 +1,4 @@
+//go:build !linux
// +build !linux
package stats
diff --git a/weed/stats/memory_supported.go b/weed/stats/memory_supported.go
index 91fdd005b..55ad4c6bb 100644
--- a/weed/stats/memory_supported.go
+++ b/weed/stats/memory_supported.go
@@ -1,3 +1,4 @@
+//go:build linux
// +build linux
package stats
diff --git a/weed/storage/backend/memory_map/memory_map_other.go b/weed/storage/backend/memory_map/memory_map_other.go
index e06a0b59a..63c168f6a 100644
--- a/weed/storage/backend/memory_map/memory_map_other.go
+++ b/weed/storage/backend/memory_map/memory_map_other.go
@@ -1,3 +1,4 @@
+//go:build !windows
// +build !windows
package memory_map
diff --git a/weed/storage/backend/memory_map/memory_map_windows.go b/weed/storage/backend/memory_map/memory_map_windows.go
index 7eb713442..4a1a48f99 100644
--- a/weed/storage/backend/memory_map/memory_map_windows.go
+++ b/weed/storage/backend/memory_map/memory_map_windows.go
@@ -1,3 +1,4 @@
+//go:build windows
// +build windows
package memory_map
diff --git a/weed/storage/backend/s3_backend/s3_sessions.go b/weed/storage/backend/s3_backend/s3_sessions.go
index e7b3410e6..be10ad8e5 100644
--- a/weed/storage/backend/s3_backend/s3_sessions.go
+++ b/weed/storage/backend/s3_backend/s3_sessions.go
@@ -34,9 +34,9 @@ func createSession(awsAccessKeyId, awsSecretAccessKey, region, endpoint string)
}
config := &aws.Config{
- Region: aws.String(region),
- Endpoint: aws.String(endpoint),
- S3ForcePathStyle: aws.Bool(true),
+ Region: aws.String(region),
+ Endpoint: aws.String(endpoint),
+ S3ForcePathStyle: aws.Bool(true),
S3DisableContentMD5Validation: aws.Bool(true),
}
if awsAccessKeyId != "" && awsSecretAccessKey != "" {
diff --git a/weed/storage/backend/volume_create.go b/weed/storage/backend/volume_create.go
index d4bd8e40f..93719198b 100644
--- a/weed/storage/backend/volume_create.go
+++ b/weed/storage/backend/volume_create.go
@@ -1,3 +1,4 @@
+//go:build !linux && !windows
// +build !linux,!windows
package backend
diff --git a/weed/storage/backend/volume_create_linux.go b/weed/storage/backend/volume_create_linux.go
index 260c2c2a3..9b03dcda2 100644
--- a/weed/storage/backend/volume_create_linux.go
+++ b/weed/storage/backend/volume_create_linux.go
@@ -1,3 +1,4 @@
+//go:build linux
// +build linux
package backend
diff --git a/weed/storage/backend/volume_create_windows.go b/weed/storage/backend/volume_create_windows.go
index 7d40ec0d7..0bbb4959b 100644
--- a/weed/storage/backend/volume_create_windows.go
+++ b/weed/storage/backend/volume_create_windows.go
@@ -1,3 +1,4 @@
+//go:build windows
// +build windows
package backend
diff --git a/weed/storage/needle_map/compact_map_cases_test.go b/weed/storage/needle_map/compact_map_cases_test.go
index 305925699..83376e3e8 100644
--- a/weed/storage/needle_map/compact_map_cases_test.go
+++ b/weed/storage/needle_map/compact_map_cases_test.go
@@ -1,3 +1,4 @@
+//go:build 5BytesOffset
// +build 5BytesOffset
package needle_map
diff --git a/weed/storage/types/offset_4bytes.go b/weed/storage/types/offset_4bytes.go
index 5348d5b36..5835b24d7 100644
--- a/weed/storage/types/offset_4bytes.go
+++ b/weed/storage/types/offset_4bytes.go
@@ -1,3 +1,4 @@
+//go:build !5BytesOffset
// +build !5BytesOffset
package types
diff --git a/weed/storage/types/offset_5bytes.go b/weed/storage/types/offset_5bytes.go
index b6181fc11..4b16bd822 100644
--- a/weed/storage/types/offset_5bytes.go
+++ b/weed/storage/types/offset_5bytes.go
@@ -1,3 +1,4 @@
+//go:build 5BytesOffset
// +build 5BytesOffset
package types
diff --git a/weed/util/constants_4bytes.go b/weed/util/constants_4bytes.go
index a29d9d3b0..187e33909 100644
--- a/weed/util/constants_4bytes.go
+++ b/weed/util/constants_4bytes.go
@@ -1,3 +1,4 @@
+//go:build !5BytesOffset
// +build !5BytesOffset
package util
diff --git a/weed/util/constants_5bytes.go b/weed/util/constants_5bytes.go
index 91ce4066f..7c6a158cf 100644
--- a/weed/util/constants_5bytes.go
+++ b/weed/util/constants_5bytes.go
@@ -1,3 +1,4 @@
+//go:build 5BytesOffset
// +build 5BytesOffset
package util
diff --git a/weed/util/file_util_non_posix.go b/weed/util/file_util_non_posix.go
index ffcfef6d5..29aecffa6 100644
--- a/weed/util/file_util_non_posix.go
+++ b/weed/util/file_util_non_posix.go
@@ -1,3 +1,4 @@
+//go:build linux || darwin || freebsd || netbsd || openbsd || plan9 || solaris || zos
// +build linux darwin freebsd netbsd openbsd plan9 solaris zos
package util
diff --git a/weed/util/file_util_posix.go b/weed/util/file_util_posix.go
index 22ca60b3b..0bec8abad 100644
--- a/weed/util/file_util_posix.go
+++ b/weed/util/file_util_posix.go
@@ -1,3 +1,4 @@
+//go:build windows
// +build windows
package util
diff --git a/weed/util/grace/signal_handling.go b/weed/util/grace/signal_handling.go
index 7cca46764..fc7afcad9 100644
--- a/weed/util/grace/signal_handling.go
+++ b/weed/util/grace/signal_handling.go
@@ -1,3 +1,4 @@
+//go:build !plan9
// +build !plan9
package grace
diff --git a/weed/util/grace/signal_handling_notsupported.go b/weed/util/grace/signal_handling_notsupported.go
index 5335915a1..de898159a 100644
--- a/weed/util/grace/signal_handling_notsupported.go
+++ b/weed/util/grace/signal_handling_notsupported.go
@@ -1,3 +1,4 @@
+//go:build plan9
// +build plan9
package grace