Search Options

Results per page
Sort
Preferred Languages
Advance

Results 231 - 240 of 303 for caliper (0.07 sec)

  1. android/guava/src/com/google/common/util/concurrent/AggregateFuture.java

        this.futures = checkNotNull(futures);
        this.allMustSucceed = allMustSucceed;
        this.collectsValues = collectsValues;
      }
    
      @Override
      @SuppressWarnings("Interruption") // We are propagating an interrupt from a caller.
      protected final void afterDone() {
        super.afterDone();
    
        @RetainedLocalRef ImmutableCollection<? extends Future<?>> localFutures = futures;
        releaseResources(OUTPUT_FUTURE_DONE); // nulls out `futures`
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  2. CHANGELOG/CHANGELOG-1.32.md

      Similarly you can also access  kubelet's `/pods` endpoint to fetch a list of Pods bound to that node by granting the caller `nodes/pods` permission in RBAC.
      Similarly you can also access kubelet's `/configz` endpoint to fetch kubelet's configuration by granting the caller `nodes/configz` permission in RBAC.
    Registered: Fri Nov 01 09:05:11 UTC 2024
    - Last Modified: Tue Oct 29 20:17:52 UTC 2024
    - 121.6K bytes
    - Viewed (0)
  3. src/main/java/jcifs/util/transport/Transport.java

            return disconnect(hard, true);
        }
    
    
        /**
         * Disconnect the transport
         * 
         * @param hard
         * @param inUse
         *            whether the caller is holding a usage reference on the transport
         * @return whether conenction was in use
         * @throws IOException
         */
        public synchronized boolean disconnect ( boolean hard, boolean inUse ) throws IOException {
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Nov 01 18:12:21 UTC 2020
    - 24.1K bytes
    - Viewed (0)
  4. cmd/object-api-interface.go

    	PreserveETag                        string    // preserves this etag during a PUT call.
    	NoLock                              bool      // indicates to lower layers if the caller is expecting to hold locks.
    	ProxyRequest                        bool      // only set for GET/HEAD in active-active replication scenario
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  5. android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java

       * in no particular order.
       *
       * <p>The returned array will be "safe" in that no references to it are maintained by this queue.
       * (In other words, this method must allocate a new array). The caller is thus free to modify the
       * returned array.
       *
       * <p>This method acts as bridge between array-based and collection-based APIs.
       *
       * @return an array containing all of the elements in this queue
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Jun 07 21:36:32 UTC 2024
    - 19K bytes
    - Viewed (0)
  6. cmd/bucket-metadata-sys.go

    		return errInvalidArgument
    	}
    
    	if err := meta.Save(ctx, objAPI); err != nil {
    		return err
    	}
    
    	sys.Set(meta.Name, meta)
    	globalNotificationSys.LoadBucketMetadata(bgContext(ctx), meta.Name) // Do not use caller context here
    	return nil
    }
    
    // Delete delete the bucket metadata for the specified bucket.
    // must be used by all callers instead of using Update() with nil configData.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 20.4K bytes
    - Viewed (0)
  7. internal/grid/types.go

    func NewBytesCap(size int) *Bytes {
    	b := Bytes(GetByteBufferCap(size))
    	return &b
    }
    
    // NewBytesWith returns a new Bytes with the provided content.
    // When sent as a parameter, the caller gives up ownership of the byte slice.
    // When returned as response, the handler also gives up ownership of the byte slice.
    func NewBytesWith(b []byte) *Bytes {
    	bb := Bytes(b)
    	return &bb
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  8. tensorflow/c/eager/parallel_device/parallel_device_lib.cc

      // finished, if any.
      //
      // `cancellation_manager` must live until after `Join` finishes and pending
      // `is_async` operations finish. In addition to allowing the caller to cancel
      // the operation, its `StartCancel` method will be called if op execution
      // fails on any device in order to cancel the others.
      void StartExecute(TFE_Context* context, const char* operation_name,
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Mon Oct 21 04:14:14 UTC 2024
    - 25.9K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/base/Optional.java

       * Optional.orElseGet}, except when {@code supplier} returns {@code null}. In this case this
       * method throws an exception, whereas the Java 8+ method returns the {@code null} to the caller.
       *
       * @throws NullPointerException if this optional's value is absent and the supplier returns {@code
       *     null}
       */
      public abstract T or(Supplier<? extends T> supplier);
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 31 14:20:11 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/base/Verify.java

     * which approach to use, <b>don't worry</b> too much about it; just pick something that seems
     * reasonable and it will be fine.
     *
     * <ul>
     *   <li>If checking whether the <i>caller</i> has violated your method or constructor's contract
     *       (such as by passing an invalid argument), use the utilities of the {@link Preconditions}
     *       class instead.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon May 17 14:07:47 UTC 2021
    - 18.5K bytes
    - Viewed (0)
Back to top