Search Options

Results per page
Sort
Preferred Languages
Advance

Results 301 - 310 of 621 for takeIf (1.32 sec)

  1. docs/bigdata/README.md

    ```
    sudo pip install yq
    alias kv-pairify='yq ".configuration[]" | jq ".[]" | jq -r ".name + \"=\" + .value"'
    ```
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Aug 12 18:20:36 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  2. CONTRIBUTING.md

    ![image](https://github.com/tensorflow/tensorflow/assets/52792999/3eea4ca5-daa0-4570-b0b5-2a2b03a724a3)
    
    ### Contributor License Agreements
    
    We'd love to accept your patches! Before we can take them, we have to jump a couple of legal hurdles.
    
    Please fill out either the individual or corporate Contributor License Agreement (CLA).
    
    Registered: Tue Dec 30 12:39:10 UTC 2025
    - Last Modified: Sat Jan 11 04:47:59 UTC 2025
    - 15.9K bytes
    - Viewed (0)
  3. cmd/iam-store.go

    		scred := su.Credentials
    		if scred.ParentUser != parentUser {
    			return updatedAt, fmt.Errorf("%w: the service account access key is taken by another user", errIAMServiceAccountNotAllowed)
    		}
    		return updatedAt, fmt.Errorf("%w: the service account access key already taken", errIAMServiceAccountNotAllowed)
    	}
    
    	// Parent user must not be a service account.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 87.1K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/util/concurrent/TestThread.java

        throw new NoSuchMethodError(methodName);
      }
    
      @Override
      public void run() {
        assertSame(this, Thread.currentThread());
        try {
          while (true) {
            Request request = requestQueue.take();
            Object result;
            try {
              result = invokeMethod(request.methodName, request.arguments);
            } catch (ThreadDeath death) {
              return;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 21:00:51 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  5. cmd/local-locker.go

    		return false, nil
    	}
    	// Wait for mutex
    	defer l.getMutex()()
    	if ctx.Err() != nil {
    		return false, ctx.Err()
    	}
    	if !l.canTakeLock(args.Resources...) {
    		// Not all locks can be taken on resources,
    		// reject it completely.
    		return false, nil
    	}
    
    	// No locks held on the all resources, so claim write
    	// lock on all resources at once.
    	now := UTCNow()
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 12K bytes
    - Viewed (0)
  6. internal/hash/reader.go

    type Options struct {
    	MD5Hex     string
    	SHA256Hex  string
    	Size       int64
    	ActualSize int64
    	DisableMD5 bool
    	ForceMD5   []byte
    }
    
    // NewReaderWithOpts is like NewReader but takes `Options` as argument, allowing
    // callers to indicate if they want to disable md5sum checksum.
    func NewReaderWithOpts(ctx context.Context, src io.Reader, opts Options) (*Reader, error) {
    	// return hard limited reader
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Wed Jun 25 15:08:54 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  7. internal/bucket/lifecycle/lifecycle.go

    				// Indicates whether MinIO will remove a delete marker with no noncurrent versions.
    				// Only latest marker is removed. If set to true, the delete marker will be expired;
    				// if set to false the policy takes no action. This cannot be specified with Days or
    				// Date in a Lifecycle Expiration Policy.
    				events = append(events, Event{
    					Action: DeleteVersionAction,
    					RuleID: rule.ID,
    					Due:    now,
    				})
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Thu Apr 03 06:45:06 UTC 2025
    - 18.2K bytes
    - Viewed (0)
  8. cmd/sftp-server-driver.go

    	return f.permissions.CriticalOptions["AccessKey"]
    }
    
    func (f *sftpDriver) Fileread(r *sftp.Request) (ra io.ReaderAt, err error) {
    	// This is not timing the actual read operation, but the time it takes to prepare the reader.
    	stopFn := globalSftpMetrics.log(r, f.AccessKey())
    	defer stopFn(0, err)
    
    	flags := r.Pflags()
    	if !flags.Read {
    		// sanity check
    		return nil, os.ErrInvalid
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Feb 10 16:35:49 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  9. docs/contribute/concurrency.md

    ### Holding multiple locks
    
    You're allowed to take the Http2Connection lock while holding the Http2Writer lock. But not vice-versa. Because taking the Http2Writer lock can block.
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
  10. README.md

    ---
    
    ### 🔗 **Additional Resources**
    
    To make the most out of Gradle, take advantage of these additional resources:
    
    - **[Gradle Documentation](https://docs.gradle.org/)** - Your go-to guide for all Gradle-related documentation.
    Registered: Wed Dec 31 11:36:14 UTC 2025
    - Last Modified: Mon Oct 20 22:15:26 UTC 2025
    - 7.8K bytes
    - Viewed (0)
Back to top