OLD | NEW |
1 package ingester | 1 package ingester |
2 | 2 |
3 import ( | 3 import ( |
4 "fmt" | 4 "fmt" |
5 "io/ioutil" | 5 "io/ioutil" |
6 "os" | 6 "os" |
7 "path/filepath" | 7 "path/filepath" |
8 "runtime" | 8 "runtime" |
9 "testing" | 9 "testing" |
10 | 10 |
(...skipping 19 matching lines...) Expand all Loading... |
30 | 30 |
31 // Create a temporary place for a filetilestore. | 31 // Create a temporary place for a filetilestore. |
32 tileDir, err := ioutil.TempDir("", "skiaperf") | 32 tileDir, err := ioutil.TempDir("", "skiaperf") |
33 if err != nil { | 33 if err != nil { |
34 t.Fatal("Failed to create testing Tile dir: ", err) | 34 t.Fatal("Failed to create testing Tile dir: ", err) |
35 } | 35 } |
36 defer os.RemoveAll(tileDir) | 36 defer os.RemoveAll(tileDir) |
37 | 37 |
38 git, err := gitinfo.NewGitInfo(filepath.Join(tr.Dir, "testrepo"), false,
false) | 38 git, err := gitinfo.NewGitInfo(filepath.Join(tr.Dir, "testrepo"), false,
false) |
39 if err != nil { | 39 if err != nil { |
40 » » glog.Fatal("Failed loading Git info: %s\n", err) | 40 » » glog.Fatalf("Failed loading Git info: %s\n", err) |
41 } | 41 } |
42 | 42 |
43 // Construct an Ingestor and have it UpdateCommitInfo. | 43 // Construct an Ingestor and have it UpdateCommitInfo. |
44 i, err := NewIngester(git, tileDir, config.DATASET_NANO, NanoBenchIngest
ion, "", "") | 44 i, err := NewIngester(git, tileDir, config.DATASET_NANO, NanoBenchIngest
ion, "", "") |
45 if err != nil { | 45 if err != nil { |
46 t.Fatal("Failed to create ingester:", err) | 46 t.Fatal("Failed to create ingester:", err) |
47 } | 47 } |
48 | 48 |
49 if err := i.UpdateCommitInfo(false); err != nil { | 49 if err := i.UpdateCommitInfo(false); err != nil { |
50 t.Fatal("Failed to ingest commits:", err) | 50 t.Fatal("Failed to ingest commits:", err) |
(...skipping 105 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
156 | 156 |
157 benchData.Options["system"] = "Linux" | 157 benchData.Options["system"] = "Linux" |
158 addBenchDataToTile(benchData, tile, offset, metricsProcessed) | 158 addBenchDataToTile(benchData, tile, offset, metricsProcessed) |
159 if got, want := "Linux", tile.Traces[key].Params()["system"]; got != wan
t { | 159 if got, want := "Linux", tile.Traces[key].Params()["system"]; got != wan
t { |
160 t.Errorf("Failed to update params: Got %v Want %v", got, want) | 160 t.Errorf("Failed to update params: Got %v Want %v", got, want) |
161 } | 161 } |
162 if got, want := int64(27), metricsProcessed.Count(); got != want { | 162 if got, want := int64(27), metricsProcessed.Count(); got != want { |
163 t.Errorf("Wrong number of points ingested: Got %v Want %v", got,
want) | 163 t.Errorf("Wrong number of points ingested: Got %v Want %v", got,
want) |
164 } | 164 } |
165 } | 165 } |
OLD | NEW |