diff options
| author | ISHIDA Wataru <ishida.wataru@lab.ntt.co.jp> | 2016-05-24 05:47:52 +0000 |
|---|---|---|
| committer | FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp> | 2016-06-06 12:43:20 +0900 |
| commit | aca6fd6ad4409b4cb63682bff3c79fca8ca2800d (patch) | |
| tree | eb91718c87ddcdaa0d2133f3aaccfee6dbe7f7a8 /openswitch | |
| parent | 10746e5f4b303aba553c2bb759afe3a8d4ffe3aa (diff) | |
server: refactoring for monitorbestchanged api. use watcher infra
Signed-off-by: ISHIDA Wataru <ishida.wataru@lab.ntt.co.jp>
Diffstat (limited to 'openswitch')
| -rw-r--r-- | openswitch/openswitch.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/openswitch/openswitch.go b/openswitch/openswitch.go index 1792fc9e..c6ff5e55 100644 --- a/openswitch/openswitch.go +++ b/openswitch/openswitch.go @@ -567,15 +567,15 @@ func (m *OpsManager) GobgpMonitor(ready *bool) { time.Sleep(time.Duration(time.Second * 2)) reqCh := m.grpcCh family := bgp.RF_IPv4_UC - arg := &api.Arguments{ - Resource: api.Resource_GLOBAL, - Family: uint32(family), + arg := &api.Table{ + Type: api.Resource_GLOBAL, + Family: uint32(family), } for { if !*ready { return } - req := server.NewGrpcRequest(server.REQ_MONITOR_GLOBAL_BEST_CHANGED, "", bgp.RouteFamily(0), arg) + req := server.NewGrpcRequest(server.REQ_MONITOR_RIB, "", bgp.RouteFamily(arg.Family), arg) reqCh <- req res := <-req.ResponseCh if err := res.Err(); err != nil { |