- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 22 for reopened (0.21 sec)
-
internal/s3select/select.go
rsc.reader, err = rsc.segmentReader(rsc.offset) if err != nil { return 0, err } } return rsc.reader.Read(p) } // Close call to implement io.Closer. Calling Read/Seek after Close reopens the // object for reading and a subsequent Close call is required to ensure // resources are freed. func (rsc *ObjectReadSeekCloser) Close() error { rsc.closerOnce.Do(func() { if rsc.reader != nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/ByteSourceTest.java
TestByteSource okSource = new TestByteSource(bytes); assertThrows(IOException.class, () -> okSource.copyTo(new TestByteSink(option))); // ensure stream was closed IF it was opened (depends on implementation whether or not it's // opened at all if sink.newOutputStream() throws). assertTrue( "stream not closed when copying to sink with option: " + option,
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 16.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/ByteSourceTest.java
TestByteSource okSource = new TestByteSource(bytes); assertThrows(IOException.class, () -> okSource.copyTo(new TestByteSink(option))); // ensure stream was closed IF it was opened (depends on implementation whether or not it's // opened at all if sink.newOutputStream() throws). assertTrue( "stream not closed when copying to sink with option: " + option,
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 16.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/CharSourceTest.java
TestCharSource okSource = new TestCharSource(STRING); assertThrows(IOException.class, () -> okSource.copyTo(new TestCharSink(option))); // ensure reader was closed IF it was opened (depends on implementation whether or not it's // opened at all if sink.newWriter() throws). assertTrue( "stream not closed when copying to sink with option: " + option,
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 12K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/CharSourceTest.java
TestCharSource okSource = new TestCharSource(STRING); assertThrows(IOException.class, () -> okSource.copyTo(new TestCharSink(option))); // ensure reader was closed IF it was opened (depends on implementation whether or not it's // opened at all if sink.newWriter() throws). assertTrue( "stream not closed when copying to sink with option: " + option,
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 13K bytes - Viewed (0) -
README.md
[![Fuzzing Status](https://oss-fuzz-build-logs.storage.googleapis.com/badges/tensorflow.svg)](https://bugs.chromium.org/p/oss-fuzz/issues/list?sort=-opened&can=1&q=proj:tensorflow) [![Fuzzing Status](https://oss-fuzz-build-logs.storage.googleapis.com/badges/tensorflow-py.svg)](https://bugs.chromium.org/p/oss-fuzz/issues/list?sort=-opened&can=1&q=proj:tensorflow-py) [![OSSRank](https://shields.io/endpoint?url=https://ossrank.com/shield/44)](https://ossrank.com/p/44)
Plain Text - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Thu Oct 05 15:00:10 GMT 2023 - 11.9K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbCopyUtil.java
ioff += maxChunkSize; } if ( dfd == null || !dfd.isValid() ) { // don't reopen the file for every round if it's not necessary, keep the lock dfd = openCopyTargetFile(dest, src.getAttributes(), !write); }
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Tue Jul 07 10:52:42 GMT 2020 - 17.1K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFileOutputStream.java
this.writeSizeFile = sendBufferSize; return; } this.openFlags &= ~ ( SmbConstants.O_CREAT | SmbConstants.O_TRUNC ); /* in case we close and reopen */ this.writeSize = sendBufferSize - 70; this.useNTSmbs = th.hasCapability(SmbConstants.CAP_NT_SMBS); if ( !this.useNTSmbs ) { log.debug("No support for NT SMBs"); }
Java - Registered: Sun May 05 00:10:10 GMT 2024 - Last Modified: Sat Nov 13 15:14:04 GMT 2021 - 11.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt
* - Both request discover no existing connection. They both make a connection. * - The first request "wins the race". * - The second request discovers it "lost the race" and closes the connection it just opened. * - The second request uses the coalesced connection from request1. * - The coalesced connection is violently closed after servicing the first request.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 18.7K bytes - Viewed (0) -
internal/ioutil/ioutil.go
// // This code is similar in spirit to io.Copy but it is only to be // used with DIRECT I/O based file descriptor and it is expected that // input writer *os.File not a generic io.Writer. Make sure to have // the file opened for writes with syscall.O_DIRECT flag. func CopyAligned(w io.Writer, r io.Reader, alignedBuf []byte, totalSize int64, file *os.File) (int64, error) { if totalSize == 0 { return 0, nil } var written int64
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 19 11:26:59 GMT 2024 - 10.3K bytes - Viewed (0)