- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 16 for Asyncer (0.06 sec)
-
docs/en/docs/async.md
### Other forms of asynchronous code
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Wed Aug 28 23:33:37 UTC 2024 - 23.5K bytes - Viewed (0) -
cmd/untar.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 22 00:33:43 UTC 2024 - 6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/SynchronizedTableTest.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Aug 06 17:23:04 UTC 2024 - 4.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/SynchronizedTableTest.java
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Aug 06 17:23:04 UTC 2024 - 4.6K bytes - Viewed (0) -
cmd/bucket-replication.go
replLogIf(ctx, err) } continue } p.resyncer.Lock() p.resyncer.statusMap[bucket] = meta p.resyncer.Unlock() tgts := meta.cloneTgtStats() for arn, st := range tgts { switch st.ResyncStatus { case ResyncFailed, ResyncStarted, ResyncPending: go p.resyncer.resyncBucket(ctx, objAPI, true, resyncOpts{ bucket: bucket, arn: arn,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 10 06:49:55 UTC 2024 - 116.1K bytes - Viewed (0) -
cmd/bucket-replication-handlers.go
if _, err = globalBucketMetadataSys.Update(ctx, bucket, bucketTargetsFile, tgtBytes); err != nil { writeErrorResponseJSON(ctx, w, toAPIError(ctx, err), r.URL) return } if err := globalReplicationPool.Get().resyncer.start(ctx, objectAPI, resyncOpts{ bucket: bucket, arn: arn, resyncID: resetID, resyncBefore: resetBeforeDate, }); err != nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 23.3K bytes - Viewed (0) -
internal/http/server.go
// Take a copy of server fields. var tlsConfig *tls.Config if srv.TLSConfig != nil { tlsConfig = srv.TLSConfig.Clone() } handler := srv.Handler // if srv.Handler holds non-synced state -> possible data race // Create new HTTP listener. var listener *httpListener listener, listenErrs := newHTTPListener( listenCtx, srv.Addrs, srv.TCPOptions, ) var interfaceFound bool
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 19 18:42:47 UTC 2024 - 6.1K bytes - Viewed (0) -
cmd/site-replication.go
m.LastUpdate = UTCNow() } globalReplicationPool.Get().resyncer.statusMap[bucket] = m globalReplicationPool.Get().resyncer.Unlock() } } rs.Status = ResyncCanceled rs.LastUpdate = UTCNow() if err := saveSiteResyncMetadata(ctx, rs, objAPI); err != nil { return res, err } select { case globalReplicationPool.Get().resyncer.resyncCancelCh <- struct{}{}: case <-ctx.Done(): }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 185.1K bytes - Viewed (0) -
docs/en/docs/release-notes.md
* 📝 Add docs about Environment Variables and Virtual Environments. PR [#12054](https://github.com/fastapi/fastapi/pull/12054) by [@tiangolo](https://github.com/tiangolo). * 📝 Add Asyncer mention in async docs. PR [#12037](https://github.com/fastapi/fastapi/pull/12037) by [@tiangolo](https://github.com/tiangolo).
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Fri Nov 01 11:25:57 UTC 2024 - 460.3K bytes - Viewed (0) -
cmd/storage-datatypes.go
UpdateOpts UpdateMetadataOpts `msg:"uo"` FI FileInfo `msg:"fi"` } // UpdateMetadataOpts provides an optional input to indicate if xl.meta updates need to be fully synced to disk. type UpdateMetadataOpts struct { NoPersistence bool `msg:"np"` } // CheckPartsHandlerParams are parameters for CheckPartsHandler type CheckPartsHandlerParams struct { DiskID string `msg:"id"`
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 15:30:50 UTC 2024 - 17.3K bytes - Viewed (0)