- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 119 for Hockin (0.19 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 ")
Go - Registered: Sun Mar 24 09:35:10 GMT 2024 - Last Modified: Fri Dec 15 08:32:56 GMT 2023 - 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, },
Go - Registered: Sun Mar 24 09:35:10 GMT 2024 - Last Modified: Fri Dec 15 08:32:56 GMT 2023 - 1.2K bytes - Viewed (0) -
okhttp/src/test/java/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
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 75.4K bytes - Viewed (0) -
internal/dsync/lock-args.go
Quorum int } // 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
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 04:34:26 GMT 2024 - 1.7K 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);
Java - Registered: Fri Mar 22 12:43:11 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 28.2K 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.
Plain Text - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Sep 29 04:28:45 GMT 2022 - 3.9K 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'
Go - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K 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": [
Shell Script - Registered: Sun Mar 24 19:28:08 GMT 2024 - Last Modified: Fri May 26 05:07:25 GMT 2023 - 2.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/LazyLogger.java
private volatile @Nullable Logger logger; LazyLogger(Class<?> ownerOfLogger) { this.loggerName = ownerOfLogger.getName(); } Logger get() { /* * We use double-checked locking. We could the try racy single-check idiom, but that would * depend on Logger not contain mutable state. * * We could use Suppliers.memoizingSupplier here, but I micro-optimized to this implementation
Java - Registered: Fri Mar 22 12:43:11 GMT 2024 - Last Modified: Wed Dec 13 19:45:20 GMT 2023 - 1.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/ConnectionListener.kt
*/ package okhttp3 import okio.IOException /** * Listener for connection events. Extend this class to monitor the new connections and closes. * * All event methods must execute fast, without external locking, cannot throw exceptions, * attempt to mutate the event parameters, or be reentrant back into the client. * Any IO - writing to files or network should be done asynchronously. */ @ExperimentalOkHttpApi
Plain Text - Registered: Fri Mar 22 11:42:09 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 2.2K bytes - Viewed (0)