- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 10 for propagation (0.08 seconds)
-
internal/grid/README.md
Context timeouts are propagated, and a default timeout of 1 minute is added if none is specified. There is no cancellation propagation for single payload requests. When the context is canceled, the request will return at once with an appropriate error. However, the remote call will not see the cancellation - as can be seen from the 'missing' context on the handler.
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Oct 10 18:57:03 GMT 2025 - 9.4K bytes - Click Count (0) -
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/pathmap/AdminPathmapAction.java
return asHtml(path_AdminPathmap_AdminPathmapJsp).renderWith(data -> { searchPaging(data, form); }); } /** * Handles search pagination and data preparation for rendering. * * @param data the render data to populate with path mapping items * @param form the search form containing current search criteria */
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Nov 20 13:56:35 GMT 2025 - 15.4K 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)