lokinet/llarp/peerstats/types.cpp

#include <peerstats/types.hpp>

namespace llarp
{
  PeerStats::PeerStats() = default;

  PeerStats::PeerStats(const RouterID& routerId_) : routerId(routerId_)
  {
  }

  PeerStats&
  PeerStats::operator+=(const PeerStats& other)
  {
    numConnectionAttempts += other.numConnectionAttempts;
    numConnectionSuccesses += other.numConnectionSuccesses;
    numConnectionRejections += other.numConnectionRejections;
    numConnectionTimeouts += other.numConnectionTimeouts;

    numPathBuilds += other.numPathBuilds;
    numPacketsAttempted += other.numPacketsAttempted;
    numPacketsSent += other.numPacketsSent;
    numPacketsDropped += other.numPacketsDropped;
    numPacketsResent += other.numPacketsResent;

    numDistinctRCsReceived += other.numDistinctRCsReceived;
    numLateRCs += other.numLateRCs;

    peakBandwidthBytesPerSec = std::max(peakBandwidthBytesPerSec, other.peakBandwidthBytesPerSec);
    longestRCReceiveInterval = std::max(longestRCReceiveInterval, other.longestRCReceiveInterval);
    leastRCRemainingLifetime = std::max(leastRCRemainingLifetime, other.leastRCRemainingLifetime);
    lastRCUpdated = std::max(lastRCUpdated, other.lastRCUpdated);

    return *this;
  }

  bool
  PeerStats::operator==(const PeerStats& other)
  {
    return routerId == other.routerId and numConnectionAttempts == other.numConnectionAttempts
        and numConnectionSuccesses == other.numConnectionSuccesses
        and numConnectionRejections == other.numConnectionRejections
        and numConnectionTimeouts == other.numConnectionTimeouts

        and numPathBuilds == other.numPathBuilds
        and numPacketsAttempted == other.numPacketsAttempted
        and numPacketsSent == other.numPacketsSent and numPacketsDropped == other.numPacketsDropped
        and numPacketsResent == other.numPacketsResent

        and numDistinctRCsReceived == other.numDistinctRCsReceived
        and numLateRCs == other.numLateRCs

        and peakBandwidthBytesPerSec == other.peakBandwidthBytesPerSec
        and longestRCReceiveInterval == other.longestRCReceiveInterval
        and leastRCRemainingLifetime == other.leastRCRemainingLifetime
        and lastRCUpdated == other.lastRCUpdated;
  }

  util::StatusObject
  PeerStats::toJson() const
  {
    return {
        {"routerId", routerId.ToString()},
        // {"numConnectionAttempts", numConnectionAttempts},
        // {"numConnectionSuccesses", numConnectionSuccesses},
        // {"numConnectionRejections", numConnectionRejections},
        // {"numConnectionTimeouts", numConnectionTimeouts},
        // {"numPathBuilds", numPathBuilds},
        // {"numPacketsAttempted", numPacketsAttempted},
        // {"numPacketsSent", numPacketsSent},
        // {"numPacketsDropped", numPacketsDropped},
        // {"numPacketsResent", numPacketsResent},
        {"numDistinctRCsReceived", numDistinctRCsReceived},
        {"numLateRCs", numLateRCs},
        // {"peakBandwidthBytesPerSec", peakBandwidthBytesPerSec},
        {"longestRCReceiveInterval", longestRCReceiveInterval.count()},
        {"leastRCRemainingLifetime", leastRCRemainingLifetime.count()},
        {"lastRCUpdated", lastRCUpdated.count()},
    };
  }

};  // namespace llarp