From 7fa9f2ad590fddf49e723712a2ed826349ee014e Mon Sep 17 00:00:00 2001 From: m1093782566 Date: Wed, 6 Sep 2017 19:07:42 +0800 Subject: [PATCH] support ipvs flush API --- pkg/util/ipvs/ipvs_linux.go | 13 +------------ 1 file changed, 1 insertion(+), 12 deletions(-) diff --git a/pkg/util/ipvs/ipvs_linux.go b/pkg/util/ipvs/ipvs_linux.go index be50ad515c..4dc732588e 100644 --- a/pkg/util/ipvs/ipvs_linux.go +++ b/pkg/util/ipvs/ipvs_linux.go @@ -142,18 +142,7 @@ func (runner *runner) GetVirtualServers() ([]*VirtualServer, error) { // Flush is part of Interface. Currently we delete IPVS services one by one func (runner *runner) Flush() error { - vss, err := runner.GetVirtualServers() - if err != nil { - return err - } - for _, vs := range vss { - err := runner.DeleteVirtualServer(vs) - // TODO: aggregate errors? - if err != nil { - return err - } - } - return nil + return runner.ipvsHandle.Flush() } // AddRealServer is part of Interface.