Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 8 of 8 for propagation (0.08 seconds)

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

      // methods that involve volatile read/write operations, in practice there is no issue. Also, the
      // way in such a visibility issue would surface is most likely as a failure of cancel() to
      // propagate to the input. Cancellation propagation is fundamentally racy so this is fine.
      //
      // Future versions of the JMM may revise safe construction semantics in such a way that we can
      // safely publish these objects and we won't need this whole discussion.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 17 19:26:39 GMT 2026
    - 64.2K bytes
    - Click Count (0)
  2. CHANGELOG/CHANGELOG-1.32.md

    - Added request header UID propagation, behind an alpha `RemoteRequestHeaderUID` feature gate. ([#129081](https://github.com/kubernetes/kubernetes/pull/129081), [@stalz](https://github.com/stlaz)) [SIG API SIG API Machinery, cluster lifecycle, testing]
    
    ### Failing Test
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu Feb 26 23:58:21 GMT 2026
    - 470.5K bytes
    - Click Count (0)
  3. internal/stmt_store/stmt_store.go

    //	error: An error if the statement preparation fails.
    func (s *lruStore) New(ctx context.Context, key string, isTransaction bool, conn ConnPool, locker sync.Locker) (_ *Stmt, err error) {
    	// Create a Stmt object and set its Transaction property.
    	// The prepared channel is used to synchronize the statement preparation state.
    	cacheStmt := &Stmt{
    		Transaction: isTransaction,
    Created: Sun Apr 05 09:35:12 GMT 2026
    - Last Modified: Sat Mar 21 11:35:55 GMT 2026
    - 6.1K bytes
    - Click Count (0)
  4. docs/en/docs/release-notes.md

    ## 0.122.1 (2025-11-30)
    
    ### Fixes
    
    * 🐛 Fix hierarchical security scope propagation. PR [#5624](https://github.com/fastapi/fastapi/pull/5624) by [@kristjanvalur](https://github.com/kristjanvalur).
    
    ### Docs
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Apr 03 12:07:04 GMT 2026
    - 631K bytes
    - Click Count (0)
  5. src/test/java/org/codelibs/fess/crawler/interval/FessIntervalControllerTest.java

            try {
                // Note: In unit test environment, ComponentUtil may not be fully initialized
                // The improved error handling should catch and log any exceptions
                // without propagating them
                controller.delayForWaitingNewUrl();
            } catch (Exception e) {
                fail("delayForWaitingNewUrl should not throw exceptions: " + e.getMessage());
            }
        }
    
        /**
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Wed Jan 14 14:29:07 GMT 2026
    - 6.2K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/app/web/admin/elevateword/AdminElevatewordAction.java

            return asHtml(path_AdminElevateword_AdminElevatewordJsp).renderWith(data -> {
                searchPaging(data, form);
            });
        }
    
        /**
         * Handles search pagination and data preparation for rendering.
         *
         * @param data render data to populate with search results
         * @param form search form containing current search state
         */
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Jan 23 23:57:26 GMT 2026
    - 22.2K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/AbstractFuture.java

       *     cancelled or set.
       * @since 19.0
       */
      @CanIgnoreReturnValue
      @SuppressWarnings("Interruption") // We are propagating an interrupt from a caller.
      protected boolean setFuture(ListenableFuture<? extends V> future) {
        checkNotNull(future);
        @RetainedLocalRef Object localValue = value();
        if (localValue == null) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 14:39:00 GMT 2026
    - 43.6K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

            }
            throw new AssertionError(status);
          }
          future.addListener(() -> provideValueAndCloser(consumer, this), executor);
        }
    
        @SuppressWarnings("Interruption") // We are propagating an interrupt from a caller.
        boolean cancel(boolean mayInterruptIfRunning) {
          logger.get().log(FINER, "cancelling {0}", closingFutureToString());
          boolean cancelled = future.cancel(mayInterruptIfRunning);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 101.7K bytes
    - Click Count (0)
Back to Top