Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 388 for finishes (0.44 sec)

  1. pkg/volume/util/nestedpendingoperations/nestedpendingoperations.go

    	// Defer operations are executed in Last-In is First-Out order. In this case
    	// the lock is acquired first when operationCompletes begins, and is
    	// released when the method finishes, after the lock is released cond is
    	// signaled to wake waiting goroutine.
    	defer grm.cond.Signal()
    	grm.lock.Lock()
    	defer grm.lock.Unlock()
    
    	if *err == nil || !grm.exponentialBackOffOnError {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 26 01:29:17 UTC 2022
    - 12.6K bytes
    - Viewed (0)
  2. tensorflow/compiler/jit/device_compiler_test.cc

      fn.set_name("foo");
    
      // Using a mock here to determine when the async compilation finishes. This is
      // to avoid using absl::SleepFor().
      // `RegisterCompilation` is the last call that happens just before the async
      // compilation completes. We use the completion of this call to determine when
      // the compilation finshes to verify expected behavior.
      Notification done;
      EXPECT_CALL(*mock_profiler_,
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Mar 12 06:33:33 UTC 2024
    - 19.8K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/conn.go

    	// serveHTTPComplete is channel that is closed/selected when "websocket#ServeHTTP" finishes.
    	serveHTTPComplete := make(chan struct{})
    	// Ensure panic in spawned goroutine is propagated into the parent goroutine.
    	panicChan := make(chan any, 1)
    	go func() {
    		// If websocket server returns, propagate panic if necessary. Otherwise,
    		// signal HTTPServe finished by closing "serveHTTPComplete".
    		defer func() {
    			if p := recover(); p != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 04 19:10:30 UTC 2024
    - 14.5K bytes
    - Viewed (0)
  4. src/net/cgo_unix.go

    // context is cancellable. It is intended for use with calls that don't support context
    // cancellation (cgo, syscalls). blocking func may still be running after this function finishes.
    // For the duration of the execution of the blocking function, the thread is 'acquired' using [acquireThread],
    // blocking might not be executed when the context gets canceled early.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sun Apr 14 18:23:45 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  5. tensorflow/c/eager/parallel_device/parallel_device_lib.h

      // return a bad status the caller must run all of the `Join`s or any future
      // `StartExecute`s will deadlock).
      //
      // If `is_async=false` (constructor argument), `cancellation_manager` must
      // live until `Join` finishes. If `is_async=true` it must live until `Join` is
      // followed by `TFE_ContextAsyncWait` to clear pending operations. It will be
      // used to cancel all other operations if any fails.
      //
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Tue Apr 25 15:21:13 UTC 2023
    - 12.9K bytes
    - Viewed (0)
  6. docs/en/docs/advanced/custom-response.md

    1. This is the generator function. It's a "generator function" because it contains `yield` statements inside.
    2. By using a `with` block, we make sure that the file-like object is closed after the generator function is done. So, after it finishes sending the response.
    3. This `yield from` tells the function to iterate over that thing named `file_like`. And then, for each part iterated, yield that part as coming from this generator function.
    
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Thu Apr 18 19:53:19 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  7. platforms/core-execution/execution/src/main/java/org/gradle/internal/execution/steps/AssignImmutableWorkspaceStep.java

     * inconsistent), then a unique temporary workspace directory is provided to the work to create its outputs
     * in, and the work is executed.</li>
     * <li>When the execution of the work finishes, we snapshot the outputs of the work, and store their hashes
     * in the {code metadata.bin} file in the temporary workspace directory.</li>
     * <li>We then attempt to move the temporary workspace directory (including the newly generated
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Mar 19 16:44:11 UTC 2024
    - 19.7K bytes
    - Viewed (0)
  8. docs/en/docs/tutorial/dependencies/dependencies-with-yield.md

    ```Python
    with open("./somefile.txt") as f:
        contents = f.read()
        print(contents)
    ```
    
    Underneath, the `open("./somefile.txt")` creates an object that is called a "Context Manager".
    
    When the `with` block finishes, it makes sure to close the file, even if there were exceptions.
    
    When you create a dependency with `yield`, **FastAPI** will internally create a context manager for it, and combine it with some other related tools.
    
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Sat Feb 24 23:06:37 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  9. src/net/tcpsock.go

    	}
    	return nil
    }
    
    // SetLinger sets the behavior of Close on a connection which still
    // has data waiting to be sent or to be acknowledged.
    //
    // If sec < 0 (the default), the operating system finishes sending the
    // data in the background.
    //
    // If sec == 0, the operating system discards any unsent or
    // unacknowledged data.
    //
    // If sec > 0, the data is sent in the background as with sec < 0.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 03:10:07 UTC 2024
    - 13.7K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apimachinery/pkg/util/wait/backoff.go

    	// safe for use from multiple threads. It returns a timer for backoff, and caller shall backoff
    	// until Timer.C() drains. If the second Backoff() is called before the timer from the first
    	// Backoff() call finishes, the first timer will NOT be drained and result in undetermined
    	// behavior.
    	Backoff() clock.Timer
    }
    
    // Deprecated: Will be removed when the legacy polling functions are removed.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 14 19:14:11 UTC 2023
    - 16.5K bytes
    - Viewed (0)
Back to top