Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 133 for Hockin (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  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.
    
    Registered: 2025-05-25 19:28
    - Last Modified: 2025-02-26 09:25
    - 3.9K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top