Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 737 for chosen (0.11 sec)

  1. mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt

     * and [ShutdownOutputAtEnd] that close a socket after a response, and where there are
     * follow-up requests. The client is unblocked and free to continue as soon as it has received the
     * entire response body. If and when the client makes a subsequent request using a pooled socket the
     * server may not have had time to close the socket. The socket will be closed at an indeterminate
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  2. src/main/java/jcifs/context/AbstractCIFSContext.java

            return false;
        }
    
    
        /**
         * {@inheritDoc}
         * 
         *
         * @see jcifs.CIFSContext#close()
         */
        @Override
        public boolean close () throws CIFSException {
            if ( !this.closed ) {
                Runtime.getRuntime().removeShutdownHook(this);
            }
            return false;
        }
    
    
        /**
         * {@inheritDoc}
         *
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Tue Jul 07 10:50:16 UTC 2020
    - 3.7K bytes
    - Viewed (0)
  3. src/main/java/jcifs/internal/smb1/com/SmbComWriteAndX.java

            this.off = off;
            this.dataLength = len;
            this.digest = null; /*
                                 * otherwise recycled commands
                                 * like writeandx will choke if session
                                 * closes in between
                                 */
        }
    
    
        /**
         * @param writeMode
         *            the writeMode to set
         */
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 5.1K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt

        this.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).
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt

        while (true) {
          if (closed) throw IOException("closed")
    
          if (frameLength > 0L) {
            source.readFully(messageFrameBuffer, frameLength)
    
            if (!isClient) {
              messageFrameBuffer.readAndWriteUnsafe(maskCursor!!)
              maskCursor.seek(messageFrameBuffer.size - frameLength)
              toggleMask(maskCursor, maskKey!!)
              maskCursor.close()
            }
          }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 9.8K bytes
    - Viewed (0)
  6. guava/src/com/google/common/collect/RangeSet.java

     * Range#isConnected(Range) disconnected} ranges of type {@code C}.
     *
     * <p>Implementations that choose to support the {@link #add(Range)} operation are required to
     * ignore empty ranges and coalesce connected ranges. For example:
     *
     * <pre>{@code
     * RangeSet<Integer> rangeSet = TreeRangeSet.create();
     * rangeSet.add(Range.closed(1, 10)); // {[1, 10]}
     * rangeSet.add(Range.closedOpen(11, 15)); // disconnected range; {[1, 10], [11, 15)}
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 22 21:19:52 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt

        val relay = edit(file, upstream, metadata, 1024)
        val source1 = relay.newSource()
        val source2 = relay.newSource()
        source1!!.close()
        source1.close() // Unnecessary. Shouldn't decrement the reference count.
        assertThat(relay.isClosed).isFalse()
        source2!!.close()
        assertThat(relay.isClosed).isTrue()
        assertFile(Relay.PREFIX_DIRTY, -1L, -1, null, null)
      }
    
      @Test
      fun racingReaders() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  8. docs/fr/docs/help-fastapi.md

        * Lire d'autres idées, articles, et sur les outils que j'ai créés.
        * Suivez-moi pour lire quand je publie quelque chose de nouveau.
    
    ## Tweeter sur **FastAPI**
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Mon Jul 29 23:35:07 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  9. internal/event/target/postgresql.go

    	}
    
    	// Delete the event from store.
    	return target.store.Del(key)
    }
    
    // Close - closes underneath connections to PostgreSQL database.
    func (target *PostgreSQLTarget) Close() error {
    	close(target.quitCh)
    	if target.updateStmt != nil {
    		// FIXME: log returned error. ignore time being.
    		_ = target.updateStmt.Close()
    	}
    
    	if target.deleteStmt != nil {
    		// FIXME: log returned error. ignore time being.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  10. cmd/bitrot_test.go

    	}
    	_, err = writer.Write([]byte("aaaaaaaaaa"))
    	if err != nil {
    		t.Fatal(err)
    	}
    	_, err = writer.Write([]byte("aaaaa"))
    	if err != nil {
    		t.Fatal(err)
    	}
    	if bw, ok := writer.(io.Closer); ok {
    		bw.Close()
    	}
    
    	reader := newBitrotReader(disk, nil, volume, filePath, 35, bitrotAlgo, bitrotWriterSum(writer), 10)
    	b := make([]byte, 10)
    	if _, err = reader.ReadAt(b, 0); err != nil {
    		t.Fatal(err)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 2.1K bytes
    - Viewed (0)
Back to top