- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 2,942 for continueCh (0.69 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) -
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) -
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) -
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) -
src/cmd/vendor/rsc.io/markdown/parse.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 13.8K bytes - Viewed (0) -
src/path/match.go
if ok { // if we're the last chunk, make sure we exhausted the name if len(pattern) == 0 && len(t) > 0 { continue } name = t continue Pattern } if err != nil { return false, err } } } // Before returning false with no error, // check that the remainder of the pattern is syntactically valid. for len(pattern) > 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 23 17:33:57 UTC 2023 - 5.3K bytes - Viewed (0) -
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) -
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)