| Index: appengine/logdog/coordinator/coordinatorTest/archival.go
|
| diff --git a/appengine/logdog/coordinator/coordinatorTest/archival.go b/appengine/logdog/coordinator/coordinatorTest/archival.go
|
| index 532a8c0930e97fa3670fe18d2de431a4d665b884..0d5042f0183e3fc8e04887b44265f68090172fd3 100644
|
| --- a/appengine/logdog/coordinator/coordinatorTest/archival.go
|
| +++ b/appengine/logdog/coordinator/coordinatorTest/archival.go
|
| @@ -67,3 +67,10 @@ func (ap *ArchivalPublisher) StreamNames() []string {
|
| sort.Strings(taskStreams)
|
| return taskStreams
|
| }
|
| +
|
| +// Clear clears recorded tasks.
|
| +func (ap *ArchivalPublisher) Clear() {
|
| + ap.Lock()
|
| + defer ap.Unlock()
|
| + ap.tasks = nil
|
| +}
|
|
|