bgpwtf/cccampix/irr: limit concurrency
Change-Id: I958322f33c86469f9c3e21d1bd962faede2a3fee
diff --git a/bgpwtf/cccampix/irr/main.go b/bgpwtf/cccampix/irr/main.go
index 1492e6c..90061fb 100644
--- a/bgpwtf/cccampix/irr/main.go
+++ b/bgpwtf/cccampix/irr/main.go
@@ -29,10 +29,10 @@
}
s := &service{
- iana: provider.NewIANA(),
+ iana: provider.NewIANA(2),
providers: map[provider.IRR]provider.Provider{
- provider.IRR_RIPE: provider.NewRIPE(),
- provider.IRR_ARIN: provider.NewARIN(),
+ provider.IRR_RIPE: provider.NewRIPE(10),
+ provider.IRR_ARIN: provider.NewARIN(2),
},
}
pb.RegisterIRRServer(mi.GRPC(), s)
@@ -68,7 +68,7 @@
prov, ok := s.providers[irr]
if !ok {
- return nil, status.Errorf(codes.NotFound, "AS belongs to unhandled IRR %s", irr.String())
+ return nil, status.Errorf(codes.Unimplemented, "AS belongs to unhandled IRR %s", irr.String())
}
res, err := prov.Query(ctx, asn)