From ff5ca5e04100bb6cdfbcbc90c83b50005ecae661 Mon Sep 17 00:00:00 2001 From: Jeff Hill Date: Wed, 5 Aug 2009 23:56:26 +0000 Subject: [PATCH] added ioIsPending func --- src/cas/generic/casCoreClient.h | 7 +++++++ src/cas/generic/casPVI.h | 6 ++++++ 2 files changed, 13 insertions(+) diff --git a/src/cas/generic/casCoreClient.h b/src/cas/generic/casCoreClient.h index 407122389..cf655705b 100644 --- a/src/cas/generic/casCoreClient.h +++ b/src/cas/generic/casCoreClient.h @@ -135,6 +135,8 @@ protected: casCtx ctx; bool userStartedAsyncIO; + bool ioIsPending () const; + private: // for io that does not have a channel tsDLList < casAsyncIOI > ioList; @@ -247,5 +249,10 @@ inline void casCoreClient::casMonEventDestroy ( this->eventSys.casMonEventDestroy ( ev, guard ); } +inline bool casCoreClient :: ioIsPending () const +{ + return this->ioList.count () > 0u; +} + #endif // casCoreClienth diff --git a/src/cas/generic/casPVI.h b/src/cas/generic/casPVI.h index 4ea22c463..5328eec1e 100644 --- a/src/cas/generic/casPVI.h +++ b/src/cas/generic/casPVI.h @@ -51,6 +51,7 @@ public: caServerI * getPCAS () const; caStatus attachToServer ( caServerI & cas ); aitIndex nativeCount (); + bool ioIsPending () const; void clearOutstandingReads ( tsDLList < class casAsyncIOI > &); void destroyAllIO ( tsDLList < casAsyncIOI > & ); @@ -113,5 +114,10 @@ inline casPV * casPVI::apiPointer () return this->pPV; } +inline bool casPVI :: ioIsPending () const +{ + return this->nIOAttached > 0u; +} + #endif // casPVIh