- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 3,889 for close1 (0.1 sec)
-
platforms/core-configuration/model-core/src/main/java/org/gradle/model/internal/core/DefaultModelViewState.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Sep 28 09:51:04 UTC 2023 - 2.7K bytes - Viewed (0) -
guava/src/com/google/common/io/CharSink.java
checkNotNull(charSequence); Closer closer = Closer.create(); try { Writer out = closer.register(openStream()); out.append(charSequence); out.flush(); // https://code.google.com/p/guava-libraries/issues/detail?id=1330 } catch (Throwable e) { throw closer.rethrow(e); } finally { closer.close(); } } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 17 14:35:11 UTC 2023 - 6.9K bytes - Viewed (0) -
src/internal/poll/fd_mutex.go
return true } } } // increfAndClose sets the state of mu to closed. // It returns false if the file was already closed. func (mu *fdMutex) increfAndClose() bool { for { old := atomic.LoadUint64(&mu.state) if old&mutexClosed != 0 { return false } // Mark as closed and acquire a reference. new := (old | mutexClosed) + mutexRef if new&mutexRefMask == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 20 16:55:30 UTC 2018 - 6.4K bytes - Viewed (0) -
guava/src/com/google/common/io/ByteSource.java
} Closer closer = Closer.create(); try { InputStream in = closer.register(openStream()); return countBySkipping(in); } catch (IOException e) { // skip may not be supported... at any rate, try reading } finally { closer.close(); } closer = Closer.create(); try { InputStream in = closer.register(openStream());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 17 14:35:11 UTC 2023 - 26.2K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/IoActions.java
return result; } /** * Closes the given resource rethrowing any {@link IOException} as a {@link UncheckedIOException}. * * @param resource The resource to be closed */ public static void uncheckedClose(@Nullable Closeable resource) { try { if (resource != null) { resource.close(); } } catch (IOException e) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 5.3K bytes - Viewed (0) -
internal/s3select/simdj/reader.go
if !ok { dstRec = &Record{} } dstRec.object = v return dstRec, nil } // Close - closes underlying reader. func (r *Reader) Close() error { // Close the input. // Potentially racy if the stream decoder is still reading. if r.readCloser != nil { r.readCloser.Close() } if r.exitReader != nil { close(r.exitReader) r.readerWg.Wait() r.exitReader = nil r.input = nil } return nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 30 17:02:22 UTC 2023 - 4.9K bytes - Viewed (0) -
src/net/http/httputil/persist.go
cc.r = nil return } // Close calls [ClientConn.Hijack] and then also closes the underlying connection. func (cc *ClientConn) Close() error { c, _ := cc.Hijack() if c != nil { return c.Close() } return nil } // Write writes a request. An [ErrPersistEOF] error is returned if the connection // has been closed in an HTTP keep-alive sense. If req.Close equals true, the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 11.1K bytes - Viewed (0) -
android/guava/src/com/google/common/io/ByteSource.java
} Closer closer = Closer.create(); try { InputStream in = closer.register(openStream()); return countBySkipping(in); } catch (IOException e) { // skip may not be supported... at any rate, try reading } finally { closer.close(); } closer = Closer.create(); try { InputStream in = closer.register(openStream());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 17 14:35:11 UTC 2023 - 26.2K bytes - Viewed (0) -
platforms/core-runtime/io/src/main/java/org/gradle/internal/io/LineBufferingOutputStream.java
} /** * Closes this output stream and releases any system resources associated with this stream. The general contract of * <code>close</code> is that it closes the output stream. A closed stream cannot perform output operations and * cannot be reopened. */ @Override public void close() throws IOException { hasBeenClosed = true; flush();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:51:14 UTC 2024 - 3.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
new ClosingCallable<TestCloseable>() { @Override public TestCloseable call(DeferredCloser closer) throws Exception { closer.eventuallyClose(closeable1, closingExecutor); closer.eventuallyClose(closeable2, closingExecutor); return closeable3; } }, executor)
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 75.3K bytes - Viewed (0)