PurpleI2P/i2pd
1
0
Fork 0
mirror of https://github.com/PurpleI2P/i2pd.git synced 2025-01-08 18:47:52 +00:00
Code Issues Releases Activity

use correct latency computation

Browse Source
This commit is contained in:
Jeff Becker 2016-11-15 11:15:48 -05:00
parent 98a55c0613
commit 69888e148e
2 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
Tunnel.cpp
View File

@ -23,18 +23,23 @@ namespace tunnel
void TunnelLatency::AddSample(Sample s) void TunnelLatency::AddSample(Sample s)
{ {
m_samples ++; std::unique_lock<std::mutex> l(m_access);
m_latency += s / m_samples; m_samples.push_back(s);
} }
bool TunnelLatency::HasSamples() const bool TunnelLatency::HasSamples() const
{ {
return m_samples > 0; std::unique_lock<std::mutex> l(m_access);
return m_samples.size() > 0;
} }
TunnelLatency::Latency TunnelLatency::GetMeanLatency() const TunnelLatency::Latency TunnelLatency::GetMeanLatency() const
{ {
return m_latency; std::unique_lock<std::mutex> l(m_access);
Latency l = 0;
for(auto s : m_samples)
l += s;
return l / m_samples.size();
} }

5
Tunnel.h
View File

@ -90,9 +90,8 @@ namespace tunnel
bool HasSamples() const; bool HasSamples() const;
Latency GetMeanLatency() const; Latency GetMeanLatency() const;
Latency m_latency = 0; std::vector<Sample> m_samples;
std::size_t m_samples = 0; std::mutex m_access;
}; };
class OutboundTunnel; class OutboundTunnel;