From: Jeroen van der Heijden <jeroen@transceptor.technology>
Date: Fri, 24 Jan 2020 15:13:47 +0000 (+0100)
Subject: Update tee
X-Git-Tag: archive/raspbian/2.0.44-1+rpi1~1^2~3^2~5^2~12
X-Git-Url: https://dgit.raspbian.org/?a=commitdiff_plain;h=7a3e5223aa19bb8e49fd106f1b635e8661d7d36f;p=siridb-server.git

Update tee
---

diff --git a/include/siri/version.h b/include/siri/version.h
index 8e20aa3f..f8a086c9 100644
--- 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 f29080ed..12c06445 100644
--- 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 37e03587..449dbab7 100644
--- 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))