Method TestMaxConnTimeoutFails

net2/http2/simple_pool_test.go:171–226

(c *C)

}

func (s *SimplePoolSuite) TestMaxConnTimeoutFails(c *C) {
	server, addr := test_utils.SetupTestServer(false)
	defer server.Close()

	params := ConnectionParams{
		MaxConns:                 2,
		MaxIdle:                  1,
		ConnectionAcquireTimeout: 1 * time.Second,
	}
	pool := NewSimplePool(addr, params)
	pool.closeWait = 100 * time.Millisecond

	// do 10 requests concurrently
	origMaxProcs := runtime.GOMAXPROCS(runtime.NumCPU())
	defer func() { runtime.GOMAXPROCS(origMaxProcs) }()

	tooManyConn := make(chan int)

	const count = 5
	for i := 0; i < count; i++ {
		go func() {
			// /slow_request takes about 500ms. With 5 requests in parallel and 2 connections
			// we should finish within 1.5 seconds. Since ConnectionAcquireTimeout is 1 second
			// the last request will fail
			req, err := http.NewRequest("GET", "/slow_request", nil)
			c.Assert(err, IsNil)

			_, err = pool.Do(req)
			if err == nil {
				tooManyConn <- 0
			} else {
				_, ok := err.(DialError)
				c.Assert(ok, IsTrue)
				c.Log(err)
				c.Assert(
					strings.HasPrefix(
						err.Error(),
						"Dial Error: Reached maximum active requests for connection pool"),
					IsTrue)
				tooManyConn <- 1
			}
		}()
	}

	tooManyConnCount := 0
	for i := 0; i < count; i++ {
		select {
		case cnt := <-tooManyConn:
			tooManyConnCount += cnt
		case <-time.After(5 * time.Second):
			c.FailNow()
		}
	}

	c.Assert(tooManyConnCount, Equals, 1)
}

func (s *SimplePoolSuite) TestMaxConn(c *C) {