status-im
/
consul
mirror of https://github.com/status-im/consul.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity

Use error wrapping to preserve error type info

This commit is contained in:
Joel May 2020-11-10 21:50:09 +00:00
parent 77451d944e
commit f600285eb4
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
agent/pool/pool.go
View File

@ -519,7 +519,7 @@ START:
// Try to get a conn first
conn, err := p.acquire(dc, nodeName, addr)
if err != nil {
return nil, nil, fmt.Errorf("failed to get conn: %v", err)
return nil, nil, fmt.Errorf("failed to get conn: %w", err)
}
// Get a client
@ -533,7 +533,7 @@ START:
retries++
goto START
}
return nil, nil, fmt.Errorf("failed to start stream: %v", err)
return nil, nil, fmt.Errorf("failed to start stream: %w", err)
}
return conn, client, nil
}
@ -575,14 +575,14 @@ func (p *ConnPool) rpcInsecure(dc string, addr net.Addr, method string, args int
var codec rpc.ClientCodec
conn, _, err := p.dial(dc, addr, 0, RPCTLSInsecure)
if err != nil {
return fmt.Errorf("rpcinsecure error establishing connection: %v", err)
return fmt.Errorf("rpcinsecure error establishing connection: %w", err)
}
codec = msgpackrpc.NewCodecFromHandle(true, true, conn, structs.MsgpackHandle)
// Make the RPC call
err = msgpackrpc.CallWithCodec(codec, method, args, reply)
if err != nil {
return fmt.Errorf("rpcinsecure error making call: %v", err)
return fmt.Errorf("rpcinsecure error making call: %w", err)
}
return nil