- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for Unlock (0.33 sec)
-
cmd/bucket-replication.go
p.mu.RLock() workers := min(len(p.workers)+1, maxWorkers) existing := len(p.workers) p.mu.RUnlock() p.ResizeWorkers(workers, existing) } maxMRFWorkers := min(maxWorkers, MRFWorkerMaxLimit) if p.ActiveMRFWorkers() < maxMRFWorkers { p.mu.RLock() workers := min(p.mrfWorkerSize+1, maxMRFWorkers) p.mu.RUnlock() p.ResizeFailedWorkers(workers)
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Apr 20 09:05:54 GMT 2024 - 112K bytes - Viewed (1) -
android/guava/src/com/google/common/cache/LocalCache.java
} finally { unlock(); postWriteCleanup(); } } // reference queues, for garbage collection cleanup /** Cleanup collected entries when the lock is available. */ void tryDrainReferenceQueues() { if (tryLock()) { try { drainReferenceQueues(); } finally { unlock(); } } }
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 144.7K bytes - Viewed (0) -
guava/src/com/google/common/cache/LocalCache.java
} finally { unlock(); postWriteCleanup(); } } // reference queues, for garbage collection cleanup /** Cleanup collected entries when the lock is available. */ void tryDrainReferenceQueues() { if (tryLock()) { try { drainReferenceQueues(); } finally { unlock(); } } }
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:40:56 GMT 2024 - 150.3K bytes - Viewed (0) -
cmd/site-replication.go
nil, ) resultsMu.Lock() results.NodeResults = append(results.NodeResults, result) resultsMu.Unlock() return }() } wg.Wait() return } // GetClusterInfo - returns site replication information. func (c *SiteReplicationSys) GetClusterInfo(ctx context.Context) (info madmin.SiteReplicationInfo, err error) { c.RLock() defer c.RUnlock() if !c.enabled { return info, nil
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 182.7K bytes - Viewed (1) -
tensorflow/c/c_api.cc
bool ExtendSessionGraphHelper(TF_Session* session, TF_Status* status) { if (session->graph != nullptr) { // Take the graph lock before the session lock to avoid deadlock. This is // safe since session->graph does not change. session->graph->mu.lock(); mutex_lock session_lock(session->mu); const Graph& graph = session->graph->graph; const string& mutation_warning = session->graph->sessions[session];
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Mon Apr 15 03:35:10 GMT 2024 - 102.3K bytes - Viewed (0) -
src/cmd/cgo/internal/test/callback.go
callbackMutex.Lock() callbackToken++ i := callbackToken callbackFuncs[i] = f callbackMutex.Unlock() // Pass the address of i because the C function was written to // take a pointer. We could pass an int if we felt like // rewriting the C code. C.callback(unsafe.Pointer(&i)) callbackMutex.Lock() delete(callbackFuncs, i) callbackMutex.Unlock() } //export goCallback
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Fri May 12 12:00:02 GMT 2023 - 111.5K bytes - Viewed (0) -
doc/go1.17_spec.html
of an interface type or of elements of a composite type remains unchanged: </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
HTML - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Thu Apr 11 20:22:45 GMT 2024 - 211.6K bytes - Viewed (0) -
cmd/object-handlers_test.go
return } // push the obtained upload ID from the response into the array. testUploads.Lock() testUploads.uploads = append(testUploads.uploads, multipartResponse.UploadID) testUploads.Unlock() }() } // Wait till all go routines finishes execution. wg.Wait() // Validate the upload ID by an attempt to list parts using it.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Mar 10 21:09:36 GMT 2024 - 160K bytes - Viewed (0) -
cmd/object-handlers.go
return } // Take read lock on object, here so subsequent lower-level // calls do not need to. lock := objectAPI.NewNSLock(bucket, object) lkctx, err := lock.GetRLock(ctx, globalOperationTimeout) if err != nil { writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL) return } ctx = lkctx.Context() defer lock.RUnlock(lkctx) getObjectNInfo := objectAPI.GetObjectNInfo
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 05 11:39:31 GMT 2024 - 124.7K bytes - Viewed (0) -
api/go1.3.txt
pkg syscall (linux-amd64-cgo), type Flock_t struct, Pad_cgo_0 [4]uint8 pkg syscall (linux-amd64-cgo), type Flock_t struct, Pad_cgo_1 [4]uint8 pkg syscall (linux-amd64-cgo), type Flock_t struct, Pid int32 pkg syscall (linux-amd64-cgo), type Flock_t struct, Start int64 pkg syscall (linux-amd64-cgo), type Flock_t struct, Type int16 pkg syscall (linux-amd64-cgo), type Flock_t struct, Whence int16
Plain Text - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Mon Jun 02 02:45:00 GMT 2014 - 117K bytes - Viewed (0)