- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 384 for pselect (0.18 sec)
-
src/internal/trace/parser.go
EvGoStart = 14 // goroutine starts running [timestamp, goroutine id, seq] EvGoEnd = 15 // goroutine ends [timestamp] EvGoStop = 16 // goroutine stops (like in select{}) [timestamp, stack] EvGoSched = 17 // goroutine calls Gosched [timestamp, stack] EvGoPreempt = 18 // goroutine is preempted [timestamp, stack]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:31:04 UTC 2024 - 4.7K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/internal/component/external/model/ExternalModuleDependencyMetadata.java
return selectLegacyConfigurations(variantSelector, consumerAttributes, targetComponentState, consumerSchema); } /** * Select target graph variants in an ecosystem-dependent manner. * * This method is called when the target component does not have variants to select from. */ protected abstract GraphVariantSelectionResult selectLegacyConfigurations( GraphVariantSelector variantSelector,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 22 19:04:04 UTC 2024 - 7.7K bytes - Viewed (0) -
pilot/pkg/xds/discovery.go
// Key is the generator type - will match the Generator metadata to set the per-connection // default generator, or the combination of Generator metadata and TypeUrl to select a // different generator for a type. // Normal istio clients use the default generator - will not be impacted by this. Generators map[string]model.XdsResourceGenerator
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K bytes - Viewed (0) -
cmd/callhome.go
defer callhomeTimer.Stop() for { if !globalCallhomeConfig.Enabled() { // Stop the processing as callhome got disabled return false } select { case <-ctx.Done(): // indicates that we do not need to run callhome anymore return false case <-callhomeTimer.C: if !globalCallhomeConfig.Enabled() { // Stop the processing as callhome got disabled
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 17 16:53:34 UTC 2024 - 5.3K bytes - Viewed (0) -
internal/logger/target/http/http.go
currentGlobalBuffer, ok := logChBuffers[name] logChLock.Unlock() if !ok { return } for _, v := range entries { select { case currentGlobalBuffer <- v: default: } } if mainWorker { drain: for { select { case v, ok := <-h.logCh: if !ok { break drain } currentGlobalBuffer <- v default: break drain
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 14.9K bytes - Viewed (0) -
internal/http/listener.go
func (listener *httpListener) start() { // Closure to send acceptResult to acceptCh. // It returns true if the result is sent else false if returns when doneCh is closed. send := func(result acceptResult) bool { select { case listener.acceptCh <- result: // Successfully written to acceptCh return true case <-listener.ctx.Done(): return false } } // Closure to handle TCPListener until done channel is closed.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 5.5K bytes - Viewed (0) -
src/crypto/internal/edwards25519/field/fe.go
} // mask64Bits returns 0xffffffff if cond is 1, and 0 otherwise. func mask64Bits(cond int) uint64 { return ^(uint64(cond) - 1) } // Select sets v to a if cond == 1, and to b if cond == 0. func (v *Element) Select(a, b *Element, cond int) *Element { m := mask64Bits(cond) v.l0 = (m & a.l0) | (^m & b.l0) v.l1 = (m & a.l1) | (^m & b.l1) v.l2 = (m & a.l2) | (^m & b.l2)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 13 18:57:38 UTC 2024 - 11.8K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/stablehlo/tests/composite-lowering.mlir
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Jun 06 18:45:51 UTC 2024 - 32.6K bytes - Viewed (0) -
pilot/pkg/features/pilot.go
"If enabled, service entries with selectors will select pods from the cluster. "+ "It is safe to disable it if you are quite sure you don't need this feature").Get() EnableK8SServiceSelectWorkloadEntries = env.RegisterBoolVar("PILOT_ENABLE_K8S_SELECT_WORKLOAD_ENTRIES", true, "If enabled, Kubernetes services with selectors will select workload entries with matching labels. "+
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/xds/server.go
// initialization is complete. <-con.initialized for { // Go select{} statements are not ordered; the same channel can be chosen many times. // For requests, these are higher priority (client may be blocked on startup until these are done) // and often very cheap to handle (simple ACK), so we check it first. select { case req, ok := <-con.reqChan: if ok { if err := ctx.Process(req); err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0)