Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 297 for continueCh (0.14 sec)

  1. src/net/http/transport.go

    	continueCh := rc.continueCh
    	for {
    		resp, err = ReadResponse(pc.br, rc.treq.Request)
    		if err != nil {
    			return
    		}
    		resCode := resp.StatusCode
    		if continueCh != nil && resCode == StatusContinue {
    			if trace != nil && trace.Got100Continue != nil {
    				trace.Got100Continue()
    			}
    			continueCh <- struct{}{}
    			continueCh = nil
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 91K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go

    		{
    			name:   "test List with pregenerated continue token",
    			prefix: "/pods/second/",
    			pred: storage.SelectionPredicate{
    				Label:    labels.Everything(),
    				Field:    fields.Everything(),
    				Limit:    1,
    				Continue: secondContinuation,
    			},
    			expectedOut: []example.Pod{*preset[2]},
    		},
    		{
    			name:   "ignores resource version 0 for List with pregenerated continue token",
    			prefix: "/pods/second/",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 91.4K bytes
    - Viewed (0)
  3. src/regexp/testdata/testregex.c

    				case 'c':
    					cflags |= REG_COMMENT;
    					continue;
    				case 'd':
    					cflags |= REG_SHELL_DOT;
    					continue;
    				case 'e':
    					eflags |= REG_NOTEOL;
    					continue;
    				case 'f':
    					cflags |= REG_MULTIPLE;
    					continue;
    				case 'g':
    					cflags |= NOTEST;
    					continue;
    				case 'h':
    					cflags |= REG_MULTIREF;
    					continue;
    				case 'i':
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Sep 08 04:08:51 UTC 2014
    - 51.3K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    		prefer := make([]bool, len(onlineDisks))
    		for index, disk := range onlineDisks {
    			if disk == OfflineDisk {
    				continue
    			}
    			if !metaArr[index].IsValid() {
    				continue
    			}
    			if !metaArr[index].Erasure.Equal(fi.Erasure) {
    				continue
    			}
    			checksumInfo := metaArr[index].Erasure.GetChecksumInfo(partNumber)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 78.6K bytes
    - Viewed (0)
  5. src/cmd/compile/internal/ssa/regalloc.go

    			for _, live := range s.live[b.ID] {
    				if live.dist >= unlikelyDistance {
    					// Don't preload anything live after the loop.
    					continue
    				}
    				vid := live.ID
    				vi := &s.values[vid]
    				if vi.regs != 0 {
    					continue
    				}
    				if vi.rematerializeable {
    					continue
    				}
    				v := s.orig[vid]
    				m := s.compatRegs(v.Type) &^ s.used
    				// Used desired register if available.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Nov 21 17:49:56 UTC 2023
    - 87.2K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool.go

    				if disk == OfflineDisk {
    					continue
    				}
    				stats, err := disk.StatInfoFile(ctx, volume, file, true)
    				if err != nil {
    					continue
    				}
    				for _, si := range stats {
    					found++
    					var r io.ReadCloser
    					if !si.Dir {
    						r, err = disk.ReadFileStream(ctx, volume, si.Name, 0, si.Size)
    						if err != nil {
    							continue
    						}
    					} else {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu May 30 11:58:12 UTC 2024
    - 82.5K bytes
    - Viewed (0)
  7. pilot/pkg/model/virtualservice_test.go

    			*r = networking.HTTPRouteDestination{}
    		},
    		func(r *networking.HTTPRedirect, c fuzz.Continue) {
    			*r = networking.HTTPRedirect{}
    		},
    		func(r *networking.HTTPDirectResponse, c fuzz.Continue) {
    			*r = networking.HTTPDirectResponse{}
    		},
    		func(r *networking.Delegate, c fuzz.Continue) {
    			*r = networking.Delegate{}
    		},
    
    		func(r *networking.HTTPRewrite, c fuzz.Continue) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 21 17:42:54 UTC 2024
    - 60.6K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/runtime/framework.go

    		pg := f.pluginsMap[e.Name]
    		if !reflect.TypeOf(pg).Implements(pluginType) {
    			continue
    		}
    
    		// We append MultiPoint plugins to the list of Score plugins. So if this plugin has already been
    		// encountered, let the individual Score weight take precedence.
    		if _, ok := f.scorePluginWeight[e.Name]; ok {
    			continue
    		}
    		// a weight of zero is not permitted, plugins can be disabled explicitly
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  9. pkg/proxy/winkernel/proxier.go

    	for _, epInfo := range proxier.endpointsMap[svcName] {
    		ep, ok := epInfo.(*endpointInfo)
    		if !ok {
    			continue
    		}
    		if isLocalTrafficDSR && !ep.IsLocal() {
    			// KEP-1669: Ignore remote endpoints when the ExternalTrafficPolicy is Local (DSR Mode)
    			continue
    		}
    		// If Readiness Probe fails and pod is not under delete, then
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
  10. src/cmd/go/internal/modget/get.go

    		q, err := newQuery(arg)
    		if err != nil {
    			base.Error(err)
    			continue
    		}
    
    		if q.version == "none" {
    			switch q.pattern {
    			case "go":
    				base.Errorf("go: cannot use go@none")
    				continue
    			case "toolchain":
    				dropToolchain = true
    				continue
    			}
    		}
    
    		// If there were no arguments, CleanPatterns returns ".". Set the raw
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 18:26:32 UTC 2024
    - 66.5K bytes
    - Viewed (0)
Back to top