diff options
Diffstat (limited to 'cpp/test/Ice/retry/InstrumentationI.cpp')
-rw-r--r-- | cpp/test/Ice/retry/InstrumentationI.cpp | 47 |
1 files changed, 27 insertions, 20 deletions
diff --git a/cpp/test/Ice/retry/InstrumentationI.cpp b/cpp/test/Ice/retry/InstrumentationI.cpp index 1a156e93fea..f5e4e9c8591 100644 --- a/cpp/test/Ice/retry/InstrumentationI.cpp +++ b/cpp/test/Ice/retry/InstrumentationI.cpp @@ -13,7 +13,7 @@ namespace { -int nRetry = 0; +int nRetry = 0; int nFailure = 0; int nInvocation = 0; IceUtil::Mutex* staticMutex = 0; @@ -39,44 +39,44 @@ class InvocationObserverI : public Ice::Instrumentation::InvocationObserver { public: - virtual void + virtual void attach() { } - virtual void + virtual void detach() { IceUtilInternal::MutexPtrLock<IceUtil::Mutex> lock(staticMutex); ++nInvocation; } - virtual void + virtual void failed(const ::std::string&) { IceUtilInternal::MutexPtrLock<IceUtil::Mutex> lock(staticMutex); ++nFailure; } - virtual void + virtual void retried() { IceUtilInternal::MutexPtrLock<IceUtil::Mutex> lock(staticMutex); ++nRetry; } - virtual void + virtual void userException() { } - virtual ::Ice::Instrumentation::RemoteObserverPtr + virtual ::Ice::Instrumentation::RemoteObserverPtr getRemoteObserver(const ::Ice::ConnectionInfoPtr&, const ::Ice::EndpointPtr&, ::Ice::Int, ::Ice::Int) { return 0; } - virtual ::Ice::Instrumentation::CollocatedObserverPtr + virtual ::Ice::Instrumentation::CollocatedObserverPtr getCollocatedObserver(const Ice::ObjectAdapterPtr&, ::Ice::Int, ::Ice::Int) { return 0; @@ -90,49 +90,49 @@ class CommunicatorObserverI : public Ice::Instrumentation::CommunicatorObserver { public: - virtual Ice::Instrumentation::ObserverPtr + virtual Ice::Instrumentation::ObserverPtr getConnectionEstablishmentObserver(const Ice::EndpointPtr&, const ::std::string&) { return 0; } - virtual Ice::Instrumentation::ObserverPtr + virtual Ice::Instrumentation::ObserverPtr getEndpointLookupObserver(const Ice::EndpointPtr&) { return 0; } - virtual Ice::Instrumentation::ConnectionObserverPtr - getConnectionObserver(const Ice::ConnectionInfoPtr&, - const Ice::EndpointPtr&, + virtual Ice::Instrumentation::ConnectionObserverPtr + getConnectionObserver(const Ice::ConnectionInfoPtr&, + const Ice::EndpointPtr&, Ice::Instrumentation::ConnectionState, const Ice::Instrumentation::ConnectionObserverPtr&) { return 0; } - virtual Ice::Instrumentation::ThreadObserverPtr - getThreadObserver(const ::std::string&, - const ::std::string&, - Ice::Instrumentation::ThreadState, + virtual Ice::Instrumentation::ThreadObserverPtr + getThreadObserver(const ::std::string&, + const ::std::string&, + Ice::Instrumentation::ThreadState, const Ice::Instrumentation::ThreadObserverPtr&) { return 0; } - virtual Ice::Instrumentation::InvocationObserverPtr + virtual Ice::Instrumentation::InvocationObserverPtr getInvocationObserver(const Ice::ObjectPrx&, const ::std::string&, const Ice::Context&) { return invocationObserver; } - virtual Ice::Instrumentation::DispatchObserverPtr + virtual Ice::Instrumentation::DispatchObserverPtr getDispatchObserver(const Ice::Current&, Ice::Int) { return 0; } - virtual void + virtual void setObserverUpdater(const Ice::Instrumentation::ObserverUpdaterPtr&) { } @@ -171,6 +171,13 @@ testEqual(int& value, int expected) } +void initCounts() +{ + nRetry = 0; + nFailure = 0; + nInvocation = 0; +} + Ice::Instrumentation::CommunicatorObserverPtr getObserver() { |