Skip to content

Commit

Permalink
apply suggestions
Browse files Browse the repository at this point in the history
Signed-off-by: Nikita Skrynnik <nikita.skrynnik@xored.com>
  • Loading branch information
NikitaSkrynnik committed Feb 24, 2022
1 parent 0fc5ace commit 5565160
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 19 deletions.
4 changes: 2 additions & 2 deletions .golangci.yml
Original file line number Diff line number Diff line change
Expand Up @@ -29,14 +29,14 @@ linters-settings:
goimports:
local-prefixes: github.com/networkservicemesh/sdk
gocyclo:
min-complexity: 17
min-complexity: 15
maligned:
suggest-new: true
dupl:
threshold: 150
funlen:
Lines: 110
Statements: 60
Statements: 50
goconst:
min-len: 2
min-occurrences: 2
Expand Down
2 changes: 1 addition & 1 deletion pkg/networkservice/chains/nsmgr/forwarder_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -98,7 +98,7 @@ func testForwarderShouldBeSelectedCorrectlyOnNSMgrRestart(t *testing.T, nodeNum,
require.Equal(t, pathSegmentCount, len(conn.Path.PathSegments))
require.Equal(t, expectedForwarderName, conn.GetPath().GetPathSegments()[2].Name)

for i := 0; i < 2; i++ {
for i := 0; i < 10; i++ {
request.Connection = conn.Clone()
conn, err = nsc.Request(ctx, request.Clone())
require.NoError(t, err)
Expand Down
20 changes: 4 additions & 16 deletions pkg/networkservice/common/discoverforwarder/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -100,23 +100,11 @@ func (d *discoverForwarderServer) Request(ctx context.Context, request *networks
datapathForwarder = segments[pathIndex+1].Name
}

for _, candidate := range nses {
if candidate.Name != datapathForwarder {
continue
}
u, err := url.Parse(candidate.Url)

if err != nil {
logger.Errorf("can not parse forwarder=%v url=%v error=%v", candidate.Name, u, err.Error())
return nil, errors.WithStack(err)
}

resp, err := next.Server(ctx).Request(clienturlctx.WithClientURL(ctx, u), request)
if err != nil {
continue
for i, candidate := range nses {
if candidate.Name == datapathForwarder {
nses[0], nses[i] = nses[i], nses[0]
break
}
storeForwarderName(ctx, candidate.Name)
return resp, nil
}

var candidatesErr = errors.New("all forwarders have failed")
Expand Down

0 comments on commit 5565160

Please sign in to comment.