dn724/dncurrency
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages 1 Wiki Activity Actions

Bandwidth limiter container info

Browse source
This commit is contained in:
Piotr Wójcik 2024-11-11 19:40:17 +01:00
commit e902b69884
3 changed files with 11 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

8
nano/node/bandwidth_limiter.cpp
View file

@ -41,6 +41,14 @@ void nano::bandwidth_limiter::reset (std::size_t limit, double burst_ratio, nano
limiter.reset (limit, burst_ratio); limiter.reset (limit, burst_ratio);
} }
nano::container_info nano::bandwidth_limiter::container_info () const
{
nano::container_info info;
info.put ("generic", limiter_generic.size ());
info.put ("bootstrap", limiter_bootstrap.size ());
return info;
}
/* /*
* bandwidth_limiter_config * bandwidth_limiter_config
*/ */

2
nano/node/bandwidth_limiter.hpp
View file

@ -37,6 +37,8 @@ public:
*/ */
void reset (std::size_t limit, double burst_ratio, nano::transport::traffic_type type = nano::transport::traffic_type::generic); void reset (std::size_t limit, double burst_ratio, nano::transport::traffic_type type = nano::transport::traffic_type::generic);
nano::container_info container_info () const;
private: private:
/** /**
* Returns reference to limiter corresponding to the limit type * Returns reference to limiter corresponding to the limit type

1
nano/node/node.cpp
View file

@ -1217,6 +1217,7 @@ nano::container_info nano::node::container_info () const
info.add ("local_block_broadcaster", local_block_broadcaster.container_info ()); info.add ("local_block_broadcaster", local_block_broadcaster.container_info ());
info.add ("rep_tiers", rep_tiers.container_info ()); info.add ("rep_tiers", rep_tiers.container_info ());
info.add ("message_processor", message_processor.container_info ()); info.add ("message_processor", message_processor.container_info ());
info.add ("bandwidth", outbound_limiter.container_info ());
return info; return info;
} }