Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 887 for closure (0.06 sec)

  1. src/main/java/jcifs/smb1/netbios/NbtSocket.java

        public void close() throws IOException {
            if( log.level > 3 )
                log.println( "close: " + this );
            super.close();
        }
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 20:39:42 UTC 2019
    - 4.8K bytes
    - Viewed (0)
  2. internal/dsync/dsync-client_test.go

    		u:    u,
    		rest: rest.NewClient(u, tr, nil),
    	}
    }
    
    // Close closes the underlying socket file descriptor.
    func (restClient *ReconnectRESTClient) IsOnline() bool {
    	// If rest client has not connected yet there is nothing to close.
    	return restClient.rest != nil
    }
    
    func (restClient *ReconnectRESTClient) IsLocal() bool {
    	return false
    }
    
    // Close closes the underlying socket file descriptor.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jan 20 17:36:09 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt

            throw complete(e)
          }
        }
    
        @Throws(IOException::class)
        override fun close() {
          if (closed) return
          closed = true
          if (contentLength != -1L && bytesReceived != contentLength) {
            throw ProtocolException("unexpected end of stream")
          }
          try {
            super.close()
            complete(null)
          } catch (e: IOException) {
            throw complete(e)
          }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/io/AppendableWriterTest.java

        assertTrue(spy.flushed);
        assertFalse(spy.closed);
    
        writer.close();
        assertTrue(spy.flushed);
        assertTrue(spy.closed);
      }
    
      public void testCloseIsFinal() throws IOException {
        StringBuilder builder = new StringBuilder();
        Writer writer = new AppendableWriter(builder);
    
        writer.write("Hi");
        writer.close();
    
        assertThrows(IOException.class, () -> writer.write(" Greg"));
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

    @Timeout(5)
    @Tag("Slow")
    class Http2ConnectionTest {
      private val peer = MockHttp2Peer()
      private val taskFaker = TaskFaker()
    
      @AfterEach fun tearDown() {
        peer.close()
        taskFaker.close()
      }
    
      @Test fun serverPingsClientHttp2() {
        // Write the mocking script.
        peer.sendFrame().settings(Settings())
        peer.acceptFrame() // ACK
        peer.sendFrame().ping(false, 2, 3)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  6. okhttp/src/test/java/okhttp3/internal/connection/RetryConnectionTest.kt

      @RegisterExtension
      val clientTestRule = OkHttpClientTestRule()
    
      private var client = clientTestRule.newClient()
    
      @AfterEach internal fun tearDown() {
        factory.close()
      }
    
      @Test fun nonRetryableIOException() {
        val exception = IOException("Non-handshake exception")
        assertThat(retryTlsHandshake(exception)).isFalse()
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

          ignoreIoExceptions {
            stream.close(streamCode, cause)
          }
        }
    
        // Close the writer to release its resources (such as deflaters).
        ignoreIoExceptions {
          writer.close()
        }
    
        // Close the socket to break out the reader thread, which will clean up after itself.
        ignoreIoExceptions {
          socket.close()
        }
    
        // Release the threads.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  8. src/main/java/jcifs/SmbTransport.java

         */
        <T extends SmbTransport> T unwrap ( Class<T> type );
    
    
        /**
         * 
         * {@inheritDoc}
         *
         * @see java.lang.AutoCloseable#close()
         */
        @Override
        public void close ();
    
    
        /**
         * @return the connected address
         */
        Address getRemoteAddress ();
    
    
        /**
         * @return the connected host name
         */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 1.5K bytes
    - Viewed (0)
  9. internal/ioutil/append-file_nix.go

    	if osync {
    		flags |= os.O_SYNC
    	}
    	appendFile, err := os.OpenFile(dst, flags, 0o666)
    	if err != nil {
    		return err
    	}
    	defer appendFile.Close()
    
    	srcFile, err := os.Open(src)
    	if err != nil {
    		return err
    	}
    	defer srcFile.Close()
    	_, err = io.Copy(appendFile, srcFile)
    	return err
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 1.3K bytes
    - Viewed (0)
  10. okhttp/src/main/kotlin/okhttp3/WebSocket.kt

       * message.
       *
       * This method returns true if the message was enqueued. Messages that would overflow the outgoing
       * message buffer will be rejected and trigger a [graceful shutdown][close] of this web socket.
       * This method returns false in that case, and in any other case where this web socket is closing,
       * closed, or canceled.
       *
       * This method returns immediately.
       */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.3K bytes
    - Viewed (0)
Back to top