mirror of
https://github.com/seaweedfs/seaweedfs.git
synced 2024-01-19 02:48:24 +00:00
b9aee2defb
The volume TTL and file TTL are not necessarily the same. as long as file TTL is smaller than volume TTL, it'll be fine. volume TTL is used when assigning file id, e.g. http://.../dir/assign?ttl=3h file TTL is used when uploading
46 lines
1.3 KiB
Go
46 lines
1.3 KiB
Go
package main
|
|
|
|
import (
|
|
"code.google.com/p/weed-fs/go/glog"
|
|
"code.google.com/p/weed-fs/go/storage"
|
|
)
|
|
|
|
func init() {
|
|
cmdCompact.Run = runCompact // break init cycle
|
|
cmdCompact.IsDebug = cmdCompact.Flag.Bool("debug", false, "enable debug mode")
|
|
}
|
|
|
|
var cmdCompact = &Command{
|
|
UsageLine: "compact -dir=/tmp -volumeId=234",
|
|
Short: "run weed tool compact on volume file if corrupted",
|
|
Long: `Force an compaction to remove deleted files from volume files.
|
|
The compacted .dat file is stored as .cpd file.
|
|
The compacted .idx file is stored as .cpx file.
|
|
|
|
`,
|
|
}
|
|
|
|
var (
|
|
compactVolumePath = cmdCompact.Flag.String("dir", "/tmp", "data directory to store files")
|
|
compactVolumeCollection = cmdCompact.Flag.String("collection", "", "volume collection name")
|
|
compactVolumeId = cmdCompact.Flag.Int("volumeId", -1, "a volume id. The volume should already exist in the dir.")
|
|
)
|
|
|
|
func runCompact(cmd *Command, args []string) bool {
|
|
|
|
if *compactVolumeId == -1 {
|
|
return false
|
|
}
|
|
|
|
vid := storage.VolumeId(*compactVolumeId)
|
|
v, err := storage.NewVolume(*compactVolumePath, *compactVolumeCollection, vid, nil, nil)
|
|
if err != nil {
|
|
glog.Fatalf("Load Volume [ERROR] %s\n", err)
|
|
}
|
|
if err = v.Compact(); err != nil {
|
|
glog.Fatalf("Compact Volume [ERROR] %s\n", err)
|
|
}
|
|
|
|
return true
|
|
}
|