public/k3s
1
0
Fork 0
mirror of https://git.vectorsigma.ru/public/k3s.git synced 2026-08-08 16:19:46 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix windows socket prefix

Browse Source 
Signed-off-by: Brad Davidson <brad.davidson@rancher.com>
(cherry picked from commit f5b0d7884f)
Signed-off-by: Brad Davidson <brad.davidson@rancher.com>
This commit is contained in:
Brad Davidson
2025-04-09 00:11:04 +00:00
committed by Brad Davidson
parent d13c793f0b
commit 650e431b1c
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
pkg/agent/cri/cri.go
View File

@@ -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
}