diff options
Diffstat (limited to 'worker_test.go')
-rwxr-xr-x | worker_test.go | 66 |
1 files changed, 0 insertions, 66 deletions
diff --git a/worker_test.go b/worker_test.go deleted file mode 100755 index e82d383e..00000000 --- a/worker_test.go +++ /dev/null @@ -1,66 +0,0 @@ -package roadrunner - -import ( - "context" - "os/exec" - "sync" - "testing" - - "github.com/stretchr/testify/assert" -) - -func Test_GetState(t *testing.T) { - ctx := context.Background() - cmd := exec.Command("php", "tests/client.php", "echo", "pipes") - - w, err := NewPipeFactory().SpawnWorkerWithContext(ctx, cmd) - go func() { - assert.NoError(t, w.Wait()) - assert.Equal(t, StateStopped, w.State().Value()) - }() - - assert.NoError(t, err) - assert.NotNil(t, w) - - assert.Equal(t, StateReady, w.State().Value()) - err = w.Stop(ctx) - if err != nil { - t.Errorf("error stopping the WorkerProcess: error %v", err) - } -} - -func Test_Kill(t *testing.T) { - ctx := context.Background() - cmd := exec.Command("php", "tests/client.php", "echo", "pipes") - - w, err := NewPipeFactory().SpawnWorkerWithContext(ctx, cmd) - wg := &sync.WaitGroup{} - wg.Add(1) - go func() { - defer wg.Done() - assert.Error(t, w.Wait()) - // TODO changed from stopped, discuss - assert.Equal(t, StateErrored, w.State().Value()) - }() - - assert.NoError(t, err) - assert.NotNil(t, w) - - assert.Equal(t, StateReady, w.State().Value()) - err = w.Kill() - if err != nil { - t.Errorf("error killing the WorkerProcess: error %v", err) - } - wg.Wait() -} - -func Test_OnStarted(t *testing.T) { - cmd := exec.Command("php", "tests/client.php", "broken", "pipes") - assert.Nil(t, cmd.Start()) - - w, err := InitBaseWorker(cmd) - assert.Nil(t, w) - assert.NotNil(t, err) - - assert.Equal(t, "can't attach to running process", err.Error()) -} |