- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 316 for Breiding (0.17 sec)
-
cmd/xl-storage.go
// for io.EOF. // // If an EOF happens after reading some but not all the bytes, // ReadFile returns ErrUnexpectedEOF. // // If the BitrotVerifier is not nil or not verified ReadFile // tries to verify whether the disk has bitrot. // // Additionally ReadFile also starts reading from an offset. ReadFile // semantics are same as io.ReadFull.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureInnocuousThreadTest.java
SettableFuture<?> unused = SettableFuture.create(); // Hack to load AbstractFuture et. al. in a new classloader so that it tries to re-read the // cancellation-cause system property. This allows us to test what happens if reading the // property is forbidden and then continue running tests normally in one jvm without resorting // to even crazier hacks to reset static final boolean fields.
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Dec 16 19:54:45 GMT 2020 - 5.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/CountingInputStreamTest.java
assertEquals(20, counter.skip(30)); assertEquals(20, counter.getCount()); assertEquals(0, counter.skip(20)); assertEquals(20, counter.getCount()); // Test reading a single byte while we're in the right state assertEquals(-1, counter.read()); assertEquals(20, counter.getCount()); } public void testReadArrayEOF() throws IOException {
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 3.5K bytes - Viewed (0) -
src/main/java/jcifs/netbios/Lmhosts.java
long lm; if ( ( lm = f.lastModified() ) > this.lastModified ) { if ( log.isDebugEnabled() ) { log.debug("Reading " + tc.getConfig().getLmHostsFileName()); } this.lastModified = lm; this.table.clear(); try ( FileReader r = new FileReader(f) ) {
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 6.1K bytes - Viewed (0) -
tensorflow/c/eager/c_api_experimental_reader.h
// test(); // int64_t value = TFE_MonitoringReadCounter1(reader, "label-value"); // Opaque handle to a reader. typedef struct TFE_MonitoringCounterReader TFE_MonitoringCounterReader; // Returns a handle to be used for reading values from streamz counter. The // counter can have been created with any number of labels. TF_CAPI_EXPORT extern TFE_MonitoringCounterReader* TFE_MonitoringNewCounterReader(const char* name);
C - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Apr 20 03:14:47 GMT 2023 - 2.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/CountingInputStreamTest.java
assertEquals(20, counter.skip(30)); assertEquals(20, counter.getCount()); assertEquals(0, counter.skip(20)); assertEquals(20, counter.getCount()); // Test reading a single byte while we're in the right state assertEquals(-1, counter.read()); assertEquals(20, counter.getCount()); } public void testReadArrayEOF() throws IOException {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 3.5K bytes - Viewed (0) -
src/main/java/jcifs/netbios/SessionServicePacket.java
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sun Jul 01 13:12:10 GMT 2018 - 4.6K bytes - Viewed (0) -
okhttp-hpacktests/src/test/java/okhttp3/internal/http2/hpackjson/HpackJsonUtil.kt
import okio.ByteString import okio.ByteString.Companion.decodeHex import okio.FileSystem import okio.Path import okio.Path.Companion.toOkioPath import okio.buffer import okio.source /** * Utilities for reading HPACK tests. */ object HpackJsonUtil { @Suppress("unused") private val MOSHI = Moshi.Builder() .add( object : Any() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.3K bytes - Viewed (0) -
cmd/erasure-decode.go
readerIndex := 0 var wg sync.WaitGroup // if readTrigger is true, it implies next disk.ReadAt() should be tried // if readTrigger is false, it implies previous disk.ReadAt() was successful and there is no need // to try reading the next disk. for readTrigger := range readTriggerCh { newBufLK.RLock() canDecode := p.canDecode(newBuf) newBufLK.RUnlock() if canDecode { break } if readerIndex == len(p.readers) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 9.4K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/DefaultDependencyResolverResult.java
* @param test the test output directory, or {@code null} if none * @param cache cache of module information about each dependency * @throws IOException if an error occurred while reading module information * * TODO: this is currently not called */ void addOutputDirectory(Path main, Path test, PathModularizationCache cache) throws IOException { if (outputModules != null) {
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Mon Mar 25 10:50:01 GMT 2024 - 14.2K bytes - Viewed (0)