Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 103 for pins (0.02 sec)

  1. internal/grid/grid.go

    	biggerBufMin = 32 << 10
    
    	// This is the maximum size of bigger buffers.
    	biggerBufMax = maxBufferSize
    
    	// If there is a queue, merge up to this many messages.
    	maxMergeMessages = 50
    
    	// clientPingInterval will ping the remote handler every 15 seconds.
    	// Clients disconnect when we exceed 2 intervals.
    	clientPingInterval = 15 * time.Second
    
    	// Deadline for single (non-streaming) requests to complete.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  2. 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)
  3. impl/maven-core/src/main/java/org/apache/maven/lifecycle/DefaultLifecycles.java

            Map<String, Lifecycle> phaseToLifecycleMap = new HashMap<>();
    
            for (Lifecycle lifecycle : getLifeCycles()) {
                for (String phase : lifecycle.getPhases()) {
                    // The first definition wins.
                    Lifecycle original = phaseToLifecycleMap.put(phase, lifecycle);
                    if (original != null && logger.isWarnEnabled()) {
                        logger.warn(
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  4. okhttp/src/test/java/okhttp3/KotlinSourceModernTest.kt

        val pin: String = CertificatePinner.pin(certificate)
        val default: CertificatePinner = CertificatePinner.DEFAULT
      }
    
      @Test
      fun certificatePinnerBuilder() {
        val builder: CertificatePinner.Builder = CertificatePinner.Builder()
        builder.add("", "pin1", "pin2")
      }
    
      @Test
      fun challenge() {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 01 14:21:25 UTC 2024
    - 46.5K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. okhttp/src/test/java/okhttp3/internal/concurrent/TaskRunnerTest.kt

          "FINE: Q10000 starting              : task",
          "FINE: Q10000 finished run in   0 µs: task",
        )
      }
    
      /** Repeat with a delay of 200 but schedule with a delay of 50. The schedule wins. */
      @Test fun executeScheduledEarlierReplacesRepeatedLater() {
        val task =
          object : Task("task") {
            val schedules = mutableListOf(50.µs)
            val delays = mutableListOf(200.µs, -1)
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 23K bytes
    - Viewed (0)
  8. docs/pt/docs/advanced/behind-a-proxy.md

    Você pode obter o `root_path` atual usado pela sua aplicação para cada solicitação, ele faz parte do dicionário `scope` (que faz parte da especificação ASGI).
    
    Aqui estamos incluindo ele na mensagem apenas para fins de demonstração.
    
    {* ../../docs_src/behind_a_proxy/tutorial001.py hl[8] *}
    
    Então, se você iniciar o Uvicorn com:
    
    <div class="termy">
    
    ```console
    $ fastapi run main.py --root-path /api/v1
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 27 15:28:18 UTC 2024
    - 12.2K 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/internal/http2/Http2Test.kt

        assertThat(sendPingFrame(true, expectedPayload1, expectedPayload2)).isEqualTo(frame)
        reader.nextFrame(
          requireSettings = false,
          object : BaseTestHandler() {
            override fun ping(
              ack: Boolean,
              payload1: Int,
              payload2: Int,
            ) {
              assertThat(ack).isTrue()
              assertThat(payload1).isEqualTo(expectedPayload1)
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 28.1K bytes
    - Viewed (0)
Back to top