- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 54 for mute (0.15 sec)
-
cmd/bucket-replication-stats.go
Cache map[string]*BucketReplicationStats mostRecentStats BucketStatsMap registry metrics.Registry sync.RWMutex // mutex for Cache mostRecentStatsMu sync.Mutex // mutex for mostRecentStats wlock sync.RWMutex // mutex for active workers movingAvgTicker *time.Ticker // Ticker for calculating moving averages wTimer *time.Ticker // ticker for calculating active workers
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 13.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/SetOperationsTest.java
HashSet<String> mut = Sets.symmetricDifference(friends, enemies).copyInto(new HashSet<String>()); enemies.add("Dave"); assertEquals(3, symmetricDifferenceFriendsFirst.size()); assertEquals(4, immut.size()); assertEquals(4, mut.size()); immut = Sets.symmetricDifference(enemies, friends).immutableCopy();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Feb 19 20:34:55 GMT 2024 - 14.7K bytes - Viewed (0) -
tensorflow/c/c_api_experimental.cc
return nullptr; #else TF_Library* lib_handle = new TF_Library; static tensorflow::mutex mu(tensorflow::LINKER_INITIALIZED); static std::unordered_map<std::string, void*>* loaded_libs = new std::unordered_map<std::string, void*>(); tensorflow::Env* env = tensorflow::Env::Default(); { tensorflow::mutex_lock lock(mu); auto it = loaded_libs->find(library_filename); if (it != loaded_libs->end()) {
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Mon Apr 15 03:35:10 GMT 2024 - 29.4K bytes - Viewed (0) -
doc/go_mem.html
or a <i>synchronizing operation</i> such as an atomic data access, a mutex operation, or a channel operation,</li> <li>its location in the program,</li> <li>the memory location or variable being accessed, and</li> <li>the values read or written by the operation.</li> </ul> <p> Some memory operations are <i>read-like</i>, including read, atomic read, mutex lock, and channel receive.
HTML - Registered: Tue May 07 11:14:38 GMT 2024 - Last Modified: Mon Mar 04 15:54:42 GMT 2024 - 26.6K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache.h
std::list<Key>::iterator lra_iterator; /// The timestamp (seconds since epoch) at which the block was cached. uint64_t timestamp; /// Mutex to guard state variable absl::Mutex mu; /// The state of the block. FetchState state ABSL_GUARDED_BY(mu) = FetchState::CREATED; /// Wait on cond_var if state is FETCHING. absl::CondVar cond_var; };
C - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Mon Aug 31 04:46:34 GMT 2020 - 10.6K bytes - Viewed (0) -
cmd/prepare-storage.go
) var printEndpointError = func() func(Endpoint, error, bool) { var mutex sync.Mutex printOnce := make(map[Endpoint]map[string]int) return func(endpoint Endpoint, err error, once bool) { reqInfo := (&logger.ReqInfo{}).AppendTags("endpoint", endpoint.String()) ctx := logger.SetReqInfo(GlobalContext, reqInfo) mutex.Lock() defer mutex.Unlock() m, ok := printOnce[endpoint] if !ok { m = make(map[string]int)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 11.1K bytes - Viewed (0) -
tensorflow/c/c_api_function.cc
} int TF_GraphNumFunctions(TF_Graph* g) { tensorflow::mutex_lock l(g->mu); return g->graph.flib_def().num_functions(); } int TF_GraphGetFunctions(TF_Graph* g, TF_Function** funcs, int max_func, TF_Status* status) { tensorflow::FunctionDefLibrary lib; { tensorflow::mutex_lock l(g->mu); lib = g->graph.flib_def().ToProto(); }
C++ - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Mon Apr 15 03:35:10 GMT 2024 - 13.6K bytes - Viewed (2) -
cmd/globals.go
// into an SSE-S3 request. If enabled a valid, non-empty KMS // configuration must be present. globalAutoEncryption bool // Is compression enabled? globalCompressConfigMu sync.Mutex globalCompressConfig compress.Config // Some standard object extensions which we strictly dis-allow for compression.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 16.5K bytes - Viewed (0) -
internal/config/identity/plugin/config.go
return nil } plugin := AuthNPlugin{ args: args, client: &http.Client{Transport: args.Transport}, shutdownCtx: shutdownCtx, serviceMetrics: &metrics{ Mutex: sync.Mutex{}, LastCheckSuccess: time.Unix(0, 0), LastCheckFailure: time.Unix(0, 0), lastFullMinute: serviceRTTMinuteStats{}, currentMinute: serviceRTTMinuteStats{}, }, }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 13.3K bytes - Viewed (3) -
cmd/bucket-replication-metrics.go
) // rateMeasurement captures the transfer details for one bucket/target //msgp:ignore rateMeasurement type rateMeasurement struct { lock sync.Mutex bytesSinceLastWindow uint64 // Total bytes since last window was processed startTime time.Time // Start time for window expMovingAvg float64 // Previously calculated exponential moving average }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Feb 06 06:00:45 GMT 2024 - 14.2K bytes - Viewed (0)