From 5184d1807a681ccd0579bc21857357c6ffe28a0e Mon Sep 17 00:00:00 2001
From: Jeff Hill <johill@lanl.gov>
Date: Wed, 6 Aug 2003 16:47:59 +0000
Subject: [PATCH] added test to detect ca context run down problems

---
 src/ca/acctst.c | 43 +++++++++++++++++++++++++++++++++++++++++--
 1 file changed, 41 insertions(+), 2 deletions(-)

diff --git a/src/ca/acctst.c b/src/ca/acctst.c
index cf2e90019..5744b0c86 100644
--- a/src/ca/acctst.c
+++ b/src/ca/acctst.c
@@ -2407,10 +2407,49 @@ void verifyChannelPriorities ( const char *pName, unsigned interestLevel )
     showProgressEnd ( interestLevel );
 }
 
-void verifyImmediateTearDown ()
+void verifyImmediateTearDown ( const char * pName, unsigned interestLevel )
 {
+    unsigned i;
+    double value;
+    int status;
+    chid chan;
+
+    showProgressBegin ( "verifyImmediateTearDown", interestLevel );
+
+    for ( i = 0u; i < 1000; i++ ) {
+        ca_task_initialize ();
+        status = ca_create_channel ( pName, 0, 0, 0, & chan );
+        SEVCHK ( status, "immediate tear down channel create failed" );
+        status = ca_pend_io ( timeoutToPendIO );
+        SEVCHK ( status, "immediate tear down channel connect failed" );
+        assert ( status == ECA_NORMAL );
+        value = i;
+        status = ca_put ( DBR_DOUBLE, chan, & value );
+        SEVCHK ( status, "immediate tear down channel put failed" );
+        ca_task_exit ();
+        if ( i % 100 == 0 ) {
+            showProgress ( interestLevel );
+        }
+    }
+
+    /* 
+     * verify that puts pending when we call ca_task_exit() 
+     * get flushed out
+     */
     ca_task_initialize ();
+    status = ca_create_channel ( pName, 0, 0, 0, & chan );
+    SEVCHK ( status, "immediate tear down channel create failed" );
+    status = ca_pend_io ( timeoutToPendIO );
+    SEVCHK ( status, "immediate tear down channel connect failed" );
+    assert ( status == ECA_NORMAL );
+    status = ca_get ( DBR_DOUBLE, chan, & value );
+    SEVCHK ( status, "immediate tear down channel get failed" );
+    status = ca_pend_io ( timeoutToPendIO );
+    SEVCHK ( status, "immediate tear down channel get failed" );
+    assert ( value == i - 1u );
     ca_task_exit ();
+
+    showProgressEnd ( interestLevel );
 }
 
 /*
@@ -2592,7 +2631,7 @@ int acctst ( char *pName, unsigned interestLevel, unsigned channelCount,
         epicsEnvSet ( "EPICS_CA_MAX_ARRAY_BYTES", tmpString ); 
     }
 
-    verifyImmediateTearDown ();
+    verifyImmediateTearDown ( pName, interestLevel );
 
 	status = ca_context_create ( select );
     SEVCHK ( status, NULL );