- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 523 for donec (0.12 sec)
-
cmd/peer-rest-client.go
// Listen - listen on peers. func (client *peerRESTClient) Listen(ctx context.Context, listenCh chan<- []byte, v url.Values) { go func() { for { client.doListen(ctx, listenCh, v) select { case <-ctx.Done(): return default: // There was error in the REST request, retry after sometime as probably the peer is down. time.Sleep(5 * time.Second) } } }() }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
cmd/tier-journal.go
return } defer ro.Close() mr := msgpNewReader(ro) defer readMsgpReaderPoolPut(mr) done := false for { var entry jentry err := entry.DecodeMsg(mr) if errors.Is(err, io.EOF) { done = true break } if err != nil { logger.LogIf(ctx, fmt.Errorf("tier-journal: failed to decode journal entry %s", err)) break }
Go - Registered: Sun Feb 25 19:28:16 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 7.4K bytes - Viewed (0) -
cmd/metacache-walk.go
return err } ctx, done, err := p.TrackDiskHealth(ctx, storageMetricWalkDir, opts.Bucket, opts.BaseDir) if err != nil { return err } defer done(&err) return p.storage.WalkDir(ctx, opts, wr) } // WalkDir will traverse a directory and return all entries found. // On success a meta cache stream will be returned, that should be closed when done.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K bytes - Viewed (0) -
internal/dsync/dsync_test.go
// fmt.Println("Unlocking dm1") dm1st.Unlock(context.Background()) }() expect += 2 * testDrwMutexAcquireTimeout var wg sync.WaitGroup wg.Add(2) go func() { defer wg.Done() dm2nd.Lock(id, source) // Release lock after 10 seconds go func() { time.Sleep(2 * testDrwMutexAcquireTimeout) // fmt.Println("Unlocking dm2") dm2nd.Unlock(context.Background())
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
// We need new data from upstream. while (true) { val upstreamPos = ******@****.***amPos if (sourcePos != upstreamPos) break // No more data upstream. We're done. if (complete) return -1L // Another thread is already reading. Wait for that. if (upstreamReader != null) { timeout.waitUntilNotified(this@Relay)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
internal/grid/grid_test.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 30 15:03:35 GMT 2024 - 30.1K bytes - Viewed (0) -
ci/official/containers/linux_arm64/build.sh
Shell Script - Registered: Tue May 07 12:40:20 GMT 2024 - Last Modified: Fri Nov 03 13:38:49 GMT 2023 - 2.3K bytes - Viewed (0) -
cmd/os_other.go
maxEntries = opts.count } done := false remaining := opts.count for !done { // Read up to max number of entries. fis, err := d.Readdir(maxEntries) if err != nil { if err == io.EOF { break } return nil, osErrToFileErr(err) } if opts.count > -1 { if remaining <= len(fis) { fis = fis[:remaining] done = true } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Sep 13 15:14:36 GMT 2023 - 4K bytes - Viewed (0) -
cmd/data-scanner.go
if i.heal.enabled { done := globalScannerMetrics.time(scannerMetricHealCheck) size = i.applyHealing(ctx, o, oi) done() if healDeleteDangling { done := globalScannerMetrics.time(scannerMetricCleanAbandoned) err := o.CheckAbandonedParts(ctx, i.bucket, i.objectPath(), madmin.HealOpts{Remove: healDeleteDangling}) done() if err != nil {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 11:18:58 GMT 2024 - 47.6K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
continue } mergeCh <- append(grid.GetByteBuffer()[:0], buf.Bytes()...) case <-ctx.Done(): grid.PutByteBuffer(buf.Bytes()) return } } }() peers, _ := newPeerRestClients(globalEndpoints) err := globalHTTPListen.Subscribe(mask, localCh, ctx.Done(), func(ev event.Event) bool { if ev.S3.Bucket.Name != "" && bucketName != "" { if ev.S3.Bucket.Name != bucketName {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0)