blob: d5e89b96d636db857e32b3e01bebf03869234d34 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
|
/*
* Copyright (c) 2017-2019 Cisco and/or its affiliates.
* Licensed 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.
*/
#pragma once
#include <hicn/transport/portability/c_portability.h>
#include <cstdint>
namespace transport {
namespace protocol {
class TransportStatistics {
static constexpr double default_alpha = 0.7;
public:
TransportStatistics(double alpha = default_alpha)
: retx_count_(0),
bytes_received_(0),
average_rtt_(0),
avg_window_size_(0),
interest_tx_(0),
alpha_(alpha),
loss_ratio_(0.0),
queuing_delay_(0.0) {}
TRANSPORT_ALWAYS_INLINE void updateRetxCount(uint64_t retx) {
retx_count_ += retx;
}
TRANSPORT_ALWAYS_INLINE void updateBytesRecv(uint64_t bytes) {
bytes_received_ += bytes;
}
TRANSPORT_ALWAYS_INLINE void updateAverageRtt(uint64_t rtt) {
average_rtt_ = (alpha_ * average_rtt_) + ((1. - alpha_) * double(rtt));
}
TRANSPORT_ALWAYS_INLINE void updateAverageWindowSize(double current_window) {
avg_window_size_ =
(alpha_ * avg_window_size_) + ((1. - alpha_) * current_window);
}
TRANSPORT_ALWAYS_INLINE void updateInterestTx(uint64_t int_tx) {
interest_tx_ += int_tx;
}
TRANSPORT_ALWAYS_INLINE void updateLossRatio(double loss_ratio) {
loss_ratio_ = loss_ratio;
}
TRANSPORT_ALWAYS_INLINE void updateQueuingDelay(double queuing_delay) {
queuing_delay_ = queuing_delay;
}
TRANSPORT_ALWAYS_INLINE uint64_t getRetxCount() const { return retx_count_; }
TRANSPORT_ALWAYS_INLINE uint64_t getBytesRecv() const {
return bytes_received_;
}
TRANSPORT_ALWAYS_INLINE double getAverageRtt() const { return average_rtt_; }
TRANSPORT_ALWAYS_INLINE double getAverageWindowSize() const {
return avg_window_size_;
}
TRANSPORT_ALWAYS_INLINE uint64_t getInterestTx() const {
return interest_tx_;
}
TRANSPORT_ALWAYS_INLINE double getLossRatio() const {
return loss_ratio_;
}
TRANSPORT_ALWAYS_INLINE double getQueuingDelay() const {
return queuing_delay_;
}
TRANSPORT_ALWAYS_INLINE void reset() {
retx_count_ = 0;
bytes_received_ = 0;
average_rtt_ = 0;
avg_window_size_ = 0;
interest_tx_ = 0;
loss_ratio_ = 0;
}
private:
uint64_t retx_count_;
uint64_t bytes_received_;
double average_rtt_;
double avg_window_size_;
uint64_t interest_tx_;
double alpha_;
double loss_ratio_;
double queuing_delay_;
};
} // end namespace protocol
} // end namespace transport
|
