Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for Asyncer (0.2 sec)

  1. 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)
  2. cmd/untar.go

    	}
    	tarReader := tar.NewReader(r)
    	n := 0
    	asyncWriters := make(chan struct{}, 16)
    	var wg sync.WaitGroup
    
    	var asyncErr error
    	var asyncErrMu sync.Mutex
    	for {
    		if !o.ignoreErrs {
    			asyncErrMu.Lock()
    			err := asyncErr
    			asyncErrMu.Unlock()
    			if err != nil {
    				return err
    			}
    		}
    
    		header, err := tarReader.Next()
    		switch {
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 22 00:33:43 UTC 2024
    - 6K bytes
    - Viewed (2)
  3. android/guava-tests/test/com/google/common/collect/SynchronizedTableTest.java

      protected Table<String, Integer, Character> create(@Nullable Object... data) {
        TestTable<String, Integer, Character> table = new TestTable<>();
        Table<String, Integer, Character> synced = Synchronized.table(table, table.mutex);
        populate(synced, data);
        return synced;
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Aug 06 17:23:04 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/collect/SynchronizedTableTest.java

      protected Table<String, Integer, Character> create(@Nullable Object... data) {
        TestTable<String, Integer, Character> table = new TestTable<>();
        Table<String, Integer, Character> synced = Synchronized.table(table, table.mutex);
        populate(synced, data);
        return synced;
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Aug 06 17:23:04 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top