- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 721 for Scaled (0.04 sec)
-
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
* initial write to timer is never definitely visible to Fire.run since it is assigned after * SES.schedule is called. Therefore Fire.run has to check for null. However, it should be visible * if Fire.run is called by delegate.addListener since addListener is called after the assignment * to timer, and importantly this is the main situation in which we need to be able to see the * write. *
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
* caught above) can linger and affect listeners. */ } /** * Called before runInterruptibly - if true, runInterruptibly and afterRanInterruptibly will not * be called. */ abstract boolean isDone(); /** * Do interruptible work here - do not complete Futures here, as their listeners could be * interrupted.
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 10K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractService.java
* <p>This method should return promptly; prefer to do work on a different thread where it is * convenient. It is invoked exactly once on service shutdown, even when {@link #stopAsync} is * called multiple times. * * <p>If {@link #stopAsync} is called on a {@link State#STARTING} service, this method is not * invoked immediately. Instead, it will be deferred until after the service is {@link
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Feb 19 21:24:11 UTC 2025 - 20.7K bytes - Viewed (0) -
cmd/storage-datatypes_test.go
": "jIJPsrkkVYYMvc7edBrNl+7zcM7+ZwXqMb/YAjBO/ck=", "X-Minio-Internal-Server-Side-Encryption-S3-Kms-Key-Id": "my-minio-key", "X-Minio-Internal-Server-Side-Encryption-S3-Kms-Sealed-Key": "IAAfAP2p7ZLv3UpLwBnsKkF2mtWba0qoY42tymK0szRgGvAxBNcXyHXYooe9dQpeeEJWgKUa/8R61oCy1mFwIg==", "X-Minio-Internal-Server-Side-Encryption-S3-Sealed-Key": "IAAfAPFYRDkHVirJBJxBixNj3PLWt78dFuUTyTLIdLG820J7XqLPBO4gpEEEWw/DoTsJIb+apnaem+rKtQ1h3Q==", "X-Minio-Internal-Server-Side-Encryption-Seal-Algorithm": "DAREv2-HMAC-SHA256",...
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 9.1K bytes - Viewed (0) -
src/main/java/jcifs/smb1/util/LogStream.java
* * @param level the logging level to set */ public static void setLevel(final int level) { LogStream.level = level; } /** * This must be called before <code>getInstance</code> is called or * it will have no effect. * * @param stream the PrintStream to use for logging */ public static void setInstance(final PrintStream stream) {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 2.1K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
} } private fun logEvent(e: ConnectionEvent) { if (e.connection != null) { assertThat(Thread.holdsLock(e.connection), "Called with lock $${e.connection}") .isFalse() } for (lock in forbiddenLocks) { assertThat(Thread.holdsLock(lock), "Called with lock $lock") .isFalse() } if (enforceOrder) { checkForStartEvent(e) }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri May 30 21:28:20 UTC 2025 - 5.7K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/client/FaultTolerantClient.java
*/ public interface RequestListener { /** * Called when a request starts. * * @param client the fault-tolerant client * @param request the request data */ void onRequestStart(FaultTolerantClient client, RequestData request); /** * Called before each request attempt. * * @param client the fault-tolerant client
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 7.8K bytes - Viewed (0) -
src/test/java/jcifs/http/NtlmHttpURLConnectionTest.java
* We mock a simple 200 OK response to test the handshake is called. * @throws IOException */ @Test void testGettersTriggerHandshake() throws IOException { // Arrange // Spy on the connection to verify handshake() is called NtlmHttpURLConnection spiedConnection = spy(ntlmConnection); doNothing().when(spiedConnection).connect();
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 12.6K bytes - Viewed (0) -
src/test/java/jcifs/MsrpcQueryInformationPolicyTest.java
// Verify that the super constructor was called with the correct arguments // Note: Mockito cannot directly verify super constructor calls. // We assume if the object is created, the super constructor was called. // We can verify the state of the object after construction. // Verify ptype and flags are set correctly
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 1.7K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/job/impl/ScriptExecutorTest.java
scriptExecutor.addShutdownListener(listener); // Verify listener not called yet assertFalse(listener.wasShutdownCalled()); // Call shutdown scriptExecutor.shutdown(); // Verify listener was called assertTrue(listener.wasShutdownCalled()); } public void test_shutdown_withoutListener() {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Tue Aug 19 14:09:36 UTC 2025 - 10.2K bytes - Viewed (0)