- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 791 for readArg (0.41 sec)
-
src/cmd/trace/testdata/mktests.go
} defer f.Close() // Write out the trace. r, err := raw.NewReader(&trace) if err != nil { log.Fatalf("reading trace: %v", err) } w, err := raw.NewTextWriter(f, version.Current) for { ev, err := r.ReadEvent() if err == io.EOF { break } if err != nil { log.Fatalf("reading trace: %v", err) } if err := w.WriteEvent(ev); err != nil { log.Fatalf("writing trace: %v", err) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 1.2K bytes - Viewed (0) -
src/internal/zstd/fse_test.go
tests := []struct { name string distribution []int16 tableBits int toBaseline func(*Reader, int, []fseEntry, []fseBaselineEntry) error predef []fseBaselineEntry }{ { name: "literal", distribution: literalPredefinedDistribution, tableBits: 6, toBaseline: (*Reader).makeLiteralBaselineFSE, predef: predefinedLiteralTable[:], }, { name: "offset",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 18 20:34:13 UTC 2023 - 2.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugins.go
return nil, true, nil } ret, err := f(config2) return ret, true, err } // splitStream reads the stream bytes and constructs two copies of it. func splitStream(config io.Reader) (io.Reader, io.Reader, error) { if config == nil || reflect.ValueOf(config).IsNil() { return nil, nil, nil } configBytes, err := io.ReadAll(config) if err != nil { return nil, nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 29 15:48:39 UTC 2023 - 6K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/DefaultModelXmlFactory.java
Path path = request.getPath(); URL url = request.getURL(); Reader reader = request.getReader(); InputStream inputStream = request.getInputStream(); if (path == null && url == null && reader == null && inputStream == null) { throw new IllegalArgumentException("path, url, reader or inputStream must be non null"); } try { InputSource source = null;
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Apr 12 10:50:18 UTC 2024 - 5.4K bytes - Viewed (0) -
src/encoding/csv/fuzz_test.go
result, err := r.ReadAll() if err != nil { t.Logf("reader = %#v\n", r) t.Logf("records = %v\n", records) t.Fatal(err) } // The reader turns \r\n into \n. for _, record := range records { for i, s := range record { record[i] = strings.ReplaceAll(s, "\r\n", "\n") } } // Note that the reader parses the quoted record "" as an empty string,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 05 01:26:13 UTC 2024 - 2.5K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
*/ object DisconnectAtEnd : SocketPolicy /** * Request immediate close of connection without even reading the request. Use to simulate buggy * SSL servers closing connections in response to unrecognized TLS extensions. */ object DisconnectAtStart : SocketPolicy /** * Close connection after reading the request but before writing the response. Use this to * simulate late connection pool failures. */
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 4.6K bytes - Viewed (0) -
src/test/java/org/codelibs/opensearch/extension/analysis/NumberConcatenationFilterFactory.java
final File suffixWordsFile = environment.configFile().resolve(suffixWordsPath).toFile(); try (Reader reader = IOUtils.getDecodingReader(new FileInputStream(suffixWordsFile), StandardCharsets.UTF_8)) { suffixWords = WordlistLoader.getWordSet(reader); } catch (final IOException e) {
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 2.4K bytes - Viewed (0) -
src/net/http/httptest/httptest.go
// "https". // // The Request.Proto is always HTTP/1.1. // // An empty method means "GET". // // The provided body may be nil. If the body is of type *bytes.Reader, // *strings.Reader, or *bytes.Buffer, the Request.ContentLength is // set. // // NewRequest panics on error for ease of use in testing, where a // panic is acceptable. //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 11 18:09:14 UTC 2024 - 2.6K bytes - Viewed (0) -
src/internal/coverage/cfile/testsupport.go
cdr, err = decodecounter.NewCounterDataReader(cdf, cf) if err != nil { return fmt.Errorf("reading counter data file %s: %s", cdf, err) } var data decodecounter.FuncPayload for { ok, err := cdr.NextFunc(&data) if err != nil { return fmt.Errorf("reading counter data file %s: %v", cdf, err) } if !ok { break } // NB: sanity check on pkg and func IDs?
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 09:57:47 UTC 2024 - 8.7K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/internal/impl/DefaultPluginXmlFactory.java
Path path = request.getPath(); URL url = request.getURL(); Reader reader = request.getReader(); InputStream inputStream = request.getInputStream(); if (path == null && url == null && reader == null && inputStream == null) { throw new IllegalArgumentException("path, url, reader or inputStream must be non null"); } try {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Mon Mar 25 10:50:01 UTC 2024 - 5K bytes - Viewed (0)