Search Options

Results per page
Sort
Preferred Languages
Advance

Results 291 - 300 of 414 for Kqueue (0.03 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt

          return getResponseWithInterceptorChain()
        } finally {
          client.dispatcher.finished(this)
        }
      }
    
      override fun enqueue(responseCallback: Callback) {
        check(executed.compareAndSet(false, true)) { "Already Executed" }
    
        callStart()
        client.dispatcher.enqueue(AsyncCall(responseCallback))
      }
    
      override fun isExecuted(): Boolean = executed.get()
    
      private fun callStart() {
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Nov 05 18:28:35 UTC 2025
    - 19.7K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/OpenJSSETest.kt

      @StartStop
      private val server = MockWebServer()
    
      @BeforeEach
      fun setUp() {
        platform.assumeOpenJSSE()
      }
    
      @Test
      fun testTlsv13Works() {
        enableTls()
    
        server.enqueue(MockResponse(body = "abc"))
    
        val request = Request(server.url("/"))
    
        val response = client.newCall(request).execute()
    
        response.use {
          assertEquals(200, response.code)
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 3.7K bytes
    - Viewed (0)
  3. internal/event/target/redis.go

    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    			return nil, fmt.Errorf("unable to initialize the queue store of Redis `%s`: %w", id, err)
    		}
    	}
    
    	pool := &redis.Pool{
    		MaxIdle:     3,
    		IdleTimeout: 2 * 60 * time.Second,
    		Dial: func() (redis.Conn, error) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 9.1K bytes
    - Viewed (0)
  4. guava-testlib/src/com/google/common/testing/ArbitraryInstances.java

    import java.util.NavigableMap;
    import java.util.NavigableSet;
    import java.util.Optional;
    import java.util.OptionalDouble;
    import java.util.OptionalInt;
    import java.util.OptionalLong;
    import java.util.Queue;
    import java.util.Random;
    import java.util.Set;
    import java.util.SortedMap;
    import java.util.SortedSet;
    import java.util.UUID;
    import java.util.concurrent.BlockingDeque;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 17:50:58 UTC 2025
    - 21.4K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

        // contract.
        // This is somewhat annoying, but turns out to be very fast in practice. Alternatively, we could
        // drop the contract on the method that enforces this queue like behavior since depending on it
        // is likely to be a bug anyway.
    
        // N.B. All writes to the list and the next pointers must have happened before the above
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  6. internal/event/target/nsq.go

    		queueStore = store.NewQueueStore[event.Event](queueDir, args.QueueLimit, event.StoreExtension)
    		if err := queueStore.Open(); err != nil {
    			return nil, fmt.Errorf("unable to initialize the queue store of NSQ `%s`: %w", id, err)
    		}
    	}
    
    	target := &NSQTarget{
    		id:         event.TargetID{ID: id, Name: "nsq"},
    		args:       args,
    		loggerOnce: loggerOnce,
    		store:      queueStore,
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Interceptor.kt

     *
     * Other exception types cancel the current call:
     *
     *  * For synchronous calls made with [Call.execute], the exception is propagated to the caller.
     *
     *  * For asynchronous calls made with [Call.enqueue], an [IOException] is propagated to the caller
     *    indicating that the call was canceled. The interceptor's exception is delivered to the current
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  8. docs/pt/docs/tutorial/security/first-steps.md

    * O frontend armazena esse token temporariamente em algum lugar.
    * O usuário clica no frontend para ir para outra seção do aplicativo web.
    * O frontend precisa buscar mais dados da API.
        * Mas precisa de autenticação para aquele endpoint específico.
        * Então, para autenticar com nossa API, ele envia um header `Authorization` com o valor `Bearer ` mais o token.
        * Se o token contém `foobar`, o conteúdo do header `Authorization` seria: `Bearer foobar`.
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Wed Nov 12 16:23:57 UTC 2025
    - 8.9K bytes
    - Viewed (0)
  9. internal/grid/grid.go

    	// This is the assumed size of bigger buffers and allocation size.
    	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
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 7K bytes
    - Viewed (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/JSSETest.kt

        // TODO test jdk.tls.client.enableSessionTicketExtension
        // TODO check debugging information
    
        enableTls()
    
        server.enqueue(MockResponse(body = "abc"))
    
        val request = Request(server.url("/"))
    
        val response = client.newCall(request).execute()
    
        response.use {
          assertEquals(200, response.code)
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Wed Jun 18 12:28:21 UTC 2025
    - 5.5K bytes
    - Viewed (0)
Back to top