diff options
Diffstat (limited to 'unmaintained')
| -rw-r--r-- | unmaintained/load_test/load_test_meta_tail/load_test_meta_tail.go | 13 |
1 files changed, 9 insertions, 4 deletions
diff --git a/unmaintained/load_test/load_test_meta_tail/load_test_meta_tail.go b/unmaintained/load_test/load_test_meta_tail/load_test_meta_tail.go index b89e8de51..b77d77ddc 100644 --- a/unmaintained/load_test/load_test_meta_tail/load_test_meta_tail.go +++ b/unmaintained/load_test/load_test_meta_tail/load_test_meta_tail.go @@ -12,10 +12,11 @@ import ( ) var ( - dir = flag.String("dir", "/tmp", "directory to create files") - n = flag.Int("n", 100, "the number of metadata") - tailFiler = flag.String("filer", "localhost:8888", "the filer address") - isWrite = flag.Bool("write", false, "only write") + dir = flag.String("dir", "/tmp", "directory to create files") + n = flag.Int("n", 100, "the number of metadata") + tailFiler = flag.String("filer", "localhost:8888", "the filer address") + isWrite = flag.Bool("write", false, "only write") + writeInterval = flag.Duration("writeInterval", 0, "write interval, e.g., 1s") ) func main() { @@ -54,6 +55,7 @@ func startGenerateMetadata() { for i := 0; i < *n; i++ { name := fmt.Sprintf("file%d", i) + glog.V(0).Infof("write %s/%s", *dir, name) if err := filer_pb.CreateEntry(client, &filer_pb.CreateEntryRequest{ Directory: *dir, Entry: &filer_pb.Entry{ @@ -63,6 +65,9 @@ func startGenerateMetadata() { fmt.Printf("create entry %s: %v\n", name, err) return err } + if *writeInterval > 0 { + time.Sleep(*writeInterval) + } } return nil |