Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 25 for acknowledged (0.13 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/flowcontrol/WindowCounter.kt

        private set
    
      /** The total number of bytes acknowledged by outgoing `WINDOW_UPDATE` frames. */
      var acknowledged: Long = 0L
        private set
    
      val unacknowledged: Long
        @Synchronized get() = total - acknowledged
    
      @Synchronized
      fun update(
        total: Long = 0,
        acknowledged: Long = 0,
      ) {
        check(total >= 0)
        check(acknowledged >= 0)
    
        this.total += total
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 1.3K bytes
    - Viewed (0)
  2. src/main/java/jcifs/internal/smb2/lock/Smb2LeaseBreakAcknowledgment.java

        private int leaseState;
    
        /**
         * Create a lease break acknowledgment
         *
         * @param config configuration
         * @param leaseKey lease key
         * @param leaseState acknowledged lease state
         */
        public Smb2LeaseBreakAcknowledgment(Configuration config, Smb2LeaseKey leaseKey, int leaseState) {
            super(config, SMB2_OPLOCK_BREAK);
            this.leaseKey = leaseKey;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 23 02:21:31 UTC 2025
    - 4.2K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

         * implementations (nghttp2) forbid peers from taking advantage of settings before they have
         * acknowledged! In particular, we shouldn't send frames that assume a new `initialWindowSize`
         * until we send the frame that acknowledges this new size.
         *
         * Since we can't ACK settings on the current reader thread (the reader thread can't write) we
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 31.8K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt

      headers: Headers?,
    ) : Lockable,
      Socket {
      // Internal state is guarded by `this`. No long-running or potentially blocking operations are
      // performed while the lock is held.
    
      /** The bytes consumed and acknowledged by the stream. */
      val readBytes: WindowCounter = WindowCounter(id)
    
      /** The total number of bytes produced by the application. */
      var writeBytesTotal = 0L
        internal set
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Jul 07 18:57:05 UTC 2025
    - 22.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/dict/DictionaryManager.java

                        .execute()) {
                    final Map<String, Object> contentMap = response.getContent(OpenSearchCurl.jsonParser());
                    if (!Constants.TRUE.equalsIgnoreCase(contentMap.get("acknowledged").toString())) {
                        throw new DictionaryException("Failed to update " + dictFile.getPath());
                    }
                } catch (final IOException e) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 7.7K bytes
    - Viewed (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

        assertThat(frame2.type).isEqualTo(Http2.TYPE_RST_STREAM)
        val frame3 = peer.takeFrame()
        assertThat(frame3.type).isEqualTo(Http2.TYPE_RST_STREAM)
        assertThat(connection.readBytes.acknowledged).isEqualTo(0L)
        assertThat(connection.readBytes.total).isEqualTo(2048L)
      }
    
      @Test fun receiveGoAwayHttp2() {
        // Write the mocking script.
        peer.sendFrame().settings(Settings())
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 75.5K bytes
    - Viewed (0)
  7. src/cmd/api/main_test.go

    			feature := take(&required)
    			if exceptionSet[feature] {
    				// An "unfortunate" case: the feature was once
    				// included in the API (e.g. go1.txt), but was
    				// subsequently removed. These are already
    				// acknowledged by being in the file
    				// "api/except.txt". No need to print them out
    				// here.
    			} else if portRemoved(feature) {
    				// okay.
    			} else if featureSet[featureWithoutContext(feature)] {
    				// okay.
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Thu Feb 20 03:25:33 UTC 2025
    - 31.4K bytes
    - Viewed (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

        assertThat(TimeUnit.NANOSECONDS.toMillis(elapsedUntilFailure).toDouble())
          .isCloseTo(1000.0, 250.0)
    
        // Confirm a single ping was sent but not acknowledged.
        val logs = testLogHandler.takeAll()
        assertThat(countFrames(logs, "FINE: >> 0x00000000     8 PING          "))
          .isEqualTo(1)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 73.4K bytes
    - Viewed (0)
  9. src/main/java/jcifs/internal/smb2/lock/Smb2LockResponse.java

    import jcifs.Configuration;
    import jcifs.internal.SMBProtocolDecodingException;
    import jcifs.internal.smb2.ServerMessageBlock2Response;
    import jcifs.internal.util.SMBUtil;
    
    /**
     * SMB2 Lock response message. This response acknowledges the successful
     * acquisition or release of byte-range locks.
     *
     * @author mbechler
     *
     */
    public class Smb2LockResponse extends ServerMessageBlock2Response {
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  10. .github/pull_request_template.md

    please ask on the developers list.
    
    To make clear that you license your contribution under
    the [Apache License Version 2.0, January 2004](http://www.apache.org/licenses/LICENSE-2.0)
    you have to acknowledge this by using the following check-box.
    
    - [ ] I hereby declare this contribution to be licenced under the [Apache License Version 2.0, January 2004](http://www.apache.org/licenses/LICENSE-2.0)
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:30:05 UTC 2025
    - 1.5K bytes
    - Viewed (0)
Back to top