mirror of https://github.com/hashicorp/consul
consul: Remove unreachable error handling
parent
b1c04e7660
commit
6ef6e43418
|
@ -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()
|
||||||
|
|
Loading…
Reference in New Issue