mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2024-01-19 02:48:24 +00:00
refactor(shell): readability improvements (#3704)
Signed-off-by: Ryan Russell <git@ryanrussell.org> Signed-off-by: Ryan Russell <git@ryanrussell.org>
This commit is contained in:
parent
277976bd76
commit
824f7ad9e1
|
@ -98,7 +98,7 @@ func (c *commandFsConfigure) Do(args []string, commandEnv *CommandEnv, writer io
|
||||||
return fmt.Errorf("parse replication %s: %v", *replication, err)
|
return fmt.Errorf("parse replication %s: %v", *replication, err)
|
||||||
}
|
}
|
||||||
if *volumeGrowthCount%rp.GetCopyCount() != 0 {
|
if *volumeGrowthCount%rp.GetCopyCount() != 0 {
|
||||||
return fmt.Errorf("volumeGrowthCount %d should be devided by replication copy count %d", *volumeGrowthCount, rp.GetCopyCount())
|
return fmt.Errorf("volumeGrowthCount %d should be divided by replication copy count %d", *volumeGrowthCount, rp.GetCopyCount())
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -21,7 +21,7 @@ func (c *commandLock) Name() string {
|
||||||
func (c *commandLock) Help() string {
|
func (c *commandLock) Help() string {
|
||||||
return `lock in order to exclusively manage the cluster
|
return `lock in order to exclusively manage the cluster
|
||||||
|
|
||||||
This is a blocking operation if there is alread another lock.
|
This is a blocking operation if there is already another lock.
|
||||||
`
|
`
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -96,7 +96,7 @@ After caching the file content, the entry.RemoteEntry will be
|
||||||
remoteEntry.LastLocalSyncTsNs == time.Now.UnixNano()
|
remoteEntry.LastLocalSyncTsNs == time.Now.UnixNano()
|
||||||
Attributes.FileSize = uint64(remoteEntry.RemoteSize)
|
Attributes.FileSize = uint64(remoteEntry.RemoteSize)
|
||||||
Attributes.Mtime = remoteEntry.RemoteMtime
|
Attributes.Mtime = remoteEntry.RemoteMtime
|
||||||
chunks = non-emtpy
|
chunks = non-empty
|
||||||
|
|
||||||
When "weed filer.remote.sync" to upload local changes to remote, the criteria is:
|
When "weed filer.remote.sync" to upload local changes to remote, the criteria is:
|
||||||
|
|
||||||
|
|
|
@ -285,7 +285,7 @@ func TestCircuitBreakerShell(t *testing.T) {
|
||||||
t.Error(err)
|
t.Error(err)
|
||||||
}
|
}
|
||||||
if !reflect.DeepEqual(actual, expect) {
|
if !reflect.DeepEqual(actual, expect) {
|
||||||
t.Fatal("result of s3 circuit breaker shell command is unexpect!")
|
t.Fatal("result of s3 circuit breaker shell command is unexpected!")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -60,7 +60,7 @@ func (c *commandS3CleanUploads) Do(args []string, commandEnv *CommandEnv, writer
|
||||||
|
|
||||||
for _, bucket := range buckets {
|
for _, bucket := range buckets {
|
||||||
if err := c.cleanupUploads(commandEnv, writer, filerBucketsPath, bucket, *uploadedTimeAgo, signingKey); err != nil {
|
if err := c.cleanupUploads(commandEnv, writer, filerBucketsPath, bucket, *uploadedTimeAgo, signingKey); err != nil {
|
||||||
fmt.Fprintf(writer, fmt.Sprintf("failed cleanup uploads for backet %s: %v", bucket, err))
|
fmt.Fprintf(writer, fmt.Sprintf("failed cleanup uploads for bucket %s: %v", bucket, err))
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue