Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 31 for acknowledged (1.1 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. ci/official/requirements_updater/README.md

    ```
    
    where `3.12` is the `Python` version you wish to update.
    
    Note, since it is still `pip` and `pip-compile` tools used under the hood, so
    most of the command line arguments and features supported by those tools will be
    acknowledged by the Bazel requirements updater command as well. For example, if
    you wish the updater to consider pre-release versions simply pass `--pre`
    argument to the bazel command:
    
    ```
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Sat Jun 29 00:19:18 UTC 2024
    - 3K bytes
    - Viewed (0)
  4. 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)
  5. SECURITY.md

    ## Reporting a Vulnerability
    
    All security bugs in [minio/minio](https://github,com/minio/minio) (or other minio/* repositories)
    should be reported by email to ******@****.***. Your email will be acknowledged within 48 hours,
    and you'll receive a more detailed response to your email within 72 hours indicating the next steps
    in handling your report.
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sat Feb 12 00:51:25 UTC 2022
    - 2.2K bytes
    - Viewed (0)
  6. 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)
  7. docs/contribute/concurrency.md

    #### Shared reader thread
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top