| OLD | NEW |
| 1 // Copyright 2015 The LUCI Authors. All rights reserved. | 1 // Copyright 2015 The LUCI Authors. All rights reserved. |
| 2 // Use of this source code is governed under the Apache License, Version 2.0 | 2 // Use of this source code is governed under the Apache License, Version 2.0 |
| 3 // that can be found in the LICENSE file. | 3 // that can be found in the LICENSE file. |
| 4 | 4 |
| 5 package deps | 5 package deps |
| 6 | 6 |
| 7 import ( | 7 import ( |
| 8 "fmt" | 8 "fmt" |
| 9 "testing" | 9 "testing" |
| 10 "time" | 10 "time" |
| (...skipping 377 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 388
1: {Id: dm.NewAttemptID(x, 1)}, | 388
1: {Id: dm.NewAttemptID(x, 1)}, |
| 389
2: {Id: dm.NewAttemptID(x, 2)}, | 389
2: {Id: dm.NewAttemptID(x, 2)}, |
| 390 }, | 390 }, |
| 391 }, | 391 }, |
| 392 }, | 392 }, |
| 393 }) | 393 }) |
| 394 }) | 394 }) |
| 395 | 395 |
| 396 }) | 396 }) |
| 397 | 397 |
| 398 » » » » Convey("early stop", func() { | 398 » » » » // This is disabled beacuse it was flaky. |
| 399 » » » » // BUG: crbug.com/621170 |
| 400 » » » » SkipConvey("early stop", func() { |
| 399 req.Limit.MaxDepth = 100 | 401 req.Limit.MaxDepth = 100 |
| 400 req.Limit.MaxTime = google_pb.NewDuratio
n(time.Nanosecond) | 402 req.Limit.MaxTime = google_pb.NewDuratio
n(time.Nanosecond) |
| 401 tc := clock.Get(c).(testclock.TestClock) | 403 tc := clock.Get(c).(testclock.TestClock) |
| 402 tc.SetTimerCallback(func(d time.Duration
, t clock.Timer) { | 404 tc.SetTimerCallback(func(d time.Duration
, t clock.Timer) { |
| 403 tc.Add(d + time.Second) | 405 tc.Add(d + time.Second) |
| 404 }) | 406 }) |
| 405 ret, err := newDecoratedDeps().WalkGraph
(c, req) | 407 ret, err := newDecoratedDeps().WalkGraph
(c, req) |
| 406 So(err, ShouldBeNil) | 408 So(err, ShouldBeNil) |
| 407 So(ret.HadMore, ShouldBeTrue) | 409 So(ret.HadMore, ShouldBeTrue) |
| 408 }) | 410 }) |
| 409 | 411 |
| 410 }) | 412 }) |
| 411 }) | 413 }) |
| 412 }) | 414 }) |
| 413 } | 415 } |
| OLD | NEW |