- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 133 for Hockin (0.04 sec)
-
clause/locking.go
LockingOptionsNoWait = "NOWAIT" ) type Locking struct { Strength string Table Table Options string } // Name where clause name func (locking Locking) Name() string { return "FOR" } // Build build where clause func (locking Locking) Build(builder Builder) { builder.WriteString(locking.Strength) if locking.Table.Name != "" { builder.WriteString(" OF ")
Registered: 2025-05-25 09:35 - Last Modified: 2023-12-15 08:32 - 773 bytes - Viewed (0) -
clause/locking_test.go
Result string Vars []interface{} }{ { []clause.Interface{clause.Select{}, clause.From{}, clause.Locking{Strength: clause.LockingStrengthUpdate}}, "SELECT * FROM `users` FOR UPDATE", nil, }, { []clause.Interface{clause.Select{}, clause.From{}, clause.Locking{Strength: clause.LockingStrengthShare, Table: clause.Table{Name: clause.CurrentTable}}}, "SELECT * FROM `users` FOR SHARE OF `users`", nil, },
Registered: 2025-05-25 09:35 - Last Modified: 2023-12-15 08:32 - 1.2K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt
// We buffer some outbound data and headers and confirm that the END_STREAM flag comes with the // headers (and not with the data). // Write the mocking script. for the client peer.setClient(true) // Write the mocking script. peer.sendFrame().settings(Settings()) peer.sendFrame().headers(true, 3, headerEntries("client", "abc")) peer.acceptFrame() // ACK
Registered: 2025-05-30 11:42 - Last Modified: 2025-05-28 23:28 - 75.5K bytes - Viewed (0) -
docs/bucket/retention/README.md
Object locking requires locking to be enabled on a bucket at the time of bucket creation refer to `mc mb --with-lock`, object locking enables versioning on the bucket and cannot be disabled.
Registered: 2025-05-25 19:28 - Last Modified: 2025-02-26 09:25 - 3.9K bytes - Viewed (0) -
docs/bucket/replication/setup_replication.sh
#!/bin/sh # Create buckets with versioning and object locking enabled. mc mb -l source/bucket mc mb -l dest/bucket #### Create a replication admin on source alias # create a replication admin user : repladmin mc admin user add source repladmin repladmin123 # create a replication policy for repladmin cat >repladmin-policy-source.json <<EOF { "Version": "2012-10-17", "Statement": [ { "Action": [
Registered: 2025-05-25 19:28 - Last Modified: 2023-05-26 05:07 - 2.6K bytes - Viewed (0) -
internal/dsync/lock-args.go
Quorum *int `msgp:"omitempty"` } // ResponseCode is the response code for a locking request. type ResponseCode uint8 // Response codes for a locking request. const ( RespOK ResponseCode = iota RespLockConflict RespLockNotInitialized RespLockNotFound RespErr ) // LockResp is a locking request response. type LockResp struct { Code ResponseCode Err string
Registered: 2025-05-25 19:28 - Last Modified: 2024-07-24 10:24 - 1.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
/* * TODO(cpovirk): move ForwardingTestCase somewhere common, and use it to * test the forwarded methods */ } @AndroidIncompatible // Mocking ExecutorService is forbidden there. TODO(b/218700094): Don't mock. public void testListeningDecorator_noWrapExecuteTask() { ExecutorService delegate = mock(ExecutorService.class);
Registered: 2025-05-30 12:43 - Last Modified: 2025-05-13 18:46 - 28K bytes - Viewed (0) -
internal/dsync/drwmutex.go
var wg sync.WaitGroup for lockID := range restClnts { wg.Add(1) go func(lockID int) { defer wg.Done() if sendRelease(ctx, ds, restClnts[lockID], owner, (*locks)[lockID], isReadLock, names...) { (*locks)[lockID] = "" } }(lockID) } wg.Wait() // Return true if releaseAll was successful, otherwise we return 'false'
Registered: 2025-05-25 19:28 - Last Modified: 2025-01-31 19:54 - 20.4K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
* * <ul> * <li>for an unnested {@code lock()} and {@code unlock()}, a cycle detecting lock takes 38ns as * opposed to the 24ns taken by a plain lock. * <li>for nested locking, the cost increases with the depth of the nesting: * <ul> * <li>2 levels: average of 64ns per lock()/unlock() * <li>3 levels: average of 77ns per lock()/unlock()
Registered: 2025-05-30 12:43 - Last Modified: 2025-03-17 20:26 - 35.9K bytes - Viewed (0) -
internal/bucket/lifecycle/evaluator.go
} if e.replCfg.HasActiveRules(obj.Name, true) && !obj.VersionPurgeStatus.Empty() { return true } return false } // IsObjectLocked checks if it is appropriate to remove an // object according to locking configuration when this is lifecycle/ bucket quota asking. // (copied over from enforceRetentionForDeletion) func (e *Evaluator) IsObjectLocked(obj ObjectOpts) bool { if e.lockRetention == nil || !e.lockRetention.LockEnabled {
Registered: 2025-05-25 19:28 - Last Modified: 2025-04-08 15:41 - 4.6K bytes - Viewed (0)