From 6ee8a39047e6982afc1479ed9febbcc80b8616e2 Mon Sep 17 00:00:00 2001
From: "Jeff Hill johill@lanl.gov" <Unknown>
Date: Tue, 14 May 2013 17:08:41 -0600
Subject: [PATCH] regression test for
 https://bugs.launchpad.net/epics-base/+bug/1179642

---
 src/ca/client/acctst.c | 82 ++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 82 insertions(+)

diff --git a/src/ca/client/acctst.c b/src/ca/client/acctst.c
index f2d102868..3cafa9730 100644
--- a/src/ca/client/acctst.c
+++ b/src/ca/client/acctst.c
@@ -13,6 +13,7 @@
  * Authors:
  * Jeff Hill
  * Murali Shankar - initial versions of verifyMultithreadSubscr
+ * Michael Abbott - multiSubscrDestroyLateNoCallbackTest
  * 
  */
 
@@ -1328,6 +1329,85 @@ void test_sync_groups ( chid chan, unsigned interestLevel  )
     showProgressEnd ( interestLevel );
 }
 
+#define multiSubscrDestroyLateNoCallbackEventCount 100000
+
+struct MultiSubscrDestroyLateNoCallbackEventData {
+    evid m_id;
+    int m_callbackIsOk;
+    struct MultiSubscrDestroyLateNoCallbackTestData * m_pTestData;
+};
+
+struct MultiSubscrDestroyLateNoCallbackTestData {
+    chid m_chan;
+    epicsMutexId m_mutex;
+    struct MultiSubscrDestroyLateNoCallbackEventData
+        m_eventData [multiSubscrDestroyLateNoCallbackEventCount];
+};
+
+static void noLateCallbackDetect ( struct event_handler_args args )
+{
+    const struct MultiSubscrDestroyLateNoCallbackEventData * pEventData = args.usr;
+    epicsMutexLockStatus lockStatus = epicsMutexLock ( pEventData->m_pTestData->m_mutex );
+    verify ( lockStatus == epicsMutexLockOK );
+    verify ( pEventData->m_callbackIsOk );
+    epicsMutexUnlock ( pEventData->m_pTestData->m_mutex );
+}
+
+/*
+ * verify that a subscription callback never comes after the subscription is destroyed
+ */
+static void multiSubscrDestroyLateNoCallbackTest ( const char *pName, unsigned interestLevel )
+{
+    unsigned i;
+    int status;
+
+    showProgressBegin ( "multiSubscrDestroyLateNoCallbackTest", interestLevel );
+
+    struct MultiSubscrDestroyLateNoCallbackTestData * pTestData =
+        calloc ( 1u, sizeof ( struct MultiSubscrDestroyLateNoCallbackTestData ) );
+    verify ( pTestData );
+
+    pTestData->m_mutex =  epicsMutexCreate ();
+    verify ( pTestData->m_mutex );
+
+    status = ca_create_channel ( pName, 0, 0,
+        CA_PRIORITY_DEFAULT, &pTestData->m_chan );
+    status = ca_pend_io ( timeoutToPendIO );
+    SEVCHK ( status, "multiSubscrDestroyLateNoCallbackTest: channel connect failed" );
+    verify ( status == ECA_NORMAL );
+
+
+    for ( i=0; i < multiSubscrDestroyLateNoCallbackEventCount; i++ ) {
+        epicsMutexLockStatus lockStatus = epicsMutexLock ( pTestData->m_mutex );
+        verify ( lockStatus == epicsMutexLockOK );
+        pTestData->m_eventData[i].m_callbackIsOk = TRUE;
+        pTestData->m_eventData[i].m_pTestData = pTestData;
+        epicsMutexUnlock ( pTestData->m_mutex );
+        SEVCHK ( ca_add_event ( DBR_GR_FLOAT, pTestData->m_chan, noLateCallbackDetect,
+                    &pTestData->m_eventData, &pTestData->m_eventData[i].m_id ) , NULL );
+    }
+
+    for ( i=0; i < multiSubscrDestroyLateNoCallbackEventCount; i++ ) {
+        epicsMutexLockStatus lockStatus;
+        SEVCHK ( ca_clear_event ( pTestData->m_eventData[i].m_id ) , NULL );
+        lockStatus = epicsMutexLock ( pTestData->m_mutex );
+        verify ( lockStatus == epicsMutexLockOK );
+        pTestData->m_eventData[i].m_callbackIsOk = FALSE;
+        epicsMutexUnlock ( pTestData->m_mutex );
+    }
+
+    SEVCHK ( ca_clear_channel ( pTestData->m_chan ), NULL );
+
+    ca_context_destroy ();
+
+    epicsMutexDestroy ( pTestData->m_mutex );
+
+    free ( pTestData );
+
+    showProgressEnd ( interestLevel );
+}
+
+
 /*
  * multiSubscriptionDeleteTest
  *
@@ -3263,6 +3343,8 @@ int acctst ( const char * pName, unsigned interestLevel, unsigned channelCount,
         epicsEnvSet ( "EPICS_CA_MAX_ARRAY_BYTES", tmpString ); 
     }
 
+    multiSubscrDestroyLateNoCallbackTest ( pName, interestLevel );
+
     status = ca_context_create ( select );
     SEVCHK ( status, NULL );