added ioIsPending func
This commit is contained in:
@@ -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
|
||||
|
||||
|
||||
@@ -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
|
||||
|
||||
|
||||
Reference in New Issue
Block a user