- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 187 for mateix (0.08 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)