Search Options

Results per page
Sort
Preferred Languages
Advance

Results 431 - 440 of 777 for callee (0.04 sec)

  1. cmd/bucket-lifecycle.go

    // UpdateWorkers at the end of this function leaves n goroutines waiting for
    // transition tasks
    func (t *transitionState) UpdateWorkers(n int) {
    	t.mu.Lock()
    	defer t.mu.Unlock()
    	if t.objAPI == nil { // Init hasn't been called yet.
    		return
    	}
    	t.updateWorkers(n)
    }
    
    func (t *transitionState) updateWorkers(n int) {
    	if n == 0 {
    		n = 100
    	}
    
    	for t.numWorkers < n {
    		go t.worker(t.objAPI)
    		t.numWorkers++
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  2. tensorflow/c/eager/c_api.cc

          static_cast<tensorflow::ContextDevicePlacementPolicy>(policy));
    }
    
    // Note: this function looks up a thread local policy. So it should be called in
    // the appropriate client thread. In particular, in async mode, it may not be
    // safe to call this function from the async EagerExecutor threads.
    extern TFE_ContextDevicePlacementPolicy TFE_ContextGetDevicePlacementPolicy(
        TFE_Context* ctx) {
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:11:17 UTC 2024
    - 43.9K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/collect/ImmutableSortedSet.java

       * safe to do so. The exact circumstances under which a copy will or will not be performed are
       * undocumented and subject to change.
       *
       * <p>This method is not type-safe, as it may be called on elements that are not mutually
       * comparable.
       *
       * @throws ClassCastException if the elements are not mutually comparable
       * @throws NullPointerException if any of {@code elements} is null
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  4. docs/en/docs/tutorial/dependencies/dependencies-with-yield.md

    # Dependencies with yield
    
    FastAPI supports dependencies that do some <abbr title='sometimes also called "exit code", "cleanup code", "teardown code", "closing code", "context manager exit code", etc.'>extra steps after finishing</abbr>.
    
    To do this, use `yield` instead of `return`, and write the extra steps (code) after.
    
    /// tip
    
    Make sure to use `yield` one single time per dependency.
    
    ///
    
    /// note | "Technical Details"
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 14K bytes
    - Viewed (0)
  5. internal/s3select/jstream/decoder.go

    			i, err = d.objectOrdered()
    		} else {
    			i, err = d.object()
    		}
    		return i, Object, err
    	default:
    		return nil, Unknown, d.mkError(ErrSyntax, "looking for beginning of value")
    	}
    }
    
    // string called by `any` or `object`(for map keys) after reading `"`
    func (d *Decoder) string() (string, error) {
    	d.scratch.reset()
    	c := d.next()
    
    scan:
    	for {
    		switch {
    		case c == '"':
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/SmbPipeHandleImpl.java

                        return this.handle.acquire();
                    }
    
                    // TODO: wait for pipe, still not sure when this needs to be called exactly
                    if ( this.uncPath.startsWith("\\pipe\\") ) {
                        th.send(new TransWaitNamedPipe(th.getConfig(), this.uncPath), new TransWaitNamedPipeResponse(th.getConfig()));
                    }
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Mon Apr 13 17:05:22 UTC 2020
    - 10.3K bytes
    - Viewed (0)
  7. okhttp/src/main/kotlin/okhttp3/WebSocket.kt

       * be transmitted before the close message is sent but subsequent calls to [send] will return
       * false and their messages will not be enqueued.
       *
       * This returns true if a graceful shutdown was initiated by this call. It returns false if
       * a graceful shutdown was already underway or if the web socket is already closed or canceled.
       *
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/MutableClassToInstanceMap.java

        return new MutableClassToInstanceMap<>(new HashMap<Class<? extends @NonNull B>, B>());
      }
    
      /**
       * Returns a new {@code MutableClassToInstanceMap} instance backed by a given empty {@code
       * backingMap}. The caller surrenders control of the backing map, and thus should not allow any
       * direct references to it to remain accessible.
       */
      public static <B extends @Nullable Object> MutableClassToInstanceMap<B> create(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  9. cmd/storage-errors.go

    // errLessData - returned when less data available than what was requested.
    var errLessData = StorageErr("less data available than what was requested")
    
    // errMoreData = returned when more data was sent by the caller than what it was supposed to.
    var errMoreData = StorageErr("more data was sent than what was advertised")
    
    // indicates readDirFn to return without further applying the fn()
    var errDoneForNow = errors.New("done for now")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Apr 04 12:04:40 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  10. internal/config/lambda/target/webhook.go

    func (target *WebhookTarget) Close() error {
    	target.cancel()
    	return nil
    }
    
    func (target *WebhookTarget) init() error {
    	return target.lazyInit.Do(target.initWebhook)
    }
    
    // Only called from init()
    func (target *WebhookTarget) initWebhook() error {
    	args := target.args
    	transport := target.transport
    
    	if args.ClientCert != "" && args.ClientKey != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 08 21:39:49 UTC 2024
    - 6.7K bytes
    - Viewed (0)
Back to top