Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for getTid (0.15 sec)

  1. cni/pkg/nodeagent/net.go

    	if err := s.syncHostIPSets(ambientPods); err != nil {
    		log.Warnf("failed to sync host IPset: %v", err)
    		consErr = append(consErr, err)
    	}
    
    	podsByUID := slices.GroupUnique(ambientPods, (*corev1.Pod).GetUID)
    	if err := s.buildZtunnelSnapshot(podsByUID); err != nil {
    		log.Warnf("failed to construct initial ztunnel snapshot: %v", err)
    		consErr = append(consErr, err)
    	}
    
    	return errors.Join(consErr...)
    }
    
    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)
  2. cmd/test-utils_test.go

    // Temp files created in default Tmp dir
    var globalTestTmpDir = os.TempDir()
    
    // reseed - returns a new seed every time the function is called.
    func reseed() uint32 {
    	return uint32(time.Now().UnixNano() + int64(os.Getpid()))
    }
    
    // nextSuffix - provides a new unique suffix every time the function is called.
    func nextSuffix() string {
    	randmu.Lock()
    	r := randN
    	// Initial seed required, generate one.
    	if r == 0 {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  3. istioctl/pkg/writer/pilot/status.go

    				continue
    			}
    			cds, lds, eds, rds, ecds := getSyncStatus(&clientConfig)
    			cp := multixds.CpInfo(dr)
    			fullStatus = append(fullStatus, &xdsWriterStatus{
    				proxyID:               clientConfig.GetNode().GetId(),
    				clusterID:             meta.ClusterID.String(),
    				istiodID:              cp.ID,
    				istiodVersion:         meta.IstioVersion,
    				clusterStatus:         cds,
    				listenerStatus:        lds,
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Mar 15 04:16:55 GMT 2024
    - 6.1K bytes
    - Viewed (0)
  4. istioctl/pkg/validate/validate.go

    		_ = un.EachListItem(func(item runtime.Object) error {
    			castItem := item.(*unstructured.Unstructured)
    			if castItem.GetKind() == name.ServiceStr {
    				err := v.validateServicePortPrefix(istioNamespace, castItem)
    				if err != nil {
    					errs = multierror.Append(errs, err)
    				}
    			}
    			if castItem.GetKind() == name.DeploymentStr {
    				err := v.validateDeploymentLabel(istioNamespace, castItem, writer)
    				if err != nil {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Jan 22 17:58:52 GMT 2024
    - 15K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-v2_test.go

    			return xl.versions[i].header.ModTime > xl.versions[j].header.ModTime
    		}) {
    			t.Errorf("Contents not sorted")
    		}
    		for i := range xl.versions {
    			hdr := xl.versions[i].header
    			ver, err := xl.getIdx(i)
    			if err != nil {
    				t.Error(err)
    				continue
    			}
    			gotHdr := ver.header()
    			if hdr != gotHdr {
    				t.Errorf("Header does not match, index: %+v != meta: %+v", hdr, gotHdr)
    			}
    		}
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Mar 08 17:50:48 GMT 2024
    - 36.4K bytes
    - Viewed (0)
Back to top