github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-01 07:47:56 +00:00
Code Issues Projects Releases Wiki Activity

dynamic resource allocation: add timeouts for communiction with plugin (#114844)

Browse Source 
* add timeouts for communication with dra plugin

* move timeout constant to k8s.io/kubernetes/pkg/kubelet/cm/util

* move settings of timeout to pkg/kubelet/plugin/dra/plugin/client.go

* remove timeout constant
This commit is contained in:
Saza 2023-03-13 20:34:56 +09:00 committed by GitHub
parent 185cd95b9c
commit d34b0275a3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
pkg/kubelet/cm/dra/plugin/client.go
View File

@ -22,6 +22,7 @@ import (
"fmt" "fmt"
"io" "io"
"net" "net"
"time"
"google.golang.org/grpc" "google.golang.org/grpc"
"google.golang.org/grpc/credentials/insecure" "google.golang.org/grpc/credentials/insecure"
@ -131,6 +132,9 @@ func (r *draPluginClient) NodePrepareResource(
ResourceHandle: resourceHandle, ResourceHandle: resourceHandle,
} }
ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
defer cancel()
return nodeClient.NodePrepareResource(ctx, req) return nodeClient.NodePrepareResource(ctx, req)
} }
@ -165,6 +169,9 @@ func (r *draPluginClient) NodeUnprepareResource(
CdiDevices: cdiDevices, CdiDevices: cdiDevices,
} }
ctx, cancel := context.WithTimeout(ctx, 10*time.Second)
defer cancel()
return nodeClient.NodeUnprepareResource(ctx, req) return nodeClient.NodeUnprepareResource(ctx, req)
} }