Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 187 for mateix (0.08 sec)

  1. tensorflow/c/eager/c_api_experimental.cc

    #include "tensorflow/core/lib/monitoring/gauge.h"
    #include "tensorflow/core/lib/monitoring/sampler.h"
    #include "tensorflow/core/platform/casts.h"
    #include "tensorflow/core/platform/errors.h"
    #include "tensorflow/core/platform/mutex.h"
    #include "tensorflow/core/platform/strcat.h"
    
    using tensorflow::string;
    
    void TFE_OpReset(TFE_Op* op_to_reset, const char* op_or_function_name,
                     const char* raw_device_name, TF_Status* status) {
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 35.9K bytes
    - Viewed (0)
  2. cmd/bucket-replication.go

    		})
    		return
    	}
    	ctx = lkctx.Context()
    	defer lk.Unlock(lkctx)
    
    	rinfos := replicatedInfos{Targets: make([]replicatedTargetInfo, 0, len(dsc.targetsMap))}
    	var wg sync.WaitGroup
    	var mu sync.Mutex
    	for _, tgtEntry := range dsc.targetsMap {
    		if !tgtEntry.Replicate {
    			continue
    		}
    		// if dobj.TargetArn is not empty string, this is a case of specific target being re-synced.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  3. cmd/bucket-lifecycle.go

    	src     lcEventSrc
    	event   lifecycle.Event
    }
    
    type transitionState struct {
    	transitionCh chan transitionTask
    
    	ctx        context.Context
    	objAPI     ObjectLayer
    	mu         sync.Mutex
    	numWorkers int
    	killCh     chan struct{}
    
    	activeTasks          atomic.Int64
    	missedImmediateTasks atomic.Int64
    
    	lastDayMu    sync.RWMutex
    	lastDayStats map[string]*lastDayTierStats
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  4. cmd/test-utils_test.go

    )
    
    // Random number state.
    // We generate random temporary file names so that there's a good
    // chance the file doesn't exist yet.
    var (
    	randN  uint32
    	randmu sync.Mutex
    )
    
    // Temp files created in default Tmp dir
    var globalTestTmpDir = os.TempDir()
    
    // reseed - returns a new seed every time the function is called.
    func reseed() uint32 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 77K bytes
    - Viewed (0)
  5. cmd/bucket-policy-handlers_test.go

    	credentials auth.Credentials, t *testing.T,
    ) {
    	bucketName1 := fmt.Sprintf("%s-1", bucketName)
    
    	const n = 100
    	start := make(chan struct{})
    	var ok, errs int
    	var wg sync.WaitGroup
    	var mu sync.Mutex
    	wg.Add(n)
    	for i := 0; i < n; i++ {
    		go func() {
    			defer wg.Done()
    			// Sync start.
    			<-start
    			if err := obj.MakeBucket(GlobalContext, bucketName1, MakeBucketOptions{}); err != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 32.9K bytes
    - Viewed (0)
  6. internal/grid/grid_test.go

    	errFatal(err)
    
    	// Wait for the server start the request.
    	<-reqStarted
    
    	// Block until we have exceeded the deadline several times over.
    	nowBlocking := make(chan struct{})
    	var mu sync.Mutex
    	time.AfterFunc(time.Second, func() {
    		mu.Lock()
    		cancel()
    		close(nowBlocking)
    		mu.Unlock()
    	})
    	if inCap > 0 {
    		go func() {
    			defer close(st.Requests)
    			if !blockReq {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 36.4K bytes
    - Viewed (0)
  7. doc/go_spec.html

    </p>
    
    <pre>
    // A Mutex is a data type with two methods, Lock and Unlock.
    type Mutex struct         { /* Mutex fields */ }
    func (m *Mutex) Lock()    { /* Lock implementation */ }
    func (m *Mutex) Unlock()  { /* Unlock implementation */ }
    
    // NewMutex has the same composition as Mutex but its method set is empty.
    type NewMutex Mutex
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Oct 02 00:58:01 UTC 2024
    - 282.5K bytes
    - Viewed (0)
  8. cmd/erasure-healing.go

    func listAllBuckets(ctx context.Context, storageDisks []StorageAPI, healBuckets map[string]VolInfo, readQuorum int) error {
    	g := errgroup.WithNErrs(len(storageDisks))
    	var mu sync.Mutex
    	for index := range storageDisks {
    		index := index
    		g.Go(func() error {
    			if storageDisks[index] == nil {
    				// we ignore disk not found errors
    				return nil
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  9. cmd/xl-storage-disk-id-check.go

    	return diskMetric
    }
    
    // lockedLastMinuteLatency accumulates totals lockless for each second.
    type lockedLastMinuteLatency struct {
    	cachedSec int64
    	cached    atomic.Pointer[AccElem]
    	mu        sync.Mutex
    	init      sync.Once
    	lastMinuteLatency
    }
    
    func (e *lockedLastMinuteLatency) add(value time.Duration) {
    	e.addSize(value, 0)
    }
    
    // addSize will add a duration and size.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  10. 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 {
    		return err
    	}
    
    	if len(allBuckets) == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top