Add instrumentation to root, add capability to forward to siblings if no path is known to a peer.

node/Meter.hpp

@@ -0,0 +1,89 @@
+/*
+ * Copyright (c)2019 ZeroTier, Inc.
+ *
+ * Use of this software is governed by the Business Source License included
+ * in the LICENSE.TXT file in the project's root directory.
+ *
+ * Change Date: 2023-01-01
+ *
+ * On the date above, in accordance with the Business Source License, use
+ * of this software will be governed by version 2.0 of the Apache License.
+ */
+/****/
+
+#ifndef ZT_METER_HPP
+#define ZT_METER_HPP
+
+#include "Constants.hpp"
+#include "Mutex.hpp"
+
+#define ZT_METER_HISTORY_LENGTH 4
+#define ZT_METER_HISTORY_TICK_DURATION 1000
+
+namespace ZeroTier {
+
+/**
+ * Transfer rate meter (thread-safe)
+ */
+class Meter
+{
+public:
+	ZT_ALWAYS_INLINE Meter()
+	{
+		for(int i=0;i<ZT_METER_HISTORY_LENGTH;++i)
+			_history[i] = 0.0;
+		_ts = 0;
+		_count = 0;
+	}
+	ZT_ALWAYS_INLINE Meter(const Meter &m) { *this = m; }
+
+	ZT_ALWAYS_INLINE Meter &operator=(const Meter &m)
+	{
+		m._lock.lock();
+		for(int i=0;i<ZT_METER_HISTORY_LENGTH;++i)
+			_history[i] = m._history[i];
+		_ts = m._ts;
+		_count = m._count;
+		m._lock.unlock();
+		return *this;
+	}
+
+	template<typename I>
+	ZT_ALWAYS_INLINE void log(const int64_t now,I count)
+	{
+		_lock.lock();
+		const int64_t since = now - _ts;
+		if (since >= 1000) {
+			_ts = now;
+			for(int i=1;i<ZT_METER_HISTORY_LENGTH;++i)
+				_history[i-1] = _history[i];
+			_history[ZT_METER_HISTORY_LENGTH-1] = (double)_count / ((double)since / 1000.0);
+			_count = 0;
+		}
+		_count += (unsigned long)count;
+		_lock.unlock();
+	}
+
+	ZT_ALWAYS_INLINE double perSecond(const int64_t now) const
+	{
+		_lock.lock();
+		int64_t since = (now - _ts);
+		if (since <= 0) since = 1;
+		double r = (double)_count / ((double)since / 1000.0);
+		for(int i=0;i<ZT_METER_HISTORY_LENGTH;++i)
+			r += _history[i];
+		r /= (double)(ZT_METER_HISTORY_LENGTH + 1);
+		_lock.unlock();
+		return r;
+	}
+
+private:
+	double _history[ZT_METER_HISTORY_LENGTH];
+	int64_t _ts;
+	unsigned long _count;
+	Mutex _lock;
+};
+
+} // namespace ZeroTier
+
+#endif