- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 1,043 for channel (0.2 sec)
-
internal/grid/grid_test.go
close(nowBlocking) // Block until test is done. <-stopBlocking return nil }) }() <-nowBlocking // Wait for the receiver channel to fill. for len(st.responses) != cap(st.responses) { time.Sleep(time.Millisecond) } cancel() <-serverCanceled local.debugMsg(debugIsOutgoingClosed, st.muxID, func(closed bool) { if !closed { t.Error("expected outgoing closed") } else {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 36.4K bytes - Viewed (0) -
RELEASE.md
### Bug Fixes and Other Changes * <SIMILAR TO ABOVE SECTION, BUT FOR OTHER IMPORTANT CHANGES / BUG FIXES> * <IF A CHANGE CLOSES A GITHUB ISSUE, IT SHOULD BE DOCUMENTED HERE> * <NOTES SHOULD BE GROUPED PER AREA> ## Keras <INSERT SMALL BLURB ABOUT RELEASE FOCUS AREA AND POTENTIAL TOOLCHAIN CHANGES> ### Breaking Changes * <DOCUMENT BREAKING CHANGES HERE>
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Tue Oct 22 14:33:53 UTC 2024 - 735.3K bytes - Viewed (0) -
cmd/object-api-utils.go
rng := rand.New(rand.NewSource(time.Now().UTC().UnixNano())) var d net.Dialer var retry int for retry < len(hosts) { ctx, cancel := context.WithTimeout(GlobalContext, 300*time.Millisecond) host = hosts[rng.Intn(len(hosts))] conn, err := d.DialContext(ctx, "tcp", host) cancel() if err != nil { retry++ continue } conn.Close() break } return host }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 08 15:29:58 UTC 2024 - 37.1K bytes - Viewed (0) -
cmd/data-scanner.go
// scanDataFolder will scanner the basepath+cache.Info.Name and return an updated cache. // The returned cache will always be valid, but may not be updated from the existing. // Before each operation sleepDuration is called which can be used to temporarily halt the scanner. // If the supplied context is canceled the function will return at the first chance.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 21:10:34 UTC 2024 - 48.4K bytes - Viewed (0) -
cmd/admin-handlers.go
} // Start profiling on remote servers. for _, profiler := range profiles { // Limit start time to max 10s. ctx, cancel := context.WithTimeout(ctx, 10*time.Second) globalNotificationSys.StartProfiling(ctx, profiler) // StartProfiling blocks, so we can cancel now. cancel() // Start profiling locally as well. prof, err := startProfiler(profiler) if err == nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 04 11:32:32 UTC 2024 - 99.7K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.14.md
- [Other notable changes](#other-notable-changes) - [v1.14.9](#v1149) - [Downloads for v1.14.9](#downloads-for-v1149) - [Client Binaries](#client-binaries-1) - [Server Binaries](#server-binaries-1) - [Node Binaries](#node-binaries-1) - [Changelog since v1.14.8](#changelog-since-v1148) - [Other notable changes](#other-notable-changes-1) - [v1.14.8](#v1148)
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Mon Jun 14 22:06:39 UTC 2021 - 271.5K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.32.md
- [Changes by Kind](#changes-by-kind) - [API Change](#api-change) - [Feature](#feature) - [Documentation](#documentation) - [Bug or Regression](#bug-or-regression) - [Other (Cleanup or Flake)](#other-cleanup-or-flake) - [Dependencies](#dependencies) - [Added](#added) - [Changed](#changed) - [Removed](#removed) - [v1.32.0-alpha.2](#v1320-alpha2)
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Tue Oct 29 20:17:52 UTC 2024 - 121.6K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.29.md
- [Container Images](#container-images-2) - [Changelog since v1.29.7](#changelog-since-v1297) - [Changes by Kind](#changes-by-kind-2) - [API Change](#api-change) - [Bug or Regression](#bug-or-regression-2) - [Dependencies](#dependencies-2) - [Added](#added-2) - [Changed](#changed-2) - [Removed](#removed-2) - [v1.29.7](#v1297) - [Downloads for v1.29.7](#downloads-for-v1297)
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Wed Oct 23 04:37:31 UTC 2024 - 375.1K bytes - Viewed (1) -
cmd/erasure-object.go
Healing: false, } mrfCheck := make(chan FileInfo) defer xioutil.SafeClose(mrfCheck) var rw sync.Mutex // Ask for all disks first; go func() { ctx, cancel := context.WithCancel(ctx) defer cancel() wg := sync.WaitGroup{} for i, disk := range disks { if disk == nil { done <- false continue } if !disk.IsOnline() { done <- false continue
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 78.8K bytes - Viewed (0) -
cmd/erasure-server-pool.go
// Updates must be closed before we return. defer xioutil.SafeClose(updates) ctx, cancel := context.WithCancel(ctx) defer cancel() var wg sync.WaitGroup var mu sync.Mutex var results []dataUsageCache var firstErr error allBuckets, err := z.ListBuckets(ctx, BucketOptions{}) if err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 89.8K bytes - Viewed (0)