Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 513 for Completer (0.07 sec)

  1. internal/s3select/message.go

    		strconv.FormatInt(bytesReturned, 10) + `</BytesReturned></Stats>`)
    	return genMessage(statsHeader, payload)
    }
    
    // endMessage - indicates that the request is complete, and no more messages will be sent.
    // You should not assume that the request is complete until the client receives an End message.
    //
    // Header specification:
    // End messages contain two headers, as follows:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 15.2K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/Service.java

        /** A service in this state is operational. */
        RUNNING,
    
        /** A service in this state is transitioning to {@link #TERMINATED}. */
        STOPPING,
    
        /**
         * A service in this state has completed execution normally. It does minimal work and consumes
         * minimal resources.
         */
        TERMINATED,
    
        /**
         * A service in this state has encountered a problem and may not be operational. It cannot be
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 10.7K bytes
    - Viewed (0)
  3. cmd/bucket-replication-utils_test.go

    		expectedCompletedSize:             249,
    		expectedReplicationStatusInternal: "arn1=COMPLETED;",
    		expectedReplicationStatus:         replication.Completed,
    		expectedOpType:                    replication.ObjectReplicationType,
    		expectedAction:                    replicateAll,
    	},
    	{ // 3. replication completed to single target; failed to another
    		name: "replication completed to single target",
    		tgtInfos: []replicatedTargetInfo{
    			{
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 08 20:27:40 UTC 2023
    - 9.3K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt

          if (entry.currentEditor == this) {
            if (civilizedFileSystem) {
              completeEdit(this, false) // Delete it now.
            } else {
              entry.zombie = true // We can't delete it until the current edit completes.
            }
          }
        }
    
        /**
         * Returns an unbuffered input stream to read the last committed value, or null if no value has
         * been committed.
         */
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 34.7K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java

        assertSame(defaultThread.getThreadGroup(), thread.getThreadGroup());
        assertSame(defaultThread.getUncaughtExceptionHandler(), thread.getUncaughtExceptionHandler());
    
        assertFalse(completed);
        thread.start();
        thread.join();
        assertTrue(completed);
    
        // Creating a new thread from the same ThreadFactory will have the same
        // pool ID but a thread ID of 2.
        Thread thread2 = threadFactory.newThread(monitoredRunnable);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt

        } else {
          timeout().deadlineNanoTime(nowNs + originalDurationNs)
        }
      }
    }
    
    /**
     * Attempts to exhaust this, returning true if successful. This is useful when reading a complete
     * source is helpful, such as when doing so completes a cache body or frees a socket connection for
     * reuse.
     */
    internal fun Source.discard(
      timeout: Int,
      timeUnit: TimeUnit,
    ): Boolean =
      try {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon May 13 13:42:37 UTC 2024
    - 10.7K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/UncheckedThrowingFuture.java

      }
    
      public void complete(RuntimeException e) {
        if (!super.setException(new WrapperException(checkNotNull(e)))) {
          throw new IllegalStateException("Future was already complete: " + this);
        }
      }
    
      public void complete(Error e) {
        if (!super.setException(new WrapperException(checkNotNull(e)))) {
          throw new IllegalStateException("Future was already complete: " + this);
        }
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 12 20:02:10 UTC 2018
    - 3.2K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/ThreadFactoryBuilderTest.java

        assertSame(defaultThread.getThreadGroup(), thread.getThreadGroup());
        assertSame(defaultThread.getUncaughtExceptionHandler(), thread.getUncaughtExceptionHandler());
    
        assertFalse(completed);
        thread.start();
        thread.join();
        assertTrue(completed);
    
        // Creating a new thread from the same ThreadFactory will have the same
        // pool ID but a thread ID of 2.
        Thread thread2 = threadFactory.newThread(monitoredRunnable);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  9. docs/distributed/DECOMMISSION.md

    ```
    
    ## Restart a canceled or failed decommission
    
    ```
    λ mc admin decommission start alias/ http://minio{1...2}/data{1...4}
    ```
    
    ## When decommission is 'Complete'
    
    Once decommission is complete, it will be indicated with *Complete* status.  *Complete* means that now you can now safely remove the first pool argument from the MinIO command line.
    
    ```
    λ mc admin decommission status alias/
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 11 14:59:49 UTC 2022
    - 8.3K bytes
    - Viewed (0)
  10. cmd/bucket-lifecycle.go

    // - in progress (no content on MinIO's disks yet)
    // - completed
    // - completed but expired (again, no content on MinIO's disks)
    func (r restoreObjStatus) OnDisk() bool {
    	if expiry, ok := r.Expiry(); ok && time.Now().UTC().Before(expiry) {
    		// completed
    		return true
    	}
    	return false // in progress or completed but expired
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
Back to top