From 650e431b1c7f3bee28a08191c4e3bc67da8d3536 Mon Sep 17 00:00:00 2001 From: Brad Davidson Date: Wed, 9 Apr 2025 00:11:04 +0000 Subject: [PATCH] Fix windows socket prefix Signed-off-by: Brad Davidson (cherry picked from commit f5b0d7884f5ce229b7fcd7218cd4dd422554b605) Signed-off-by: Brad Davidson --- pkg/agent/cri/cri.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/pkg/agent/cri/cri.go b/pkg/agent/cri/cri.go index 8b6ee950fc..909a46f049 100644 --- a/pkg/agent/cri/cri.go +++ b/pkg/agent/cri/cri.go @@ -2,6 +2,7 @@ package cri import ( "context" + "strings" "time" "github.com/sirupsen/logrus" @@ -14,7 +15,11 @@ const maxMsgSize = 1024 * 1024 * 16 // Connection connects to a CRI socket at the given path. func Connection(ctx context.Context, address string) (*grpc.ClientConn, error) { - addr, dialer, err := k8sutil.GetAddressAndDialer(socketPrefix + address) + if !strings.HasPrefix(address, socketPrefix) { + address = socketPrefix + address + } + + addr, dialer, err := k8sutil.GetAddressAndDialer(address) if err != nil { return nil, err }