Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Locks (0.03 sec)

  1. cmd/iam-store.go

    		if !groups.Contains(group) {
    			continue
    		}
    		groups.Remove(group)
    		c.iamUserGroupMemberships[member] = groups
    	}
    }
    
    // policyDBGet - lower-level helper; does not take locks.
    //
    // If a group is passed, it returns policies associated with the group.
    //
    // If a user is passed, it returns policies of the user along with any groups
    // that the server knows the user is a member of.
    //
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Oct 14 16:35:37 UTC 2024
    - 83.2K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool.go

    		unlockOnDefer = true
    	}
    
    	checkPrecondFn := opts.CheckPrecondFn
    	opts.CheckPrecondFn = nil // do not need to apply pre-conditions at lower layer.
    	opts.NoLock = true        // no locks needed at lower levels for getObjectInfo()
    	objInfo, zIdx, err := z.getLatestObjectInfoWithIdx(ctx, bucket, object, opts)
    	if err != nil {
    		if objInfo.DeleteMarker {
    			if opts.VersionID == "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt

    import okhttp3.internal.EMPTY_BYTE_ARRAY
    import okhttp3.internal.EMPTY_HEADERS
    import okhttp3.internal.concurrent.TaskFaker
    import okhttp3.internal.concurrent.TaskRunner
    import okhttp3.internal.connection.Locks.withLock
    import okhttp3.internal.notifyAll
    import okhttp3.internal.wait
    import okio.AsyncTimeout
    import okio.Buffer
    import okio.BufferedSource
    import okio.Source
    import okio.buffer
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 75.4K bytes
    - Viewed (0)
  4. guava/src/com/google/common/collect/MapMakerInternalMap.java

    import java.util.concurrent.CancellationException;
    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.concurrent.atomic.AtomicReferenceArray;
    import java.util.concurrent.locks.ReentrantLock;
    import javax.annotation.CheckForNull;
    
    /**
     * The concurrent hash map implementation built by {@link MapMaker}.
     *
     * <p>This implementation is heavily derived from revision 1.96 of <a
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 90.8K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

    import java.util.concurrent.CancellationException;
    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.concurrent.atomic.AtomicReferenceArray;
    import java.util.concurrent.locks.ReentrantLock;
    import javax.annotation.CheckForNull;
    
    /**
     * The concurrent hash map implementation built by {@link MapMaker}.
     *
     * <p>This implementation is heavily derived from revision 1.96 of <a
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 90.8K bytes
    - Viewed (0)
  6. docs/changelogs/changelog_3x.md

        interface will make your code easier to test. When you test code that makes
        HTTP requests, you can use this interface to replace the real `OkHttpClient`
        with your own mocks or fakes.
    
        The interface will also let you use OkHttp's API with another HTTP client's
        implementation. This is useful in sandboxed environments like Google App
        Engine.
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Feb 06 14:55:54 UTC 2022
    - 50.8K bytes
    - Viewed (0)
Back to top