@@ -13,12 +13,12 @@ import (
13
13
14
14
"github.com/cockroachdb/cockroach/pkg/base"
15
15
"github.com/cockroachdb/cockroach/pkg/storage"
16
- "github.com/cockroachdb/cockroach/pkg/testutils"
17
16
"github.com/cockroachdb/cockroach/pkg/testutils/pgurlutils"
18
17
"github.com/cockroachdb/cockroach/pkg/testutils/serverutils"
19
18
"github.com/cockroachdb/cockroach/pkg/testutils/testfixtures"
20
19
"github.com/cockroachdb/cockroach/pkg/util/leaktest"
21
20
"github.com/cockroachdb/cockroach/pkg/util/log"
21
+ "github.com/cockroachdb/cockroach/pkg/util/stop"
22
22
_ "github.com/cockroachdb/cockroach/pkg/workload/tpcc"
23
23
)
24
24
@@ -66,8 +66,8 @@ func BenchmarkTPCC(b *testing.B) {
66
66
}
67
67
68
68
func run (b * testing.B , storeDir string , workloadFlags []string ) {
69
- pgURL , closeServer := startCockroach (b , storeDir )
70
- defer closeServer ( )
69
+ server , pgURL := startCockroach (b , storeDir )
70
+ defer server . Stopper (). Stop ( context . Background () )
71
71
c , output := startClient (b , pgURL , workloadFlags )
72
72
73
73
var s synchronizer
@@ -89,11 +89,11 @@ func run(b *testing.B, storeDir string, workloadFlags []string) {
89
89
}
90
90
}
91
91
92
- func startCockroach (b testing. TB , storeDir string ) ( pgURL string , closeServer func ()) {
93
- ctx := context . Background ()
94
-
92
+ func startCockroach (
93
+ b testing. TB , storeDir string ,
94
+ ) ( server serverutils. TestServerInterface , pgURL string ) {
95
95
// Clone the store dir.
96
- td , engCleanup := testutils .TempDir (b )
96
+ td := b .TempDir ()
97
97
c , output := cloneEngine .
98
98
withEnv (srcEngineEnvVar , storeDir ).
99
99
withEnv (dstEngineEnvVar , td ).
@@ -115,12 +115,9 @@ func startCockroach(b testing.TB, storeDir string) (pgURL string, closeServer fu
115
115
b .Fatalf ("failed to create pgurl: %s" , err )
116
116
}
117
117
u .Path = databaseName
118
+ s .Stopper ().AddCloser (stop .CloserFn (urlCleanup ))
118
119
119
- return u .String (), func () {
120
- engCleanup ()
121
- s .Stopper ().Stop (ctx )
122
- urlCleanup ()
123
- }
120
+ return s , u .String ()
124
121
}
125
122
126
123
func startClient (
0 commit comments