| 1530 | "fetch_updated_peer_lists_loop" ); |
| 1531 | } |
| 1532 | void node_impl::update_bandwidth_data(uint32_t bytes_read_this_second, uint32_t bytes_written_this_second) |
| 1533 | { |
| 1534 | VERIFY_CORRECT_THREAD(); |
| 1535 | _average_network_read_speed_seconds.push_back(bytes_read_this_second); |
| 1536 | _average_network_write_speed_seconds.push_back(bytes_written_this_second); |
| 1537 | ++_average_network_usage_second_counter; |
| 1538 | if (_average_network_usage_second_counter >= 60) |
| 1539 | { |
| 1540 | _average_network_usage_second_counter = 0; |
| 1541 | ++_average_network_usage_minute_counter; |
| 1542 | uint32_t average_read_this_minute = (uint32_t)boost::accumulate(_average_network_read_speed_seconds, uint64_t(0)) / (uint32_t)_average_network_read_speed_seconds.size(); |
| 1543 | _average_network_read_speed_minutes.push_back(average_read_this_minute); |
| 1544 | uint32_t average_written_this_minute = (uint32_t)boost::accumulate(_average_network_write_speed_seconds, uint64_t(0)) / (uint32_t)_average_network_write_speed_seconds.size(); |
| 1545 | _average_network_write_speed_minutes.push_back(average_written_this_minute); |
| 1546 | if (_average_network_usage_minute_counter >= 60) |
| 1547 | { |
| 1548 | _average_network_usage_minute_counter = 0; |
| 1549 | uint32_t average_read_this_hour = (uint32_t)boost::accumulate(_average_network_read_speed_minutes, uint64_t(0)) / (uint32_t)_average_network_read_speed_minutes.size(); |
| 1550 | _average_network_read_speed_hours.push_back(average_read_this_hour); |
| 1551 | uint32_t average_written_this_hour = (uint32_t)boost::accumulate(_average_network_write_speed_minutes, uint64_t(0)) / (uint32_t)_average_network_write_speed_minutes.size(); |
| 1552 | _average_network_write_speed_hours.push_back(average_written_this_hour); |
| 1553 | } |
| 1554 | } |
| 1555 | } |
| 1556 | void node_impl::bandwidth_monitor_loop() |
| 1557 | { |
| 1558 | VERIFY_CORRECT_THREAD(); |