- Sort Score
- Result 10 results
- Languages All
Results 1291 - 1300 of 1,789 for dfmail (0.09 sec)
-
android/guava-testlib/src/com/google/common/util/concurrent/testing/MockFutureListener.java
// Verify that the listener executed in a reasonable amount of time. Assert.assertTrue(countDownLatch.await(1L, SECONDS)); try { future.get(); Assert.fail("This call was supposed to throw an ExecutionException"); } catch (ExecutionException expected) { Assert.assertSame(expectedCause, expected.getCause()); } } public void assertTimeout() throws Exception {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri May 12 18:12:42 UTC 2023 - 3K bytes - Viewed (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/CommonsCliOptions.java
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 18.5K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
// Unlike the other cases, we actually want to use the "old" event for terminated job pods // - kubernetes will (weirdly) issue a new status to the pod with no IP on termination, meaning // our check of `pod.status` will fail for (some) termination events. // // We will get subsequent events that append a new status with the IP put back, but it's simpler // and safer to just check the old pod status for the IP.
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 11.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/hash/MacHashFunctionTest.java
public void testNoProviders() { ProviderList providers = Providers.getProviderList(); Providers.setProviderList(ProviderList.newList()); try { Hashing.hmacMd5(MD5_KEY); fail("expected ISE"); } catch (IllegalStateException expected) { } finally { Providers.setProviderList(providers); } } public void testMultipleUpdates() throws Exception {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Jul 23 14:22:54 UTC 2024 - 13.8K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
// once the pod restarts (in CrashLoopBackoff), which can take some time. // We don't want to constantly try to apply the iptables rules, which is unneeded and will fail. // Instead, we track which UIDs we repaired and skip them if already repaired. // // An alternative would be to write something to the Pod (status, annotation, etc).
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Sat Feb 10 00:31:55 UTC 2024 - 10.4K bytes - Viewed (0) -
compat/maven-resolver-provider/src/test/java/org/apache/maven/repository/internal/VersionTest.java
import org.eclipse.aether.util.version.GenericVersionScheme; import org.junit.jupiter.api.Test; import static java.util.stream.Collectors.toList; import static org.junit.jupiter.api.Assertions.fail; /** */ public class VersionTest extends AbstractVersionTest { private final ModelVersionParser modelVersionParser = new DefaultModelVersionParser(new GenericVersionScheme());
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 17.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
null -> return // no open event true -> return // found open event false -> return@loop // this is not the open event so continue } } Assertions.fail<Any>("event $e without matching start event") } } override fun connectStart( route: Route, call: Call, ) = logEvent(ConnectionEvent.ConnectStart(System.nanoTime(), route, call))
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.6K bytes - Viewed (0) -
src/main/webapp/WEB-INF/view/admin/joblog/admin_joblog.jsp
</c:when> <c:when test="${data.jobStatus == 'fail'}"> <span class="badge bg-danger"><la:message key="labels.joblog_status_fail"/></span>
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Feb 13 07:47:04 UTC 2020 - 11.4K bytes - Viewed (0) -
internal/s3select/json/reader.go
func (r *Reader) Close() error { // Close the input. err := r.readCloser.Close() for range r.valueCh { // Drain values so we don't leak a goroutine. // Since we have closed the input, it should fail rather quickly. } return err } // NewReader - creates new JSON reader using readCloser. func NewReader(readCloser io.ReadCloser, args *ReaderArgs) *Reader { readCloser = &syncReadCloser{rc: readCloser}
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 23 19:35:41 UTC 2024 - 3.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
// If the server returned parameters we don't understand, fail the web socket. if (unknownValues) return false // If the server returned a value for client_max_window_bits, fail the web socket. if (clientMaxWindowBits != null) return false // If the server returned an illegal server_max_window_bits, fail the web socket.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Apr 01 14:21:25 UTC 2024 - 22.1K bytes - Viewed (0)