Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 225 for broadcasts (0.18 sec)

  1. src/cmd/internal/obj/x86/anames.go

    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 11 18:32:50 UTC 2023
    - 19.1K bytes
    - Viewed (0)
  2. src/cmd/cgo/internal/test/issue9400_linux.go

    	// Start signaller
    	atomic.StoreInt32(&issue9400.Baton, 0)
    	go func() {
    		// Wait for RewindAndSetgid
    		for atomic.LoadInt32(&issue9400.Baton) == 0 {
    			runtime.Gosched()
    		}
    		// Broadcast SIGSETXID
    		runtime.LockOSThread()
    		C.setgid(0)
    		// Indicate that signalling is done
    		atomic.StoreInt32(&issue9400.Baton, 0)
    	}()
    
    	// Grow the stack and put down a test pattern
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jul 18 19:55:29 UTC 2023
    - 1.7K bytes
    - Viewed (0)
  3. platforms/core-runtime/build-operations/src/main/java/org/gradle/internal/operations/DefaultBuildOperationListenerManager.java

        private List<ProgressShieldingBuildOperationListener> listeners = Collections.emptyList();
        private final Lock listenersLock = new ReentrantLock();
    
        private final BuildOperationListener broadcaster = new BuildOperationListener() {
            @Override
            public void started(BuildOperationDescriptor buildOperation, OperationStartEvent startEvent) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Oct 24 14:19:43 UTC 2023
    - 5.3K bytes
    - Viewed (0)
  4. subprojects/core/src/main/java/org/gradle/internal/service/scopes/GradleScopeServices.java

        }
    
        @Provides
        org.gradle.api.execution.TaskExecutionListener createTaskExecutionListener(ListenerBroadcast<org.gradle.api.execution.TaskExecutionListener> broadcast) {
            return broadcast.getSource();
        }
    
        @Provides
        TaskListenerInternal createTaskListenerInternal(ListenerManager listenerManager) {
            return listenerManager.getBroadcaster(TaskListenerInternal.class);
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon May 27 09:21:42 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  5. tensorflow/compiler/mlir/tf2xla/tests/legalize-tf-include-tf2xla-fallback.mlir

      func.return %1 : tensor<4x7xcomplex<f64>>
    }
    
    // BatchMatMulV2 has native as well as fallback lowering patterns available.
    // The fallback pattern uses dot_general without broadcast on operands and then
    // transposes the output which is faster. However, the fallback pattern doesn't
    // support dynamic shaped operands like the native lowering. Verify that
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Nov 16 19:04:03 UTC 2023
    - 3.2K bytes
    - Viewed (0)
  6. tensorflow/compiler/mlir/tensorflow/tests/xla_broadcast.mlir

    // RUN: tf-opt %s -split-input-file -tf-xla-broadcast | FileCheck %s
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Jun 13 18:52:07 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  7. tensorflow/compiler/mlir/lite/transforms/optimize_patterns.td

      // It is safe to perform this transform here because-
      // the shapes of `pre_broadcast` and `dim` must be broadcast
      // compatible for the `broadcast_to` op to be valid.
      // And considering, `shape(post_broadcast)` == `shape(%input1)`,
      // `post_broadcast` is broadcast compatible with `input1`.
      def FuseBroadcastInto#SelectOp : Pat<
        (SelectOp
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu May 16 20:31:41 UTC 2024
    - 66.4K bytes
    - Viewed (0)
  8. tensorflow/compiler/jit/jit_compilation_pass_registration.cc

    // ReportClusteringInfoPass pass needs to run after all of the auto-clustering
    // passes have run but before encapsulation has run.  This way it can easily
    // compute a summary of the clustering decisions we made and broadcast it via
    // xla_activity_listener.
    REGISTER_OPTIMIZATION(OptimizationPassRegistry::POST_REWRITE_FOR_EXEC, 40,
                          ReportClusteringInfoPass);
    
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed Jan 11 21:53:08 UTC 2023
    - 3.8K bytes
    - Viewed (0)
  9. pkg/registry/core/service/portallocator/controller/repair.go

    		portRange:     portRange,
    		alloc:         alloc,
    		leaks:         map[int]int{},
    		broadcaster:   eventBroadcaster,
    		recorder:      recorder,
    	}
    }
    
    // RunUntil starts the controller until the provided ch is closed.
    func (c *Repair) RunUntil(onFirstSuccess func(), stopCh chan struct{}) {
    	c.broadcaster.StartRecordingToSink(stopCh)
    	defer c.broadcaster.Shutdown()
    
    	var once sync.Once
    	wait.Until(func() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Sep 30 15:46:06 UTC 2023
    - 10.4K bytes
    - Viewed (0)
  10. platforms/core-runtime/stdlib-java-extensions/src/main/java/org/gradle/internal/service/scopes/EventScope.java

     * Events are not visible to listeners in descendent scopes.
     *
     * <p>This annotation is used primarily to indicate to developers the scopes where this listener are available. There is also
     * some validation when a broadcaster or listener of this type is used in an incorrect scope.
     *
     * @see Scope
     */
    @Retention(RetentionPolicy.RUNTIME)
    @Target(ElementType.TYPE)
    @Inherited
    public @interface EventScope {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Jun 10 14:28:48 UTC 2024
    - 1.5K bytes
    - Viewed (0)
Back to top