Initial commit of RR 2.0v2.0.0-alpha1

1 files changed, 0 insertions, 1961 deletions

diff --git a/service/http/handler_test.go b/service/http/handler_test.go
deleted file mode 100644
index cb1cd728..00000000
--- a/service/http/handler_test.go
+++ /dev/null
@@ -1,1961 +0,0 @@
-package http
-
-import (
-	"bytes"
-	"context"
-	"github.com/spiral/roadrunner"
-	"github.com/stretchr/testify/assert"
-	"io/ioutil"
-	"mime/multipart"
-	"net/http"
-	"net/http/httptest"
-	"net/url"
-	"os"
-	"runtime"
-	"strings"
-	"testing"
-	"time"
-)
-
-// get request and return body
-func get(url string) (string, *http.Response, error) {
-	r, err := http.Get(url)
-	if err != nil {
-		return "", nil, err
-	}
-	b, err := ioutil.ReadAll(r.Body)
-	if err != nil {
-		return "", nil, err
-	}
-
-	err = r.Body.Close()
-	if err != nil {
-		return "", nil, err
-	}
-	return string(b), r, err
-}
-
-// get request and return body
-func getHeader(url string, h map[string]string) (string, *http.Response, error) {
-	req, err := http.NewRequest("GET", url, bytes.NewBuffer(nil))
-	if err != nil {
-		return "", nil, err
-	}
-
-	for k, v := range h {
-		req.Header.Set(k, v)
-	}
-
-	r, err := http.DefaultClient.Do(req)
-	if err != nil {
-		return "", nil, err
-	}
-
-	b, err := ioutil.ReadAll(r.Body)
-	if err != nil {
-		return "", nil, err
-	}
-
-	err = r.Body.Close()
-	if err != nil {
-		return "", nil, err
-	}
-	return string(b), r, err
-}
-
-func TestHandler_Echo(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php echo pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	body, r, err := get("http://localhost:8177/?hello=world")
-	assert.NoError(t, err)
-	assert.Equal(t, 201, r.StatusCode)
-	assert.Equal(t, "WORLD", body)
-}
-
-func Test_HandlerErrors(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php echo pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	wr := httptest.NewRecorder()
-	rq := httptest.NewRequest("POST", "/", bytes.NewBuffer([]byte("data")))
-
-	h.ServeHTTP(wr, rq)
-	assert.Equal(t, 500, wr.Code)
-}
-
-func Test_Handler_JSON_error(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php echo pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	wr := httptest.NewRecorder()
-	rq := httptest.NewRequest("POST", "/", bytes.NewBuffer([]byte("{sd")))
-	rq.Header.Add("Content-Type", "application/json")
-	rq.Header.Add("Content-Size", "3")
-
-	h.ServeHTTP(wr, rq)
-	assert.Equal(t, 500, wr.Code)
-}
-
-func TestHandler_Headers(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php header pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8078", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 100)
-
-	req, err := http.NewRequest("GET", "http://localhost:8078?hello=world", nil)
-	assert.NoError(t, err)
-
-	req.Header.Add("input", "sample")
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, "world", r.Header.Get("Header"))
-	assert.Equal(t, "SAMPLE", string(b))
-}
-
-func TestHandler_Empty_User_Agent(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php user-agent pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8088", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	req, err := http.NewRequest("GET", "http://localhost:8088?hello=world", nil)
-	assert.NoError(t, err)
-
-	req.Header.Add("user-agent", "")
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, "", string(b))
-}
-
-func TestHandler_User_Agent(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php user-agent pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8088", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	req, err := http.NewRequest("GET", "http://localhost:8088?hello=world", nil)
-	assert.NoError(t, err)
-
-	req.Header.Add("User-Agent", "go-agent")
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, "go-agent", string(b))
-}
-
-func TestHandler_Cookies(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php cookie pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8079", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	req, err := http.NewRequest("GET", "http://localhost:8079", nil)
-	assert.NoError(t, err)
-
-	req.AddCookie(&http.Cookie{Name: "input", Value: "input-value"})
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, "INPUT-VALUE", string(b))
-
-	for _, c := range r.Cookies() {
-		assert.Equal(t, "output", c.Name)
-		assert.Equal(t, "cookie-output", c.Value)
-	}
-}
-
-func TestHandler_JsonPayload_POST(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php payload pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8090", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	req, err := http.NewRequest(
-		"POST",
-		"http://localhost"+hs.Addr,
-		bytes.NewBufferString(`{"key":"value"}`),
-	)
-	assert.NoError(t, err)
-
-	req.Header.Add("Content-Type", "application/json")
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, `{"value":"key"}`, string(b))
-}
-
-func TestHandler_JsonPayload_PUT(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php payload pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8081", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	req, err := http.NewRequest("PUT", "http://localhost"+hs.Addr, bytes.NewBufferString(`{"key":"value"}`))
-	assert.NoError(t, err)
-
-	req.Header.Add("Content-Type", "application/json")
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, `{"value":"key"}`, string(b))
-}
-
-func TestHandler_JsonPayload_PATCH(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php payload pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8082", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	req, err := http.NewRequest("PATCH", "http://localhost"+hs.Addr, bytes.NewBufferString(`{"key":"value"}`))
-	assert.NoError(t, err)
-
-	req.Header.Add("Content-Type", "application/json")
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, `{"value":"key"}`, string(b))
-}
-
-func TestHandler_FormData_POST(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php data pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8083", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 500)
-
-	form := url.Values{}
-
-	form.Add("key", "value")
-	form.Add("name[]", "name1")
-	form.Add("name[]", "name2")
-	form.Add("name[]", "name3")
-	form.Add("arr[x][y][z]", "y")
-	form.Add("arr[x][y][e]", "f")
-	form.Add("arr[c]p", "l")
-	form.Add("arr[c]z", "")
-
-	req, err := http.NewRequest("POST", "http://localhost"+hs.Addr, strings.NewReader(form.Encode()))
-	assert.NoError(t, err)
-
-	req.Header.Add("Content-Type", "application/x-www-form-urlencoded")
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-
-	assert.Equal(t, `{"arr":{"c":{"p":"l","z":""},"x":{"y":{"e":"f","z":"y"}}},"key":"value","name":["name1","name2","name3"]}`, string(b))
-}
-
-func TestHandler_FormData_POST_Overwrite(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php data pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8083", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	form := url.Values{}
-
-	form.Add("key", "value1")
-	form.Add("key", "value2")
-
-	req, err := http.NewRequest("POST", "http://localhost"+hs.Addr, strings.NewReader(form.Encode()))
-	assert.NoError(t, err)
-
-	req.Header.Add("Content-Type", "application/x-www-form-urlencoded")
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-
-	assert.Equal(t, `{"key":"value2","arr":{"x":{"y":null}}}`, string(b))
-}
-
-func TestHandler_FormData_POST_Form_UrlEncoded_Charset(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php data pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8083", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	form := url.Values{}
-
-	form.Add("key", "value")
-	form.Add("name[]", "name1")
-	form.Add("name[]", "name2")
-	form.Add("name[]", "name3")
-	form.Add("arr[x][y][z]", "y")
-	form.Add("arr[x][y][e]", "f")
-	form.Add("arr[c]p", "l")
-	form.Add("arr[c]z", "")
-
-	req, err := http.NewRequest("POST", "http://localhost"+hs.Addr, strings.NewReader(form.Encode()))
-	assert.NoError(t, err)
-
-	req.Header.Add("Content-Type", "application/x-www-form-urlencoded; charset=UTF-8")
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-
-	assert.Equal(t, `{"arr":{"c":{"p":"l","z":""},"x":{"y":{"e":"f","z":"y"}}},"key":"value","name":["name1","name2","name3"]}`, string(b))
-}
-
-func TestHandler_FormData_PUT(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php data pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8084", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 500)
-
-	form := url.Values{}
-
-	form.Add("key", "value")
-	form.Add("name[]", "name1")
-	form.Add("name[]", "name2")
-	form.Add("name[]", "name3")
-	form.Add("arr[x][y][z]", "y")
-	form.Add("arr[x][y][e]", "f")
-	form.Add("arr[c]p", "l")
-	form.Add("arr[c]z", "")
-
-	req, err := http.NewRequest("PUT", "http://localhost"+hs.Addr, strings.NewReader(form.Encode()))
-	assert.NoError(t, err)
-
-	req.Header.Add("Content-Type", "application/x-www-form-urlencoded")
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-
-	assert.Equal(t, `{"arr":{"c":{"p":"l","z":""},"x":{"y":{"e":"f","z":"y"}}},"key":"value","name":["name1","name2","name3"]}`, string(b))
-}
-
-func TestHandler_FormData_PATCH(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php data pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8085", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	form := url.Values{}
-
-	form.Add("key", "value")
-	form.Add("name[]", "name1")
-	form.Add("name[]", "name2")
-	form.Add("name[]", "name3")
-	form.Add("arr[x][y][z]", "y")
-	form.Add("arr[x][y][e]", "f")
-	form.Add("arr[c]p", "l")
-	form.Add("arr[c]z", "")
-
-	req, err := http.NewRequest("PATCH", "http://localhost"+hs.Addr, strings.NewReader(form.Encode()))
-	assert.NoError(t, err)
-
-	req.Header.Add("Content-Type", "application/x-www-form-urlencoded")
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-
-	assert.Equal(t, `{"arr":{"c":{"p":"l","z":""},"x":{"y":{"e":"f","z":"y"}}},"key":"value","name":["name1","name2","name3"]}`, string(b))
-}
-
-func TestHandler_Multipart_POST(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php data pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8019", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	var mb bytes.Buffer
-	w := multipart.NewWriter(&mb)
-	err := w.WriteField("key", "value")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("key", "value")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("name[]", "name1")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("name[]", "name2")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("name[]", "name3")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[x][y][z]", "y")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[x][y][e]", "f")
-
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[c]p", "l")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[c]z", "")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.Close()
-	if err != nil {
-		t.Errorf("error closing the writer: error %v", err)
-	}
-
-	req, err := http.NewRequest("POST", "http://localhost"+hs.Addr, &mb)
-	assert.NoError(t, err)
-
-	req.Header.Set("Content-Type", w.FormDataContentType())
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-
-	assert.Equal(t, `{"arr":{"c":{"p":"l","z":""},"x":{"y":{"e":"f","z":"y"}}},"key":"value","name":["name1","name2","name3"]}`, string(b))
-}
-
-func TestHandler_Multipart_PUT(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php data pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8020", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 500)
-
-	var mb bytes.Buffer
-	w := multipart.NewWriter(&mb)
-	err := w.WriteField("key", "value")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("key", "value")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("name[]", "name1")
-
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("name[]", "name2")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("name[]", "name3")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[x][y][z]", "y")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[x][y][e]", "f")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[c]p", "l")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[c]z", "")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.Close()
-	if err != nil {
-		t.Errorf("error closing the writer: error %v", err)
-	}
-
-	req, err := http.NewRequest("PUT", "http://localhost"+hs.Addr, &mb)
-	assert.NoError(t, err)
-
-	req.Header.Set("Content-Type", w.FormDataContentType())
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-
-	assert.Equal(t, `{"arr":{"c":{"p":"l","z":""},"x":{"y":{"e":"f","z":"y"}}},"key":"value","name":["name1","name2","name3"]}`, string(b))
-}
-
-func TestHandler_Multipart_PATCH(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php data pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8021", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 500)
-
-	var mb bytes.Buffer
-	w := multipart.NewWriter(&mb)
-	err := w.WriteField("key", "value")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("key", "value")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("name[]", "name1")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("name[]", "name2")
-
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("name[]", "name3")
-
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[x][y][z]", "y")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[x][y][e]", "f")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[c]p", "l")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.WriteField("arr[c]z", "")
-	if err != nil {
-		t.Errorf("error writing the field: error %v", err)
-	}
-
-	err = w.Close()
-	if err != nil {
-		t.Errorf("error closing the writer: error %v", err)
-	}
-
-	req, err := http.NewRequest("PATCH", "http://localhost"+hs.Addr, &mb)
-	assert.NoError(t, err)
-
-	req.Header.Set("Content-Type", w.FormDataContentType())
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-
-		}
-	}()
-
-	b, err := ioutil.ReadAll(r.Body)
-	assert.NoError(t, err)
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-
-	assert.Equal(t, `{"arr":{"c":{"p":"l","z":""},"x":{"y":{"e":"f","z":"y"}}},"key":"value","name":["name1","name2","name3"]}`, string(b))
-}
-
-func TestHandler_Error(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php error pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	_, r, err := get("http://localhost:8177/?hello=world")
-	assert.NoError(t, err)
-	assert.Equal(t, 500, r.StatusCode)
-}
-
-func TestHandler_Error2(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php error2 pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	_, r, err := get("http://localhost:8177/?hello=world")
-	assert.NoError(t, err)
-	assert.Equal(t, 500, r.StatusCode)
-}
-
-func TestHandler_Error3(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php pid pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	b2 := &bytes.Buffer{}
-	for i := 0; i < 1024*1024; i++ {
-		b2.Write([]byte("  "))
-	}
-
-	req, err := http.NewRequest("POST", "http://localhost"+hs.Addr, b2)
-	assert.NoError(t, err)
-
-	r, err := http.DefaultClient.Do(req)
-	assert.NoError(t, err)
-	defer func() {
-		err := r.Body.Close()
-		if err != nil {
-			t.Errorf("error during the closing Body: error %v", err)
-
-		}
-	}()
-
-	assert.NoError(t, err)
-	assert.Equal(t, 500, r.StatusCode)
-}
-
-func TestHandler_ResponseDuration(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php echo pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	gotresp := make(chan interface{})
-	h.Listen(func(event int, ctx interface{}) {
-		if event == EventResponse {
-			c := ctx.(*ResponseEvent)
-
-			if c.Elapsed() > 0 {
-				close(gotresp)
-			}
-		}
-	})
-
-	body, r, err := get("http://localhost:8177/?hello=world")
-	assert.NoError(t, err)
-
-	<-gotresp
-
-	assert.Equal(t, 201, r.StatusCode)
-	assert.Equal(t, "WORLD", body)
-}
-
-func TestHandler_ResponseDurationDelayed(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php echoDelay pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	gotresp := make(chan interface{})
-	h.Listen(func(event int, ctx interface{}) {
-		if event == EventResponse {
-			c := ctx.(*ResponseEvent)
-
-			if c.Elapsed() > time.Second {
-				close(gotresp)
-			}
-		}
-	})
-
-	body, r, err := get("http://localhost:8177/?hello=world")
-	assert.NoError(t, err)
-
-	<-gotresp
-
-	assert.Equal(t, 201, r.StatusCode)
-	assert.Equal(t, "WORLD", body)
-}
-
-func TestHandler_ErrorDuration(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php error pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	goterr := make(chan interface{})
-	h.Listen(func(event int, ctx interface{}) {
-		if event == EventError {
-			c := ctx.(*ErrorEvent)
-
-			if c.Elapsed() > 0 {
-				close(goterr)
-			}
-		}
-	})
-
-	_, r, err := get("http://localhost:8177/?hello=world")
-	assert.NoError(t, err)
-
-	<-goterr
-
-	assert.Equal(t, 500, r.StatusCode)
-}
-
-func TestHandler_IP(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-			TrustedSubnets: []string{
-				"10.0.0.0/8",
-				"127.0.0.0/8",
-				"172.16.0.0/12",
-				"192.168.0.0/16",
-				"::1/128",
-				"fc00::/7",
-				"fe80::/10",
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php ip pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	err := h.cfg.parseCIDRs()
-	if err != nil {
-		t.Errorf("error parsing CIDRs: error %v", err)
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: "127.0.0.1:8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	body, r, err := get("http://127.0.0.1:8177/")
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, "127.0.0.1", body)
-}
-
-func TestHandler_XRealIP(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-			TrustedSubnets: []string{
-				"10.0.0.0/8",
-				"127.0.0.0/8",
-				"172.16.0.0/12",
-				"192.168.0.0/16",
-				"::1/128",
-				"fc00::/7",
-				"fe80::/10",
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php ip pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	err := h.cfg.parseCIDRs()
-	if err != nil {
-		t.Errorf("error parsing CIDRs: error %v", err)
-	}
-
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: "127.0.0.1:8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	body, r, err := getHeader("http://127.0.0.1:8177/", map[string]string{
-		"X-Real-Ip": "200.0.0.1",
-	})
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, "200.0.0.1", body)
-}
-
-func TestHandler_XForwardedFor(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-			TrustedSubnets: []string{
-				"10.0.0.0/8",
-				"127.0.0.0/8",
-				"172.16.0.0/12",
-				"192.168.0.0/16",
-				"100.0.0.0/16",
-				"200.0.0.0/16",
-				"::1/128",
-				"fc00::/7",
-				"fe80::/10",
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php ip pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	err := h.cfg.parseCIDRs()
-	if err != nil {
-		t.Errorf("error parsing CIDRs: error %v", err)
-	}
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: "127.0.0.1:8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	body, r, err := getHeader("http://127.0.0.1:8177/", map[string]string{
-		"X-Forwarded-For": "100.0.0.1, 200.0.0.1, invalid, 101.0.0.1",
-	})
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, "101.0.0.1", body)
-
-	body, r, err = getHeader("http://127.0.0.1:8177/", map[string]string{
-		"X-Forwarded-For": "100.0.0.1, 200.0.0.1, 101.0.0.1, invalid",
-	})
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, "101.0.0.1", body)
-}
-
-func TestHandler_XForwardedFor_NotTrustedRemoteIp(t *testing.T) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-			TrustedSubnets: []string{
-				"10.0.0.0/8",
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php ip pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      1,
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	err := h.cfg.parseCIDRs()
-	if err != nil {
-		t.Errorf("error parsing CIDRs: error %v", err)
-	}
-	assert.NoError(t, h.rr.Start())
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: "127.0.0.1:8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			t.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			t.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	body, r, err := getHeader("http://127.0.0.1:8177/", map[string]string{
-		"X-Forwarded-For": "100.0.0.1, 200.0.0.1, invalid, 101.0.0.1",
-	})
-
-	assert.NoError(t, err)
-	assert.Equal(t, 200, r.StatusCode)
-	assert.Equal(t, "127.0.0.1", body)
-}
-
-func BenchmarkHandler_Listen_Echo(b *testing.B) {
-	h := &Handler{
-		cfg: &Config{
-			MaxRequestSize: 1024,
-			Uploads: &UploadsConfig{
-				Dir:    os.TempDir(),
-				Forbid: []string{},
-			},
-		},
-		rr: roadrunner.NewServer(&roadrunner.ServerConfig{
-			Command: "php ../../tests/http/client.php echo pipes",
-			Relay:   "pipes",
-			Pool: &roadrunner.Config{
-				NumWorkers:      int64(runtime.NumCPU()),
-				AllocateTimeout: 10000000,
-				DestroyTimeout:  10000000,
-			},
-		}),
-	}
-
-	err := h.rr.Start()
-	if err != nil {
-		b.Errorf("error starting the worker pool: error %v", err)
-	}
-	defer h.rr.Stop()
-
-	hs := &http.Server{Addr: ":8177", Handler: h}
-	defer func() {
-		err := hs.Shutdown(context.Background())
-		if err != nil {
-			b.Errorf("error during the shutdown: error %v", err)
-		}
-	}()
-
-	go func() {
-		err := hs.ListenAndServe()
-		if err != nil && err != http.ErrServerClosed {
-			b.Errorf("error listening the interface: error %v", err)
-		}
-	}()
-	time.Sleep(time.Millisecond * 10)
-
-	bb := "WORLD"
-	for n := 0; n < b.N; n++ {
-		r, err := http.Get("http://localhost:8177/?hello=world")
-		if err != nil {
-			b.Fail()
-		}
-		// Response might be nil here
-		if r != nil {
-			br, err := ioutil.ReadAll(r.Body)
-			if err != nil {
-				b.Errorf("error reading Body: error %v", err)
-			}
-			if string(br) != bb {
-				b.Fail()
-			}
-			err = r.Body.Close()
-			if err != nil {
-				b.Errorf("error closing the Body: error %v", err)
-			}
-		} else {
-			b.Errorf("got nil response")
-		}
-	}
-}