- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 826 for pselect (0.3 sec)
-
pkg/envoy/agent.go
// If somehow we do not shutdown from the SIGTERM fast enough, we may get a SIGKILL later. func (a *Agent) Run(ctx context.Context) { log.Info("Starting proxy agent") go a.runWait(a.abortCh) select { case status := <-a.statusCh: if status.err != nil { if status.err.Error() == errOutOfMemory { log.Warnf("Envoy may have been out of memory killed. Check memory usage and limits.") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 24 16:04:22 UTC 2024 - 9K 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) -
docs/debugging/s3-check-md5/main.go
flag.StringVar(&secretKey, "secret-key", "zuf+tfteSlswRu7BJ86wekitnifILbZam1KYY3TG", "S3 Secret Key") flag.StringVar(&bucket, "bucket", "", "Select a specific bucket") flag.StringVar(&prefix, "prefix", "", "Select a prefix") flag.BoolVar(&debug, "debug", false, "Prints HTTP network calls to S3 endpoint") flag.BoolVar(&versions, "versions", false, "Verify all versions")
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Feb 17 01:15:57 UTC 2024 - 6.3K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/internal/component/resolution/failure/describer/UnknownArtifactSelectionFailureDescriber.java
} return result; } private String buildUnknownArtifactVariantFailureMsg(UnknownArtifactSelectionFailure failure) { return String.format("Could not select a variant of %s that matches the consumer attributes.", failure.getRequestedName()); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Feb 28 13:08:22 UTC 2024 - 2.4K bytes - Viewed (0) -
src/os/signal/signal.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:33:12 UTC 2024 - 8.3K bytes - Viewed (0) -
migrator/migrator.go
// Query in gorm.ViewOption is a [subquery] // // // CREATE VIEW `user_view` AS SELECT * FROM `users` WHERE age > 20 // q := DB.Model(&User{}).Where("age > ?", 20) // DB.Debug().Migrator().CreateView("user_view", gorm.ViewOption{Query: q}) // // // CREATE OR REPLACE VIEW `users_view` AS SELECT * FROM `users` WITH CHECK OPTION // q := DB.Model(&User{})
Registered: Wed Jun 12 16:27:09 UTC 2024 - Last Modified: Fri Apr 26 07:15:49 UTC 2024 - 29K 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) -
internal/bucket/bandwidth/monitor.go
if !ok { tm = &bucketMeasurement{} } tm.incrementBytes(bytes) m.bucketsMeasurement[opts] = tm } // SelectionFunction for buckets type SelectionFunction func(bucket string) bool // SelectBuckets will select all the buckets passed in. func SelectBuckets(buckets ...string) SelectionFunction { if len(buckets) == 0 { return func(bucket string) bool { return true } } return func(bucket string) bool {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Feb 19 22:54:46 UTC 2024 - 6K bytes - Viewed (0) -
pkg/kube/krt/filter.go
} if f.selects != nil { attrs = append(attrs, fmt.Sprintf("selects=%v", f.selects)) } if f.labels != nil { attrs = append(attrs, fmt.Sprintf("labels=%v", f.labels)) } if f.generic != nil { attrs = append(attrs, "generic") } res := strings.Join(attrs, ",") return fmt.Sprintf("{%s}", res) } // FilterObjectName selects a Kubernetes object by name.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 4.8K bytes - Viewed (0)