Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 65 for synchronous (0.18 sec)

  1. cmd/bucket-replication.go

    		// whether to replicate as the target could be temporarily down
    		opts.TargetArn = tgtArn
    		replicate := cfg.Replicate(opts)
    		var synchronous bool
    		if tgt != nil {
    			synchronous = tgt.replicateSync
    		}
    		dsc.Set(newReplicateTargetDecision(tgtArn, replicate, synchronous))
    	}
    	return dsc
    }
    
    // Standard headers that needs to be extracted from User metadata.
    var standardHeaders = []string{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  2. okhttp/src/main/kotlin/okhttp3/internal/connection/ConnectPlan.kt

      ) {
        // Do nothing.
      }
    
      override fun noNewExchanges() {
        // Do nothing.
      }
    
      override fun cancel() {
        canceled = true
        // Close the raw socket so we don't end up doing synchronous I/O.
        rawSocket?.closeQuietly()
      }
    
      override fun retry(): RoutePlanner.Plan {
        return ConnectPlan(
          taskRunner = taskRunner,
          connectionPool = connectionPool,
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 18.6K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/UrlComponentEncodingTester.kt

          encodings[ 0x13] = encoding // Device Control 3 (oft. XOFF)
          encodings[ 0x14] = encoding // Device Control 4
          encodings[ 0x15] = encoding // Negative Acknowledgment
          encodings[ 0x16] = encoding // Synchronous idle
          encodings[ 0x17] = encoding // End of Transmission Block
          encodings[ 0x18] = encoding // Cancel
          encodings[ 0x19] = encoding // End of Medium
          encodings[ 0x1a] = encoding // Substitute
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 12.3K bytes
    - Viewed (0)
  4. doc/godebug.md

    and the [go command documentation](/cmd/go#hdr-Build_and_test_caching).
    
    ### Go 1.23
    
    Go 1.23 changed the channels created by package time to be unbuffered
    (synchronous), which makes correct use of the [`Timer.Stop`](/pkg/time/#Timer.Stop)
    and [`Timer.Reset`](/pkg/time/#Timer.Reset) method results much easier.
    The [`asynctimerchan` setting](/pkg/time/#NewTimer) disables this change.
    Plain Text
    - Registered: Tue May 07 11:14:38 GMT 2024
    - Last Modified: Tue Apr 16 17:29:58 GMT 2024
    - 13.5K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

    import okio.buffer
    import okio.sink
    import okio.source
    
    /**
     * A socket connection to a remote peer. A connection hosts streams which can send and receive
     * data.
     *
     * Many methods in this API are **synchronous:** the call is completed before the method returns.
     * This is typical for Java but atypical for HTTP/2. This is motivated by exception transparency:
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 32.6K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnection.kt

          override fun cancel() {
            exchange.cancel()
          }
        }
      }
    
      override fun route(): Route = route
    
      override fun cancel() {
        // Close the raw socket so we don't end up doing synchronous I/O.
        rawSocket?.closeQuietly()
      }
    
      override fun socket(): Socket = socket!!
    
      /** Returns true if this connection is ready to host new streams. */
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sat Apr 20 17:03:43 GMT 2024
    - 15.4K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/cache/CacheBuilder.java

       * CacheLoader#reload}.
       *
       * <p>As the default implementation of {@link CacheLoader#reload} is synchronous, it is
       * recommended that users of this method override {@link CacheLoader#reload} with an asynchronous
       * implementation; otherwise refreshes will be performed during unrelated cache read and write
       * operations.
       *
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 15 16:12:13 GMT 2024
    - 44.8K bytes
    - Viewed (0)
  8. okhttp/src/test/java/okhttp3/InterceptorTest.kt

      }
    
      @Test
      fun networkInterceptorThrowsRuntimeExceptionSynchronous() {
        interceptorThrowsRuntimeExceptionSynchronous(true)
      }
    
      /**
       * When an interceptor throws an unexpected exception, synchronous callers can catch it and deal
       * with it.
       */
      private fun interceptorThrowsRuntimeExceptionSynchronous(network: Boolean) {
        addInterceptor(network) { chain: Interceptor.Chain? -> throw RuntimeException("boom!") }
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Sun Jan 14 10:20:09 GMT 2024
    - 27.8K bytes
    - Viewed (0)
  9. docs/en/docs/alternatives.md

    It has an interesting, uncommon feature: using the same framework, it's possible to create APIs and also CLIs.
    
    As it is based on the previous standard for synchronous Python web frameworks (WSGI), it can't handle Websockets and other things, although it still has high performance too.
    
    !!! info
    Plain Text
    - Registered: Sun May 05 07:19:11 GMT 2024
    - Last Modified: Thu Apr 18 19:53:19 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

        }
    
        /**
         * Returns the final value of the associated {@link ClosingFuture}, or throws an exception as
         * {@link Future#get()} would.
         *
         * <p>Because the asynchronous operation has already completed, this method is synchronous and
         * returns immediately.
         *
         * @throws CancellationException if the computation was cancelled
         * @throws ExecutionException if the computation threw an exception
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 98.5K bytes
    - Viewed (0)
Back to top