Search Options

Results per page
Sort
Preferred Languages
Advance

Results 251 - 260 of 310 for Binding (0.1 sec)

  1. cmd/batch-rotate.go

    	batchKeyRotateAPIVersion           = "v1"
    	batchKeyRotateJobDefaultRetries    = 3
    	batchKeyRotateJobDefaultRetryDelay = 25 * time.Millisecond
    )
    
    // Start the batch key rottion job, resumes if there was a pending job via "job.ID"
    func (r *BatchJobKeyRotateV1) Start(ctx context.Context, api ObjectLayer, job BatchJobRequest) error {
    	ri := &batchJobInfo{
    		JobID:     job.ID,
    		JobType:   string(job.Type()),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 18 17:59:03 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  2. src/main/java/jcifs/util/transport/Transport.java

    /**
     * This class simplifies communication for protocols that support
     * multiplexing requests. It encapsulates a stream and some protocol
     * knowledge (provided by a concrete subclass) so that connecting,
     * disconnecting, sending, and receiving can be syncronized
     * properly. Apparatus is provided to send and receive requests
     * concurrently.
     */
    
    public abstract class Transport implements Runnable, AutoCloseable {
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 01 18:12:21 UTC 2020
    - 24.1K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/AbstractService.java

      /**
       * This method is called by {@link #stopAsync} when the service is still starting (i.e. {@link
       * #startAsync} has been called but {@link #notifyStarted} has not). Subclasses can override the
       * method to cancel pending work and then call {@link #notifyStopped} to stop the service.
       *
       * <p>This method should return promptly; prefer to do work on a different thread where it is
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 20.4K bytes
    - Viewed (0)
  4. cmd/storage-datatypes.go

    	IsLatest bool `msg:"is"`
    
    	// Deleted is set when this FileInfo represents
    	// a deleted marker for a versioned bucket.
    	Deleted bool `msg:"del"`
    
    	// TransitionStatus is set to Pending/Complete for transitioned
    	// entries based on state of transition
    	TransitionStatus string `msg:"ts"`
    	// TransitionedObjName is the object name on the remote tier corresponding
    	// to object (version) on the source tier.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  5. cmd/batch-handlers.go

    	}
    	_, err = api.CompleteMultipartUpload(ctx, tgtBucket, tgtObject, res.UploadID, uploadedParts, opts)
    	return err
    }
    
    // StartFromSource starts the batch replication job from remote source, resumes if there was a pending job via "job.ID"
    func (r *BatchJobReplicateV1) StartFromSource(ctx context.Context, api ObjectLayer, job BatchJobRequest) error {
    	ri := &batchJobInfo{
    		JobID:     job.ID,
    		JobType:   string(job.Type()),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  6. docs/en/docs/virtual-environments.md

    ```
    
    and use that one.
    
    ////
    
    An important detail is that it will put the virtual environment path at the **beginning** of the `PATH` variable. The system will find it **before** finding any other Python available. This way, when you run `python`, it will use the Python **from the virtual environment** instead of any other `python` (for example, a `python` from a global environment).
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sat Aug 24 03:16:23 UTC 2024
    - 21.7K bytes
    - Viewed (0)
  7. tests/query_test.go

    	if len(results2) != 0 {
    		t.Errorf("Search all records with inline map containing null value finding 0 records")
    	}
    
    	DB.Find(&results2, map[string]interface{}{"name": users[0].Name, "company_id": nil})
    	if len(results2) != 1 {
    		t.Errorf("Search all records with inline map containing null value finding 1 record")
    	}
    
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Mon Jun 24 09:42:59 UTC 2024
    - 50.4K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/Futures.java

          InCompletionOrderState<T> localState = state;
          if (super.cancel(interruptIfRunning)) {
            /*
             * requireNonNull is generally safe: If cancel succeeded, then this Future was still
             * pending, so its `state` field hasn't been nulled out yet.
             *
             * OK, it's technically possible for this to fail in the presence of unsafe publishing, as
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  9. Makefile.core.mk

    # Target run by the pre-commit script, to automate formatting and lint
    # If pre-commit script is not used, please run this manually.
    precommit: format lint
    
    format: fmt ## Auto formats all code. This should be run before sending a PR.
    
    fmt: format-go format-python tidy-go
    
    ifeq ($(DEBUG),1)
    # gobuild script uses custom linker flag to set the variables.
    RELEASE_LDFLAGS=''
    else
    RELEASE_LDFLAGS='-extldflags -static -s -w'
    endif
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Oct 03 23:53:59 UTC 2024
    - 18.4K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/cache/CacheBuilderTest.java

      }
    
      @GwtIncompatible // QueuingRemovalListener
      public void testRemovalNotification_clear() throws InterruptedException {
        // If a clear() happens while a computation is pending, we should not get a removal
        // notification.
    
        final AtomicBoolean shouldWait = new AtomicBoolean(false);
        final CountDownLatch computingLatch = new CountDownLatch(1);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 15:00:32 UTC 2024
    - 24.9K bytes
    - Viewed (0)
Back to top