- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,081 for readArg (0.1 sec)
-
src/io/io.go
// ErrUnexpectedEOF means that EOF was encountered in the // middle of reading a fixed-size block or data structure. var ErrUnexpectedEOF = errors.New("unexpected EOF") // ErrNoProgress is returned by some clients of a [Reader] when // many calls to Read have failed to return any data or error, // usually the sign of a broken [Reader] implementation. var ErrNoProgress = errors.New("multiple Read calls return no data or error")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:34:10 UTC 2024 - 21.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/ElevateWordService.java
} public void importCsv(final Reader reader) { final PermissionHelper permissionHelper = ComponentUtil.getPermissionHelper(); final CsvConfig cfg = new CsvConfig(',', '"', '"'); cfg.setEscapeDisabled(false); cfg.setQuoteDisabled(false); @SuppressWarnings("resource") final CsvReader csvReader = new CsvReader(reader, cfg); try { List<String> list;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 15.5K bytes - Viewed (0) -
src/runtime/rwmutex_test.go
func HammerRWMutex(gomaxprocs, numReaders, num_iterations int) { GOMAXPROCS(gomaxprocs) // Number of active readers + 10000 * number of active writers. var activity int32 var rwm RWMutex rwm.Init() cdone := make(chan bool) go writer(&rwm, num_iterations, &activity, cdone) var i int for i = 0; i < numReaders/2; i++ { go reader(&rwm, num_iterations, &activity, cdone) } go writer(&rwm, num_iterations, &activity, cdone)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Dec 15 22:00:45 UTC 2023 - 4.2K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sync/semaphore/semaphore.go
// Consider a semaphore used as a read-write lock, with N tokens, N // readers, and one writer. Each reader can Acquire(1) to obtain a read // lock. The writer can Acquire(N) to obtain a write lock, excluding all // of the readers. If we allow the readers to jump ahead in the queue, // the writer will starve — there is always one token available for every // reader. break } s.cur += w.n s.waiters.Remove(next)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 03 02:38:00 UTC 2024 - 4.3K bytes - Viewed (0) -
pkg/kubelet/server/server_test.go
defer resp.Body.Close() if resp.StatusCode != http.StatusOK { t.Errorf("expected status code %d, got %d", http.StatusOK, resp.StatusCode) } body, readErr := io.ReadAll(resp.Body) if readErr != nil { // copying the response body did not work t.Fatalf("Cannot copy resp: %#v", readErr) } result := string(body) if !strings.Contains(result, "ok") { t.Errorf("expected body contains ok, got %s", result) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.5K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/text/unicode/norm/readwriter.go
r.lastBoundary = lastBoundary(&r.rb.f, r.outbuf) if r.lastBoundary == -1 { r.lastBoundary = 0 } } } } // Reader returns a new reader that implements Read // by reading data from r and returning f(data). func (f Form) Reader(r io.Reader) io.Reader { const chunk = 4000 buf := make([]byte, chunk) rr := &normReader{rb: reorderBuffer{}, r: r, inbuf: buf} rr.rb.init(f, buf) return rr
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 24 13:01:26 UTC 2024 - 2.9K bytes - Viewed (0) -
platforms/native/platform-native/src/main/java/org/gradle/nativeplatform/toolchain/internal/gcc/metadata/GccMetadataProvider.java
private String determineVendor(String error, VersionNumber versionNumber, File gccBinary) { BufferedReader reader = new BufferedReader(new StringReader(error)); String majorMinorOnly = versionNumber.getMajor() + "." + versionNumber.getMinor(); String line; try { while ((line = reader.readLine()) != null) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jan 15 06:39:06 UTC 2024 - 13K bytes - Viewed (0) -
src/net/http/internal/chunked_test.go
} } func TestChunkEndReadError(t *testing.T) { readErr := fmt.Errorf("chunk end read error") r := NewChunkedReader(io.MultiReader(strings.NewReader("4\r\nabcd"), iotest.ErrReader(readErr))) if _, err := io.ReadAll(r); err != readErr { t.Errorf("expected %v, got %v", readErr, err) } } func TestChunkReaderTooMuchOverhead(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jan 04 20:45:19 UTC 2024 - 8K bytes - Viewed (0) -
src/internal/trace/batch.go
gen, err := binary.ReadUvarint(r) if err != nil { return batch{}, gen, fmt.Errorf("error reading batch gen: %w", err) } m, err := binary.ReadUvarint(r) if err != nil { return batch{}, gen, fmt.Errorf("error reading batch M ID: %w", err) } ts, err := binary.ReadUvarint(r) if err != nil { return batch{}, gen, fmt.Errorf("error reading batch timestamp: %w", err) } // Read in the size of the batch to follow.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.9K bytes - Viewed (0) -
platforms/software/resources/src/main/java/org/gradle/internal/resource/TextResource.java
*/ boolean getHasEmptyContent() throws ResourceException; /** * Returns an *unbuffered* reader over the content of this resource. * * <p>Note that this method, or reading from the provided reader, may be expensive when {@link #isContentCached()} returns false, depending on the implementation. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 4.5K bytes - Viewed (0)