14
14
#include < rpc/mining.h>
15
15
#include < rpc/protocol.h>
16
16
#include < rpc/request.h>
17
+ #include < tinyformat.h>
17
18
#include < util/strencodings.h>
18
19
#include < util/system.h>
19
20
#include < util/translation.h>
20
21
#include < util/url.h>
21
22
23
+ #include < algorithm>
22
24
#include < functional>
23
25
#include < memory>
24
26
#include < stdio.h>
@@ -297,12 +299,12 @@ class NetinfoRequestHandler : public BaseRequestHandler
297
299
{
298
300
private:
299
301
static constexpr int8_t UNKNOWN_NETWORK{-1 };
300
- static constexpr size_t m_networks_size{3 };
302
+ static constexpr uint8_t m_networks_size{3 };
301
303
const std::array<std::string, m_networks_size> m_networks{{" ipv4" , " ipv6" , " onion" }};
302
304
std::array<std::array<uint16_t , m_networks_size + 2 >, 3 > m_counts{{{}}}; // !< Peer counts by (in/out/total, networks/total/block-relay)
303
305
int8_t NetworkStringToId (const std::string& str) const
304
306
{
305
- for (size_t i = 0 ; i < m_networks_size; ++i) {
307
+ for (uint8_t i = 0 ; i < m_networks_size; ++i) {
306
308
if (str == m_networks.at (i)) return i;
307
309
}
308
310
return UNKNOWN_NETWORK;
@@ -313,21 +315,22 @@ class NetinfoRequestHandler : public BaseRequestHandler
313
315
bool IsVersionSelected () const { return m_details_level == 3 || m_details_level == 4 ; }
314
316
bool m_is_asmap_on{false };
315
317
size_t m_max_addr_length{0 };
318
+ size_t m_max_age_length{4 };
316
319
size_t m_max_id_length{2 };
317
320
struct Peer {
318
- int id;
319
- int mapped_as;
320
- int version;
321
- int64_t conn_time;
321
+ std::string addr;
322
+ std::string sub_version;
323
+ std::string network;
324
+ std::string age;
325
+ double min_ping;
326
+ double ping;
322
327
int64_t last_blck;
323
328
int64_t last_recv;
324
329
int64_t last_send;
325
330
int64_t last_trxn;
326
- double min_ping;
327
- double ping;
328
- std::string addr;
329
- std::string network;
330
- std::string sub_version;
331
+ int id;
332
+ int mapped_as;
333
+ int version;
331
334
bool is_block_relay;
332
335
bool is_outbound;
333
336
bool operator <(const Peer& rhs) const { return std::tie (is_outbound, min_ping) < std::tie (rhs.is_outbound , rhs.min_ping ); }
@@ -336,9 +339,16 @@ class NetinfoRequestHandler : public BaseRequestHandler
336
339
std::string ChainToString () const
337
340
{
338
341
if (gArgs .GetChainName () == CBaseChainParams::TESTNET) return " testnet" ;
342
+ if (gArgs .GetChainName () == CBaseChainParams::SIGNET) return " signet" ;
339
343
if (gArgs .GetChainName () == CBaseChainParams::REGTEST) return " regtest" ;
340
344
return " " ;
341
345
}
346
+ std::string PingTimeToString (double seconds) const
347
+ {
348
+ if (seconds < 0 ) return " " ;
349
+ const double milliseconds{round (1000 * seconds)};
350
+ return milliseconds > 999999 ? " -" : ToString (milliseconds);
351
+ }
342
352
const int64_t m_time_now{GetSystemTimeInSeconds ()};
343
353
344
354
public:
@@ -398,10 +408,12 @@ class NetinfoRequestHandler : public BaseRequestHandler
398
408
const double min_ping{peer[" minping" ].isNull () ? -1 : peer[" minping" ].get_real ()};
399
409
const double ping{peer[" pingtime" ].isNull () ? -1 : peer[" pingtime" ].get_real ()};
400
410
const std::string addr{peer[" addr" ].get_str ()};
411
+ const std::string age{conn_time == 0 ? " " : ToString ((m_time_now - conn_time) / 60 )};
401
412
const std::string sub_version{peer[" subver" ].get_str ()};
402
- m_peers.push_back ({peer_id, mapped_as, version, conn_time, last_blck, last_recv, last_send, last_trxn, min_ping, ping, addr, network, sub_version, is_block_relay, is_outbound});
403
- m_max_id_length = std::max (ToString (peer_id).length (), m_max_id_length);
413
+ m_peers.push_back ({addr, sub_version, network, age, min_ping, ping, last_blck, last_recv, last_send, last_trxn, peer_id, mapped_as, version, is_block_relay, is_outbound});
404
414
m_max_addr_length = std::max (addr.length () + 1 , m_max_addr_length);
415
+ m_max_age_length = std::max (age.length (), m_max_age_length);
416
+ m_max_id_length = std::max (ToString (peer_id).length (), m_max_id_length);
405
417
m_is_asmap_on |= (mapped_as != 0 );
406
418
}
407
419
}
@@ -412,23 +424,24 @@ class NetinfoRequestHandler : public BaseRequestHandler
412
424
// Report detailed peer connections list sorted by direction and minimum ping time.
413
425
if (DetailsRequested () && !m_peers.empty ()) {
414
426
std::sort (m_peers.begin (), m_peers.end ());
415
- result += " Peer connections sorted by direction and min ping\n <-> relay net mping ping send recv txn blk uptime " ;
427
+ result += strprintf ( " Peer connections sorted by direction and min ping\n <-> relay net mping ping send recv txn blk %*s " , m_max_age_length, " age " ) ;
416
428
if (m_is_asmap_on) result += " asmap " ;
417
429
result += strprintf (" %*s %-*s%s\n " , m_max_id_length, " id" , IsAddressSelected () ? m_max_addr_length : 0 , IsAddressSelected () ? " address" : " " , IsVersionSelected () ? " version" : " " );
418
430
for (const Peer& peer : m_peers) {
419
431
std::string version{ToString (peer.version ) + peer.sub_version };
420
432
result += strprintf (
421
- " %3s %5s %5s%6s %7s%5s%5s%5s%5s%7s %*i %*s %-*s%s\n " ,
433
+ " %3s %5s %5s%7s %7s%5s%5s%5s%5s %*s %*i %*s %-*s%s\n " ,
422
434
peer.is_outbound ? " out" : " in" ,
423
435
peer.is_block_relay ? " block" : " full" ,
424
436
peer.network ,
425
- peer. min_ping == - 1 ? " " : ToString ( round ( 1000 * peer.min_ping ) ),
426
- peer. ping == - 1 ? " " : ToString ( round ( 1000 * peer.ping ) ),
437
+ PingTimeToString ( peer.min_ping ),
438
+ PingTimeToString ( peer.ping ),
427
439
peer.last_send == 0 ? " " : ToString (m_time_now - peer.last_send ),
428
440
peer.last_recv == 0 ? " " : ToString (m_time_now - peer.last_recv ),
429
441
peer.last_trxn == 0 ? " " : ToString ((m_time_now - peer.last_trxn ) / 60 ),
430
442
peer.last_blck == 0 ? " " : ToString ((m_time_now - peer.last_blck ) / 60 ),
431
- peer.conn_time == 0 ? " " : ToString ((m_time_now - peer.conn_time ) / 60 ),
443
+ m_max_age_length, // variable spacing
444
+ peer.age ,
432
445
m_is_asmap_on ? 7 : 0 , // variable spacing
433
446
m_is_asmap_on && peer.mapped_as != 0 ? ToString (peer.mapped_as ) : " " ,
434
447
m_max_id_length, // variable spacing
@@ -437,24 +450,28 @@ class NetinfoRequestHandler : public BaseRequestHandler
437
450
IsAddressSelected () ? peer.addr : " " ,
438
451
IsVersionSelected () && version != " 0" ? version : " " );
439
452
}
440
- result += " ms ms sec sec min min min \n\n " ;
453
+ result += strprintf ( " ms ms sec sec min min %*s \n\n " , m_max_age_length, " min " ) ;
441
454
}
442
455
443
456
// Report peer connection totals by type.
444
457
result += " ipv4 ipv6 onion total block-relay\n " ;
445
458
const std::array<std::string, 3 > rows{{" in" , " out" , " total" }};
446
- for (size_t i = 0 ; i < m_networks_size; ++i) {
459
+ for (uint8_t i = 0 ; i < m_networks_size; ++i) {
447
460
result += strprintf (" %-5s %5i %5i %5i %5i %5i\n " , rows.at (i), m_counts.at (i).at (0 ), m_counts.at (i).at (1 ), m_counts.at (i).at (2 ), m_counts.at (i).at (m_networks_size), m_counts.at (i).at (m_networks_size + 1 ));
448
461
}
449
462
450
463
// Report local addresses, ports, and scores.
451
464
result += " \n Local addresses" ;
452
- const UniValue& local_addrs{networkinfo[" localaddresses" ]};
465
+ const std::vector< UniValue> & local_addrs{networkinfo[" localaddresses" ]. getValues () };
453
466
if (local_addrs.empty ()) {
454
467
result += " : n/a\n " ;
455
468
} else {
456
- for (const UniValue& addr : local_addrs.getValues ()) {
457
- result += strprintf (" \n %-40i port %5i score %6i" , addr[" address" ].get_str (), addr[" port" ].get_int (), addr[" score" ].get_int ());
469
+ size_t max_addr_size{0 };
470
+ for (const UniValue& addr : local_addrs) {
471
+ max_addr_size = std::max (addr[" address" ].get_str ().length () + 1 , max_addr_size);
472
+ }
473
+ for (const UniValue& addr : local_addrs) {
474
+ result += strprintf (" \n %-*s port %6i score %6i" , max_addr_size, addr[" address" ].get_str (), addr[" port" ].get_int (), addr[" score" ].get_int ());
458
475
}
459
476
}
460
477
0 commit comments