Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for awaitPong (0.07 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Connection.kt

        }
      }
    
      /** For testing: sends a ping and waits for a pong. */
      @Throws(InterruptedException::class)
      fun writePingAndAwaitPong() {
        writePing()
        awaitPong()
      }
    
      /** For testing: sends a ping to be awaited with [awaitPong]. */
      @Throws(InterruptedException::class)
      fun writePing() {
        withLock {
          awaitPingsSent++
        }
    
        // 0x4f 0x4b 0x6f 0x6b is "OKok".
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 31.8K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt

            throw ConnectionShutdownException()
          }
        }
        connection.writePing()
        connection.shutdown(ErrorCode.PROTOCOL_ERROR)
        assertThat(connection.openStreamCount()).isEqualTo(1)
        connection.awaitPong() // Prevent the peer from exiting prematurely.
    
        // Verify the peer received what was expected.
        val synStream1 = peer.takeFrame()
        assertThat(synStream1.type).isEqualTo(Http2.TYPE_HEADERS)
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 75.5K bytes
    - Viewed (0)
  3. .github/workflows/label-approved.yml

          env:
            TOKEN: ${{ secrets.GITHUB_TOKEN }}
            CONFIG: >
              {
                "approved-1":
                  {
                    "number": 1,
                    "await_label": "awaiting-review"
                  }
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Fri Aug 15 21:44:06 UTC 2025
    - 1.1K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt

      private var receivedPingCount = 0
    
      /** Total number of pongs received by this web socket. */
      private var receivedPongCount = 0
    
      /** True if we have sent a ping that is still awaiting a reply. */
      private var awaitingPong = false
    
      init {
        require("GET" == originalRequest.method) {
          "Request must be GET: ${originalRequest.method}"
        }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 21.6K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

        // launched by this test is either:
        //
        // (a) Blocked attempting to enter the monitor.
        // (b) Waiting for the single guard to become satisfied.
        // (c) Occupying the monitor and awaiting the tearDownLatch.
        //
        // Except for (c), every thread should occupy the monitor very briefly, and every thread leaves
        // the monitor with the guard satisfied. Therefore as soon as tearDownLatch is triggered, we
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 27K bytes
    - Viewed (0)
  6. docs/en/docs/async.md

    ## `async` and `await` { #async-and-await }
    
    Modern versions of Python have a very intuitive way to define asynchronous code. This makes it look just like normal "sequential" code and do the "awaiting" for you at the right moments.
    
    When there is an operation that will require waiting before giving the results and has support for these new Python features, you can code it like:
    
    ```Python
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 24K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

         * comments.
         */
    
        @Weak final MapMakerInternalMap<K, V, E, S> map;
    
        /**
         * The number of live elements in this segment's region. This does not include unset elements
         * which are awaiting cleanup.
         */
        volatile int count;
    
        /**
         * Number of updates that alter the size of the table. This is used during bulk-read methods to
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 90K bytes
    - Viewed (0)
  8. CHANGELOG/CHANGELOG-1.32.md

    - Terminated Pods on a node will not be re-admitted on kubelet restart. This fixes the problem of Completed Pods awaiting for the finalizer marked as Failed after the kubelet restart. ([#126343](https://github.com/kubernetes/kubernetes/pull/126343), [@SergeyKanzhelev](https://github.com/SergeyKanzhelev)) [SIG Node and Testing]
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Wed Aug 13 14:49:49 UTC 2025
    - 412.3K bytes
    - Viewed (0)
  9. docs/en/docs/release-notes.md

    ### Internal
    
    * 🔧 Update sponsors, remove Flint. PR [#10349](https://github.com/tiangolo/fastapi/pull/10349) by [@tiangolo](https://github.com/tiangolo).
    * 🔧 Rename label "awaiting review" to "awaiting-review" to simplify search queries. PR [#10343](https://github.com/tiangolo/fastapi/pull/10343) by [@tiangolo](https://github.com/tiangolo).
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Fri Sep 05 12:48:45 UTC 2025
    - 544.1K bytes
    - Viewed (0)
  10. CHANGELOG/CHANGELOG-1.31.md

    - Terminated Pods on a node will not be re-admitted on kubelet restart. This fixes the problem of Completed Pods awaiting for the finalizer marked as Failed after the kubelet restart. ([#127207](https://github.com/kubernetes/kubernetes/pull/127207), [@SergeyKanzhelev](https://github.com/SergeyKanzhelev)) [SIG Node and Testing]
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Wed Aug 13 19:49:57 UTC 2025
    - 429.6K bytes
    - Viewed (0)
Back to top