Tests: skips adjusted.
This commit is contained in:
@@ -601,8 +601,14 @@ Content-Length: 10
|
|||||||
'proxy ipv6 invalid 4',
|
'proxy ipv6 invalid 4',
|
||||||
)
|
)
|
||||||
|
|
||||||
@unittest.skip('not yet')
|
|
||||||
def test_proxy_loop(self):
|
def test_proxy_loop(self):
|
||||||
|
self.skip_alerts.extend(
|
||||||
|
[
|
||||||
|
r'socket.*failed',
|
||||||
|
r'accept.*failed',
|
||||||
|
r'new connections are not accepted',
|
||||||
|
]
|
||||||
|
)
|
||||||
self.conf(
|
self.conf(
|
||||||
{
|
{
|
||||||
"listeners": {
|
"listeners": {
|
||||||
@@ -625,6 +631,7 @@ Content-Length: 10
|
|||||||
)
|
)
|
||||||
|
|
||||||
self.get_http10(no_recv=True)
|
self.get_http10(no_recv=True)
|
||||||
|
self.get_http10(read_timeout=1)
|
||||||
|
|
||||||
if __name__ == '__main__':
|
if __name__ == '__main__':
|
||||||
TestProxy.main()
|
TestProxy.main()
|
||||||
|
|||||||
@@ -125,18 +125,23 @@ class TestStatic(TestApplicationProto):
|
|||||||
self.assertEqual(resp['status'], 200, 'fallback proxy status')
|
self.assertEqual(resp['status'], 200, 'fallback proxy status')
|
||||||
self.assertEqual(resp['body'], '', 'fallback proxy')
|
self.assertEqual(resp['body'], '', 'fallback proxy')
|
||||||
|
|
||||||
@unittest.skip('not yet')
|
def test_fallback_proxy_loop(self):
|
||||||
def test_fallback_proxy_cycle(self):
|
self.skip_alerts.extend(
|
||||||
self.action_update(
|
[
|
||||||
{
|
r'open.*/blah/index.html.*failed',
|
||||||
"share": "/blah",
|
r'accept.*failed',
|
||||||
"fallback": {"proxy": "http://127.0.0.1:7080"},
|
r'socket.*failed',
|
||||||
}
|
r'new connections are not accepted',
|
||||||
|
]
|
||||||
)
|
)
|
||||||
self.assertNotEqual(self.get()['status'], 200, 'fallback cycle')
|
|
||||||
|
self.action_update(
|
||||||
|
{"share": "/blah", "fallback": {"proxy": "http://127.0.0.1:7080"}}
|
||||||
|
)
|
||||||
|
self.get(no_recv=True)
|
||||||
|
|
||||||
self.assertIn('success', self.conf_delete('listeners/*:7081'))
|
self.assertIn('success', self.conf_delete('listeners/*:7081'))
|
||||||
self.assertNotEqual(self.get()['status'], 200, 'fallback cycle 2')
|
self.get(read_timeout=1)
|
||||||
|
|
||||||
def test_fallback_invalid(self):
|
def test_fallback_invalid(self):
|
||||||
def check_error(conf):
|
def check_error(conf):
|
||||||
|
|||||||
Reference in New Issue
Block a user