Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 44 for Rd (0.04 sec)

  1. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go

    			// catch-all flow schema.
    			panic(fmt.Sprintf("no fallback catch-all flow schema found for request %#+v and user %#+v", rd.RequestInfo, rd.User))
    		}
    		selectedFlowSchema = catchAllFlowSchema
    		klog.Warningf("no match found for request %#+v and user %#+v; selecting catchAll=%s as fallback flow schema", rd.RequestInfo, rd.User, fcfmt.Fmt(selectedFlowSchema))
    	}
    	plName := selectedFlowSchema.Spec.PriorityLevelConfiguration.Name
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 48.8K bytes
    - Viewed (0)
  2. src/io/io_test.go

    }
    
    func BenchmarkCopyNSmall(b *testing.B) {
    	bs := bytes.Repeat([]byte{0}, 512+1)
    	rd := bytes.NewReader(bs)
    	buf := new(Buffer)
    	b.ResetTimer()
    
    	for i := 0; i < b.N; i++ {
    		CopyN(buf, rd, 512)
    		rd.Reset(bs)
    	}
    }
    
    func BenchmarkCopyNLarge(b *testing.B) {
    	bs := bytes.Repeat([]byte{0}, (32*1024)+1)
    	rd := bytes.NewReader(bs)
    	buf := new(Buffer)
    	b.ResetTimer()
    
    	for i := 0; i < b.N; i++ {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Oct 09 22:04:41 UTC 2023
    - 18.9K bytes
    - Viewed (0)
  3. cmd/server-main.go

    	}
    }
    
    func mergeServerCtxtFromConfigFile(configFile string, ctxt *serverCtxt) error {
    	rd, err := xioutil.ReadFile(configFile)
    	if err != nil {
    		return err
    	}
    
    	cfReader := bytes.NewReader(rd)
    
    	cv := config.ServerConfigVersion{}
    	if err = yaml.Unmarshal(rd, &cv); err != nil {
    		return err
    	}
    
    	switch cv.Version {
    	case "v1", "v2":
    	default:
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jun 04 15:12:57 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  4. src/syscall/syscall_linux_test.go

    		// This will return when the write side is closed.
    		n, err := syscall.Read(int(rd.Fd()), data)
    		if !(n == 0 && err == nil) {
    			t.Errorf("expected read to return 0, got %d, %s", n, err)
    		}
    
    		// Clean up rd and also ensure rd stays reachable so
    		// it doesn't get closed by GC.
    		rd.Close()
    		wg.Done()
    	}()
    	<-ready
    
    	// Loop here to give the goroutine more time to block in read.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 23K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/crawler/FessCrawlerThread.java

            if (childUrlSet != null) {
                // add an url
                try {
                    storeChildUrls(childUrlSet.stream().filter(rd -> StringUtil.isNotBlank(rd.getUrl())).collect(Collectors.toSet()),
                            urlQueue.getUrl(), urlQueue.getDepth() != null ? urlQueue.getDepth() + 1 : 1);
                } catch (final Throwable t) {
    Registered: Wed Jun 12 13:08:18 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  6. pkg/xds/server.go

    	Subscribed sets.String
    	// Unsubscribed indicates the client no longer requires these resources
    	Unsubscribed sets.String
    }
    
    var emptyResourceDelta = ResourceDelta{}
    
    func (rd ResourceDelta) IsEmpty() bool {
    	return len(rd.Subscribed) == 0 && len(rd.Unsubscribed) == 0
    }
    
    type Resources = []*discovery.Resource
    
    func ResourcesToAny(r Resources) []*anypb.Any {
    	a := make([]*anypb.Any, 0, len(r))
    	for _, rr := range r {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 13 20:55:20 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  7. pilot/pkg/networking/core/tracing.go

    		}
    	}
    
    	// Add configured resource detectors
    	if otelProvider.ResourceDetectors != nil {
    		res := []*core.TypedExtensionConfig{}
    		rd := otelProvider.ResourceDetectors
    
    		if rd.Environment != nil {
    			res = append(res, xdsfilters.EnvironmentResourceDetector)
    		}
    		if rd.Dynatrace != nil {
    			res = append(res, xdsfilters.DynatraceResourceDetector)
    		}
    		oc.ResourceDetectors = res
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 16 17:05:28 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  8. src/vendor/golang.org/x/net/nettest/conntest.go

    func testBasicIO(t *testing.T, c1, c2 net.Conn) {
    	want := make([]byte, 1<<20)
    	rand.New(rand.NewSource(0)).Read(want)
    
    	dataCh := make(chan []byte)
    	go func() {
    		rd := bytes.NewReader(want)
    		if err := chunkedCopy(c1, rd); err != nil {
    			t.Errorf("unexpected c1.Write error: %v", err)
    		}
    		if err := c1.Close(); err != nil {
    			t.Errorf("unexpected c1.Close error: %v", err)
    		}
    	}()
    
    	go func() {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  9. cmd/admin-handlers-config-kv.go

    	}
    
    	vars := mux.Vars(r)
    
    	subSys := vars["subSys"]
    	key := vars["key"]
    
    	_, envOnly := r.Form["env"]
    
    	rd, err := GetHelp(subSys, key, envOnly)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	json.NewEncoder(w).Encode(rd)
    }
    
    // SetConfigHandler - PUT /minio/admin/v3/config
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  10. src/cmd/vendor/github.com/google/pprof/profile/legacy_profile.go

    // ParseMemoryMap should be called after setting on a profile to
    // associate locations to the corresponding mapping based on their
    // address.
    func ParseProcMaps(rd io.Reader) ([]*Mapping, error) {
    	s := bufio.NewScanner(rd)
    	return parseProcMapsFromScanner(s)
    }
    
    func parseProcMapsFromScanner(s *bufio.Scanner) ([]*Mapping, error) {
    	var mapping []*Mapping
    
    	var attrs []string
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 22 18:58:12 UTC 2022
    - 32.8K bytes
    - Viewed (0)
Back to top