- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for dine (0.13 sec)
-
cni/pkg/nodeagent/server_test.go
} 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) } } func (wg *WaitGroup) C() <-chan struct{} { return 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) -
cni/pkg/log/uds_test.go
if want, got := len(wantLevels), len(gotLogs); want != got { t.Fatalf("Number of logs want %v, got %v logs: %v", want, got, gotLogs) } for i, l := range gotLogs { // For each line, there should be two level string, e.g. // "2021-07-09T03:26:08.984951Z debug debug log" if got, want := strings.Count(l, wantLevels[i]), 2; want != got { t.Errorf("Number of log level string want %v, got %v", want, got)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Mar 16 00:20:01 GMT 2024 - 2.5K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
// K8S may get a pod Add event without any IPs in the object, and the pod will later be updated with IPs. // // We always need the IPs, but this is fine because this AddPodToMesh can be called from the CNI plugin as well, // which always has the firsthand info of the IPs, even before K8S does - so we pass them separately here because
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
cni/pkg/repair/netns.go
// There should be 1 or 2 processes that match: the pause container should always be there, and the istio-validation *might*. // We want the pause container, as the istio-validation one may exit before we are done. // We do this by detecting the longest running process. We could look at `cmdline`, but is likely more reliable to weird platforms. for _, p := range procs { ns := getPidNamespace(p.PID)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Dec 20 22:14:13 GMT 2023 - 4.8K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
if err != nil { return probeSet, err } probeSet.Flush() return probeSet, nil } func (s *Server) Start() { log.Info("CNI ambient server starting") s.kubeClient.RunAndWait(s.ctx.Done()) log.Info("CNI ambient server kubeclient started") pods := s.handlers.GetAmbientPods() err := s.dataplane.ConstructInitialSnapshot(pods) if err != nil { log.Warnf("failed to construct initial snapshot: %v", err)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 7.2K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
"", ).Return(nil) server := &meshDataplane{ kubeClient: client.Kube(), netServer: fs, } handlers := setupHandlers(ctx, client, server, "istio-system") client.RunAndWait(ctx.Done()) go handlers.Start() // label the namespace labelsPatch := []byte(fmt.Sprintf(`{"metadata":{"labels":{"%s":"%s"}}}`, constants.DataplaneModeLabel, constants.DataplaneModeAmbient))
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
istioctl/pkg/xds/client.go
err = adscConn.Send(dr) if err != nil { return nil, err } response, err := adscConn.WaitVersion(opts.Timeout, dr.TypeUrl, "") return response, err } // DialOptions constructs gRPC dial options from command line configuration func DialOptions(opts clioptions.CentralControlPlaneOptions, ns, serviceAccount string, kubeClient kube.CLIClient, ) ([]grpc.DialOption, error) { ctx := context.TODO()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Dec 19 22:42:42 GMT 2023 - 3.7K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
// make sure the uid was taken from cache and netns closed netns := fixture.podNsMap.Take(string(pod.UID)) assert.Equal(t, nil, netns) // run gc to clean up ns: //revive:disable-next-line:call-to-gc Just a test that we are cleaning up the netns runtime.GC() assertNSClosed(t, closed) } func TestServerDeletePod(t *testing.T) { ctx, cancel := context.WithCancel(context.Background())
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
cni/test/install_cni.go
cancel() wg.Wait() }() go func() { runInstall(ctx, tempCNIConfDir, tempCNIBinDir, tempK8sSvcAcctDir, envPreconf, filepath.Join(env.IstioSrc, "cni/test/testdata/bindir"), chainedCNIPlugin, t) wg.Done() }() resultFile := tempCNIConfDir + "/" + resultFileName if chainedCNIPlugin && delayedConfFile != "" { retry.UntilSuccessOrFail(t, func() error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0)