- Sort Score
- Num 10 results
- Language All
Results 1 - 8 of 8 for propagation (0.08 seconds)
-
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) -
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) -
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) -
docs/en/docs/release-notes.md
Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Fri Apr 03 12:07:04 GMT 2026 - 631K bytes - Click Count (0) -
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) -
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) -
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) -
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)