- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 123 for iowait (0.15 sec)
-
internal/dsync/dsync_test.go
cancel := func() { cl() wg.Done() } if !dm.GetLock(ctx, cancel, id, source, Options{Timeout: 5 * time.Minute}) { t.Fatal("GetLock() should be successful") } // Wait until context is canceled wg.Wait() if ctx.Err() == nil { t.Fatal("Unexpected error", ctx.Err()) } // Should be safe operation in all cases dm.Unlock(context.Background()) } // Test Unlock should not timeout
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0) -
internal/grid/connection.go
return true }) c.inStream.Range(func(key uint64, value *muxServer) bool { value.close() return true }) c.inStream.Clear() c.outgoing.Clear() // Wait for existing to exit c.handleMsgWg.Wait() } func (c *Connection) updateState(s State) { c.connChange.L.Lock() defer c.connChange.L.Unlock() // We may have reads that aren't locked, so update atomically.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 42.6K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
func (f *fakeServer) ConstructInitialSnapshot(ambientPods []*corev1.Pod) error { if f.testWG != nil { defer f.testWG.Done() } args := f.Called(ambientPods) return args.Error(0) } // Custom "wait group with timeout" for waiting for fakeServer calls in a goroutine to finish type WaitGroup struct { count int32 done chan struct{} } func NewWaitGroup() *WaitGroup { return &WaitGroup{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K bytes - Viewed (0) -
cmd/batch-expire.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
cmd/namespace-lock_test.go
} // lk2 lk2ch := make(chan struct{}) go func() { defer close(lk2ch) nsLk.lock(ctx, "volume", "path", "source", "opsID", false, 1*time.Millisecond) }() time.Sleep(1 * time.Millisecond) // wait for goroutine to advance; ref=2 // Unlock the 1st lock; ref=1 after this line nsLk.unlock("volume", "path", false) // Taking another lockMapMutex here allows queuing up additional lockers. This should
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 23 18:58:53 GMT 2021 - 3.1K bytes - Viewed (0) -
internal/grid/debug.go
manager.debugMsg(debugShutdown) } for _, server := range t.Servers { server.Close() } for _, listener := range t.Listeners { listener.Close() } }) } // WaitAllConnect will wait for all connections to be established. func (t *TestGrid) WaitAllConnect(ctx context.Context) { for _, manager := range t.Managers { for _, remote := range manager.Targets() { if manager.HostName() == remote {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 08 18:15:27 GMT 2024 - 4.2K bytes - Viewed (0) -
misc/linkcheck/linkcheck.go
log.Printf(" url %s has #%s", url, id) } fragExists[urlFrag{url, id}] = true } return nil } func main() { flag.Parse() go crawlLoop() crawl(*root, "") wg.Wait() close(urlq) for uf, needers := range neededFrags { if !fragExists[uf] { problems = append(problems, fmt.Sprintf("Missing fragment for %+v from %v", uf, needers)) } }
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Wed Oct 06 15:53:04 GMT 2021 - 3.9K bytes - Viewed (0) -
cmd/dynamic-timeouts_test.go
timeout.LogSuccess(time.Duration(float64(time.Second) * rng.Float64())) } to := timeout.Timeout() if to < time.Millisecond || to > time.Second { panic(to) } } }() } wg.Wait() } func TestDynamicTimeoutHitMinimum(t *testing.T) { const minimum = 30 * time.Second timeout := newDynamicTimeout(time.Minute, minimum) initial := timeout.Timeout()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Oct 14 10:08:40 GMT 2022 - 5.4K bytes - Viewed (0) -
cmd/erasure-metadata.go
fi.Erasure.Index = index + 1 if fi.IsValid() { return disks[index].WriteMetadata(ctx, origbucket, bucket, prefix, fi) } return errFileCorrupt }, index) } // Wait for all the routines. mErrs := g.Wait() err := reduceWriteQuorumErrs(ctx, mErrs, objectOpIgnoredErrs, quorum) return evalDisks(disks, mErrs), err } func commonParity(parities []int, defaultParityCount int) int {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 19.2K bytes - Viewed (1) -
cmd/peer-rest-server.go
if traceOpts.TraceTypes().Contains(madmin.TraceBootstrap) { go globalBootstrapTracer.Publish(ctx, globalTrace) } // Wait for remote to cancel and SubscribeJSON to exit. wg.Wait() return nil } func (s *peerRESTServer) BackgroundHealStatusHandler(_ *grid.MSS) (*grid.JSON[madmin.BgHealState], *grid.RemoteErr) {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0)