Line data    Source code

       1             : /*
       2             :  * Copyright (c) 2016 Juniper Networks, Inc. All rights reserved.
       3             :  */
       4             : 
       5             : #include "bgp/peer_stats.h"
       6             : 
       7           0 : void PeerStats::FillProtoStats(const IPeerDebugStats::ProtoStats &stats,
       8             :                                PeerProtoStats *proto_stats) {
       9           0 :     proto_stats->set_open(stats.open);
      10           0 :     proto_stats->set_keepalive(stats.keepalive);
      11           0 :     proto_stats->set_close(stats.close);
      12           0 :     proto_stats->set_update(stats.update);
      13           0 :     proto_stats->set_notification(stats.notification);
      14           0 :     proto_stats->set_total(stats.open + stats.keepalive + stats.close +
      15           0 :         stats.update + stats.notification);
      16           0 : }
      17             : 
      18           0 : void PeerStats::FillRouteUpdateStats(const IPeerDebugStats::UpdateStats &stats,
      19             :                                      PeerUpdateStats *rt_stats) {
      20           0 :     rt_stats->set_total(stats.total);
      21           0 :     rt_stats->set_reach(stats.reach);
      22           0 :     rt_stats->set_unreach(stats.unreach);
      23           0 : }
      24             : 
      25           0 : void PeerStats::FillRxErrorStats(const IPeerDebugStats::RxErrorStats &src,
      26             :                                  PeerRxErrorStats *dest) {
      27           0 :     PeerRxInet6ErrorStats error_stats;
      28           0 :     error_stats.set_bad_inet6_xml_token_count(src.inet6_bad_xml_token_count);
      29           0 :     error_stats.set_bad_inet6_prefix_count(src.inet6_bad_prefix_count);
      30           0 :     error_stats.set_bad_inet6_nexthop_count(src.inet6_bad_nexthop_count);
      31           0 :     error_stats.set_bad_inet6_afi_safi_count(src.inet6_bad_afi_safi_count);
      32           0 :     dest->set_inet6_error_stats(error_stats);
      33           0 : }
      34             : 
      35           0 : void PeerStats::FillRxRouteStats(const IPeerDebugStats::RxRouteStats &src,
      36             :                                  PeerRxRouteStats *dest) {
      37           0 :     dest->set_total_path_count(src.total_path_count);
      38           0 :     dest->set_primary_path_count(src.primary_path_count);
      39           0 : }
      40             : 
      41           0 : void PeerStats::FillPeerUpdateStats(const IPeerDebugStats *peer_stats,
      42             :                                     PeerUpdateStats *rt_stats_rx,
      43             :                                     PeerUpdateStats *rt_stats_tx) {
      44             : 
      45           0 :     IPeerDebugStats::UpdateStats update_stats_rx;
      46           0 :     peer_stats->GetRxRouteUpdateStats(&update_stats_rx);
      47           0 :     FillRouteUpdateStats(update_stats_rx, rt_stats_rx);
      48             : 
      49           0 :     IPeerDebugStats::UpdateStats update_stats_tx;
      50           0 :     peer_stats->GetTxRouteUpdateStats(&update_stats_tx);
      51           0 :     FillRouteUpdateStats(update_stats_tx, rt_stats_tx);
      52           0 : }
      53             : 
      54           0 : void PeerStats::FillPeerUpdateStats(const IPeerDebugStats *peer_stats,
      55             :                                     PeerStatsData *peer_stats_data) {
      56           0 :     PeerUpdateStats stats_rx;
      57           0 :     PeerUpdateStats stats_tx;
      58             : 
      59           0 :     FillPeerUpdateStats(peer_stats, &stats_rx, &stats_tx);
      60           0 :     peer_stats_data->set_raw_rx_update_stats(stats_rx);
      61           0 :     peer_stats_data->set_raw_tx_update_stats(stats_tx);
      62           0 : }
      63             : 
      64           0 : void PeerStats::FillPeerDebugStats(const IPeerDebugStats *peer_stats,
      65             :                                    PeerStatsInfo *stats) {
      66           0 :     PeerProtoStats proto_stats_tx;
      67           0 :     PeerProtoStats proto_stats_rx;
      68           0 :     PeerUpdateStats rt_stats_rx;
      69           0 :     PeerUpdateStats rt_stats_tx;
      70           0 :     PeerRxErrorStats dest_error_stats_rx;
      71           0 :     PeerRxRouteStats dest_route_stats_rx;
      72             : 
      73           0 :     IPeerDebugStats::ProtoStats stats_rx;
      74           0 :     peer_stats->GetRxProtoStats(&stats_rx);
      75           0 :     FillProtoStats(stats_rx, &proto_stats_rx);
      76             : 
      77           0 :     IPeerDebugStats::ProtoStats stats_tx;
      78           0 :     peer_stats->GetTxProtoStats(&stats_tx);
      79           0 :     FillProtoStats(stats_tx, &proto_stats_tx);
      80             : 
      81           0 :     FillPeerUpdateStats(peer_stats, &rt_stats_rx, &rt_stats_tx);
      82             : 
      83           0 :     IPeerDebugStats::RxErrorStats src_error_stats_rx;
      84           0 :     peer_stats->GetRxErrorStats(&src_error_stats_rx);
      85           0 :     FillRxErrorStats(src_error_stats_rx, &dest_error_stats_rx);
      86             : 
      87           0 :     IPeerDebugStats::RxRouteStats src_route_stats_rx;
      88           0 :     peer_stats->GetRxRouteStats(&src_route_stats_rx);
      89           0 :     FillRxRouteStats(src_route_stats_rx, &dest_route_stats_rx);
      90             : 
      91           0 :     stats->set_rx_proto_stats(proto_stats_rx);
      92           0 :     stats->set_tx_proto_stats(proto_stats_tx);
      93           0 :     stats->set_rx_update_stats(rt_stats_rx);
      94           0 :     stats->set_tx_update_stats(rt_stats_tx);
      95           0 :     stats->set_rx_error_stats(dest_error_stats_rx);
      96           0 :     stats->set_rx_route_stats(dest_route_stats_rx);
      97           0 : }