simplified

src/ca/cac.cpp

@@ -518,7 +518,7 @@ bool cac::lookupChannelAndTransferToTCP (
          */
         pChan = this->chanTable.lookup ( cid );
         if ( ! pChan ) {
-            return true;
+            return false;
         }
 
         /*
@@ -533,7 +533,7 @@ bool cac::lookupChannelAndTransferToTCP (
                     msgForMultiplyDefinedPV ( *this, pChan->pName (), acc, addr );
                 pMsg->ioInitiate ( this->ipToAEngine );
             }
-            return true;
+            return false;
         }
 
         /*
@@ -543,7 +543,7 @@ bool cac::lookupChannelAndTransferToTCP (
         piiu = this->serverTable.lookup ( servID );
         if ( piiu ) {
             if ( ! piiu->alive () ) {
-                return true;
+                return false;
             }
         }
         else {
@@ -557,7 +557,7 @@ bool cac::lookupChannelAndTransferToTCP (
                     pBHE = new ( this->bheFreeList ) 
                                         bhe ( epicsTime (), 0u, addr.ia );
                     if ( this->beaconTable.add ( *pBHE ) < 0 ) {
-                        return true;
+                        return false;
                     }
                 }
                 this->serverTable.add ( *pnewiiu );
@@ -566,11 +566,11 @@ bool cac::lookupChannelAndTransferToTCP (
                 newIIU = true;
             }
             catch ( std::bad_alloc & ) {
-                return true;
+                return false;
             }
             catch ( ... ) {
                 this->printf ( "CAC: Unexpected exception during virtual circuit creation\n" );
-                return true;
+                return false;
             }
         }
 
@@ -614,10 +614,6 @@ bool cac::lookupChannelAndTransferToTCP (
         piiu->start ( cbGuard );
     }
 
-    if ( this->pudpiiu ) {
-        this->pudpiiu->notifySearchResponse ( currentTime );
-    }
-
     return true;
 }
 

src/ca/udpiiu.cpp

@@ -639,16 +639,26 @@ bool udpiiu::searchRespAction ( // X aCC 361
         serverAddr.ia.sin_addr = addr.ia.sin_addr;
     }
 
+    bool success;
     if ( CA_V42 ( minorVersion ) ) {
-        return this->cacRef.lookupChannelAndTransferToTCP 
+        success = this->cacRef.lookupChannelAndTransferToTCP 
             ( cbLocker, msg.m_available, msg.m_cid, 0xffff, 
                 0, minorVersion, serverAddr, currentTime );
     }
     else {
-        return this->cacRef.lookupChannelAndTransferToTCP 
+        success = this->cacRef.lookupChannelAndTransferToTCP 
             ( cbLocker, msg.m_available, msg.m_cid, msg.m_dataType, 
                 msg.m_count, minorVersion, serverAddr, currentTime );
     }
+
+    if ( success ) {
+        // deadlock can result if this is called while holding the primary
+        // mutex (because the primary mutex is used in the search timer callback)
+        this->pSearchTmr->notifySearchResponse ( this->lastReceivedSeqNo,
+            this->lastReceivedSeqNoIsValid, currentTime );
+    }
+
+    return true;
 }
 
 bool udpiiu::beaconAction ( epicsGuard < callbackMutex > &, const caHdr &msg, 
@@ -992,14 +1002,6 @@ void udpiiu::repeaterConfirmNotify ()
     this->pRepeaterSubscribeTmr->confirmNotify ();
 }
 
-void udpiiu::notifySearchResponse ( const epicsTime & currentTime )
-{
-    // deadlock can result if this is called while holding the primary
-    // mutex (because the primary mutex is used in the search timer callback)
-    this->pSearchTmr->notifySearchResponse ( this->lastReceivedSeqNo, 
-        this->lastReceivedSeqNoIsValid, currentTime );
-}
-
 void udpiiu::beaconAnomalyNotify () 
 {
     {

src/ca/udpiiu.h

@@ -91,7 +91,6 @@ public:
     void show ( unsigned level ) const;
     bool wakeupMsg ();
     void repeaterConfirmNotify ();
-    void notifySearchResponse ( const epicsTime & currentTime );
     void beaconAnomalyNotify ();
     int printf ( const char *pformat, ... );
     unsigned channelCount () const;