- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for Hancic (0.28 sec)
-
cni/pkg/nodeagent/ztunnelserver_test.go
ztun, err := newZtunnelServer(addr, pods) if err != nil { panic(err) } go ztun.Run(ctx) // now as a client connect confirm we and get snapshot resolvedAddr, err := net.ResolveUnixAddr("unixpacket", addr) if err != nil { panic(err) } ztunClient, err := net.DialUnix("unixpacket", nil, resolvedAddr) if err != nil { panic(err) } // send hello sendHello(ztunClient)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns_test.go
Name: "foo", Namespace: "bar", UID: types.UID("863b91d4-4b68-4efa-917f-4b560e3e86aa"), }} podUIDNetns, err := n.FindNetnsForPods(map[types.UID]*corev1.Pod{ pod.UID: pod, }) if err != nil { panic(err) } defer podUIDNetns.Close() if len(podUIDNetns) == 0 { t.Fatal("expected to find pod netns") } expectedUID := "863b91d4-4b68-4efa-917f-4b560e3e86aa"
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.6K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
select { case <-wg.C(): return case <-time.After(time.Second): t.Fatal("Wait group timed out!\n") } } } func (wg *WaitGroup) Add(i int32) { select { case <-wg.done: panic("use of an already closed WaitGroup") default: } atomic.AddInt32(&wg.count, i) } func (wg *WaitGroup) Done() { i := atomic.AddInt32(&wg.count, -1) if i == 0 { close(wg.done) } }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/listener.go
cidr := r.AddressPrefix pl := r.PrefixLen.GetValue() if pl != 32 && pl != 128 { cidr += fmt.Sprintf("/%d", pl) } m[cidr] = rm.OnMatch } } default: panic("unhandled") } } outputs := []string{} for k, v := range m { switch v := v.GetOnMatch().(type) { case *matcher.Matcher_OnMatch_Action: if v.Action.GetName() == name {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 18.1K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
loggingOptions.WithTeeToUDS(udsAddress, constants.UDSLogPath) } return loggingOptions } // CmdAdd is called for ADD requests func CmdAdd(args *skel.CmdArgs) (err error) { // Defer a panic recover, so that in case if panic we can still return // a proper error to the runtime. defer func() { if e := recover(); e != nil { msg := fmt.Sprintf("istio-cni panicked during cmdAdd: %v\n%v", e, string(debug.Stack()))
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 10.5K bytes - Viewed (0) -
architecture/networking/pilot.md
* Be very, very careful. * The cache has a builtin test, enabled with `UNSAFE_PILOT_ENABLE_RUNTIME_ASSERTIONS=true`, that runs in CI. This will panic if any key is written to with a different value. #### Partial Computations
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Feb 07 17:53:24 GMT 2024 - 19.1K bytes - Viewed (0) -
cni/pkg/nodeagent/fakes_test.go
func (f *fakeNs) Close() error { f.closed.Store(true) return nil } func fakeFs() fs.FS { subFs, err := fs.Sub(fakeProc, "testdata") if err != nil { panic(err) } subFs, err = fs.Sub(subFs, "cgroupns") if err != nil { panic(err) } return &fakeFsWithFakeFds{ReadDirFS: subFs.(fs.ReadDirFS)} } type fakeFsWithFakeFds struct { fs.ReadDirFS } type fakeFileFakeFds struct { fs.File
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 3.9K bytes - Viewed (0) -
operator/cmd/mesh/manifest-generate_test.go
d, err := os.MkdirTemp("", "data-snapshot-*") if err != nil { panic(fmt.Errorf("failed to make temp dir: %v", err)) } f, err := os.Open("testdata/manifest-generate/data-snapshot.tar.gz") if err != nil { panic(fmt.Errorf("failed to read data snapshot: %v", err)) } if err := extract(f, d); err != nil { panic(fmt.Errorf("failed to extract data snapshot: %v", err)) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Apr 18 18:16:49 GMT 2024 - 43.5K bytes - Viewed (0)