Search Options

Results per page
Sort
Preferred Languages
Advance

Results 111 - 120 of 142 for rocks (0.06 sec)

  1. docs/en/docs/release-notes.md

    This release also removes `graphene` as an optional dependency for GraphQL. If you need to work with GraphQL, the recommended library now is [Strawberry](https://strawberry.rocks/). You can read the new [FastAPI with GraphQL docs](https://fastapi.tiangolo.com/advanced/graphql/).
    
    ### Features
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Fri Nov 01 11:25:57 UTC 2024
    - 460.3K bytes
    - Viewed (0)
  2. cmd/notification.go

    			}
    			serverLocksResp, err := sys.peerClients[index].GetLocks(ctx)
    			if err != nil {
    				return err
    			}
    			locksResp[index] = &PeerLocks{
    				Addr:  sys.peerClients[index].host.String(),
    				Locks: serverLocksResp,
    			}
    			return nil
    		}, index)
    	}
    	for index, err := range g.Wait() {
    		reqInfo := (&logger.ReqInfo{}).AppendTags("peerAddress",
    			sys.peerClients[index].host.String())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 46.2K bytes
    - Viewed (0)
  3. cmd/peer-rest-client.go

    }
    
    // Close - marks the client as closed.
    func (client *peerRESTClient) Close() error {
    	client.restClient.Close()
    	return nil
    }
    
    // GetLocks - fetch older locks for a remote node.
    func (client *peerRESTClient) GetLocks(ctx context.Context) (lockMap map[string][]lockRequesterInfo, err error) {
    	resp, err := getLocksRPC.Call(ctx, client.gridConn(), grid.NewMSS())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  4. 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)
  5. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

       * object to facilitate testing.
       */
      private final SleepingStopwatch stopwatch;
    
      // Can't be initialized in the constructor because mocks don't call the constructor.
      @CheckForNull private volatile Object mutexDoNotUseDirectly;
    
      private Object mutex() {
        Object mutex = mutexDoNotUseDirectly;
        if (mutex == null) {
          synchronized (this) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

    import java.util.concurrent.ScheduledFuture;
    import java.util.concurrent.ThreadFactory;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.TimeoutException;
    import java.util.concurrent.locks.ReentrantLock;
    import java.util.logging.Level;
    import javax.annotation.CheckForNull;
    import org.checkerframework.checker.nullness.qual.Nullable;
    
    /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 16:22:21 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/RateLimiter.java

       * object to facilitate testing.
       */
      private final SleepingStopwatch stopwatch;
    
      // Can't be initialized in the constructor because mocks don't call the constructor.
      @CheckForNull private volatile Object mutexDoNotUseDirectly;
    
      private Object mutex() {
        Object mutex = mutexDoNotUseDirectly;
        if (mutex == null) {
          synchronized (this) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  8. 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)
  9. test-site/activator-launch-1.3.2.jar

    scala.Serializable { public void ServerLauncher$$anonfun$serverJvmArgs$3(); } xsbt/boot/Locks$.class package xsbt.boot; public final synchronized class Locks$ implements xsbti.GlobalLock { public static final Locks$ MODULE$; private final Cache locks; public static void <clinit>(); public final Object apply(java.io.File, java.util.concurrent.Callable); private Object apply0(java.io.File, java.util.concurrent.Callable); private void Locks$(); } xsbt/boot/ConfigurationParser$$anonfun$3.class package xsbt.boot; public...
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Mon Apr 20 08:41:37 UTC 2015
    - 1.2M bytes
    - Viewed (0)
  10. cmd/metacache-set.go

    			err := o.checkMetacacheState(ctx, rpc)
    			if err != nil {
    				return entries, fmt.Errorf("remote listing canceled: %w", err)
    			}
    			retries = 1
    		}
    
    		// All operations are performed without locks, so we must be careful and allow for failures.
    		// Read metadata associated with the object from a disk.
    		if retries > 0 {
    			for _, disk := range er.getDisks() {
    				if disk == nil {
    					continue
    				}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
Back to top