Removed LatencyTracker from cluster.

Turned out not to be very useful. Better to use profiling tools like systemtap.


git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@820796 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 0 insertions, 157 deletions

diff --git a/cpp/src/qpid/sys/LatencyTracker.h b/cpp/src/qpid/sys/LatencyTracker.h
deleted file mode 100644
index 3294528ff6..0000000000
--- a/cpp/src/qpid/sys/LatencyTracker.h
+++ /dev/null
@@ -1,157 +0,0 @@
-#ifndef QPID_SYS_LATENCYTRACKER_H
-#define QPID_SYS_LATENCYTRACKER_H
-
-/*
- *
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements.  See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership.  The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License.  You may obtain a copy of the License at
- * 
- *   http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied.  See the License for the
- * specific language governing permissions and limitations
- * under the License.
- *
- */
-
-#include "qpid/sys/Time.h"
-#include <string>
-#include <limits>
-#include <map>
-
-namespace qpid {
-namespace sys {
-
-/**@file Tools for measuring latency. NOT SUITABLE FOR PROUDCTION BUILDS.
- * Uses should be compiled only if QPID_LATENCY_TRACKER is defined.
- * See the convenience macros at the end of this file.
- */
-
-/** Used by LatencyCounter and LatencyTracker below */
-class LatencyStatistic {
-  public:
-    LatencyStatistic(std::string name_) : name(name_), count(0), total(0), min(std::numeric_limits<int64_t>::max()), max(0) {}
-    ~LatencyStatistic() { print(); }
-
-    void record(Duration d) {
-        total += d;
-        ++count;
-        if (d > max) max=d;
-        if (d < min) min=d;
-    }
-    
-    void print() {
-        if (count) {
-            double meanMsec =  (double(total)/count)/TIME_MSEC;
-            printf("\n==== Latency metric %s: samples=%lu mean=%fms (%f-%f)\n", name.c_str(), count, meanMsec, double(min)/TIME_MSEC, double(max)/TIME_MSEC);
-        }
-        else 
-            printf("\n==== Latency metric %s: no samples.\n", name.c_str());
-    }
-
-  private:
-    std::string name;
-    unsigned long count;
-    int64_t total, min, max;
-};
-    
-/** Measure delay between seeing the same value at start and finish. */
-template <class T> class LatencyTracker {
-  public:
-    LatencyTracker(std::string name) : measuring(false), stat(name) {}
-
-    void start(T value) {
-        sys::Mutex::ScopedLock l(lock);
-        if (!measuring) {
-            measureAt = value;
-            measuring = true;
-            startTime = AbsTime::now();
-        }
-    }
-    
-    void finish(T value) {
-        sys::Mutex::ScopedLock l(lock);
-        if(measuring && measureAt == value) {
-            stat.record(Duration(startTime, AbsTime::now()));
-            measuring = false;
-        }
-    }
-
-  private:
-    sys::Mutex lock;
-    bool measuring;
-    T measureAt;
-    AbsTime startTime;
-    LatencyStatistic stat;
-};
-
-
-/** Measures delay between the nth call to start and the nth call to finish.
- * E.g. to measure latency between sending & receiving an ordered stream of messages.
- */
-class LatencyCounter {
-  public:
-    LatencyCounter(std::string name) : measuring(false), startCount(0), finishCount(0), stat(name) {}
-
-    void start() {
-        sys::Mutex::ScopedLock l(lock);
-        if (!measuring) {
-            measureAt = startCount;
-            measuring = true;
-            startTime = AbsTime::now();
-        }
-        ++startCount;
-    }
-
-    void finish() {
-        sys::Mutex::ScopedLock l(lock);
-        if (measuring && measureAt == finishCount) {
-            stat.record(Duration(startTime, AbsTime::now()));
-            measuring = false;
-        }
-        ++finishCount;
-    }
-
-  private:
-    sys::Mutex lock;
-    bool measuring;
-    uint64_t startCount, finishCount, measureAt;
-    AbsTime startTime;
-    LatencyStatistic stat;
-};
-
-/** Measures time spent in a scope. */
-class LatencyScope {
-  public:
-    LatencyScope(LatencyStatistic& s) : stat(s), startTime(AbsTime::now()) {}
-
-    ~LatencyScope() { 
-        sys::Mutex::ScopedLock l(lock);
-        stat.record(Duration(startTime, AbsTime::now()));
-    }
-
-  private:
-    sys::Mutex lock;
-    LatencyStatistic& stat;
-    AbsTime startTime;
-};
-
-    
-/** Macros to wrap latency tracking so disabled unless QPID_LATENCY_TRACKER is defined */
-
-#if defined(QPID_LATENCY_TRACKER)
-#define LATENCY_TRACK(X) X
-#else
-#define LATENCY_TRACK(X)
-#endif
-}} // namespace qpid::sys
-
-#endif  /*!QPID_SYS_LATENCYTRACKER_H*/