aboutsummaryrefslogtreecommitdiff
path: root/vendor/github.com/smartystreets/goconvey/web/server/executor/tester.go
diff options
context:
space:
mode:
Diffstat (limited to 'vendor/github.com/smartystreets/goconvey/web/server/executor/tester.go')
-rw-r--r--vendor/github.com/smartystreets/goconvey/web/server/executor/tester.go56
1 files changed, 0 insertions, 56 deletions
diff --git a/vendor/github.com/smartystreets/goconvey/web/server/executor/tester.go b/vendor/github.com/smartystreets/goconvey/web/server/executor/tester.go
deleted file mode 100644
index 76f353a5..00000000
--- a/vendor/github.com/smartystreets/goconvey/web/server/executor/tester.go
+++ /dev/null
@@ -1,56 +0,0 @@
-package executor
-
-import (
- "errors"
- "fmt"
- "log"
- "strings"
-
- "github.com/smartystreets/goconvey/web/server/contract"
-)
-
-type ConcurrentTester struct {
- shell contract.Shell
- batchSize int
-}
-
-func (self *ConcurrentTester) SetBatchSize(batchSize int) {
- self.batchSize = batchSize
- log.Printf("Now configured to test %d packages concurrently.\n", self.batchSize)
-}
-
-func (self *ConcurrentTester) TestAll(folders []*contract.Package) {
- if self.batchSize == 1 {
- self.executeSynchronously(folders)
- } else {
- newConcurrentCoordinator(folders, self.batchSize, self.shell).ExecuteConcurrently()
- }
- return
-}
-
-func (self *ConcurrentTester) executeSynchronously(folders []*contract.Package) {
- for _, folder := range folders {
- packageName := strings.Replace(folder.Name, "\\", "/", -1)
- if !folder.Active() {
- log.Printf("Skipping execution: %s\n", packageName)
- continue
- }
- if folder.HasImportCycle {
- message := fmt.Sprintf("can't load package: import cycle not allowed\npackage %s\n\timports %s", packageName, packageName)
- log.Println(message)
- folder.Output, folder.Error = message, errors.New(message)
- } else {
- log.Printf("Executing tests: %s\n", packageName)
- folder.Output, folder.Error = self.shell.GoTest(folder.Path, packageName, folder.BuildTags, folder.TestArguments)
- }
- }
-}
-
-func NewConcurrentTester(shell contract.Shell) *ConcurrentTester {
- self := new(ConcurrentTester)
- self.shell = shell
- self.batchSize = defaultBatchSize
- return self
-}
-
-const defaultBatchSize = 10