- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 120 for pushHead (0.15 sec)
-
pkg/config/mesh/watcher.go
} w.MeshConfig.Store(meshConfig) handlers = append(handlers, w.handlers...) } // TODO hack: the first handler added is the ConfigPush, other handlers affect what will be pushed, so reversing iteration for i := len(handlers) - 1; i >= 0; i-- { handlers[i].handler() } } // Add to the FileWatcher the provided file and execute the provided function
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Dec 20 18:33:38 UTC 2023 - 7.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/authorization.go
// // STRICT policies that don't have portLevelMtls will be // handled when the Workload xDS resource is pushed (a static STRICT-equivalent policy will always be pushed) func convertPeerAuthentication(rootNamespace string, cfg *securityclient.PeerAuthentication) *security.Authorization { pa := &cfg.Spec mode := pa.GetMtls().GetMode()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 15 16:23:36 UTC 2024 - 18.4K bytes - Viewed (0) -
pkg/queue/delay.go
select { case t := <-d.enqueue: d.mu.Lock() heap.Push(d.queue, t) // put the old "head" back on the queue, it may be scheduled to execute after the one // that was just pushed heap.Push(d.queue, task) d.mu.Unlock() case <-await.C: if !push(task) { return } case <-stop: await.Stop() return } await.Stop() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jul 20 06:27:31 UTC 2023 - 6.7K bytes - Viewed (0) -
src/cmd/go/internal/mvs/graph.go
package mvs import ( "fmt" "slices" "cmd/go/internal/gover" "golang.org/x/mod/module" ) // Graph implements an incremental version of the MVS algorithm, with the // requirements pushed by the caller instead of pulled by the MVS traversal. type Graph struct { cmp func(p, v1, v2 string) int roots []module.Version required map[module.Version][]module.Version
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 01 02:52:19 UTC 2023 - 6.3K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/schedule.go
// then assign the number to other values in DFS order. count := make([]int32, 3*(len(stores)+1)) sset.clear() // reuse sparse set to ensure that a value is pushed to stack only once for n, w := len(stores), last; n > 0; n-- { storeNumber[w.ID] = int32(3 * n) count[3*n]++ sset.add(w.ID) if w.Op == OpInitMem || w.Op == OpPhi { if n != 1 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 08 15:53:17 UTC 2024 - 16.4K bytes - Viewed (0) -
pilot/pkg/xds/workload.go
// the internal book-keeping to subscribe to the Pods, so that we push updates to those Pods. w.ResourceNames = subs.Merge(have).UnsortedList() } else { // For wildcard, we record all resources that have been pushed and not removed // It was to correctly calculate removed resources during full push alongside with specific address removed. w.ResourceNames = subs.Merge(have).Difference(removed).UnsortedList() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 14:14:30 UTC 2024 - 8.7K bytes - Viewed (0) -
src/time/sleep.go
if t < 0 { // N.B. runtimeNano() and d are always positive, so addition // (including overflow) will never result in t == 0. t = 1<<63 - 1 // math.MaxInt64 } return t } // These functions are pushed to package time from package runtime. // The arg cp is a chan Time, but the declaration in runtime uses a pointer, // so we use a pointer here too. This keeps some tools that aggressively
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 04 14:21:30 UTC 2024 - 8.5K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/dom.go
vertex[n] = v.ID label[v.ID] = v.ID // ancestor[v] already zero for _, e := range succFn(v) { w := e.b // if it has a dfnum, we've already visited it if semi[w.ID] == 0 { // yes, w can be pushed multiple times. s = append(s, w) parent[w.ID] = v.ID // keep overwriting this till it is visited. } } } return n } // compressOrig is the "simple" compress function from LT paper.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Dec 03 17:08:51 UTC 2022 - 7.4K bytes - Viewed (0) -
docs/contribute/concurrency.md
### Threads #### Application's calling thread The application-layer must block on writing I/O. We can't return from a write until we've pushed its bytes onto the socket. Otherwise, if the write fails we are unable to deliver its IOException to the application. We would have told the application layer that the write succeeded, but it didn't!
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Feb 06 16:35:36 UTC 2022 - 7K bytes - Viewed (0) -
pilot/pkg/features/experimental.go
"istio.io/istio/pkg/env" "istio.io/istio/pkg/log" ) // Define experimental features here. var ( // FilterGatewayClusterConfig controls if a subset of clusters(only those required) should be pushed to gateways FilterGatewayClusterConfig = env.Register("PILOT_FILTER_GATEWAY_CLUSTER_CONFIG", false, "If enabled, Pilot will send only clusters that referenced in gateway virtual services attached to gateway").Get()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:02:38 UTC 2024 - 10.2K bytes - Viewed (0)