Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 101 - 110 of 1,261 for closer (0.05 seconds)

  1. src/main/java/org/codelibs/core/io/CloseableUtil.java

         * @see Closeable#close()
         */
        public static void close(final Closeable closeable) {
            if (closeable == null) {
                return;
            }
            try {
                closeable.close();
            } catch (final IOException e) {
                logger.log(format("ECL0017", e.getMessage()), e);
            }
        }
    
        /**
         * Closes a {@link Closeable} quietly, suppressing any {@link IOException}.
         *
    Created: Fri Apr 03 20:58:12 GMT 2026
    - Last Modified: Thu Jul 31 08:16:49 GMT 2025
    - 2.5K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt

        withLock {
          cancel = !source.finished && source.closed && (sink.finished || sink.closed)
          open = isOpen
        }
        if (cancel) {
          // RST this stream to prevent additional data from being sent. This is safe because the input
          // stream is closed (we won't use any further bytes) and the output stream is either finished
          // or closed (so RSTing both streams doesn't cause harm).
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Jul 07 18:57:05 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  3. .github/workflows/stale-pr.yml

                It will be closed in 14 days if no further activity occurs.
                If you don't want the stale bot to close it, then set a milestone for it.
              days-before-pr-close: 14
              close-pr-message: >
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Thu Sep 04 22:13:29 GMT 2025
    - 1.7K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt

      when {
        this.isNullOrEmpty() -> emptyList()
        this.size == 1 -> Collections.singletonList(this[0])
        else -> this.clone().asList().unmodifiable()
      }
    
    /** Closes this, ignoring any checked exceptions. */
    internal fun Socket.closeQuietly() {
      try {
        close()
      } catch (e: AssertionError) {
        throw e
      } catch (rethrown: RuntimeException) {
        if (rethrown.message == "bio == null") {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 10.3K bytes
    - Click Count (1)
  5. src/test/java/jcifs/smb/SmbPipeInputStreamTest.java

        @DisplayName("available() on SMB1 returns 0 and marks closed on disconnected statuses")
        void available_smb1_disconnectedStatuses(int status) throws Exception {
            // Verify SMB1 path: disconnected/server-closed statuses yield 0 and mark fd closed
            SmbPipeInputStream stream = newStreamWithInit(false);
    
            when(handle.ensureOpen()).thenReturn(fd);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 9.9K bytes
    - Click Count (0)
  6. src/main/java/jcifs/context/AbstractCIFSContext.java

         */
        @Override
        public void run() {
            try {
                this.closed = true;
                close();
            } catch (final CIFSException e) {
                log.warn("Failed to close context on shutdown", e);
            }
        }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 4K bytes
    - Click Count (0)
  7. src/archive/zip/writer.go

    	w.comment = comment
    	return nil
    }
    
    // Close finishes writing the zip file by writing the central directory.
    // It does not close the underlying writer.
    func (w *Writer) Close() error {
    	if w.last != nil && !w.last.closed {
    		if err := w.last.close(); err != nil {
    			return err
    		}
    		w.last = nil
    	}
    	if w.closed {
    		return errors.New("zip: writer closed twice")
    	}
    	w.closed = true
    
    	// write central directory
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Tue Jan 28 04:20:09 GMT 2025
    - 19.4K bytes
    - Click Count (0)
  8. src/test/java/jcifs/SmbPipeHandleTest.java

            /**
             * Verifies that the close method can be called without throwing an exception.
             * @throws CIFSException if an error occurs during close.
             */
            @Test
            public void testClose() throws CIFSException {
                assertDoesNotThrow(() -> smbPipeHandle.close(), "close() should not throw an exception on a mock object.");
                // Verify that the close method was called
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 7K bytes
    - Click Count (0)
  9. CHANGELOG/CHANGELOG-1.30.md

    - Adds exec-interactive-mode and exec-provide-cluster-info flags in kubectl config set-credentials command ([#122023](https://github.com/kubernetes/kubernetes/pull/122023), [@ardaguclu](https://github.com/ardaguclu)) [SIG CLI]
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Wed Jun 18 18:59:10 GMT 2025
    - 398.1K bytes
    - Click Count (0)
  10. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt

      @Throws(IOException::class)
      fun processNextFrame() {
        check(!closed) { "closed" }
    
        readHeader()
        if (isControlFrame) {
          readControlFrame()
        } else {
          readMessageFrame()
        }
      }
    
      @Throws(IOException::class, ProtocolException::class)
      private fun readHeader() {
        if (receivedCloseFrame) throw IOException("closed")
    
        // Disable the timeout to read the first byte of a new frame.
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 10K bytes
    - Click Count (0)
Back to Top