rpc: use DialPipeContext

This commit is contained in:
Felix Lange 2023-08-22 19:04:59 +02:00
parent 6399b86797
commit bc5cd29e63

View file

@ -38,12 +38,7 @@ func ipcListen(endpoint string) (net.Listener, error) {
// newIPCConnection will connect to a named pipe with the given endpoint as name.
func newIPCConnection(ctx context.Context, endpoint string) (net.Conn, error) {
timeout := defaultPipeDialTimeout
if deadline, ok := ctx.Deadline(); ok {
timeout = deadline.Sub(time.Now())
if timeout < 0 {
timeout = 0
}
}
return winio.DialPipe(endpoint, timeout)
ctx, cancel := context.WithTimeout(ctx, defaultPipeDialTimeout)
defer cancel()
return winio.DialPipeContext(ctx, endpoint)
}