Skip to content

Commit

Permalink
Remove the Peer from the RPC
Browse files Browse the repository at this point in the history
  • Loading branch information
armon committed Nov 13, 2013
1 parent 319e95d commit 907df05
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 2 deletions.
1 change: 0 additions & 1 deletion inmem_transport.go
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,6 @@ func (i *InmemTransport) makeRPC(target net.Addr, args interface{}) (rpcResp RPC
// Send the RPC over
respCh := make(chan RPCResponse)
peer.consumerCh <- RPC{
Peer: i.localAddr,
Command: args,
RespChan: respCh,
}
Expand Down
1 change: 0 additions & 1 deletion transport.go
Original file line number Diff line number Diff line change
Expand Up @@ -12,7 +12,6 @@ type RPCResponse struct {

// RPC has a command, and provides a Reponse mechanism
type RPC struct {
Peer net.Addr
Command interface{}
RespChan chan<- RPCResponse
}
Expand Down

0 comments on commit 907df05

Please sign in to comment.