diff --git a/main.go b/main.go index 22cba26fdfb466f2e554538d3f81f864d8c18b79..7220ba4a6c669dd44368ccbc81c16e72c534d0d7 100644 --- a/main.go +++ b/main.go @@ -79,7 +79,7 @@ func main() { go func() { for { - fmt.Print(rib.Print()) + fmt.Printf("LocRIB count: %d\n", rib.Count()) time.Sleep(time.Second * 10) } }() diff --git a/protocols/bgp/server/update_helper.go b/protocols/bgp/server/update_helper.go index 34f784a1de6f22cae74839dbf348865e58472c06..e0a24a6e3bbf1369b59b25d04f1f6c3c16930844 100644 --- a/protocols/bgp/server/update_helper.go +++ b/protocols/bgp/server/update_helper.go @@ -82,7 +82,6 @@ func serializeAndSendUpdate(out io.Writer, update serializeAbleUpdate) error { return nil } - fmt.Printf("Sending Update: %v\n", updateBytes) _, err = out.Write(updateBytes) if err != nil { return fmt.Errorf("Failed sending Update: %v", err) diff --git a/routingtable/adjRIBOut/adj_rib_out.go b/routingtable/adjRIBOut/adj_rib_out.go index b667ac7778ac50b544274970490b7acb4ffffab2..19b44b8bd2595cc550a960ace7c9c00f1fdab21a 100644 --- a/routingtable/adjRIBOut/adj_rib_out.go +++ b/routingtable/adjRIBOut/adj_rib_out.go @@ -72,12 +72,10 @@ func (a *AdjRIBOut) AddPath(pfx bnet.Prefix, p *route.Path) error { a.removePathsFromClients(pfx, oldPaths) } - fmt.Printf("Adding path: %s\n", p.Print()) pathID, err := a.pathIDManager.addPath(p) if err != nil { return fmt.Errorf("Unable to get path ID: %v", err) } - fmt.Printf("New path ID: %d\n", pathID) p.BGPPath.PathIdentifier = pathID a.rt.AddPath(pfx, p) diff --git a/routingtable/locRIB/loc_rib.go b/routingtable/locRIB/loc_rib.go index ff5750c34d226080bea079968becdec410d2704e..fd8fd0720d416f401513636c259f651e4aab15fc 100644 --- a/routingtable/locRIB/loc_rib.go +++ b/routingtable/locRIB/loc_rib.go @@ -27,6 +27,14 @@ func New() *LocRIB { return a } +//Count routes from the LocRIP +func (a *LocRIB) Count() uint64 { + a.mu.RLock() + defer a.mu.RUnlock() + + return uint64(len(a.rt.Dump())) +} + // UpdateNewClient sends current state to a new client func (a *LocRIB) UpdateNewClient(client routingtable.RouteTableClient) error { a.mu.RLock()