Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 115 for continueCh (0.18 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. 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)
  4. 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)
  5. 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)
  6. staging/src/k8s.io/apimachinery/pkg/api/resource/quantity_test.go

    				}
    				continue
    			}
    			i, ok := item.expect.AsInt64()
    			if !ok {
    				continue
    			}
    			j, ok := got.AsInt64()
    			if !ok {
    				if got.d.Dec == nil && got.i.scale >= 0 {
    					t.Errorf("%v: is an int64Amount, but can't return AsInt64: %v", item.input, got)
    				}
    				continue
    			}
    			if i != j {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 21:48:10 UTC 2024
    - 49.4K bytes
    - Viewed (0)
  7. 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)
  8. cmd/batch-handlers.go

    							batchLogIf(ctx, err)
    						}
    						continue
    					}
    				}
    			}
    			if skip(oi) {
    				continue
    			}
    			if obj.Key != prevObj {
    				prevObj = obj.Key
    				// skip replication of delete marker and all versions under the same object name if one of source or target is s3.
    				skipReplicate = obj.IsDeleteMarker && s3Type
    			}
    			if skipReplicate {
    				continue
    			}
    
    			wk.Take()
    			go func() {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Jun 11 03:13:30 UTC 2024
    - 56K bytes
    - Viewed (0)
  9. pilot/pkg/config/kube/gateway/conversion.go

    			for _, gw := range gateways[gk] {
    				if gw == pr {
    					continue // do not ban ourself
    				}
    				if gw.Port != pr.Port {
    					// We only care about listeners on the same port
    					continue
    				}
    				if gw.Protocol != pr.Protocol {
    					// We only care about listeners on the same protocol
    					continue
    				}
    				bannedHostnames.Insert(gw.OriginalHostname)
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 84.7K bytes
    - Viewed (0)
  10. src/go/build/build.go

    					inSlashStar = false
    					line = bytes.TrimSpace(line[i+len(starSlash):])
    					continue Comments
    				}
    				continue Lines
    			}
    			if bytes.HasPrefix(line, slashSlash) {
    				continue Lines
    			}
    			if bytes.HasPrefix(line, slashStar) {
    				inSlashStar = true
    				line = bytes.TrimSpace(line[len(slashStar):])
    				continue Comments
    			}
    			// Found non-comment text.
    			break Lines
    		}
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 62.3K bytes
    - Viewed (0)
Back to top