Skip to content

Commit

Permalink
go fmt fix for feature/gribi/otg_tests/get_rpc_test/get_rpc_test.go
Browse files Browse the repository at this point in the history
  • Loading branch information
self-maurya committed Dec 27, 2024
1 parent 4bfc257 commit 56d901f
Showing 1 changed file with 5 additions and 4 deletions.
9 changes: 5 additions & 4 deletions feature/gribi/otg_tests/get_rpc_test/get_rpc_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -355,10 +355,10 @@ func testIPv4LeaderActive(ctx context.Context, t *testing.T, args *testArgs) {
gnmi.Update(t, args.dut, niProto.Config(), static)
validateGetRPC(ctx, t, args.clientA)
for ip := range ateDstNetCIDR {
ipv4Path := gnmi.OC().NetworkInstance(deviations.DefaultNetworkInstance(args.dut)).Afts().Ipv4Entry(ateDstNetCIDR[ip])
lastValue, ok := gnmi.Watch(t, args.dut, ipv4Path.State(), time.Minute, func(v *ygnmi.Value[*oc.NetworkInstance_Afts_Ipv4Entry]) bool {
return v.IsPresent()
}).Await(t)
ipv4Path := gnmi.OC().NetworkInstance(deviations.DefaultNetworkInstance(args.dut)).Afts().Ipv4Entry(ateDstNetCIDR[ip])
lastValue, ok := gnmi.Watch(t, args.dut, ipv4Path.State(), time.Minute, func(v *ygnmi.Value[*oc.NetworkInstance_Afts_Ipv4Entry]) bool {
return v.IsPresent()
}).Await(t)

if !ok {
t.Fatalf("gnmi.Watch() failed value received = %s", lastValue)
Expand Down Expand Up @@ -456,3 +456,4 @@ func TestElectionID(t *testing.T) {
}
testIPv4LeaderActive(ctx, t, args)
}

0 comments on commit 56d901f

Please sign in to comment.