Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 31 for chanOf (0.22 sec)

  1. src/cmd/go/internal/modget/get.go

    			// packages imported by the main module does not change, and the query
    			// result for the module containing each such package also does not change
    			// (it is always relative to the initial build list, before applying
    			// queries). So the only way that the result of an "all" query can change
    			// is if some matching package moves from one module in the build list
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 18:26:32 UTC 2024
    - 66.5K bytes
    - Viewed (0)
  2. platforms/documentation/docs/src/docs/userguide/releases/upgrading/upgrading_version_8.adoc

    ==== Change the encoding of daemon log files
    In previous versions of Gradle, the daemon log file, located at `$<<directory_layout.adoc#dir:gradle_user_home,GRADLE_USER_HOME>>/daemon/{gradleVersion}/`, was encoded with the default JVM encoding.
    To prevent clients that may use different default encoding from reading data incorrectly, this file is now always encoded with UTF-8.
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jun 07 17:01:07 UTC 2024
    - 90.7K bytes
    - Viewed (0)
  3. tensorflow/compiler/mlir/lite/transforms/lower_static_tensor_list.cc

                                     llvm::ArrayRef<Type> updated_argument_types,
                                     llvm::ArrayRef<Type> updated_result_types) {
      // Change `func`'s argument type to `unranked_argument_types`. If its
      // return types contain a `DT_VARIANT`, change it to the unranked type
      // derived from the corresponding argument.
      rewriter.modifyOpInPlace(func, [&] {
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Jun 11 20:00:43 UTC 2024
    - 70.7K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go

    type immediateCloseWatcher struct {
    	result chan watch.Event
    }
    
    func newImmediateCloseWatcher() *immediateCloseWatcher {
    	watcher := &immediateCloseWatcher{result: make(chan watch.Event)}
    	close(watcher.result)
    	return watcher
    }
    
    // Implements watch.Interface.
    func (c *immediateCloseWatcher) ResultChan() <-chan watch.Event {
    	return c.result
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 51.8K bytes
    - Viewed (0)
  5. platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/builder/NodeState.java

            // revisit all dependencies and possibly change the classpath order!
            boolean sameDependencies = dependencies(newResolutionFilter).equals(oldStates);
            if (sameDependencies) {
                // While there will be no change to this node, there might be changes to the nodes it brings as the exclude change could concern them
                for (EdgeState outgoingEdge : outgoingEdges) {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jun 07 14:19:34 UTC 2024
    - 58.9K bytes
    - Viewed (0)
  6. pkg/scheduler/internal/queue/scheduling_queue.go

    	// for unschedulable pods. To change the default podInitialBackoffDurationSeconds used by the
    	// scheduler, update the ComponentConfig value in defaults.go
    	DefaultPodInitialBackoffDuration time.Duration = 1 * time.Second
    	// DefaultPodMaxBackoffDuration is the default value for the max backoff duration
    	// for unschedulable pods. To change the default podMaxBackoffDurationSeconds used by the
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
  7. pkg/controller/job/job_controller.go

    	// never return error
    	key, err := controller.KeyFunc(curJob)
    	if err != nil {
    		return
    	}
    
    	if curJob.Generation == oldJob.Generation {
    		// Delay the Job sync when no generation change to batch Job status updates,
    		// typically triggered by pod events.
    		jm.enqueueSyncJobBatched(logger, curJob)
    	} else {
    		// Trigger immediate sync when spec is changed.
    		jm.enqueueSyncJobImmediately(logger, curJob)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go

    	return d.requestWatchProgressCounter
    }
    
    type dummyWatch struct {
    	ch chan watch.Event
    }
    
    func (w *dummyWatch) ResultChan() <-chan watch.Event {
    	return w.ch
    }
    
    func (w *dummyWatch) Stop() {
    	close(w.ch)
    }
    
    func newDummyWatch() watch.Interface {
    	return &dummyWatch{
    		ch: make(chan watch.Event),
    	}
    }
    
    func (d *dummyStorage) Versioner() storage.Versioner { return nil }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 82.9K bytes
    - Viewed (0)
  9. src/cmd/compile/internal/ssa/rewrite.go

    						}
    					}
    				}
    
    				change = change || vchange
    				if vchange && debug > 1 {
    					fmt.Printf("rewriting %s  ->  %s\n", v0.LongString(), v.LongString())
    				}
    			}
    		}
    		if !change && !deadChange {
    			break
    		}
    		iters++
    		if (iters > itersLimit || debug >= 2) && change {
    			// We've done a suspiciously large number of rewrites (or we're in debug mode).
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 19:02:52 UTC 2024
    - 64.2K bytes
    - Viewed (0)
  10. pkg/proxy/nftables/proxier.go

    func (proxier *Proxier) SyncLoop() {
    	// Update healthz timestamp at beginning in case Sync() never succeeds.
    	if proxier.healthzServer != nil {
    		proxier.healthzServer.Updated(proxier.ipFamily)
    	}
    
    	// synthesize "last change queued" time as the informers are syncing.
    	metrics.SyncProxyRulesLastQueuedTimestamp.SetToCurrentTime()
    	proxier.syncRunner.Loop(wait.NeverStop)
    }
    
    func (proxier *Proxier) setInitialized(value bool) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
Back to top