Ticket #11306: slave_shutdown_deadlock_v2.patch

mythtv/programs/mythbackend/encoderlink.cpp

@@ -41 +41 @@
                          QString lhostname)
     : m_capturecardnum(capturecardnum), sock(lsock), hostname(lhostname),
       freeDiskSpaceKB(-1), tv(NULL), local(false), locked(false),
+      disconnected(false),
       sleepStatus(sStatus_Undefined), chanid(0)
 {
     endRecordingTime = MythDate::current().addDays(-2);
@@ -50 +51 @@
     lastSleepTime   = MythDate::current();
     lastWakeTime    = MythDate::current();
 
+    QMutexLocker locker(&sockLock);
     if (sock)
         sock->IncrRef();
 }
@@ -60 +62 @@
 EncoderLink::EncoderLink(int capturecardnum, TVRec *ltv)
     : m_capturecardnum(capturecardnum), sock(NULL),
       freeDiskSpaceKB(-1), tv(ltv), local(true), locked(false),
+      disconnected(false),
       sleepStatus(sStatus_Undefined), chanid(0)
 {
     endRecordingTime = MythDate::current().addDays(-2);
@@ -81 +84 @@
         delete tv;
         tv = NULL;
     }
+    disconnected = true;
 }
 
 /** \fn EncoderLink::SetSocket(PlaybackSock *lsock)
@@ -90 +94 @@
  */
 void EncoderLink::SetSocket(PlaybackSock *lsock)
 {
+    QMutexLocker locker(&sockLock);
     if (lsock)
     {
         lsock->IncrRef();
@@ -99 +104 @@
         else
             SetSleepStatus(sStatus_Awake);
     }
-    else
-    {
-        if (IsFallingAsleep())
-            SetSleepStatus(sStatus_Asleep);
-        else
-            SetSleepStatus(sStatus_Undefined);
-    }
-
-    if (sock)
-        sock->DecrRef();
     sock = lsock;
 }
 
+void EncoderLink::Disconnect()
+{
+  disconnected = true;
+  if (IsFallingAsleep())
+      SetSleepStatus(sStatus_Asleep);
+  else
+      SetSleepStatus(sStatus_Undefined);
+
+  if (sock)
+      sock->DecrRef();
+}
+
 /** \fn EncoderLink::SetSleepStatus(SleepStatus)
  *  \brief Sets the sleep status of a recorder
  */
@@ -128 +135 @@
  */
 bool EncoderLink::IsBusy(TunedInputInfo *busy_input, int time_buffer)
 {
+    if (disconnected)
+        return false;
+
     if (local)
         return tv->IsBusy(busy_input, time_buffer);
 
+    QMutexLocker locker(&sockLock);
     if (sock)
         return sock->IsBusy(m_capturecardnum, busy_input, time_buffer);
 
@@ -149 +160 @@
 {
     bool retval = false;
 
+    if (disconnected)
+        return false;
+
     TVState state = GetState();
 
     if (state == kState_RecordingOnly || state == kState_WatchingRecording ||
@@ -174 +188 @@
     if (local)
         retval = tv->GetState();
     else if (sock)
-        retval = (TVState)sock->GetEncoderState(m_capturecardnum);
+    {
+        QMutexLocker locker(&sockLock);
+        if (sock)
+            retval = (TVState)sock->GetEncoderState(m_capturecardnum);
+    }
     else
         LOG(VB_GENERAL, LOG_ERR, QString("Broken for card: %1")
             .arg(m_capturecardnum));
@@ -186 +204 @@
  *  \brief Returns the flag state of the recorder.
  *  \sa TVRec::GetFlags(void) const, \ref recorder_subsystem
  */
-uint EncoderLink::GetFlags(void) const
+uint EncoderLink::GetFlags(void)
 {
     uint retval = 0;
 
-    if (!IsConnected())
+    if (disconnected)
         return retval;
 
     if (local)
         retval = tv->GetFlags();
     else if (sock)
-        retval = sock->GetEncoderState(m_capturecardnum);
+    {
+        QMutexLocker locker(&sockLock);
+        if (sock)
+            retval = sock->GetEncoderState(m_capturecardnum);
+    }
     else
         LOG(VB_GENERAL, LOG_ERR, LOC + "GetFlags failed");
 
@@ -210 +232 @@
  */
 bool EncoderLink::IsRecording(const ProgramInfo *rec)
 {
+    if (disconnected)
+        return false;
     return (rec->GetChanID() == chanid &&
             rec->GetRecordingStartTime() == startRecordingTime);
 }
@@ -227 +251 @@
     bool retval = false;
     ProgramInfo *tvrec = NULL;
 
+    if (disconnected)
+        return false;
+
     if (local)
     {
         while (kState_ChangingState == GetState())
@@ -243 +270 @@
     }
     else
     {
+        QMutexLocker locker(&sockLock);
         if (sock)
             retval = sock->EncoderIsRecording(m_capturecardnum, rec);
     }
@@ -261 +289 @@
 void EncoderLink::RecordPending(const ProgramInfo *rec, int secsleft,
                                 bool hasLater)
 {
+    if (disconnected)
+        return;
+
     if (local)
         tv->RecordPending(rec, secsleft, hasLater);
-    else if (sock)
-        sock->RecordPending(m_capturecardnum, rec, secsleft, hasLater);
+    else
+    {
+        QMutexLocker locker(&sockLock);
+        if (sock)
+            sock->RecordPending(m_capturecardnum, rec, secsleft, hasLater);
+   }
 }
 
 /** \fn EncoderLink::WouldConflict(const ProgramInfo*)
@@ -286 +321 @@
 /// Checks if program is stored locally
 bool EncoderLink::CheckFile(ProgramInfo *pginfo)
 {
+    if (disconnected)
+        return false;
+
+    QMutexLocker locker(&sockLock);
     if (sock)
         return sock->CheckFile(pginfo);
 
@@ -300 +339 @@
  */
 void EncoderLink::GetDiskSpace(QStringList &o_strlist)
 {
+    if (disconnected)
+        return;
+
+    QMutexLocker locker(&sockLock);
     if (sock)
         sock->GetDiskSpace(o_strlist);
 }
@@ -312 +355 @@
  */
 long long EncoderLink::GetMaxBitrate()
 {
+    if (disconnected)
+        return -1;
+
     if (local)
         return tv->GetMaxBitrate();
-    else if (sock)
-        return sock->GetMaxBitrate(m_capturecardnum);
-
+    else
+    {
+        QMutexLocker locker(&sockLock);
+        if (sock)
+            return sock->GetMaxBitrate(m_capturecardnum);
+    }
     return -1;
 }
 
@@ -338 +387 @@
 {
     if (local)
         return tv->SetSignalMonitoringRate(rate, notifyFrontend);
-    else if (sock)
-        return sock->SetSignalMonitoringRate(m_capturecardnum, rate,
-                                             notifyFrontend);
+    else
+    {
+        QMutexLocker locker(&sockLock);
+        if (sock)
+            return sock->SetSignalMonitoringRate(m_capturecardnum, rate,
+                                                 notifyFrontend);
+    }
     return -1;
 }
 
@@ -348 +401 @@
  */
 bool EncoderLink::GoToSleep(void)
 {
-    if (IsLocal() || !sock)
+    if (disconnected)
         return false;
 
+    if (IsLocal())
+        return false;
+
+    QMutexLocker locker(&sockLock);
+    if (!sock)
+        return false;
+
+    if (sock->getBlockShutdown())
+    {
+        LOG(VB_GENERAL, LOG_NOTICE,
+            QString("EncoderLink::GoToSleep() Socket shutdown is currently blocked!"));
+        return false;
+    }
+
     lastSleepTime = MythDate::current();
 
     return sock->GoToSleep();
@@ -362 +429 @@
  */
 int EncoderLink::LockTuner()
 {
+    if (disconnected)
+        return -2;
+
     if (locked)
         return -2;
 
@@ -380 +450 @@
 {
     RecStatusType retval = rsAborted;
 
+    if (disconnected)
+        return retval;
+
     endRecordingTime = rec->GetRecordingEndTime();
     startRecordingTime = rec->GetRecordingStartTime();
     chanid = rec->GetChanID();
 
     if (local)
         retval = tv->StartRecording(rec);
-    else if (sock)
-        retval = sock->StartRecording(m_capturecardnum, rec);
     else
-        LOG(VB_GENERAL, LOG_ERR,
-            QString("Wanted to start recording on recorder %1,\n\t\t\t"
-                    "but the backend is not there anymore\n")
-                .arg(m_capturecardnum));
+    {
+        QMutexLocker locker(&sockLock);
+        if (sock)
+            retval = sock->StartRecording(m_capturecardnum, rec);
+        else
+            LOG(VB_GENERAL, LOG_ERR,
+                QString("Wanted to start recording on recorder %1,\n\t\t\t"
+                        "but the backend is not there anymore\n")
+                    .arg(m_capturecardnum));
+    }
 
     if (retval != rsRecording && retval != rsTuning)
     {
@@ -408 +485 @@
 {
     RecStatusType retval = rsAborted;
 
+    if (disconnected)
+        return retval;
+
     if (local)
         retval = tv->GetRecordingStatus();
-    else if (sock)
-        retval = sock->GetRecordingStatus(m_capturecardnum);
     else
-        LOG(VB_GENERAL, LOG_ERR,
-            QString("Wanted to get status on recorder %1,\n\t\t\t"
-                    "but the backend is not there anymore\n")
-                .arg(m_capturecardnum));
+    {
+        QMutexLocker locker(&sockLock);
+        if (sock)
+            retval = sock->GetRecordingStatus(m_capturecardnum);
+        else
+            LOG(VB_GENERAL, LOG_ERR,
+                QString("Wanted to get status on recorder %1,\n\t\t\t"
+                        "but the backend is not there anymore\n")
+                    .arg(m_capturecardnum));
+    }
 
     if (retval != rsRecording && retval != rsTuning)
     {
@@ -438 +522 @@
 {
     ProgramInfo *info = NULL;
 
+    if (disconnected)
+        return info;
+
     if (local)
         info = tv->GetRecording();
-    else if (sock)
-        info = sock->GetRecording(m_capturecardnum);
+    else
+    {
+        QMutexLocker locker(&sockLock);
+        if (sock)
+            info = sock->GetRecording(m_capturecardnum);
+    }
 
     return info;
 }
@@ -453 +544 @@
  */
 void EncoderLink::StopRecording(bool killFile)
 {
+    if (disconnected)
+        return;
+
     endRecordingTime = MythDate::current().addDays(-2);
     startRecordingTime = endRecordingTime;
     chanid = 0;
@@ -471 +565 @@
  */
 void EncoderLink::FinishRecording(void)
 {
+    if (disconnected)
+        return;
+
     if (local)
     {
         tv->FinishRecording();
@@ -505 +602 @@
  */
 float EncoderLink::GetFramerate(void)
 {
+    if (disconnected)
+        return -1;
+
     if (local)
         return tv->GetFramerate();
 
@@ -521 +621 @@
  */
 long long EncoderLink::GetFramesWritten(void)
 {
+    if (disconnected)
+        return -1;
+
     if (local)
         return tv->GetFramesWritten();
 
@@ -536 +639 @@
  */
 long long EncoderLink::GetFilePosition(void)
 {
+    if (disconnected)
+        return -1;
+
     if (local)
         return tv->GetFilePosition();
 
@@ -551 +657 @@
  */
 int64_t EncoderLink::GetKeyframePosition(uint64_t desired)
 {
+    if (disconnected)
+        return -1;
+
     if (local)
         return tv->GetKeyframePosition(desired);
 
@@ -561 +670 @@
 bool EncoderLink::GetKeyframePositions(
     int64_t start, int64_t end, frm_pos_map_t &map)
 {
+    if (disconnected)
+        return false;
+
     if (!local)
     {
         LOG(VB_GENERAL, LOG_ERR,
@@ -578 +690 @@
  */
 void EncoderLink::FrontendReady(void)
 {
+    if (disconnected)
+        return;
+
     if (local)
         tv->FrontendReady();
     else
@@ -594 +709 @@
  */
 void EncoderLink::CancelNextRecording(bool cancel)
 {
+    if (disconnected)
+        return;
+
     if (local)
         tv->CancelNextRecording(cancel);
     else
-        sock->CancelNextRecording(m_capturecardnum, cancel);
+    {
+        QMutexLocker locker(&sockLock);
+        if (sock)
+            sock->CancelNextRecording(m_capturecardnum, cancel);
+    }
 }
 
 /** \fn EncoderLink::SpawnLiveTV(LiveTVChain*, bool, QString)
@@ -613 +735 @@
  */
 void EncoderLink::SpawnLiveTV(LiveTVChain *chain, bool pip, QString startchan)
 {
+    if (disconnected)
+        return;
+
     if (local)
         tv->SpawnLiveTV(chain, pip, startchan);
     else
@@ -624 +749 @@
  */
 QString EncoderLink::GetChainID(void)
 {
+    if (disconnected)
+        return "";
+
     if (local)
         return tv->GetChainID();
 
@@ -638 +766 @@
  */
 void EncoderLink::StopLiveTV(void)
 {
+    if (disconnected)
+        return;
+
     if (local)
         tv->StopLiveTV();
     else
@@ -652 +783 @@
  */
 void EncoderLink::PauseRecorder(void)
 {
+    if (disconnected)
+        return;
+
     if (local)
         tv->PauseRecorder();
     else
@@ -665 +799 @@
  */
 void EncoderLink::SetLiveRecording(int recording)
 {
+    if (disconnected)
+        return;
+
     if (local)
         tv->SetLiveRecording(recording);
     else
@@ -677 +814 @@
  */
 void EncoderLink::SetNextLiveTVDir(QString dir)
 {
+    if (disconnected)
+        return;
+
     if (local)
         tv->SetNextLiveTVDir(dir);
     else
-        sock->SetNextLiveTVDir(m_capturecardnum, dir);
+    {
+        QMutexLocker locker(&sockLock);
+        if (sock)
+            sock->SetNextLiveTVDir(m_capturecardnum, dir);
+    }
 }
 
 /** \fn EncoderLink::GetFreeInputs(const vector<uint>&) const
@@ -689 +833 @@
  *  \sa TVRec::GetFreeInputs(const vector<uint>&) const
  */
 vector<InputInfo> EncoderLink::GetFreeInputs(
-    const vector<uint> &excluded_cardids) const
+    const vector<uint> &excluded_cardids)
 {
     vector<InputInfo> list;
 
+    if (disconnected)
+        return list;
+
     if (local)
         list = tv->GetFreeInputs(excluded_cardids);
     else
-        list = sock->GetFreeInputs(m_capturecardnum, excluded_cardids);
+    {
+        QMutexLocker locker(&sockLock);
+        if (sock)
+            list = sock->GetFreeInputs(m_capturecardnum, excluded_cardids);
+    }
 
     return list;
 }
@@ -709 +860 @@
  */
 QString EncoderLink::GetInput(void) const
 {
+    if (disconnected)
+        return QString();
+
     if (local)
         return tv->GetInput();
 
@@ -728 +882 @@
  */
 QString EncoderLink::SetInput(QString input)
 {
+    if (disconnected)
+        return QString();
+
     if (local)
         return tv->SetInput(input);
 
@@ -742 +899 @@
  */
 void EncoderLink::ToggleChannelFavorite(QString changroup)
 {
+    if (disconnected)
+        return;
+
     if (local)
         tv->ToggleChannelFavorite(changroup);
     else
@@ -757 +917 @@
  */
 void EncoderLink::ChangeChannel(ChannelChangeDirection channeldirection)
 {
+    if (disconnected)
+        return;
+
     if (local)
         tv->ChangeChannel(channeldirection);
     else
@@ -772 +935 @@
  */
 void EncoderLink::SetChannel(const QString &name)
 {
+    if (disconnected)
+        return;
+
     if (local)
         tv->SetChannel(name);
     else
@@ -788 +954 @@
  */
 int EncoderLink::GetPictureAttribute(PictureAttribute attr)
 {
+    if (disconnected)
+        return -1;
+
     if (!local)
     {
         LOG(VB_GENERAL, LOG_ERR,
@@ -810 +979 @@
                                         PictureAttribute  attr,
                                         bool              direction)
 {
+    if (disconnected)
+        return -1;
+
     if (!local)
     {
         LOG(VB_GENERAL, LOG_ERR,
@@ -831 +1003 @@
  */
 bool EncoderLink::CheckChannel(const QString &name)
 {
+    if (disconnected)
+        return false;
+
     if (local)
         return tv->CheckChannel(name);
 
@@ -849 +1024 @@
  */
 bool EncoderLink::ShouldSwitchToAnotherCard(const QString &channelid)
 {
+    if (disconnected)
+        return false;
+
     if (local)
         return tv->ShouldSwitchToAnotherCard(channelid);
 
@@ -870 +1048 @@
     bool          &is_extra_char_useful,
     QString       &needed_spacer)
 {
+    if (disconnected)
+        return false;
+
     if (local)
     {
         return tv->CheckChannelPrefix(
@@ -897 +1078 @@
                                  QString &channelname, uint    &_chanid,
                                  QString &seriesid,    QString &programid)
 {
+    if (disconnected)
+        return;
+
     if (local)
     {
         tv->GetNextProgram(direction,
@@ -912 +1096 @@
                                  QString &callsign, QString &channum,
                                  QString &channame, QString &xmltv) const
 {
+    if (disconnected)
+        return false;
+
     if (!local)
     {
         LOG(VB_GENERAL, LOG_ERR, "Should be local only query: GetChannelInfo");
@@ -927 +1114 @@
                                  QString callsign, QString channum,
                                  QString channame, QString xmltv)
 {
+    if (disconnected)
+        return false;
+
     if (!local)
     {
         LOG(VB_GENERAL, LOG_ERR, "Should be local only query: SetChannelInfo");

mythtv/programs/mythbackend/encoderlink.h

@@ -3 +3 @@
 
 #include <QString>
 #include <QMap>
+#include <QMutex>
 
 #include "tv.h"
 #include "programinfo.h"
@@ -23 +24 @@
 
     /// \brief Used to set the socket for a non-local EncoderLink.
     void SetSocket(PlaybackSock *lsock);
+
+    void Disconnect();
+
     /// \brief Returns the socket, if set, for a non-local EncoderLink.
     PlaybackSock *GetSocket(void) { return sock; }
 
@@ -42 +46 @@
     /// \brief Returns true for a local EncoderLink.
     bool IsLocal(void) const { return local; }
     /// \brief Returns true if the EncoderLink instance is usable.
-    bool IsConnected(void) const { return (IsLocal() || sock!=NULL); }
+    bool IsConnected(void) { bool value;
+                             if (disconnected)
+                                 return false;
+                             value = IsLocal();
+                             if (value)
+                                 return value;
+                             if (sock)
+                                 return true;
+                             return false;
+                           }
     /// \brief Returns true if the encoder is awake.
     bool IsAwake(void) const { return (sleepStatus == sStatus_Awake); }
     /// \brief Returns true if the encoder is asleep.
@@ -82 +95 @@
     bool IsBusyRecording(void);
 
     TVState GetState();
-    uint GetFlags(void) const;
+    uint GetFlags(void);
     bool IsRecording(const ProgramInfo *rec); // scheduler call only.
 
     bool MatchesRecording(const ProgramInfo *rec);
@@ -108 +121 @@
     void PauseRecorder(void);
     void SetLiveRecording(int);
     void SetNextLiveTVDir(QString dir);
-    vector<InputInfo> GetFreeInputs(const vector<uint> &excluded_cards) const;
+    vector<InputInfo> GetFreeInputs(const vector<uint> &excluded_cards);
     QString GetInput(void) const;
     QString SetInput(QString);
     void ToggleChannelFavorite(QString);
@@ -138 +151 @@
   private:
     int m_capturecardnum;
 
+    QMutex sockLock;
+
     PlaybackSock *sock;
+
     QString hostname;
 
     long long freeDiskSpaceKB;
@@ -147 +163 @@
 
     bool local;
     bool locked;
+    bool disconnected;
 
     SleepStatus sleepStatus;
     QDateTime sleepStatusTime;

mythtv/programs/mythbackend/mainserver.cpp

@@ -5749 +5749 @@
                         if (!elink->IsFallingAsleep())
                             isFallingAsleep = false;
 
-                        elink->SetSocket(NULL);
+                        // elink->SetSocket(NULL);
+                        elink->Disconnect();
                         if (m_sched)
                             disconnectedSlaves.push_back(elink->GetCardID());
                     }

mythtv/programs/mythbackend/playbacksock.cpp

@@ -17 +17 @@
 PlaybackSock::PlaybackSock(
     MainServer *parent, MythSocket *lsock,
     QString lhostname, PlaybackSockEventsMode eventsMode) :
-    ReferenceCounter("PlaybackSock")
+    ReferenceCounter("PlaybackSock"),
+    sockLock(QMutex::Recursive)
 {
     m_parent = parent;
     QString localhostname = gCoreContext->GetHostName();
@@ -77 +78 @@
 {
     bool ok = false;
 
+    QMutexLocker locker(&sockLock);
+
+    if (!sock)
+        return false;
+
     sock->IncrRef();
-    sock->Lock();
+
+    bool status = false;
+    unsigned int loop=10;
+    status = sock->TryLock(false);
+    while ((status == false) && (loop > 0))
+    {
+        --loop;
+        locker.unlock();
+        usleep(10000); 
+        status = sock->TryLock(false);
+    }
+    if (status == false)
+    {
+        sock->DecrRef();
+        return false;
+
+    }
+
+    locker.relock();
+
+    if (!sock)
+    {
+        sock->DecrRef();
+        return false;
+    }
 
     {
-        QMutexLocker locker(&sockLock);
         expectingreply = true;
 
         sock->writeStringList(strlist);
@@ -322 +351 @@
 {
     QStringList strlist(QString("QUERY_REMOTEENCODER %1").arg(capturecardnum));
 
+    QMutexLocker locker(&sockLock);
+    if (disconnected)
+        return true;
+
     strlist << "IS_BUSY";
     strlist << QString::number(time_buffer);
 

mythtv/programs/mythbackend/playbacksock.h

@@ -31 +31 @@
                  QString lhostname, PlaybackSockEventsMode eventsMode);
     virtual ~PlaybackSock();
 
-    void SetDisconnected(void) { disconnected = true; }
+    void SetDisconnected(void) { QMutexLocker locker(&sockLock); disconnected = true; }
     bool IsDisconnected(void) const { return disconnected; }
 
     MythSocket *getSocket(void) const { return sock; }