- Sort Score
- Num 10 results
- Language All
Results 301 - 310 of 507 for mock (0.02 seconds)
-
cmd/batch-rotate.go
versionSuspended := globalBucketVersioningSys.PrefixSuspended(srcBucket, srcObject) lock := api.NewNSLock(r.Bucket, objInfo.Name) lkctx, err := lock.GetLock(ctx, globalOperationTimeout) if err != nil { return err } ctx = lkctx.Context() defer lock.Unlock(lkctx) opts := ObjectOptions{ VersionID: objInfo.VersionID, Versioned: versioned,
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 14.7K bytes - Click Count (0) -
cmd/batch-handlers.go
if ri == nil { return } ri.mu.Lock() defer ri.mu.Unlock() if success { ri.Bucket = bucket ri.Object = info.Name } ri.countItem(info.Size, info.DeleteMarker, success, attempt) } func (ri *batchJobInfo) trackCurrentBucketBatch(bucket string, batch []ObjectInfo) { if ri == nil { return } ri.mu.Lock() defer ri.mu.Unlock() ri.Bucket = bucketCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 63.5K bytes - Click Count (1) -
cmd/metacache-set.go
"math/rand" "strconv" "strings" "sync" "sync/atomic" "time" jsoniter "github.com/json-iterator/go" "github.com/minio/minio/internal/bucket/lifecycle" "github.com/minio/minio/internal/bucket/object/lock" "github.com/minio/minio/internal/bucket/versioning" "github.com/minio/minio/internal/color" "github.com/minio/minio/internal/hash" xioutil "github.com/minio/minio/internal/ioutil" "github.com/minio/pkg/v3/console" )
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 30.7K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/MapMakerInternalMap.java
* of reads may not be immediately reflected on the algorithm's data structures. These structures * are guarded by a lock and operations are applied in batches to avoid lock contention. The * penalty of applying the batches is spread across threads so that the amortized cost is slightly * higher than performing just the operation without enforcing the capacity constraint.
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 22 18:35:44 GMT 2025 - 89.9K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/PeekingIterator.java
* * <p>See the Guava User Guide article on <a href= * "https://github.com/google/guava/wiki/CollectionHelpersExplained#peekingiterator">{@code * PeekingIterator}</a>. * * @author Mick Killianey * @since 2.0 */ @DoNotMock("Use Iterators.peekingIterator") @GwtCompatible public interface PeekingIterator<E extends @Nullable Object> extends Iterator<E> { /**
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 2.4K bytes - Click Count (0) -
internal/lock/lock_windows_test.go
// GNU Affero General Public License for more details. // // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package lock import ( "strings" "testing" ) func TestFixLongPath(t *testing.T) { // 248 is long enough to trigger the longer-than-248 checks in // fixLongPath, but short enough not to make a path component
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Oct 18 18:08:15 GMT 2023 - 2.2K bytes - Click Count (0) -
docs/site-replication/gen-oidc-sts-cred.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package main // This programs mocks user interaction against Dex IDP and generates STS // credentials. It is for MinIO testing purposes only. // // Run like: // // $ MINIO_ENDPOINT=http://localhost:9000 go run gen-oidc-sts-cred.go import (
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Apr 29 01:27:09 GMT 2022 - 2.3K bytes - Click Count (1) -
cmd/data-scanner-metric.go
if c != nil { c2 := c.clone() c = &c2 } p.cycleInfoMu.Lock() p.cycleInfo = c p.cycleInfoMu.Unlock() } // getCycle returns the current cycle metrics. // If not nil, the returned value can safely be modified. func (p *scannerMetrics) getCycle() *currentScannerCycle { p.cycleInfoMu.Lock() defer p.cycleInfoMu.Unlock() if p.cycleInfo == nil { return nil }Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Oct 01 06:06:01 GMT 2025 - 9.4K bytes - Click Count (0) -
internal/config/lambda/target/lazyinit.go
m sync.Mutex } func (l *lazyInit) Do(f func() error) error { if atomic.LoadUint32(&l.done) == 0 { return l.doSlow(f) } return nil } func (l *lazyInit) doSlow(f func() error) error { l.m.Lock() defer l.m.Unlock() if atomic.LoadUint32(&l.done) == 0 { if err := f(); err != nil { return err } // Mark as done only when f() is successful atomic.StoreUint32(&l.done, 1) } return nil
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Mar 07 16:12:41 GMT 2023 - 1.3K bytes - Click Count (0) -
internal/stmt_store/stmt_store.go
// isTransaction: Indicates whether this operation is part of a transaction, which may affect the caching strategy. // connPool: A connection pool that provides database connections. // locker: A synchronization lock that is unlocked after initialization to avoid deadlocks. // Returns: // *Stmt: A newly created statement object for executing SQL operations. // error: An error if the statement preparation fails.
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Sun Apr 27 06:05:16 GMT 2025 - 6K bytes - Click Count (0)