trafficserver-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sor...@apache.org
Subject [trafficserver] 06/09: TS-4328: Add a test for the slow response case
Date Tue, 07 Jun 2016 16:27:49 GMT
This is an automated email from the ASF dual-hosted git repository.

sorber pushed a commit to branch 6.2.x
in repository https://git-dual.apache.org/repos/asf/trafficserver.git

commit 678a2dc973b5b1f7b2f62930e9b4948834ab180b
Author: Thomas Jackson <jacksontj@apache.org>
AuthorDate: Wed Apr 6 19:50:19 2016 -0700

    TS-4328: Add a test for the slow response case
    
    If the request hits a timeout-- but we sent the request to the origin we cannot rety the
request
    
    (cherry picked from commit a6e89ed4ea1a67613c27a4136e3a7a58ef7aead7)
---
 ci/tsqa/tests/test_connect_attempts.py | 42 ++++++++++++++++++++++++++++++++++
 1 file changed, 42 insertions(+)

diff --git a/ci/tsqa/tests/test_connect_attempts.py b/ci/tsqa/tests/test_connect_attempts.py
index 58d70e1..fc037ae 100644
--- a/ci/tsqa/tests/test_connect_attempts.py
+++ b/ci/tsqa/tests/test_connect_attempts.py
@@ -111,6 +111,36 @@ def thread_partial_response(sock):
             connection.close()
 
 
+def thread_slow_response(sock):
+    '''
+    Thread to sleep a decreasing amount of time before sending the response
+
+    sleep times: 2 -> 1 -> 0
+    '''
+    sock.listen(0)
+    sleep_time = 2
+    num_requests = 0
+    # poll
+    while True:
+        select.select([sock], [], [])
+        try:
+            connection, addr = sock.accept()
+            time.sleep(sleep_time)
+            connection.send((
+                'HTTP/1.1 200 OK\r\n'
+                'Content-Length: {body_len}\r\n'
+                'Content-Type: text/html; charset=UTF-8\r\n'
+                'Connection: close\r\n\r\n{body}'.format(body_len=len(str(num_requests)),
body=num_requests)
+            ))
+            connection.close()
+            num_requests += 1
+        except Exception as e:
+            print 'connection died!', e
+            pass
+        if sleep_time > 0:
+            sleep_time -= 1
+
+
 class TestOriginServerConnectAttempts(helpers.EnvironmentCase):
     @classmethod
     def setUpEnv(cls, env):
@@ -149,6 +179,11 @@ class TestOriginServerConnectAttempts(helpers.EnvironmentCase):
         t.daemon = True
         t.start()
 
+        sock = _add_sock('slow_response')
+        t = threading.Thread(target=thread_slow_response, args=(sock,))
+        t.daemon = True
+        t.start()
+
         sock = _add_sock('partial_response')
         t = threading.Thread(target=thread_partial_response, args=(sock,))
         t.daemon = True
@@ -209,3 +244,10 @@ class TestOriginServerConnectAttempts(helpers.EnvironmentCase):
         # make sure its not the first one (otherwise the test messed up somehow)
         print ret.text
         self.assertGreater(int(ret.text), 0)
+
+    def test_slow_response(self):
+        '''Verify that we get 5xx from origins that take longer than acceptable, since we
will not retry them'''
+        url = 'http://127.0.0.1:{0}/slow_response/s'.format(self.configs['records.config']['CONFIG']['proxy.config.http.server_ports'])
+        ret = requests.get(url)
+        # make sure it worked
+        self.assertEqual(ret.status_code, 504)

-- 
To stop receiving notification emails like this one, please contact
"commits@trafficserver.apache.org" <commits@trafficserver.apache.org>.

Mime
View raw message