github/kata-containers
1
0
Fork 1
mirror of https://github.com/kata-containers/kata-containers.git synced 2025-07-04 11:06:21 +00:00
Code Issues Projects Releases Wiki Activity

agent: check: Increase timeout check request.

Browse Source 
In some slow enviroments the agent is taking more than 5 seconds
to start to serve grpc request.

This was reproducible in a Centos VM with 4 cpus running 8 pods in
parallel.

Fixes: #516

Signed-off-by: Jose Carlos Venegas Munoz <jose.carlos.venegas.munoz@intel.com>
This commit is contained in:
Jose Carlos Venegas Munoz 2018-07-26 01:22:19 +00:00
parent 12e1911aab
commit 5fc7219315
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
virtcontainers/kata_agent.go
View File

@ -34,6 +34,7 @@ import (
) )
var ( var (
checkRequestTimeout = 30 * time.Second
defaultKataSocketName = "kata.sock" defaultKataSocketName = "kata.sock"
defaultKataChannel = "agent.channel.0" defaultKataChannel = "agent.channel.0"
defaultKataDeviceID = "channel0" defaultKataDeviceID = "channel0"
@ -1278,7 +1279,7 @@ type reqFunc func(context.Context, interface{}, ...golangGrpc.CallOption) (inter
func (k *kataAgent) installReqFunc(c *kataclient.AgentClient) { func (k *kataAgent) installReqFunc(c *kataclient.AgentClient) {
k.reqHandlers = make(map[string]reqFunc) k.reqHandlers = make(map[string]reqFunc)
k.reqHandlers["grpc.CheckRequest"] = func(ctx context.Context, req interface{}, opts ...golangGrpc.CallOption) (interface{}, error) { k.reqHandlers["grpc.CheckRequest"] = func(ctx context.Context, req interface{}, opts ...golangGrpc.CallOption) (interface{}, error) {
ctx, cancel := context.WithTimeout(ctx, 5*time.Second) ctx, cancel := context.WithTimeout(ctx, checkRequestTimeout)
defer cancel() defer cancel()
return k.client.Check(ctx, req.(*grpc.CheckRequest), opts...) return k.client.Check(ctx, req.(*grpc.CheckRequest), opts...)
} }