diff --git a/MAC/GCF/PVSS/include/GCF/PVSS/PVSSservice.h b/MAC/GCF/PVSS/include/GCF/PVSS/PVSSservice.h index 45a6e8918312a2f5eb6384366429be13e5b73a5a..d612d7563af214ac415c50bcbe560b7c6d9d1e6e 100644 --- a/MAC/GCF/PVSS/include/GCF/PVSS/PVSSservice.h +++ b/MAC/GCF/PVSS/include/GCF/PVSS/PVSSservice.h @@ -66,6 +66,8 @@ public: PVSSresult dpQuerySubscribeSingle(const string& queryWhere, const string& queryFrom); PVSSresult dpQueryUnsubscribe (uint32 queryId); + + void doWork(); private: // methods diff --git a/MAC/GCF/PVSS/src/PVSSservice.cc b/MAC/GCF/PVSS/src/PVSSservice.cc index 7346225805b2f756b420d442abdb6de8a415dfcd..72cec0f4d43452f05948136c55987ccb6cc03c94 100644 --- a/MAC/GCF/PVSS/src/PVSSservice.cc +++ b/MAC/GCF/PVSS/src/PVSSservice.cc @@ -397,6 +397,16 @@ void PVSSservice::convAndForwardValueChange(const DpIdentifier& dpId, const Vari } } +// +// doWork() +// +void PVSSservice::doWork() +{ + ASSERT(itsSCADAHandler); + itsSCADAHandler->workProc(); +} + + // // dpCreate(dpname, typename) // diff --git a/MAC/GCF/PVSS/test/tPerformance.cc b/MAC/GCF/PVSS/test/tPerformance.cc index f520023b36341f253a74510c36b435c89e608096..3a8ac408193319169d62acb145d385461b6961ac 100644 --- a/MAC/GCF/PVSS/test/tPerformance.cc +++ b/MAC/GCF/PVSS/test/tPerformance.cc @@ -304,7 +304,7 @@ GCFEvent::TResult tPerformance::test1getvalue(GCFEvent& e, GCFPortInterface& p) case F_TIMER: if (gGetCounter != 0) { - itsTimerPort->setTimer(0.1); + itsTimerPort->setTimer(0.022); LOG_INFO_STR ("Waiting for " << gGetCounter << " datapoints to be read"); } else {