- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 207 for Cuppens (0.37 sec)
-
docs/features/events.md
### Events with Failures When an operation fails, a failure method is called. This is `connectFailed()` for failures while building a connection to the server, and `callFailed()` when the HTTP call fails permanently. When a failure happens it is possible that a `start` event won’t have a corresponding `end` event. ![Events Diagram](../assets/images/******@****.***) ### Events with Retries and Follow-Ups
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 7.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/JdkFutureAdaptersTest.java
listenableFuture.addListener(singleCallListener, directExecutor()); /* * Don't shut down until the listenInPoolThread task has been accepted to * run. We want to see what happens when it's interrupted, not when it's * rejected. */ submitSuccessful.await(); executorService.shutdownNow(); abstractFuture.set(DATA1); assertEquals(DATA1, listenableFuture.get());
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 9.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
// operation in the constructor. // // 1. In the listener that performs the callback. In this case it is fine since inputFuture is // assigned prior to calling addListener, and addListener happens-before any invocation of the // listener. Notably, this means that 'volatile' is unnecessary to make 'inputFuture' visible // to the listener. //
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 59.6K bytes - Viewed (0) -
.teamcity/src/test/kotlin/CIConfigIntegrationTests.kt
val subProjectFolders = subprojectRoots.map { it.listFiles(File::isDirectory).asList() }.flatten().filter { dir -> // filter out the directories that have only a `build` subdirectory - this usually happens after branch switching dir.listFiles { _: File, name: String -> name != "build" }!!.isNotEmpty() } assertFalse(subProjectFolders.isEmpty()) return subProjectFolders }
Plain Text - Registered: Wed May 08 11:36:15 GMT 2024 - Last Modified: Tue Jan 02 10:00:06 GMT 2024 - 13.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/FluentFuture.java
* exception is thrown, this exception is used as the result of the output {@code Future}. * * <p>Usage example: * * <pre>{@code * // Falling back to a zero counter in case an exception happens when processing the RPC to fetch * // counters. * ListenableFuture<Integer> faultTolerantFuture = * fetchCounters().catching(FetchException.class, x -> 0, directExecutor()); * }</pre> *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 11 19:08:44 GMT 2023 - 18.7K bytes - Viewed (0) -
internal/s3select/csv/reader.go
if cap(dst) < skip { dst = make([]byte, 0, skip+1024) } dst = dst[:skip] if skip > 0 { n, err := io.ReadFull(r.buf, dst) if err != nil && err != io.ErrUnexpectedEOF { // If an EOF happens after reading some but not all the bytes, // ReadFull returns ErrUnexpectedEOF. return dst[:n], err } dst = dst[:n] if err == io.ErrUnexpectedEOF { return dst, io.EOF } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 8.9K bytes - Viewed (0) -
internal/s3select/json/preader.go
if cap(dst) < skip { dst = make([]byte, 0, skip+1024) } dst = dst[:skip] if skip > 0 { n, err := io.ReadFull(r.buf, dst) if err != nil && err != io.ErrUnexpectedEOF { // If an EOF happens after reading some but not all the bytes, // ReadFull returns ErrUnexpectedEOF. return dst[:n], err } dst = dst[:n] if err == io.ErrUnexpectedEOF { return dst, io.EOF } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 6.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
* are running concurrently. * * <p>{@linkplain Executor#execute executed} tasks have a happens-before order as defined in the * Java Language Specification. Tasks execute with the same happens-before order that the function * calls to {@link Executor#execute `execute()`} that submitted those tasks had. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0) -
cmd/admin-heal-ops.go
// pushHealResultItem - pushes a heal result item for consumption in // the heal-status API. It blocks if there are // maxUnconsumedHealResultItems. When it blocks, the heal sequence // routine is effectively paused - this happens when the server has // accumulated the maximum number of heal records per heal // sequence. When the client consumes further records, the heal // sequence automatically resumes. The return value indicates if the
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.1K bytes - Viewed (1) -
maven-core/src/test/java/org/apache/maven/plugin/PluginManagerTest.java
/* This will not work until the RR plugin is released to get rid of the binding to the reporting exception which is a mistake. This happens after removing the reporting API from the core: java.lang.NoClassDefFoundError: org/apache/maven/reporting/MavenReportException
Java - Registered: Sun Apr 28 03:35:10 GMT 2024 - Last Modified: Sat Apr 15 17:24:20 GMT 2023 - 13.1K bytes - Viewed (0)