Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 2,195 for continueCh (0.86 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. src/net/textproto/reader.go

    func (r *Reader) ReadResponse(expectCode int) (code int, message string, err error) {
    	code, continued, message, err := r.readCodeLine(expectCode)
    	multi := continued
    	for continued {
    		line, err := r.ReadLine()
    		if err != nil {
    			return 0, "", err
    		}
    
    		var code2 int
    		var moreMessage string
    		code2, continued, moreMessage, err = parseCodeLine(line, 0)
    		if err != nil || code2 != code {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 19:57:43 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go

    	}
    
    	newItemFunc := getNewItemFunc(listObj, v)
    
    	var continueRV, withRev int64
    	var continueKey string
    	if opts.Recursive && len(opts.Predicate.Continue) > 0 {
    		continueKey, continueRV, err = storage.DecodeContinue(opts.Predicate.Continue, keyPrefix)
    		if err != nil {
    			return apierrors.NewBadRequest(fmt.Sprintf("invalid continue token: %v", err))
    		}
    		preparedKey = continueKey
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 11:56:42 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go

    			continueRV:  100,
    			rv:          "0",
    			expectedRev: 100,
    		},
    		{
    			name:        "use continueRV with empty rv",
    			continueKey: "continue",
    			continueRV:  100,
    			rv:          "",
    			expectedRev: 100,
    		},
    		{
    			name:        "continueRV = 0",
    			continueKey: "continue",
    			continueRV:  0,
    			rv:          "",
    			expectedRev: 0,
    		},
    		{
    			name:        "continueRV < 0",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 12:45:33 UTC 2024
    - 26.5K bytes
    - Viewed (0)
  5. src/go/types/stmt.go

    		}
    		switch s.Tok {
    		case token.BREAK:
    			if ctxt&breakOk == 0 {
    				check.error(s, MisplacedBreak, "break not in for, switch, or select statement")
    			}
    		case token.CONTINUE:
    			if ctxt&continueOk == 0 {
    				check.error(s, MisplacedContinue, "continue not in for statement")
    			}
    		case token.FALLTHROUGH:
    			if ctxt&fallthroughOk == 0 {
    				var msg string
    				switch {
    				case ctxt&finalSwitchCase != 0:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 30 19:19:55 UTC 2024
    - 30.6K bytes
    - Viewed (0)
  6. src/cmd/vendor/rsc.io/markdown/parse.go

    	t := *s
    	for n := 0; n < max; n++ {
    		if t.spaces > 0 {
    			t.spaces--
    			continue
    		}
    		if t.i >= len(t.text) && eolOK {
    			continue
    		}
    		if t.i < len(t.text) {
    			switch t.text[t.i] {
    			case '\t':
    				t.spaces = 4 - (t.i-t.tab)&3 - 1
    				t.i++
    				t.tab = t.i
    				continue
    			case ' ':
    				t.i++
    				continue
    			}
    		}
    		if n >= min {
    			break
    		}
    		return false
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 24 13:01:26 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  7. api/openapi-spec/v3/apis__resource.k8s.io__v1alpha2_openapi.json

            "parameters": [
              {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 12:18:45 UTC 2024
    - 656.6K bytes
    - Viewed (0)
  8. internal/kms/kms.go

    		Enclave:    c.enclave,
    		Prefix:     req.Prefix,
    		ContinueAt: req.ContinueAt,
    		Limit:      req.Limit,
    	})
    	if err != nil {
    		return nil, "", errListingKeysFailed(err)
    	}
    
    	names := make([]string, 0, len(resp.Items))
    	for _, item := range resp.Items {
    		names = append(names, item.Name)
    	}
    	return names, resp.ContinueAt, nil
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue May 07 23:55:37 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  9. staging/src/k8s.io/cli-runtime/artifacts/openapi/swagger.json

            },
            {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Feb 20 15:45:02 UTC 2024
    - 4.5M bytes
    - Viewed (0)
  10. api/openapi-spec/v3/apis__rbac.authorization.k8s.io__v1_openapi.json

            "parameters": [
              {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 04:18:56 UTC 2024
    - 352.2K bytes
    - Viewed (0)
Back to top