diff --git a/src/cas/generic/casPVI.cc b/src/cas/generic/casPVI.cc index 6efbc6eb4..17e67b154 100644 --- a/src/cas/generic/casPVI.cc +++ b/src/cas/generic/casPVI.cc @@ -29,6 +29,9 @@ * * History * $Log$ + * Revision 1.10 1998/06/16 02:31:36 jhill + * allow the PV to be created before the server + * * Revision 1.9 1997/08/05 00:47:11 jhill * fixed warnings * @@ -103,14 +106,12 @@ casPVI::~casPVI() // delete any attached channels // tsDLIterBD iter(this->chanList.first()); - const tsDLIterBD eol; - tsDLIterBD tmp; - while (iter!=eol) { + while (iter!=tsDLIterBD::eol()) { // // deleting the channel removes it from the list // - tmp = iter; + tsDLIterBD tmp = iter; ++tmp; (*iter)->destroy(); iter = tmp; diff --git a/src/cas/generic/casPVIIL.h b/src/cas/generic/casPVIIL.h index 110108157..d35d8dec7 100644 --- a/src/cas/generic/casPVIIL.h +++ b/src/cas/generic/casPVIIL.h @@ -29,6 +29,9 @@ * * History * $Log$ + * Revision 1.13 1999/04/30 15:36:26 jhill + * better range check on index to gddAitToDbr + * * Revision 1.12 1998/06/16 02:21:49 jhill * dont require that a server must exist before a PV is created * @@ -240,8 +243,7 @@ inline void casPVI::postEvent (const casEventMask &select, gdd &event) this->lock(); tsDLIterBD iter(this->chanList.first()); - const tsDLIterBD eol; - while ( iter != eol ) { + while ( iter != tsDLIterBD::eol() ) { iter->postEvent(select, event); ++iter; } diff --git a/src/cas/generic/casStrmClient.cc b/src/cas/generic/casStrmClient.cc index c852a2a37..f38179d41 100644 --- a/src/cas/generic/casStrmClient.cc +++ b/src/cas/generic/casStrmClient.cc @@ -29,6 +29,9 @@ * * History * $Log$ + * Revision 1.29 1999/05/07 23:07:11 jhill + * throw warning exception with get/put callback failure detail + * * Revision 1.28 1999/04/30 15:46:54 jhill * deal with situation where bounds on managed DD must be modified * @@ -244,13 +247,11 @@ casStrmClient::~casStrmClient() // delete all channel attached // tsDLIterBD iter(this->chanList.first()); - const tsDLIterBD eol; - tsDLIterBD tmp; - while (iter!=eol) { + while (iter!=tsDLIterBD::eol()) { // // destroying the channel removes it from the list // - tmp = iter; + tsDLIterBD tmp = iter; ++tmp; iter->clientDestroy(); iter = tmp; @@ -948,8 +949,7 @@ caStatus casStrmClient::hostNameAction() this->pHostName = pMalloc; tsDLIterBD iter(this->chanList.first()); - const tsDLIterBD eol; - while ( iter!=eol ) { + while ( iter!=tsDLIterBD::eol() ) { (*iter)->setOwner(this->pUserName, this->pHostName); ++iter; } @@ -998,8 +998,7 @@ caStatus casStrmClient::clientNameAction() this->pUserName = pMalloc; tsDLIterBD iter(this->chanList.first()); - const tsDLIterBD eol; - while ( iter!=eol ) { + while ( iter!=tsDLIterBD::eol() ) { (*iter)->setOwner(this->pUserName, this->pHostName); ++iter; } @@ -1609,8 +1608,7 @@ caStatus casStrmClient::readSyncAction() // this->osiLock(); tsDLIterBD iter(this->chanList.first()); - const tsDLIterBD eol; - while ( iter!=eol ) { + while ( iter!=tsDLIterBD::eol() ) { iter->clearOutstandingReads(); ++iter; } @@ -2132,7 +2130,7 @@ inline aitBool caServerI::roomForNewChannel() const void casStrmClient::installChannel(casChannelI &chan) { this->osiLock(); - this->getCAS().installItem(chan); + this->getCAS().installItem (chan); this->chanList.add(chan); this->osiUnlock(); } @@ -2170,7 +2168,7 @@ xSendStatus casStrmClient::xSend(char *pBufIn, bufSizeT nBytesAvailableToSend, stat = this->osdSend(pBufIn, nBytesAvailableToSend, nActualBytes); if (stat == xSendOK) { - this->elapsedAtLastSend = osiTime::getCurrent(); + this->lastSendTS = osiTime::getCurrent(); } return stat; } @@ -2186,7 +2184,7 @@ xSendStatus casStrmClient::xSend(char *pBufIn, bufSizeT nBytesAvailableToSend, // // !! this time fetch may be slowing things down !! // - this->elapsedAtLastSend = osiTime::getCurrent(); + this->lastSendTS = osiTime::getCurrent(); nActualBytes += nActualBytesDelta; if (nBytesNeedToBeSent <= nActualBytesDelta) { @@ -2211,7 +2209,7 @@ xRecvStatus casStrmClient::xRecv(char *pBufIn, bufSizeT nBytes, // // !! this time fetch may be slowing things down !! // - this->elapsedAtLastRecv = osiTime::getCurrent(); + this->lastRecvTS = osiTime::getCurrent(); } return stat; }