Commit 4dc8a771 authored by Eteri's avatar Eteri

fix keep-alive test, change address of the plugin to nexedi

parent a04dadae
...@@ -83,8 +83,7 @@ mode = 0644 ...@@ -83,8 +83,7 @@ mode = 0644
[fluentd-plugin-dev-repository] [fluentd-plugin-dev-repository]
recipe = slapos.recipe.build:gitclone recipe = slapos.recipe.build:gitclone
repository = https://lab.nexedi.com/Sokhoyan/fluent-plugin-wendelin.git repository = https://lab.nexedi.com/nexedi/fluent-plugin-wendelin.git
branch = add-keep-alive
# dir is pretty name as top-level -dev recipe # dir is pretty name as top-level -dev recipe
git-executable = ${git:location}/bin/git git-executable = ${git:location}/bin/git
......
...@@ -110,9 +110,14 @@ class TestIngestion(FluentdPluginTestCase): ...@@ -110,9 +110,14 @@ class TestIngestion(FluentdPluginTestCase):
start_fluentd_cat(self, "dummyInputDelayCheckKeepAlive", "tag_test_3") start_fluentd_cat(self, "dummyInputDelayCheckKeepAlive", "tag_test_3")
time.sleep(10) time.sleep(10)
for conn in caddy_process.connections('inet'): self.assertEqual(
if len(conn.raddr) > 1 and conn.laddr.port == 4443: ['ESTABLISHED'],
self.assertEqual('ESTABLISHED', conn.status) #conn.status == 'ESTABLISHED' : [conn.status for conn in caddy_process.connections('inet')
if len(conn.raddr) > 1 and conn.laddr.port == 4443])
#for conn in caddy_process.connections('inet'):
# if len(conn.raddr) > 1 and conn.laddr.port == 4443:
# self.assertEqual('ESTABLISHED', conn.status) #conn.status == 'ESTABLISHED' :
def test_ingest_with_15mins_delay(self): def test_ingest_with_15mins_delay(self):
''' '''
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment