- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 81 for Reads (0.02 sec)
-
compat/maven-model-builder/src/main/java/org/apache/maven/model/io/ModelReader.java
/** * Name of the property used to store the project's root directory to use with * XInclude support. */ String ROOT_DIRECTORY = "rootDirectory"; /** * Reads the model from the specified file. * * @param input The file to deserialize the model from, must not be {@code null}.
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 4.4K bytes - Viewed (0) -
cmd/erasure-decode.go
readTriggerCh := make(chan bool, len(p.readers)) defer xioutil.SafeClose(readTriggerCh) // close the channel upon return for i := 0; i < p.dataBlocks; i++ { // Setup read triggers for p.dataBlocks number of reads so that it reads in parallel. readTriggerCh <- true } disksNotFound := int32(0) bitrotHeal := int32(0) // Atomic bool flag. missingPartsHeal := int32(0) // Atomic bool flag. readerIndex := 0
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 29 01:40:52 UTC 2024 - 9.5K bytes - Viewed (0) -
internal/store/store.go
} if vals := strings.Split(key.Name, "."); len(vals) == 2 { key.Extension = "." + vals[1] key.Name = strings.TrimSuffix(key.Name, key.Extension) } return } // replayItems - Reads the items from the store and replays. func replayItems[I any](store Store[I], doneCh <-chan struct{}, log logger, id string) <-chan Key { keyCh := make(chan Key) go func() { defer xioutil.SafeClose(keyCh)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 4.2K bytes - Viewed (0) -
src/bytes/buffer.go
} return data } // ReadByte reads and returns the next byte from the buffer. // If no byte is available, it returns error [io.EOF]. func (b *Buffer) ReadByte() (byte, error) { if b.empty() { // Buffer is empty, reset to recover space. b.Reset() return 0, io.EOF } c := b.buf[b.off] b.off++ b.lastRead = opRead return c, nil } // ReadRune reads and returns the next UTF-8-encoded
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Tue Oct 29 16:47:05 UTC 2024 - 15.7K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/artifact/repository/metadata/io/MetadataReader.java
* true}. If {@code false}, unknown elements will be ignored instead of causing a failure. */ String IS_STRICT = "org.apache.maven.artifact.repository.metadata.io.isStrict"; /** * Reads the metadata from the specified file. * * @param input The file to deserialize the metadata from, must not be {@code null}.
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 3.3K bytes - Viewed (0) -
compat/maven-settings-builder/src/main/java/org/apache/maven/settings/io/SettingsReader.java
* true}. If {@code false}, unknown elements will be ignored instead of causing a failure. */ String IS_STRICT = "org.apache.maven.settings.io.isStrict"; /** * Reads the settings from the specified file. * * @param input The file to deserialize the settings from, must not be {@code null}.
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 3.4K bytes - Viewed (0) -
compat/maven-toolchain-builder/src/main/java/org/apache/maven/toolchain/io/ToolchainsReader.java
* true}. If {@code false}, unknown elements will be ignored instead of causing a failure. */ String IS_STRICT = "org.apache.maven.toolchains.io.isStrict"; /** * Reads the toolchains from the specified file. * * @param input The file to deserialize the toolchains from, must not be {@code null}.
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 3.5K bytes - Viewed (0) -
guava/src/com/google/common/io/CharSource.java
/** * Opens a new {@link Stream} for reading text one line at a time from this source. This method * returns a new, independent stream each time it is called. * * <p>The returned stream is lazy and only reads from the source in the terminal operation. If an * I/O error occurs while the stream is reading from the source or when the stream is closed, an * {@link UncheckedIOException} is thrown. *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 31 14:20:11 UTC 2024 - 25.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/cache/LocalCacheTest.java
} } int undrainedIndex = reads.size() - segment.recencyQueue.size(); checkAndDrainRecencyQueue(map, segment, reads.subList(undrainedIndex, reads.size())); readOrder.addAll(reads); checkEvictionQueues(map, segment, readOrder, writeOrder); checkExpirationTimes(map); } } public void testComputeExistingEntry() throws ExecutionException {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 19:07:49 UTC 2024 - 110.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/cache/LocalCacheTest.java
} } int undrainedIndex = reads.size() - segment.recencyQueue.size(); checkAndDrainRecencyQueue(map, segment, reads.subList(undrainedIndex, reads.size())); readOrder.addAll(reads); checkEvictionQueues(map, segment, readOrder, writeOrder); checkExpirationTimes(map); } } public void testComputeExistingEntry() throws ExecutionException {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 19:07:49 UTC 2024 - 112.3K bytes - Viewed (0)