github/kata-containers
1
0
Fork 1
mirror of https://github.com/kata-containers/kata-containers.git synced 2025-06-29 16:57:18 +00:00
Code Issues Projects Releases Wiki Activity

agent: mark agent dead when failing to connect

Browse Source 
Whenever we fail to connect, do not make any more attempts.
More attempts are possible during cleanup phase but we should
not try to connect any more there.

Signed-off-by: Peng Tao <bergwolf@hyper.sh>
This commit is contained in:
Peng Tao 2019-07-18 21:17:48 -07:00
parent c472a01006
commit 4130913ed7
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
virtcontainers/kata_agent.go
View File

@ -136,6 +136,7 @@ type kataAgent struct {
keepConn bool keepConn bool
proxyBuiltIn bool proxyBuiltIn bool
dynamicTracing bool dynamicTracing bool
dead bool
vmSocket interface{} vmSocket interface{}
ctx context.Context ctx context.Context
@ -1581,6 +1582,9 @@ func (k *kataAgent) statsContainer(sandbox *Sandbox, c Container) (*ContainerSta
} }
func (k *kataAgent) connect() error { func (k *kataAgent) connect() error {
if k.dead {
return errors.New("Dead agent")
}
// lockless quick pass // lockless quick pass
if k.client != nil { if k.client != nil {
return nil return nil
@ -1599,6 +1603,7 @@ func (k *kataAgent) connect() error {
k.Logger().WithField("url", k.state.URL).Info("New client") k.Logger().WithField("url", k.state.URL).Info("New client")
client, err := kataclient.NewAgentClient(k.ctx, k.state.URL, k.proxyBuiltIn) client, err := kataclient.NewAgentClient(k.ctx, k.state.URL, k.proxyBuiltIn)
if err != nil { if err != nil {
k.dead = true
return err return err
} }