Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for consume (0.05 sec)

  1. cmd/bucket-replication.go

    		defer xioutil.SafeClose(diffCh)
    		for res := range objInfoCh {
    			if res.Err != nil {
    				diffCh <- madmin.DiffInfo{Err: res.Err}
    				return
    			}
    			if contextCanceled(ctx) {
    				// Just consume input...
    				continue
    			}
    			obj := res.Item
    
    			// Ignore object prefixes which are excluded
    			// from versioning via the MinIO bucket versioning extension.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  2. tensorflow/c/c_api.cc

      }
      return count;
    }
    
    int TF_OperationOutputConsumers(TF_Output oper_out, TF_Input* consumers,
                                    int max_consumers) {
      int count = 0;
      for (const auto* edge : oper_out.oper->node.out_edges()) {
        if (edge->src_output() == oper_out.index) {
          if (count < max_consumers) {
            consumers[count] = {ToOperation(edge->dst()), edge->dst_input()};
          }
          ++count;
        }
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Tue May 13 06:30:43 UTC 2025
    - 102.3K bytes
    - Viewed (0)
  3. CHANGELOG/CHANGELOG-1.4.md

    * Let Services preserve client IPs and not double-hop from external LBs (alpha) ([#29409](https://github.com/kubernetes/kubernetes/pull/29409), [@girishkalele](https://github.com/girishkalele))
    * [Kubelet] Optionally consume configuration from <node-name> named config maps ([#30090](https://github.com/kubernetes/kubernetes/pull/30090), [@mtaufen](https://github.com/mtaufen))
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Thu Dec 24 02:28:26 UTC 2020
    - 133.5K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

       * any other derivation method on the original {@code ClosingFuture} instance.
       *
       * @param consumer a callback whose method will be called (using {@code executor}) when this
       *     operation is done
       */
      public void finishToValueAndCloser(
          ValueAndCloserConsumer<? super V> consumer, Executor executor) {
        checkNotNull(consumer);
        if (!compareAndUpdateState(OPEN, WILL_CREATE_VALUE_AND_CLOSER)) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 97.8K bytes
    - Viewed (0)
  5. src/main/webapp/js/admin/popper.min.js.map

    the popper grows once it's been positioned, it\n  // may happen that the popper gets misplaced because of the new content\n  // overflowing its reference element\n  // To avoid this problem, we provide two options (x and y), which allow\n  // the consumer to define the offset origin.\n  // If we position a popper on top of a reference element, we can set\n  // `x` to `top` to make the popper grow towards its top instead of\n  // its bottom.\n  let left, top;\n  if (sideA === 'bottom') {\n    // when...
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 120.9K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/ClosingFuture.java

       * any other derivation method on the original {@code ClosingFuture} instance.
       *
       * @param consumer a callback whose method will be called (using {@code executor}) when this
       *     operation is done
       */
      public void finishToValueAndCloser(
          ValueAndCloserConsumer<? super V> consumer, Executor executor) {
        checkNotNull(consumer);
        if (!compareAndUpdateState(OPEN, WILL_CREATE_VALUE_AND_CLOSER)) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 98.1K bytes
    - Viewed (0)
  7. cmd/admin-handlers.go

    	}
    }
    
    // The ConsoleLogHandler handler sends console logs to the connected HTTP client.
    func (a adminAPIHandlers) ConsoleLogHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    	objectAPI, _ := validateAdminReq(ctx, w, r, policy.ConsoleLogAdminAction)
    	if objectAPI == nil {
    		return
    	}
    	node := r.Form.Get("node")
    	// limit buffered console entries if client requested it.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
  8. src/main/webapp/js/admin/adminlte.min.js.map

    const usingDefTab = ($(SELECTOR_TAB_CONTENT).children().length > 2)\n\n    this._setupListeners()\n    this._fixHeight(true)\n\n    if (usingDefTab) {\n      const $el = $(`${SELECTOR_TAB_PANE}`).first()\n      // eslint-disable-next-line no-console\n      console.log($el)\n      const uniqueName = $el.attr('id').replace('panel-', '')\n      const navId = `#tab-${uniqueName}`\n\n      this.switchTab(navId, true)\n    }\n  }\n\n  _initFrameElement() {\n    if (window.frameElement && this._config.autoIframeMode)...
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 132.4K bytes
    - Viewed (0)
  9. src/main/webapp/js/bootstrap.min.js.map

    )\n\n    // make it clear we only want one instance per element\n    // can be removed later when multiple key/instances are fine to be used\n    if (!instanceMap.has(key) && instanceMap.size !== 0) {\n      // eslint-disable-next-line no-console\n      console.error(`Bootstrap doesn't allow more than one instance per element. Bound instance: ${Array.from(instanceMap.keys())[0]}.`)\n      return\n    }\n\n    instanceMap.set(key, instance)\n  },\n\n  get(element, key) {\n    if (elementMap.has(element))...
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sun Jan 12 06:14:02 UTC 2025
    - 211.9K bytes
    - Viewed (0)
  10. src/main/webapp/js/jquery-3.7.1.min.map

    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Oct 26 01:07:52 UTC 2024
    - 131.6K bytes
    - Viewed (0)
Back to top