- Sort Score
- Result 10 results
- Languages All
Results 1711 - 1720 of 1,872 for rare (0.04 sec)
-
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
: t; releaseShared(finalState); } else if (getState() == COMPLETING) { // If some other thread is currently completing the future, block until // they are done so we can guarantee completion. acquireShared(-1); } return doCompletion; } } static final CancellationException cancellationExceptionWithCause(
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 17 02:42:09 UTC 2024 - 13.6K bytes - Viewed (0) -
internal/event/target/kafka.go
config.Net.TLS.Config.InsecureSkipVerify = args.TLS.SkipVerify config.Net.TLS.Config.ClientAuth = args.TLS.ClientAuth config.Net.TLS.Config.RootCAs = args.TLS.RootCAs // These settings are needed to ensure that kafka client doesn't hang on brokers // refer https://github.com/IBM/sarama/issues/765#issuecomment-254333355 config.Producer.Retry.Max = 2 config.Producer.Retry.Backoff = (1 * time.Second)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 13.6K bytes - Viewed (0) -
tensorflow/c/eager/c_api_distributed_test.cc
// Pack 3 variable handles into one TFE_TensorHandle. // When remote is false, function device is placed on task0. Handle types are // REMOTE, REMOTE, LOCAL on task0. When remote is true, function device is // placed on task1, Handle types are LOCAL, REMOTE, LOCAL on task1. int num_replicas = 3; std::vector<TFE_TensorHandle*> handles = {h0, h1, h2}; TFE_TensorHandle* packed_handle =
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Sat Oct 12 05:11:17 UTC 2024 - 23.4K bytes - Viewed (0) -
src/archive/tar/reader_test.go
}, Format: FormatPAX, }}, }, { // Both BSD and GNU tar truncate long names at first NUL even // if there is data following that NUL character. // This is reasonable as GNU long names are C-strings. file: "testdata/gnu-long-nul.tar", headers: []*Header{{ Name: "0123456789", Mode: 0644, Uid: 1000, Gid: 1000, ModTime: time.Unix(1486082191, 0),
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Thu Oct 03 15:48:09 UTC 2024 - 46.9K bytes - Viewed (0) -
docs/de/docs/tutorial/path-params-numeric-validations.md
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 10.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/IteratorsTest.java
List<Integer> list = asList(1, 2); Iterator<List<Integer>> partitions = Iterators.partition(list.iterator(), 1); // Changes before the partition is retrieved are reflected list.set(0, 3); List<Integer> first = partitions.next(); // Changes after are not list.set(0, 4); assertEquals(ImmutableList.of(3), first); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 54.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/FastFallbackTest.kt
* `::1` will reach the IPv6 server. * * By orchestrating two different servers with the same port but different IP addresses, we can * test what OkHttp does when both are reachable, or if only one is reachable. * * This test only runs on host machines that have both IPv4 and IPv6 addresses for localhost. */ @Timeout(30) class FastFallbackTest { @RegisterExtension
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.3K bytes - Viewed (0) -
okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/CertificateAdapters.kt
BasicConstraints( ca = it[0] as Boolean, maxIntermediateCas = it[1] as Long?, ) }, ) /** * Note that only a subset of available choices are implemented. * * ``` * GeneralName ::= CHOICE { * otherName [0] OtherName, * rfc822Name [1] IA5String,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 13.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/CharSourceTest.java
private static final ImmutableSet<CharSink> BROKEN_SINKS = ImmutableSet.of(BROKEN_CLOSE_SINK, BROKEN_OPEN_SINK, BROKEN_WRITE_SINK); public void testCopyExceptions() { // test that exceptions are suppressed for (CharSource in : BROKEN_SOURCES) { int suppressed = runSuppressionFailureTest(in, newNormalCharSink()); assertEquals(0, suppressed);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue May 07 15:26:58 UTC 2024 - 11.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
Runnable intCounter = new Runnable() { @Override public void run() { totalCalls.incrementAndGet(); // Make sure that no other tasks are scheduled to run while this is running. assertFalse(fakePool.hasNext()); } }; assertFalse(fakePool.hasNext()); e.execute(intCounter); // A task should have been scheduled
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 11.4K bytes - Viewed (0)