Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 111 for pin1 (0.04 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/connection/RoutePlanner.kt

      /**
       * Returns true if the host and port are unchanged from when this was created. This is used to
       * detect if followups need to do a full connection-finding process including DNS resolution, and
       * certificate pin checks.
       */
      fun sameHostAndPort(url: HttpUrl): Boolean
    
      /**
       * A plan holds either an immediately-usable connection, or one that must be connected first.
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Dec 20 23:27:07 UTC 2023
    - 4.2K bytes
    - Viewed (0)
  2. tensorflow/c/eager/c_api_experimental.h

                                int num_handles, TF_Status* s,
                                void* device_info) = nullptr;
    
      // Pins the op to `device` based on inputs to `op`. Returns true
      // signifying to pin to the current custom device. Returns false
      // to pin to the physical device.
      //
      // This function is guaranteed to be called only when all of the custom-device
      // inputs are on this device.
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Wed Feb 21 22:37:46 UTC 2024
    - 39.5K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketWriter.kt

      // Masks are only a concern for client writers.
      private val maskKey: ByteArray? = if (isClient) ByteArray(4) else null
      private val maskCursor: Buffer.UnsafeCursor? = if (isClient) Buffer.UnsafeCursor() else null
    
      /** Send a ping with the supplied [payload]. */
      @Throws(IOException::class)
      fun writePing(payload: ByteString) {
        writeControlFrame(OPCODE_CONTROL_PING, payload)
      }
    
      /** Send a pong with the supplied [payload]. */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/internal/ws/WebSocketHttpTest.kt

        )
        val openAtNanos = System.nanoTime()
        newWebSocket()
        clientListener.assertOpen()
        clientListener.assertFailure(
          SocketTimeoutException::class.java,
          "sent ping but didn't receive pong within 500ms (after 0 successful ping/pongs)",
        )
        latch.countDown()
        val elapsedUntilFailure = System.nanoTime() - openAtNanos
        assertThat(TimeUnit.NANOSECONDS.toMillis(elapsedUntilFailure).toDouble())
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  5. api/go1.8.txt

    pkg database/sql/driver, type NamedValue struct, Ordinal int
    pkg database/sql/driver, type NamedValue struct, Value Value
    pkg database/sql/driver, type Pinger interface { Ping }
    pkg database/sql/driver, type Pinger interface, Ping(context.Context) error
    pkg database/sql/driver, type QueryerContext interface { QueryContext }
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Dec 21 05:25:57 UTC 2016
    - 16.3K bytes
    - Viewed (0)
  6. internal/grid/muxserver.go

    	if m.outBlock == nil {
    		// Closed
    		return
    	}
    	select {
    	case m.outBlock <- struct{}{}:
    	default:
    		gridLogIf(m.ctx, errors.New("output unblocked overflow"))
    	}
    }
    
    func (m *muxServer) ping(seq uint32) pongMsg {
    	if !m.checkSeq(seq) {
    		msg := fmt.Sprintf("receive sequence number mismatch. want %d, got %d", m.RecvSeq, seq)
    		return pongMsg{Err: &msg}
    	}
    	select {
    	case <-m.ctx.Done():
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 07 15:51:52 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  7. docs/changelogs/changelog_4x.md

        the request already contains an `Accept` header.
    
     *  Fix: Don't crash with a `NullPointerException` if a server sends a close while we're sending a
        ping. OkHttp had a race condition bug.
    
    
    ## Version 4.6.0
    
    _2020-04-28_
    
     *  Fix: Follow HTTP 307 and 308 redirects on methods other than GET and POST. We're reluctant to
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 17 13:25:31 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/internal/http2/MockHttp2Peer.kt

          errorCode: ErrorCode,
        ) {
          check(type == -1)
          this.type = Http2.TYPE_RST_STREAM
          this.streamId = streamId
          this.errorCode = errorCode
        }
    
        override fun ping(
          ack: Boolean,
          payload1: Int,
          payload2: Int,
        ) {
          check(type == -1)
          type = Http2.TYPE_PING
          this.ack = ack
          this.payload1 = payload1
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 11 22:09:35 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  9. docs/contribute/concurrency.md

    #### Do-stuff-later pool
    
    Sometimes there's an action required like calling the application layer or responding to a ping, and the thread discovering the action is not the thread that should do the work. We enqueue a runnable on this executor and it gets handled by one of the executor's threads.
    
    ### Locks
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  10. okhttp/src/test/java/okhttp3/CacheTest.kt

        val response1 = client.newCall(request).execute()
        val in1 = response1.body.source()
        assertThat(in1.readUtf8("I love ".length.toLong())).isEqualTo("I love ")
        in1.skip("puppies but hate ".length.toLong())
        assertThat(in1.readUtf8("spiders".length.toLong())).isEqualTo("spiders")
        assertThat(in1.exhausted()).isTrue()
        in1.close()
        assertThat(cache.writeSuccessCount()).isEqualTo(1)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Wed Apr 10 19:46:48 UTC 2024
    - 108.6K bytes
    - Viewed (0)
Back to top