Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 4,030 for continueCh (0.32 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. analysis/analysis-api/testData/components/expressionInfoProvider/isUsedAsExpression/continue.txt

    expression: CONTINUE
    text: continue
    Registered: Wed Jun 12 09:53:16 UTC 2024
    - Last Modified: Wed Oct 05 15:06:52 UTC 2022
    - 62 bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/continue.go

    )
    
    var (
    	ErrInvalidStartRV             = errors.New("continue key is not valid: incorrect encoded start resourceVersion (version meta.k8s.io/v1)")
    	ErrEmptyStartKey              = errors.New("continue key is not valid: encoded start key empty (version meta.k8s.io/v1)")
    	ErrGenericInvalidKey          = errors.New("continue key is not valid")
    	ErrUnrecognizedEncodedVersion = errors.New("continue key is not valid: server does not recognize this encoded version")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 31 17:30:02 UTC 2022
    - 3.5K bytes
    - Viewed (0)
  4. analysis/analysis-api/testData/components/expressionInfoProvider/isUsedAsExpression/continue.kt

    fun test(b: Boolean) {
        while (true) {
            if (b) {
                break
            } else {
                <expr>continue</expr>
            }
        }
    Registered: Wed Jun 12 09:53:16 UTC 2024
    - Last Modified: Wed Oct 05 15:06:52 UTC 2022
    - 145 bytes
    - Viewed (0)
  5. src/cmd/compile/internal/syntax/branches.go

    package syntax
    
    import "fmt"
    
    // checkBranches checks correct use of labels and branch
    // statements (break, continue, fallthrough, goto) in a function body.
    // It catches:
    //   - misplaced breaks, continues, and fallthroughs
    //   - bad labeled breaks and continues
    //   - invalid, unused, duplicate, and missing labels
    //   - gotos jumping over variable declarations and into blocks
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sun Jun 26 00:21:29 UTC 2022
    - 9.8K bytes
    - Viewed (0)
  6. 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)
  7. 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)
  8. 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)
  9. subprojects/composite-builds/src/integTest/groovy/org/gradle/integtests/composite/CompositeBuildContinueOnSingleFailureIntegrationTest.groovy

            assertTaskExecutedOnce(":buildB", ":succeeds")
            assertTaskNotExecuted(":", ":delegate")
        }
    
        @Issue("https://github.com/gradle/gradle/issues/2520")
        def "continues build when delegated task fails when run with --continue"() {
            when:
            buildA.buildFile << """
        task delegateWithFailure {
            dependsOn gradle.includedBuild('buildB').task(':fails')
        }
        task delegateWithSuccess {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jan 06 08:15:28 UTC 2023
    - 5.3K bytes
    - Viewed (0)
  10. hack/conformance/check_conformance_test_requirements.go

    	files, err := os.ReadDir(e2ePath)
    	if err != nil {
    		return fmt.Errorf("Failed to read dir %s: %w", e2ePath, err)
    	}
    	for _, file := range files {
    		if file.IsDir() {
    			continue
    		}
    		if !regGoFile.MatchString(file.Name()) {
    			continue
    		}
    		e2eFile := fmt.Sprintf("%s/%s", e2ePath, file.Name())
    		err = checkAllProviders(e2eFile)
    		if err != nil {
    			return err
    		}
    	}
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Sep 29 06:30:57 UTC 2023
    - 4.1K bytes
    - Viewed (0)
Back to top