How to use GinkgoRecover method of ginkgo Package

...91			IfName:      IfName,92			StdinData:   []byte(conf),93		}94		err := originalNs.Do(func(ns.NetNS) error {95			defer GinkgoRecover()96			_, _, err := testutils.CmdAddWithArgs(args, func() error {97				return cmdAdd(args)98			})99			return err100		})101		Expect(err).To(MatchError(ContainSubstring("must be called as a chained plugin")))102	})103	It("does nothing if IPv4 already configured", func() {104		conf := `{105  "cniVersion": "0.3.1",106  "name": "mynet",107  "type": "egress-v4",108  "prevResult": {109    "cniVersion": "0.3.1",110    "ips": [{111      "version": "4",112      "address": "192.0.2.27/24"113    }]114  },115  "ipam": {116    "type": "test-plugin"117  }118}`119		args := &skel.CmdArgs{120			ContainerID: "dummy",121			Netns:       targetNs.Path(),122			IfName:      IfName,123			StdinData:   []byte(conf),124		}125		err := originalNs.Do(func(ns.NetNS) error {126			defer GinkgoRecover()127			_, _, err := testutils.CmdAddWithArgs(args, func() error {128				return cmdAdd(args)129			})130			return err131		})132		Expect(err).NotTo(HaveOccurred())133	})134	When("chained after IPv6 ptp-ish plugin", func() {135		// The following fake ptp-like code configures veth pair with:136		//137		// Container:138		//   myeth0 with 2001:db8:1::100/64139		//   default via 2001:db8:1::1 dev myeth0140		// Host:141		//   vethX with 2001:db8:1::1/128142		//   2001:db8:1::1/128 dev vethX143		//144		var prevResult cniv1.Result145		contIP := net.ParseIP("2001:db8:1::100")146		hostIP := net.ParseIP("2001:db8:1::1")147		JustBeforeEach(func() {148			contIfIdx := 1 // contVeth149			result := cniv1.Result{150				CNIVersion: cniv1.ImplementedSpecVersion,151				IPs: []*cniv1.IPConfig{{152					Interface: &contIfIdx,153					Address: net.IPNet{154						IP:   contIP,155						Mask: net.CIDRMask(64, 128),156					},157					Gateway: hostIP,158				}},159				Routes: []*types.Route{{160					Dst: net.IPNet{161						IP:   net.IPv6zero,162						Mask: net.CIDRMask(0, 128),163					},164				}},165			}166			err := targetNs.Do(func(ns.NetNS) error {167				defer GinkgoRecover()168				hostVeth, contVeth, err := ip.SetupVeth(IfName, Mtu, "", originalNs)169				Expect(err).NotTo(HaveOccurred())170				result.Interfaces = []*cniv1.Interface{171					{172						Name: hostVeth.Name,173						Mac:  hostVeth.HardwareAddr.String(),174					},175					{176						Name:    contVeth.Name,177						Mac:     contVeth.HardwareAddr.String(),178						Sandbox: targetNs.Path(),179					},180				}181				Expect(ipam.ConfigureIface(IfName, &result)).182					To(Succeed())183				return nil184			})185			Expect(err).NotTo(HaveOccurred())186			err = originalNs.Do(func(ns.NetNS) error {187				defer GinkgoRecover()188				veth, err := netlink.LinkByName(result.Interfaces[0].Name)189				Expect(err).NotTo(HaveOccurred())190				addr := &netlink.Addr{191					IPNet: &net.IPNet{192						IP:   hostIP,193						Mask: net.CIDRMask(128, 128),194					},195					Label: "",196				}197				Expect(netlink.AddrAdd(veth, addr)).To(Succeed())198				Expect(netlink.RouteAdd(&netlink.Route{199					LinkIndex: veth.Attrs().Index,200					Dst: &net.IPNet{201						IP:   contIP,202						Mask: net.CIDRMask(128, 128),203					},204					Scope: netlink.SCOPE_HOST,205				})).206					To(Succeed())207				return nil208			})209			Expect(err).NotTo(HaveOccurred())210			prevResult = result211		})212		When("on a fake network", func() {213			var internetNs ns.NetNS214			primaryIP := net.IPNet{215				IP:   net.IPv4(198, 51, 100, 10),216				Mask: net.IPv4Mask(0xff, 0xff, 0xff, 0),217			}218			gatewayIP := net.IPv4(198, 51, 100, 1)219			BeforeEach(func() {220				var err error221				internetNs, err = testutils.NewNS()222				Expect(err).NotTo(HaveOccurred())223			})224			AfterEach(func() {225				Expect(internetNs.Close()).To(Succeed())226				Expect(testutils.UnmountNS(internetNs)).To(Succeed())227			})228			JustBeforeEach(func() {229				var internetVeth, hostVeth net.Interface230				err := originalNs.Do(func(ns.NetNS) error {231					defer GinkgoRecover()232					var err error233					internetVeth, hostVeth, err = ip.SetupVeth("eth0", Mtu, "", internetNs)234					Expect(err).NotTo(HaveOccurred())235					veth, err := netlink.LinkByName(hostVeth.Name)236					Expect(err).NotTo(HaveOccurred())237					Expect(netlink.AddrAdd(veth, &netlink.Addr{238						IPNet: &primaryIP,239						Label: "",240					})).241						To(Succeed())242					Expect(netlink.RouteAdd(&netlink.Route{243						LinkIndex: veth.Attrs().Index,244						Dst:       &defaultRoute4,245						Scope:     netlink.SCOPE_UNIVERSE,246					})).247						To(Succeed())248					return nil249				})250				Expect(err).NotTo(HaveOccurred())251				err = internetNs.Do(func(ns.NetNS) error {252					defer GinkgoRecover()253					veth, err := netlink.LinkByName(internetVeth.Name)254					Expect(err).NotTo(HaveOccurred())255					Expect(netlink.AddrAdd(veth, &netlink.Addr{256						IPNet: &net.IPNet{257							IP:   gatewayIP,258							Mask: primaryIP.Mask,259						},260						Label: "",261					})).To(Succeed())262					return nil263				})264				Expect(err).NotTo(HaveOccurred())265			})266			It("configures and deconfigures SNAT IP with ADD/DEL", func() {267				By("running ADD")268				contIP4 := net.ParseIP("192.0.2.10")269				hostIP4 := net.ParseIP("192.0.2.1")270				os.Setenv("TEST_PLUGIN_RESULT", `{271  "cniVersion": "0.3.0",272  "ips": [{273      "version": "4",274      "address": "192.0.2.10/24",275      "gateway": "192.0.2.1"276  }],277  "routes": [{"dst": "0.0.0.0/0"}]278}279`)280				// Result version must be compatible with conf version281				prevResult04, err := cniv04.NewResultFromResult(&prevResult)282				Expect(err).NotTo(HaveOccurred())283				prevResultRaw, err := json.Marshal(prevResult04)284				Expect(err).NotTo(HaveOccurred())285				conf := fmt.Sprintf(`{286  "cniVersion": "0.3.1",287  "name": "mynet",288  "type": "egress-v4",289  "prevResult": %s,290  "ifname": "mynat0",291  "mtu": 1600,292  "snatIP": "198.51.100.10",293  "ipam": {294    "type": "test-plugin"295  }296}`,297					string(prevResultRaw))298				args := &skel.CmdArgs{299					ContainerID: "dummy",300					Netns:       targetNs.Path(),301					IfName:      IfName,302					StdinData:   []byte(conf),303				}304				var resI types.Result305				var res *cniv1.Result306				err = originalNs.Do(func(ns.NetNS) error {307					defer GinkgoRecover()308					var err error309					resI, _, err = testutils.CmdAddWithArgs(args, func() error {310						return cmdAdd(args)311					})312					return err313				})314				Expect(err).NotTo(HaveOccurred())315				err = originalNs.Do(func(ns.NetNS) error {316					defer GinkgoRecover()317					out, err := exec.Command("ip", "route", "show").CombinedOutput()318					Expect(err).NotTo(HaveOccurred())319					fmt.Fprintf(GinkgoWriter, "origns routes:\n%s", out)320					out, err = exec.Command("ip", "addr").CombinedOutput()321					Expect(err).NotTo(HaveOccurred())322					fmt.Fprintf(GinkgoWriter, "origns addr:\n%s", out)323					return tcpdump.Tcpdump(ctx, GinkgoWriter, "origns", "any")324				})325				Expect(err).NotTo(HaveOccurred())326				res, err = cniv1.NewResultFromResult(resI)327				Expect(err).NotTo(HaveOccurred())328				// Plugin output should _not_ include egress v4 address329				Expect(res.IPs).To(HaveLen(1))330				Expect(res.IPs[0].Address.IP).To(Equal(contIP))331				err = targetNs.Do(func(ns.NetNS) error {332					defer GinkgoRecover()333					out, err := exec.Command("ip", "route", "show").CombinedOutput()334					Expect(err).NotTo(HaveOccurred())335					fmt.Fprintf(GinkgoWriter, "targetns routes:\n%s", out)336					out, err = exec.Command("ip", "addr").CombinedOutput()337					Expect(err).NotTo(HaveOccurred())338					fmt.Fprintf(GinkgoWriter, "targetns addrs:\n%s", out)339					link, err := netlink.LinkByName(IfNameNAT)340					Expect(err).NotTo(HaveOccurred())341					Expect(link.Attrs().MTU).To(Equal(Mtu))342					addrs, err := netlink.AddrList(link, netlink.FAMILY_V4)343					Expect(err).NotTo(HaveOccurred())344					Expect(addrs).To(ContainElement(345						WithTransform(func(a netlink.Addr) *net.IPNet { return a.IPNet },346							Equal(&net.IPNet{347								IP:   contIP4.To4(),348								Mask: net.CIDRMask(24, 32),349							}))))350					// v6 should continue to work351					if err := testutils.Ping(contIP.String(), hostIP.String(), 30); err != nil {352						return fmt.Errorf("ping %s -> %s failed: %s", contIP, hostIP, err)353					}354					// v4 to host should work355					if err := testutils.Ping(contIP4.String(), hostIP4.String(), 30); err != nil {356						return fmt.Errorf("ping %s -> %s failed: %s", contIP4, hostIP4, err)357					}358					// v4 to "Internet" should work359					// TODO: verify SNAT IP (via echo server)360					if err := testutils.Ping(contIP4.String(), gatewayIP.String(), 30); err != nil {361						return fmt.Errorf("ping %s -> %s failed: %s", contIP4, gatewayIP, err)362					}363					return nil364				})365				Expect(err).NotTo(HaveOccurred())366				By("running CHECK")367				// NB: CHECK is only defined for cniVersion 0.4.0+368				checkConf := fmt.Sprintf(`{369  "cniVersion": "0.4.0",370  "name": "mynet",371  "type": "egress-v4",372  "prevResult": %s,373  "ifname": "mynat0",374  "mtu": 1600,375  "snatIP": "198.51.100.10",376  "ipam": {377    "type": "test-plugin"378  }379}`,380					string(prevResultRaw))381				args.StdinData = []byte(checkConf)382				err = originalNs.Do(func(ns.NetNS) error {383					defer GinkgoRecover()384					return testutils.CmdCheckWithArgs(args, func() error { return cmdCheck(args) })385				})386				Expect(err).NotTo(HaveOccurred())387				By("running DEL")388				args.StdinData = []byte(conf)389				err = originalNs.Do(func(ns.NetNS) error {390					defer GinkgoRecover()391					return testutils.CmdDelWithArgs(args, func() error {392						return cmdDel(args)393					})394				})395				Expect(err).NotTo(HaveOccurred())396				err = originalNs.Do(func(ns.NetNS) error {397					defer GinkgoRecover()398					ipt, err := iptables.NewWithProtocol(iptables.ProtocolIPv4)399					Expect(err).NotTo(HaveOccurred())400					rules, err := ipt.List("nat", "POSTROUTING")401					Expect(err).NotTo(HaveOccurred())402					// Verify SNAT rule has gone403					Expect(rules).To(ConsistOf([]string{"-P POSTROUTING ACCEPT"}))404					return nil405				})406				Expect(err).NotTo(HaveOccurred())407			})408		})409	})410})...

...23		}24		return conn25	}26	BeforeEach(func() {27		defer GinkgoRecover()28		conn = factory()29	})30	It("should publish a message to a subscriber", func() {31		expectedMessage := "test message"32		sub := Subscribe(factory, "test")33		defer sub.Close()34		go func() {35			defer GinkgoRecover()36			err := Publish(conn, "test", expectedMessage)37			Ω(err).Should(BeNil())38		}()39		msg := <-sub.Messages40		Ω(msg).Should(Equal(expectedMessage))41	})42	It("should publish a message to all subscribers", func() {43		expectedMessage := "test message"44		sub1 := Subscribe(factory, "test")45		defer sub1.Close()46		sub2 := Subscribe(factory, "test")47		defer sub2.Close()48		go func() {49			defer GinkgoRecover()50			err := Publish(conn, "test", expectedMessage)51			Ω(err).Should(BeNil())52		}()53		msg := <-sub1.Messages54		Ω(msg).Should(Equal(expectedMessage))55		msg = <-sub2.Messages56		Ω(msg).Should(Equal(expectedMessage))57	})58	AfterEach(func() {59		conn.Close()60	})61})62var _ = Describe("Cheesegrinder", func() {63	It("should close the underlying connection on close", func() {...

...15	AfterEach(func() {16	})17	Describe("config sets dirs for different environment variables", func() {18		It("should set production", func() {19			defer GinkgoRecover()20			os.Setenv("ENVIRONMENT", "production")21			config = conf.GetConfig()22			Expect(config.Environment).To(Equal("production"))23			// Expect(config.WebUrl).To(Equal("https://opendriverslog.de/beta"))24			// TODO: FS: switch to beta!25			Expect(config.WebUrl).To(Equal("https://opendriverslog.de/alpha"))26		})27		It("should set development", func() {28			defer GinkgoRecover()29			os.Setenv("ENVIRONMENT", "development")30			config = conf.GetConfig()31			Expect(config.Environment).To(Equal("development"))32			Expect(config.WebUrl).To(Equal("http://localhost:4000/alpha"))33		})34		It("should set test", func() {35			defer GinkgoRecover()36			os.Setenv("ENVIRONMENT", "test")37			config = conf.GetConfig()38			Expect(config.Environment).To(Equal("test"))39			Expect(config.WebUrl).To(Equal("http://localhost:4000/test"))40		})41		It("should set intern", func() {42			defer GinkgoRecover()43			os.Setenv("ENVIRONMENT", "intern")44			config = conf.GetConfig()45			Expect(config.Environment).To(Equal("intern"))46			Expect(config.WebUrl).To(Equal("https://opendriverslog.de/beta-intern"))47		})48		It("should set beta-dev (dev-server)", func() {49			defer GinkgoRecover()50			os.Setenv("ENVIRONMENT", "dev-server")51			config = conf.GetConfig()52			Expect(config.Environment).To(Equal("dev-server"))53			Expect(config.WebUrl).To(Equal("https://opendriverslog.de/beta-dev"))54		})55		It("should set default: test", func() {56			defer GinkgoRecover()57			os.Setenv("ENVIRONMENT", "")58			config = conf.GetConfig()59			Expect(config.Environment).To(Equal("test"))60			Expect(config.WebUrl).To(Equal("http://localhost:4000/alpha"))61		})62	})63})...

1import (2func TestGinkgoRecover(t *testing.T) {3	RegisterFailHandler(Fail)4	RunSpecs(t, "GinkgoRecover Suite")5}6var _ = Describe("GinkgoRecover", func() {7	Context("When the code panics", func() {8		It("should recover from the panic", func() {9			defer GinkgoRecover()10			fmt.Println("Hello World")11			panic("Panic")12		})13	})14})

1import (2func TestGinkgoRecover(t *testing.T) {3	RegisterFailHandler(Fail)4	RunSpecs(t, "Ginkgo Recover")5}6var _ = Describe("Ginkgo Recover", func() {7	Context("Ginkgo Recover", func() {8		It("Ginkgo Recover", func() {9			defer GinkgoRecover()10			fmt.Println("This is Ginkgo Recover")11			panic("This is panic")12			fmt.Println("This is Ginkgo Recover")13		})14	})15})16func GinkgoRecover()17import (18func TestGinkgoRecover(t *testing.T) {19	RegisterFailHandler(Fail)20	RunSpecs(t, "Ginkgo Recover")21}22var _ = Describe("Ginkgo Recover", func() {23	Context("Ginkgo Recover", func() {24		It("Ginkgo Recover", func() {25			defer GinkgoRecover()26			fmt.Println("This is Ginkgo Recover")27			panic("This is panic")28			fmt.Println("This is Ginkgo Recover")29		})30	})31})

1import (2func TestGinkgoRecover(t *testing.T) {3	ginkgo.GinkgoRecover()4	fmt.Println("TestGinkgoRecover")5}6--- PASS: TestGinkgoRecover (0.00s)

1import (2func main() {3	defer ginkgo.GinkgoRecover()4	fmt.Println("Hello World")5}6import (7func main() {8	defer ginkgo.GinkgoRecover()9	panic("Hello World")10}11import (12func main() {13	defer ginkgo.GinkgoRecover()14	panic("Hello World")15}16import (17func main() {18	defer ginkgo.GinkgoRecover()19	panic("Hello World")20}21import (22func main() {23	defer ginkgo.GinkgoRecover()24	panic("Hello World")25}26import (27func main() {28	defer ginkgo.GinkgoRecover()29	panic("Hello World")30}31import (32func main() {33	defer ginkgo.GinkgoRecover()34	panic("Hello World")35}36import (37func main() {38	defer ginkgo.GinkgoRecover()39	panic("Hello World")40}

1var _ = Describe("GinkgoRecover", func() {2    It("should recover from panics in the test", func() {3        defer GinkgoRecover()4        panic("this should be recovered from")5    })6})7var _ = Describe("GinkgoRecover", func() {8    It("should recover from panics in the test", func() {9        defer GinkgoRecover()10        panic("this should be recovered from")11    })12})13var _ = Describe("GinkgoRecover", func() {14    It("should recover from panics in the test", func() {15        defer GinkgoRecover()16        panic("this should be recovered from")17    })18})19var _ = Describe("GinkgoRecover", func() {20    It("should recover from panics in the test", func() {21        defer GinkgoRecover()22        panic("this should be recovered from")23    })24})25var _ = Describe("GinkgoRecover", func() {26    It("should recover from panics in the test", func() {27        defer GinkgoRecover()28        panic("this should be recovered from")29    })30})31var _ = Describe("GinkgoRecover", func() {32    It("should recover from panics in the test", func() {33        defer GinkgoRecover()34        panic("this should be recovered from")35    })36})37var _ = Describe("GinkgoRecover", func() {38    It("should recover from panics in the test", func() {39        defer GinkgoRecover()40        panic("this should be recovered from")41    })42})

1func TestGinkgoRecover(t *testing.T){2ginkgo.GinkgoRecover()3}4func TestGinkgoWriter(t *testing.T) {5ginkgo.GinkgoWriter.Write([]byte("hello"))6}7func TestGinkgoWriter(t *testing.T) {8ginkgo.GinkgoWriter.Write([]byte("hello"))9}10func TestGinkgoWriter(t *testing.T) {11ginkgo.GinkgoWriter.Write([]byte("hello"))12}13func TestGinkgoWriter(t *testing.T) {14ginkgo.GinkgoWriter.Write([]byte("hello"))15}16func TestGinkgoWriter(t *testing.T) {17ginkgo.GinkgoWriter.Write([]byte("hello"))18}