YangWX/MQTTnet
1
0
Fork 0
mirror of https://github.com/dotnet/MQTTnet.git synced 2026-10-20 19:58:57 +08:00
Code Issues Packages Projects Releases Wiki Activity

Extend server client ResetStatistics() to reset all client statistics not only channel... (#1587)

Browse Source 
Extend reset client statistic to reset all stats
This commit is contained in:
Dalibor Kundrat
2022-11-26 14:47:17 +01:00
committed by GitHub
parent 581a024ceb
commit b5952a590a
2 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Source/MQTTnet/Server/Internal/MqttClient.cs
+1
View File
@@ -83,6 +83,7 @@ namespace MQTTnet.Server
public void ResetStatistics() public void ResetStatistics()
{ {
ChannelAdapter.ResetStatistics(); ChannelAdapter.ResetStatistics();
Statistics.ResetStatistics();
} }
public async Task RunAsync() public async Task RunAsync()
Source/MQTTnet/Server/Internal/MqttClientStatistics.cs
+7 -1
View File
@@ -73,7 +73,13 @@ namespace MQTTnet.Server
LastNonKeepAlivePacketReceivedTimestamp = LastPacketReceivedTimestamp; LastNonKeepAlivePacketReceivedTimestamp = LastPacketReceivedTimestamp;
} }
} }
public void ResetStatistics(){
Interlocked.Exchange(ref _sentApplicationMessagesCount,0);
Interlocked.Exchange(ref _receivedApplicationMessagesCount,0);
Interlocked.Exchange(ref _sentPacketsCount,0);
Interlocked.Exchange(ref _receivedPacketsCount,0);
}
public void HandleSentPacket(MqttPacket packet) public void HandleSentPacket(MqttPacket packet)
{ {
if (packet == null) if (packet == null)