summaryrefslogtreecommitdiff
path: root/static_pool_test.go
diff options
context:
space:
mode:
Diffstat (limited to 'static_pool_test.go')
-rwxr-xr-xstatic_pool_test.go9
1 files changed, 3 insertions, 6 deletions
diff --git a/static_pool_test.go b/static_pool_test.go
index a3b19bad..b75bd0bf 100755
--- a/static_pool_test.go
+++ b/static_pool_test.go
@@ -152,7 +152,7 @@ func Test_StaticPool_JobError(t *testing.T) {
assert.Nil(t, res.Body)
assert.Nil(t, res.Context)
- assert.IsType(t, JobError{}, err)
+ assert.IsType(t, ExecError{}, err)
assert.Equal(t, "hello", err.Error())
}
@@ -308,9 +308,7 @@ func Test_StaticPool_Debug_Worker(t *testing.T) {
func() *exec.Cmd { return exec.Command("php", "tests/client.php", "pid", "pipes") },
NewPipeFactory(),
Config{
- HeavyLoad: true,
- NumWorkers: 1,
- MaxJobs: 1,
+ Debug: true,
AllocateTimeout: time.Second,
DestroyTimeout: time.Second,
},
@@ -326,11 +324,10 @@ func Test_StaticPool_Debug_Worker(t *testing.T) {
res, _ := p.Exec(Payload{Body: []byte("hello")})
assert.NotEqual(t, lastPID, string(res.Body))
- // todo: necessary?
assert.Len(t, p.Workers(), 0)
for i := 0; i < 10; i++ {
- lastPID = strconv.Itoa(int(p.Workers()[0].Pid()))
+ assert.Len(t, p.Workers(), 0)
res, err := p.Exec(Payload{Body: []byte("hello")})
assert.NoError(t, err)