Merge pull request #103 from klihub/fixes/close-on-sync-failure

adaptation: close plugin if initial synchronization fails.
containerd · Aug 28, 2024 · 53760d4 · 53760d4
2 parents e1d8260 + 4aec208
commit 53760d4
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/pkg/adaptation/adaptation.go b/pkg/adaptation/adaptation.go
@@ -449,9 +449,9 @@ func (r *Adaptation) acceptPluginConnections(l net.Listener) error {
 				r.plugins = append(r.plugins, p)
 				r.sortPlugins()
 				r.Unlock()
-			}
 
-			log.Infof(ctx, "plugin %q connected", p.name())
+				log.Infof(ctx, "plugin %q connected and synchronized", p.name())
+			}
 		}
 	}()
 

diff --git a/pkg/adaptation/plugin.go b/pkg/adaptation/plugin.go
@@ -418,6 +418,7 @@ func (p *plugin) synchronize(ctx context.Context, pods []*PodSandbox, containers
 	}
 	rpl, err := p.stub.Synchronize(ctx, req)
 	if err != nil {
+		p.close()
 		return nil, err
 	}