- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 25 for nextFast (0.23 sec)
-
src/mime/multipart/multipart.go
// When there are no more parts, the error [io.EOF] is returned. // // Unlike [Reader.NextPart], it does not have special handling for // "Content-Transfer-Encoding: quoted-printable". func (r *Reader) NextRawPart() (*Part, error) { return r.nextPart(true, maxMIMEHeaderSize, maxMIMEHeaders()) } func (r *Reader) nextPart(rawPart bool, maxMIMEHeaderSize, maxMIMEHeaders int64) (*Part, error) { if r.currentPart != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 16:12:35 UTC 2024 - 14.1K bytes - Viewed (0) -
src/mime/multipart/writer_test.go
if len(s) == 0 { t.Fatal("String: unexpected empty result") } if s[0] == '\r' || s[0] == '\n' { t.Fatal("String: unexpected newline") } } r := NewReader(&b, w.Boundary()) part, err := r.NextPart() if err != nil { t.Fatalf("part 1: %v", err) } if g, e := part.FormName(), "myfile"; g != e { t.Errorf("part 1: want form name %q, got %q", e, g) } slurp, err := io.ReadAll(part) if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 06 17:36:47 UTC 2022 - 4.1K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/debug_test.go
return true } return false } func (h *nextHist) addVar(text string) { l := len(h.texts) h.vars[l-1] = append(h.vars[l-1], text) } func invertMapSU8(hf2i map[string]uint8) map[uint8]string { hi2f := make(map[uint8]string) for hs, i := range hf2i { hi2f[i] = hs } return hi2f } func (h *nextHist) equals(k *nextHist) bool { if len(h.f2i) != len(k.f2i) { return false }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 16:11:47 UTC 2024 - 28.6K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
taskRunner.assertThreadHoldsLock() val index = serialTaskQueue.indexOfFirst { it.isReady() } if (index == -1) return null val nextTask = serialTaskQueue.removeAt(index) currentTask = nextTask contextSwitchCount++ nextTask.start() return nextTask } private interface SerialTask { /** Returns true if this task is ready to start. */ fun isReady() = true
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 12.6K bytes - Viewed (0) -
src/internal/dag/parse.go
func (p *rulesParser) syntaxError(msg string) { panic(syntaxError(fmt.Sprintf("parsing graph: line %d: syntax error: %s near %s", p.lineno, msg, p.lastWord))) } // nextList parses and returns a comma-separated list of names. func (p *rulesParser) nextList() (list []string, token string) { for { tok := p.nextToken() switch tok { case "": if len(list) == 0 { return nil, "" } fallthrough
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 6.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
// Task must be null, since each execution on this executor can only produce one more // execution. checkState(submittingTaskQueue.nextTask == null); submittingTaskQueue.nextTask = task; // requireNonNull(delegate) is safe for reasons similar to requireNonNull(sequencer). submittingTaskQueue.nextExecutor = requireNonNull(delegate); delegate = null;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 22.1K bytes - Viewed (0) -
src/mime/multipart/formdata.go
if maxMemoryBytes <= 0 { if maxMemory < 0 { maxMemoryBytes = 0 } else { maxMemoryBytes = math.MaxInt64 } } var copyBuf []byte for { p, err := r.nextPart(false, maxMemoryBytes, maxHeaders) if err == io.EOF { break } if err != nil { return nil, err } if maxParts <= 0 { return nil, ErrMessageTooLarge } maxParts--
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 16:12:35 UTC 2024 - 7.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
// Task must be null, since each execution on this executor can only produce one more // execution. checkState(submittingTaskQueue.nextTask == null); submittingTaskQueue.nextTask = task; // requireNonNull(delegate) is safe for reasons similar to requireNonNull(sequencer). submittingTaskQueue.nextExecutor = requireNonNull(delegate); delegate = null;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 22.1K bytes - Viewed (0) -
src/net/net_windows_test.go
dups := make(map[string][]string) for name, addr := range want { if _, ok := dups[addr]; !ok { dups[addr] = make([]string, 0) } dups[addr] = append(dups[addr], name) } nextWant: for name, wantAddr := range want { if haveAddr, ok := have[name]; ok { if haveAddr != wantAddr { t.Errorf("unexpected MAC address for %q - %v, want %v", name, haveAddr, wantAddr) } continue
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 16.3K bytes - Viewed (0) -
src/cmd/dist/test.go
// When finished, it emits header for nextTest, which is going to run after the // pending commands are done (and runPending returns). // A test should call runPending if it wants to make sure that it is not // running in parallel with earlier tests, or if it has some other reason // for needing the earlier tests to be done. func (t *tester) runPending(nextTest *distTest) { worklist := t.worklist t.worklist = nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 16:01:35 UTC 2024 - 50K bytes - Viewed (0)