github
/
consul
mirror of https://github.com/hashicorp/consul
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Merge pull request #1028 from sebastianmarkow/master 

Remove unreachable error handling in AgentRPC.listen()
pull/1030/head
Ryan Uber 2015-06-12 22:28:10 -07:00
parent cee0af8d5c 6ef6e43418
commit 8ffa0ea8b7
1 changed files with 0 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
command/agent/rpc.go
View File

@ -304,11 +304,6 @@ func (i *AgentRPC) listen() {
} }
client.dec = codec.NewDecoder(client.reader, msgpackHandle) client.dec = codec.NewDecoder(client.reader, msgpackHandle)
client.enc = codec.NewEncoder(client.writer, msgpackHandle) client.enc = codec.NewEncoder(client.writer, msgpackHandle)
if err != nil {
i.logger.Printf("[ERR] agent.rpc: Failed to create decoder: %v", err)
conn.Close()
continue
}
// Register the client // Register the client
i.Lock() i.Lock()