- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 4,030 for continueCh (0.32 sec)
-
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) -
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) -
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) -
analysis/analysis-api/testData/components/expressionInfoProvider/isUsedAsExpression/continue.kt
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Wed Oct 05 15:06:52 UTC 2022 - 145 bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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)