Skip to content

Commit

Permalink
Address code review comments
Browse files Browse the repository at this point in the history
  • Loading branch information
prashantv committed Nov 15, 2016
1 parent 5c12f50 commit 94acfc8
Show file tree
Hide file tree
Showing 3 changed files with 2 additions and 23 deletions.
2 changes: 1 addition & 1 deletion benchmark/real_relay.go
Expand Up @@ -36,7 +36,7 @@ type fixedHosts struct {
pickI atomic.Int32
}

func (fh *fixedHosts) Get(cf relay.CallFrame, conn relay.Conn) (string, error) {
func (fh *fixedHosts) Get(cf relay.CallFrame, _ relay.Conn) (string, error) {
peers := fh.hosts[string(cf.Service())]
if len(peers) == 0 {
return "", errors.New("no peers")
Expand Down
2 changes: 1 addition & 1 deletion connection.go
Expand Up @@ -309,7 +309,7 @@ func (ch *Channel) newConnection(conn net.Conn, outboundHP string, initialState
c.inbound.onAdded = c.onExchangeAdded
c.outbound.onAdded = c.onExchangeAdded

if ch.relayHost != nil {
if ch.RelayHost() != nil {
c.relay = NewRelayer(ch, c)
}

Expand Down
21 changes: 0 additions & 21 deletions relay/noop.go

This file was deleted.

0 comments on commit 94acfc8

Please sign in to comment.