Fix pipe reconnect

badaix · Jun 29, 2024 · dea298b · dea298b
1 parent 302893e
commit dea298b
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 4 deletions.
diff --git a/common/sample_format.hpp b/common/sample_format.hpp
@@ -81,17 +81,17 @@ class SampleFormat
 
     inline double msRate() const
     {
-        return (double)rate_ / 1000.;
+        return static_cast<double>(rate_) / 1000.;
     }
 
     inline double usRate() const
     {
-        return (double)rate_ / 1000000.;
+        return static_cast<double>(rate_) / 1000000.;
     }
 
     inline double nsRate() const
     {
-        return (double)rate_ / 1000000000.;
+        return static_cast<double>(rate_) / 1000000000.;
     }
 
 private:

diff --git a/server/streamreader/pipe_stream.cpp b/server/streamreader/pipe_stream.cpp
@@ -27,6 +27,7 @@
 // standard headers
 #include <cerrno>
 #include <memory>
+#include <system_error>
 
 
 using namespace std;
@@ -59,7 +60,16 @@ void PipeStream::connect()
 {
     int fd = open(uri_.path.c_str(), O_RDONLY | O_NONBLOCK);
     if (fd < 0)
-        throw SnapException("failed to open fifo \"" + uri_.path + "\": " + cpt::to_string(errno));
+    {
+        std::string error = "failed to open fifo \"" + uri_.path + "\": " + cpt::to_string(errno);
+        if (errno == static_cast<int>(std::errc::no_such_file_or_directory))
+        {
+            LOG(ERROR, LOG_TAG) << error << "\n";
+            wait(read_timer_, 200ms, [this] { connect(); });
+            return;
+        }
+        throw SnapException(error);
+    }
 
     int pipe_size = -1;
 #if !defined(MACOS) && !defined(FREEBSD)