- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 31 for chanOf (0.22 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)