- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 548 for selects (0.19 sec)
-
internal/http/listener.go
func (listener *httpListener) start() { // Closure to handle listener until httpListener.ctxDoneCh channel is closed. handleListener := func(idx int, ln net.Listener) { for { conn, err := ln.Accept() select { case listener.acceptCh <- acceptResult{conn, err, idx}: case <-listener.ctxDoneCh: return } } } // Start separate goroutine for each listener to handle connection.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 5.8K bytes - Viewed (0) -
src/main/webapp/css/admin/bootstrap.min.css
th:100%}.input-group>.custom-file,.input-group>.custom-select,.input-group>.form-control,.input-group>.form-control-plaintext{position:relative;-ms-flex:1 1 auto;flex:1 1 auto;width:1%;min-width:0;margin-bottom:0}.input-group>.custom-file+.custom-file,.input-group>.custom-file+.custom-select,.input-group>.custom-file+.form-control,.input-group>.custom-select+.custom-file,.input-group>.custom-select+.custom-select,.input-group>.custom-select+.form-control,.input-group>.form-control+.custom-file,....Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Oct 26 01:49:09 UTC 2024 - 158.5K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/bridge/MavenRepositorySystem.java
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Feb 07 00:45:02 UTC 2025 - 33.5K bytes - Viewed (0) -
cmd/metacache-entries.go
if selected == nil { selected = entry objsAgree = 1 continue } // Names match, check meta... if prefer, ok := entry.matches(selected, r.strict); ok { selected = prefer objsAgree++ continue } } // Return dir entries, if enough... if selected != nil && selected.isDir() && dirExists >= r.dirQuorum { return selected, true }Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Aug 08 15:29:58 UTC 2024 - 24.1K bytes - Viewed (0) -
cmd/iam.go
return nil, errServerNotInitialized } select { case <-sys.configLoaded: return sys.store.GetBucketUsers(bucket) case <-ctx.Done(): return nil, ctx.Err() } } // ListUsers - list all users. func (sys *IAMSys) ListUsers(ctx context.Context) (map[string]madmin.UserInfo, error) { if !sys.Initialized() { return nil, errServerNotInitialized } select { case <-sys.configLoaded:Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Wed Oct 15 17:00:45 UTC 2025 - 76.5K bytes - Viewed (0) -
cmd/mrf.go
if m == nil { return } if atomic.LoadInt32(&m.closed) == 1 { return } m.wg.Add(1) defer m.wg.Done() if atomic.LoadInt32(&m.closing) == 1 { return } select { case m.opCh <- op: default: } } // Do not accept new MRF operations anymore and start to save // the current heal status in one available disk func (m *mrfState) shutdown() {Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 6.5K bytes - Viewed (0) -
misc/ios/README
the go_ios_$GOARCH_exec wrapper is found. For example, to run the archive/tar tests: export PATH=$GOROOT/bin:$PATH GOOS=ios GOARCH=amd64 CGO_ENABLED=1 go test archive/tar The go_ios_exec wrapper uses GOARCH to select the emulator (amd64) or the device (arm64). However, further setup is required to run tests or programs directly on a device. First make sure you have a valid developer certificate and have setup your device properly
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Tue Dec 29 21:49:26 UTC 2020 - 2.7K bytes - Viewed (0) -
src/main/webapp/css/bootstrap.min.css.map
background-image: var(--bs-gradient) !important;\n}\n\n.user-select-all {\n -webkit-user-select: all !important;\n -moz-user-select: all !important;\n user-select: all !important;\n}\n\n.user-select-auto {\n -webkit-user-select: auto !important;\n -moz-user-select: auto !important;\n user-select: auto !important;\n}\n\n.user-select-none {\n -webkit-user-select: none !important;\n -moz-user-select: none !important;\n user-select: none !important;\n}\n\n.pe-none {\n pointer-events: none !...
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sun Jan 12 06:14:02 UTC 2025 - 575.5K 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 Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 6K bytes - Viewed (0) -
internal/s3select/simdj/reader.go
// On errors, r.err will be set. This should only be accessed after r.decoded has been closed. func (r *Reader) startReader() { defer r.onReaderExit() var tmpObj simdjson.Object for { var in simdjson.Stream select { case in = <-r.input: case <-r.exitReader: return } if in.Error != nil && in.Error != io.EOF { r.err = &in.Error return } if in.Value == nil { if in.Error == io.EOF {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 30 17:02:22 UTC 2023 - 4.9K bytes - Viewed (0)