- Sort Score
- Result 10 results
- Languages All
Results 361 - 370 of 535 for consumer (0.04 sec)
-
android/guava-tests/test/com/google/common/graph/AbstractGraphTest.java
static final Integer N2 = 2; static final Integer N3 = 3; static final Integer N4 = 4; static final Integer N5 = 5; static final Integer NODE_NOT_IN_GRAPH = 1000; // TODO(user): Consider separating Strings that we've defined here to capture // identifiable substrings of expected error messages, from Strings that we've defined // here to provide error messages.
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue Oct 07 15:57:03 UTC 2025 - 17.3K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/Dfs.java
if (ki < key.length()) { key = key.substring(0, ki); } /* Subtract the server and share from the pathConsumed so that * it refects the part of the relative path consumed and not * the entire path. */ dr.pathConsumed -= 1 + server.length() + 1 + share.length(); if (referrals != null && System.currentTimeMillis() + 10000 > referrals.expiration) {
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 14.2K bytes - Viewed (0) -
src/test/java/jcifs/internal/fscc/SmbInfoAllocationTest.java
// Decode int bytesDecoded = smbInfoAllocation.decode(buffer, 0, buffer.length); // Verify we read exactly 20 bytes (4 + 4 + 4 + 4 + 4) // Note: bytesPerSect is read as Int2 but 4 bytes are consumed (padding) assertEquals(20, bytesDecoded); } @Test @DisplayName("Test capacity calculation overflow handling") void testCapacityCalculationOverflow() throws SMBProtocolDecodingException {Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 14.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
} } } } @SuppressWarnings({ "Interruption", // We are restoring an interrupt on this thread. "ThreadPriorityCheck", // TODO: b/175898629 - Consider onSpinWait. }) private void waitForInterrupt(Thread currentThread) { /* * If someone called cancel(true), it is possible that the interrupted bit hasn't been set yet.Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 10K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java
* * <p>If no backing thread factory is provided, a default backing thread factory is used as if by * calling {@code setThreadFactory(}{@link Executors#defaultThreadFactory()}{@code )}. * * <p><b>Java 21+ users:</b> consider using the {@code Thread.Builder} interface instead. E.g., * instead of {@code new ThreadFactoryBuilder().setPriority(priority).setDaemon(false).build()}, use * {@code Thread.ofPlatform().priority(priority).daemon(false).factory()}.Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:35:26 UTC 2025 - 9K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/google/AbstractMultisetSetCountTester.java
@SuppressWarnings("JUnit4ClassUsedInJUnit3") public abstract class AbstractMultisetSetCountTester<E> extends AbstractMultisetTester<E> { /* * TODO: consider adding MultisetFeatures.SUPPORTS_SET_COUNT. Currently we * assume that using setCount() to increase the count is permitted iff add() * is permitted and similarly for decrease/remove(). We assume that aRegistered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 13K bytes - Viewed (0) -
compat/maven-artifact/src/main/java/org/apache/maven/artifact/DefaultArtifact.java
} else { result = -1; } } if (result == 0) { // We don't consider the version range in the comparison, just the resolved version result = new DefaultArtifactVersion(version) .compareTo(new DefaultArtifactVersion(a.getVersion()));Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Wed Jul 23 17:27:08 UTC 2025 - 14.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
* #dispatch} is expected to be called concurrently, it is idempotent. */ @J2ktIncompatible @GwtIncompatible final class ListenerCallQueue<L> { // TODO(cpovirk): consider using the logger associated with listener.getClass(). private static final LazyLogger logger = new LazyLogger(ListenerCallQueue.class); // TODO(chrisn): promote AppendOnlyCollection for use here.
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 8.1K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/project/DefaultMavenProjectBuilder.java
* MNG-4900: Hack to workaround deficiency of legacy API which makes it impossible for plugins to access the * global profile manager which is required to build a POM like a CLI invocation does. Failure to consider * the activated profiles can cause repo declarations to be lost which in turn will result in artifact * resolution failures, in particular when using the enhanced local repo which guards access to local filesRegistered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Jun 06 14:28:57 UTC 2025 - 12.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
result.timer = scheduledExecutor.schedule(fire, time, unit); delegate.addListener(fire, directExecutor()); return result; } /* * Memory visibility of these fields. There are two cases to consider. * * 1. visibility of the writes to these fields to Fire.run: * * The initial write to delegateRef is made definitely visible via the semantics of
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 8K bytes - Viewed (0)