Support async connect

phunkyfish · Mar 20, 2023 · 34a0b83 · 34a0b83
1 parent 6cef720
commit 34a0b83
Show file tree

Hide file tree

Showing 3 changed files with 15 additions and 3 deletions.
diff --git a/src/IptvSimple.cpp b/src/IptvSimple.cpp
@@ -35,6 +35,8 @@ bool IptvSimple::Initialise()
 {
   std::lock_guard<std::mutex> lock(m_mutex);
 
+  ConnectionStateChange("", PVR_CONNECTION_STATE_CONNECTING, "");
+
   m_channels.Init();
   m_channelGroups.Init();
   m_providers.Init();
@@ -43,6 +45,11 @@ bool IptvSimple::Initialise()
   {
     m_channels.ChannelsLoadFailed();
     m_channelGroups.ChannelGroupsLoadFailed();
+    ConnectionStateChange("", PVR_CONNECTION_STATE_DISCONNECTED, "");
+  }
+  else
+  {
+    ConnectionStateChange("", PVR_CONNECTION_STATE_CONNECTED, "");
   }
   m_epg.Init(EpgMaxPastDays(), EpgMaxFutureDays());
 
@@ -116,7 +123,8 @@ void IptvSimple::Process()
       std::this_thread::sleep_for(std::chrono::milliseconds(1000));
 
       m_settings->ReloadAddonInstanceSettings();
-      m_playlistLoader.ReloadPlayList();
+      if (m_playlistLoader.ReloadPlayList())
+        ConnectionStateChange("", PVR_CONNECTION_STATE_CONNECTED, "");
       m_epg.ReloadEPG(); // Reloading EPG also updates media
 
       m_reloadChannelsGroupsAndEPG = false;

diff --git a/src/iptvsimple/PlaylistLoader.cpp b/src/iptvsimple/PlaylistLoader.cpp
@@ -517,7 +517,7 @@ void PlaylistLoader::ParseSinglePropertyIntoChannel(const std::string& line, Cha
   }
 }
 
-void PlaylistLoader::ReloadPlayList()
+bool PlaylistLoader::ReloadPlayList()
 {
   m_m3uLocation = m_settings->GetM3ULocation();
 
@@ -532,11 +532,15 @@ void PlaylistLoader::ReloadPlayList()
     m_client->TriggerChannelGroupsUpdate();
     m_client->TriggerProvidersUpdate();
     m_client->TriggerRecordingUpdate();
+
+    return true;
   }
   else
   {
     m_channels.ChannelsLoadFailed();
     m_channelGroups.ChannelGroupsLoadFailed();
+
+    return false;
   }
 }
 

diff --git a/src/iptvsimple/PlaylistLoader.h b/src/iptvsimple/PlaylistLoader.h
@@ -71,7 +71,7 @@ namespace iptvsimple
     bool Init();
 
     bool LoadPlayList();
-    void ReloadPlayList();
+    bool ReloadPlayList();
 
   private:
     static std::string ReadMarkerValue(const std::string& line, const std::string& markerName);