Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 115 for Dispatching (0.18 sec)

  1. src/log/slog/value_access_benchmark_test.go

    func (v *setVisitor) Bool(x bool)              { v.b = x }
    func (v *setVisitor) Duration(x time.Duration) { v.d = x }
    func (v *setVisitor) Any(x any)                { v.a = x }
    
    // When dispatching on all types, the "As" functions are slightly slower
    // than switching on the kind and then calling a function that checks
    // the kind again. See BenchmarkDispatch above.
    
    func (a Value) AsString() (string, bool) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Mar 21 20:55:33 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  2. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DefaultIncomingConnectionHandler.java

                    commandExecuter.executeCommand(daemonConnection, command, daemonContext, daemonStateControl);
                } catch (Throwable e) {
                    LOGGER.warn(String.format("Unable to execute command %s from %s. Dispatching the failure to the daemon client", command, connection), e);
                    daemonConnection.completed(new Failure(e));
                } finally {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:29:13 UTC 2023
    - 7K bytes
    - Viewed (0)
  3. platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r25/BuildProgressCrossVersionSpec.groovy

            }
    
            then: "build progress events must be forwarded to the attached listeners"
            events.assertIsABuild()
        }
    
        def "stops dispatching events to progress listeners when a listener fails and continues with build"() {
            given:
            goodCode()
    
            when: "launching a build"
            List<ProgressEvent> resultsOfFirstListener = []
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Sep 26 14:49:20 UTC 2023
    - 7.7K bytes
    - Viewed (0)
  4. guava/src/com/google/common/eventbus/EventBus.java

       * Returns the identifier for this event bus.
       *
       * @since 19.0
       */
      public final String identifier() {
        return identifier;
      }
    
      /** Returns the default executor this event bus uses for dispatching events to subscribers. */
      final Executor executor() {
        return executor;
      }
    
      /** Handles the given exception thrown by a subscriber with the given context. */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Jul 17 16:01:41 UTC 2023
    - 12.8K bytes
    - Viewed (0)
  5. staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_filter.go

    // Interface defines how the API Priority and Fairness filter interacts with the underlying system.
    type Interface interface {
    	// Handle takes care of queuing and dispatching a request
    	// characterized by the given digest.  The given `noteFn` will be
    	// invoked with the results of request classification.
    	// The given `workEstimator` is called, if at all, after noteFn.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:35 UTC 2023
    - 8K bytes
    - Viewed (0)
  6. platforms/core-configuration/graph-serialization/src/main/kotlin/org/gradle/internal/serialize/graph/codecs/BindingsBackedCodec.kt

     * to the proper binding (if one is found).
     *
     * The binding (a tagged codec) is chosen based on the availability of a [Binding.encoding] for the value being encoded.
     * This is basically implemented as a predicate dispatching on the value type, first available Binding.encoding wins
     * and its [Binding.tag] is recorded in the output stream so decoding can be implemented via a fast array lookup.
     *
     * @see Binding.tag
     */
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Jun 04 18:56:44 UTC 2024
    - 6K bytes
    - Viewed (0)
  7. platforms/core-configuration/core-serialization-codecs/src/main/kotlin/org/gradle/internal/serialize/codecs/core/UnsupportedTypesCodecs.kt

        bind(unsupported<UnresolvedComponentResult>())
        bind(unsupported<ArtifactResult>())
    
        // Publishing types
        bind(unsupported<Publication>())
    
        // Event dispatching infrastructure types
        bind(unsupported<ListenerBroadcast<*>>())
        bind(unsupported<AbstractBroadcastDispatch<*>>())
    
        // Direct build service references
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jun 07 23:09:56 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/eventbus/EventBus.java

       * Returns the identifier for this event bus.
       *
       * @since 19.0
       */
      public final String identifier() {
        return identifier;
      }
    
      /** Returns the default executor this event bus uses for dispatching events to subscribers. */
      final Executor executor() {
        return executor;
      }
    
      /** Handles the given exception thrown by a subscriber with the given context. */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Aug 25 16:37:57 UTC 2021
    - 12.8K bytes
    - Viewed (0)
  9. guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

     *
     * <p>Listeners are registered once via {@link #addListener} and then may be invoked by {@linkplain
     * #enqueue enqueueing} and then {@linkplain #dispatch dispatching} events.
     *
     * <p>The API of this class is designed to make it easy to achieve the following properties
     *
     * <ul>
     *   <li>Multiple events for the same listener are never dispatched concurrently.
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed Dec 13 19:45:20 UTC 2023
    - 8.2K bytes
    - Viewed (0)
  10. src/runtime/debugcall.go

    	})
    	return ret
    }
    
    // debugCallWrap starts a new goroutine to run a debug call and blocks
    // the calling goroutine. On the goroutine, it prepares to recover
    // panics from the debug call, and then calls the call dispatching
    // function at PC dispatch.
    //
    // This must be deeply nosplit because there are untyped values on the
    // stack from debugCallV2.
    //
    //go:nosplit
    func debugCallWrap(dispatch uintptr) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Apr 05 20:50:21 UTC 2024
    - 7.1K bytes
    - Viewed (0)
Back to top