Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 123 for Hockin (0.16 sec)

  1. clause/locking.go

    package clause
    
    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 ")
    		builder.WriteQuoted(locking.Table)
    	}
    
    	if locking.Options != "" {
    Go
    - Registered: 2023-09-24 09:35
    - Last Modified: 2020-06-06 13:35
    - 610 bytes
    - Viewed (0)
  2. clause/locking_test.go

    			"SELECT * FROM `users` FOR UPDATE", nil,
    		},
    		{
    			[]clause.Interface{clause.Select{}, clause.From{}, clause.Locking{Strength: "SHARE", Table: clause.Table{Name: clause.CurrentTable}}},
    			"SELECT * FROM `users` FOR SHARE OF `users`", nil,
    		},
    		{
    Go
    - Registered: 2023-09-24 09:35
    - Last Modified: 2020-06-06 14:52
    - 933 bytes
    - Viewed (0)
  3. okhttp/src/jvmTest/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: 2023-09-22 11:42
    - Last Modified: 2023-05-10 08:45
    - 75.3K bytes
    - Viewed (0)
  4. 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: 2023-09-24 19:28
    - Last Modified: 2022-09-29 04:28
    - 3.9K bytes
    - Viewed (0)
  5. 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: 2023-09-22 12:43
    - Last Modified: 2023-09-06 17:04
    - 28.2K bytes
    - Viewed (0)
  6. 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: 2023-09-22 12:43
    - Last Modified: 2023-09-06 17:04
    - 28.2K bytes
    - Viewed (0)
  7. 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: 2023-09-24 19:28
    - Last Modified: 2023-09-04 19:57
    - 19.7K bytes
    - Viewed (0)
  8. 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: 2023-09-24 19:28
    - Last Modified: 2023-05-26 05:07
    - 2.6K bytes
    - Viewed (0)
  9. guava/src/com/google/common/base/Suppliers.java

        MemoizingSupplier(Supplier<T> delegate) {
          this.delegate = checkNotNull(delegate);
        }
    
        @Override
        @ParametricNullness
        public T get() {
          // A 2-field variant of Double Checked Locking.
          if (!initialized) {
            synchronized (this) {
              if (!initialized) {
                T t = delegate.get();
                value = t;
                initialized = true;
                return t;
    Java
    - Registered: 2023-09-22 12:43
    - Last Modified: 2023-05-23 23:27
    - 13.3K bytes
    - Viewed (0)
  10. okhttp/src/jvmMain/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.
     */
    abstract class ConnectionListener {
      /**
    Plain Text
    - Registered: 2023-09-22 11:42
    - Last Modified: 2023-02-04 21:02
    - 2K bytes
    - Viewed (0)
Back to top