epics/pcas
0
0
Fork 0
Code Issues Pull Requests Projects Wiki Activity

initialize the beacon sequence number

Browse Source
This commit is contained in:
Jeff Hill
2002-08-09 16:52:39 +00:00
parent 732f5f33e5
commit 62b8f02fef
2 changed files with 21 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files

41
src/ca/bhe.cpp
View File

@@ -56,9 +56,10 @@ void bhe::operator delete ( void *pCadaver, size_t size )
* zero (so we can correctly compute the period
* between the 1st and 2nd beacons)
*/
bhe::bhe ( const epicsTime & initialTimeStamp, const inetAddrID & addr ) :
bhe::bhe ( const epicsTime & initialTimeStamp,
unsigned initialBeaconNumber, const inetAddrID & addr ) :
inetAddrID ( addr ), timeStamp ( initialTimeStamp ), averagePeriod ( - DBL_MAX ),
lastBeaconNumber ( UINT_MAX )
lastBeaconNumber ( initialBeaconNumber )
{
# ifdef DEBUG
{
@@ -91,8 +92,12 @@ bool bhe::updatePeriod ( const epicsTime & programBeginTime,
const epicsTime & currentTime, unsigned beaconNumber,
unsigned protocolRevision )
{
//
// this block is enetered if the beacon was created as a side effect of
// creating a connection and so we dont yet know the first beacon time
// and sequence number
//
if ( this->timeStamp == epicsTime () ) {
if ( CA_V410 ( protocolRevision ) ) {
this->lastBeaconNumber = beaconNumber;
}
@@ -119,9 +124,7 @@ bool bhe::updatePeriod ( const epicsTime & programBeginTime,
}
}
/*
* compute the beacon period (if we have seen at least two beacons)
*/
// compute the beacon period (if we have seen at least two beacons)
bool netChange = false;
double currentPeriod = currentTime - this->timeStamp;
if ( this->averagePeriod < 0.0 ) {
@@ -191,10 +194,8 @@ bool bhe::updatePeriod ( const epicsTime & programBeginTime,
netChange = true;
}
else {
/*
* update state of health for active virtual circuits
* if the beacon looks ok
*/
// update state of health for active virtual circuits
// if the beacon looks ok
tsDLIter < tcpiiu > iter = this->iiuList.firstIter ();
while ( iter.valid() ) {
iter->beaconArrivalNotify ();
@@ -202,20 +203,11 @@ bool bhe::updatePeriod ( const epicsTime & programBeginTime,
}
}
/*
* update a running average period
*/
this->averagePeriod = currentPeriod * 0.125 + this->averagePeriod * 0.875;
// update a running average period
this->averagePeriod = currentPeriod * 0.125 +
this->averagePeriod * 0.875;
}
//{
// char name[64];
// this->name ( name, sizeof ( name ) );
//
// printf ( "new beacon period %f for %s\n",
// this->averagePeriod, name );
//}
this->timeStamp = currentTime;
return netChange;
@@ -237,6 +229,11 @@ double bhe::period () const
return this->averagePeriod;
}
epicsTime bhe::updateTime () const
{
return this->timeStamp;
}
void bhe::registerIIU ( tcpiiu & iiu )
{
this->iiuList.add ( iiu );