new timer creation API

This commit is contained in:
Jeff Hill
2001-06-12 17:22:27 +00:00
parent 4444b74a58
commit bbb3b9a432
8 changed files with 13 additions and 15 deletions
+2 -2
View File
@@ -56,7 +56,7 @@ caStatus exAsyncPV::write ( const casCtx &ctx, const gdd &valueIn )
exAsyncWriteIO::exAsyncWriteIO ( const casCtx &ctxIn, exAsyncPV &pvIn,
const gdd &valueIn ) :
casAsyncWriteIO ( ctxIn ), pv ( pvIn ),
timer ( pvIn.getCAS()->timerQueue().createTimer () ), pValue(valueIn)
timer ( pvIn.getCAS()->createTimer () ), pValue(valueIn)
{
this->timer.start ( *this, 0.1 );
}
@@ -88,7 +88,7 @@ epicsTimerNotify::expireStatus exAsyncWriteIO::expire ( const epicsTime & curren
exAsyncReadIO::exAsyncReadIO ( const casCtx &ctxIn, exAsyncPV &pvIn,
gdd &protoIn ) :
casAsyncReadIO ( ctxIn ), pv ( pvIn ),
timer ( pvIn.getCAS()->timerQueue().createTimer() ), pProto ( protoIn )
timer ( pvIn.getCAS()->createTimer() ), pProto ( protoIn )
{
this->timer.start ( *this, 0.1 );
}
+1 -1
View File
@@ -22,7 +22,7 @@ class exFixedStringDestructor: public gddDestructor {
// exPV::exPV()
//
exPV::exPV ( pvInfo &setup, bool preCreateFlag, bool scanOnIn ) :
timer ( this->getCAS()->timerQueue().createTimer() ),
timer ( this->getCAS()->createTimer() ),
info ( setup ),
interest ( false ),
preCreate ( preCreateFlag ),
+2 -2
View File
@@ -318,7 +318,7 @@ void exServer::show (unsigned level) const
exAsyncExistIO::exAsyncExistIO ( const pvInfo &pviIn, const casCtx &ctxIn,
exServer &casIn ) :
casAsyncPVExistIO ( ctxIn ), pvi ( pviIn ),
timer ( casIn.timerQueue().createTimer () ), cas ( casIn )
timer ( casIn.createTimer () ), cas ( casIn )
{
this->timer.start ( *this, 0.00001 );
}
@@ -352,7 +352,7 @@ epicsTimerNotify::expireStatus exAsyncExistIO::expire ( const epicsTime & curren
exAsyncCreateIO::exAsyncCreateIO ( pvInfo &pviIn, exServer &casIn,
const casCtx &ctxIn, bool scanOnIn ) :
casAsyncPVAttachIO ( ctxIn ), pvi ( pviIn ),
timer ( casIn.timerQueue().createTimer () ),
timer ( casIn.createTimer () ),
cas ( casIn ), scanOn ( scanOnIn )
{
this->timer.start ( *this, 0.00001 );
+2 -4
View File
@@ -208,11 +208,9 @@ epicsShareFunc casEventMask caServer::alarmEventMask () const
//
// caServer::alarmEventMask ()
//
// for now, this assumes that everything is single threaded
//
class epicsTimerQueue & caServer::timerQueue()
class epicsTimer & caServer::createTimer()
{
return fileDescriptorManager.timerQueueRef();
return fileDescriptorManager.createTimer();
}
//
+1 -1
View File
@@ -373,7 +373,7 @@ public:
epicsShareFunc void clearEventsPostedCounter (void);
#endif
epicsShareFunc class epicsTimerQueue & timerQueue ();
epicsShareFunc class epicsTimer & createTimer ();
//caStatus enableClients ();
//caStatus disableClients ();
+1 -1
View File
@@ -27,7 +27,7 @@ private:
};
casBeaconTimer::casBeaconTimer ( double delay, caServerOS &osIn ) :
timer ( fileDescriptorManager.timerQueueRef().createTimer() ), os ( osIn )
timer ( fileDescriptorManager.createTimer() ), os ( osIn )
{
this->timer.start ( *this, delay );
}
+2 -2
View File
@@ -130,7 +130,7 @@ casDGIntfOS::~casDGIntfOS()
// casDGEvWakeup::casDGEvWakeup()
//
casDGEvWakeup::casDGEvWakeup ( casDGIntfOS &osIn ) :
timer ( fileDescriptorManager.timerQueueRef().createTimer() ), os ( osIn )
timer ( fileDescriptorManager.createTimer() ), os ( osIn )
{
this->timer.start ( *this, 0.0 );
}
@@ -168,7 +168,7 @@ epicsTimerNotify::expireStatus casDGEvWakeup::expire( const epicsTime & currentT
// casDGIOWakeup::casDGIOWakeup()
//
casDGIOWakeup::casDGIOWakeup ( casDGIntfOS &osIn ) :
timer ( fileDescriptorManager.timerQueueRef().createTimer() ), os ( osIn )
timer ( fileDescriptorManager.createTimer() ), os ( osIn )
{
this->timer.start ( *this, 0.0 );
}
+2 -2
View File
@@ -122,7 +122,7 @@ private:
// casStreamEvWakeup()
//
casStreamEvWakeup::casStreamEvWakeup ( casStreamOS &osIn ) :
timer ( fileDescriptorManager.timerQueueRef().createTimer() ), os(osIn)
timer ( fileDescriptorManager.createTimer() ), os(osIn)
{
this->timer.start ( *this, 0.0 );
}
@@ -191,7 +191,7 @@ private:
// casStreamIOWakeup::casStreamIOWakeup()
//
casStreamIOWakeup::casStreamIOWakeup ( casStreamOS &osIn ) :
timer ( fileDescriptorManager.timerQueueRef().createTimer() ), os(osIn)
timer ( fileDescriptorManager.createTimer() ), os(osIn)
{
this->timer.start ( *this, 0.0 );
}