Update tee

diff --git a/include/siri/version.h b/include/siri/version.h
index 8e20aa3fae1a4e6629cca4e65b26496abd6a7bf3..f8a086c92140938471399c2749a43b26f9e59e11 100644 (file)
--- a/include/siri/version.h
+++ b/include/siri/version.h
@@ -15,7 +15,7 @@
  * Note that debian alpha packages should use versions like this:
  *   2.0.34-0alpha0
  */
-#define SIRIDB_VERSION_PRE_RELEASE "-alpha-5"
+#define SIRIDB_VERSION_PRE_RELEASE "-alpha-6"
 
 #ifndef NDEBUG
 #define SIRIDB_VERSION_BUILD_RELEASE "+debug"

diff --git a/itest/test_tee.py b/itest/test_tee.py
index f29080ed473eb5c2a199995a77aa498614cab459..12c06445034f6c90f2b8474c3f22517df6e61f19 100644 (file)
--- a/itest/test_tee.py
+++ b/itest/test_tee.py
@@ -108,6 +108,8 @@ class TestTee(TestBase):
 
         await self.client0.connect()
 
+        await asyncio.sleep(1)
+
         await self.client0.query(
             'alter servers set tee_pipe_name "{}"'.format(PIPE_NAME))
 
@@ -152,6 +154,8 @@ class TestTee(TestBase):
             await self.client0.insert(DATA),
             {'success_msg': 'Successfully inserted 60 point(s).'})
 
+        await asyncio.sleep(1)
+
         self.assertEqual(DATA, self._tee_data)
 
         self.client0.close()

diff --git a/src/siri/db/tee.c b/src/siri/db/tee.c
index 37e03587ca360c4c5a043b33ee1972b2007ecfb4..449dbab7a06ac50a82eabf75944c5d63140ec654 100644 (file)
--- a/src/siri/db/tee.c
+++ b/src/siri/db/tee.c
@@ -150,6 +150,7 @@ static void tee__runtime_init(uv_pipe_t * pipe)
     siridb_tee_t * tee = pipe->data;
 
     tee->flags &= ~SIRIDB_TEE_FLAG_INIT;
+    tee->flags &= ~SIRIDB_TEE_FLAG_CONNECTING;
     tee->flags &= ~SIRIDB_TEE_FLAG_CONNECTED;
 
      if (siridb_tee_connect(tee))