- Sort Score
- Num 10 results
- Language All
Results 71 - 80 of 583 for Completed (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
src/main/java/jcifs/smb1/smb1/TestLocking.java
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 4.2K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/Smb2SigningDigestTest.java
startLatch.countDown(); // Start all threads boolean completed = endLatch.await(10, TimeUnit.SECONDS); executor.shutdown(); assertTrue(completed, "All threads should complete without deadlock"); assertEquals(threadCount * operationsPerThread, completedOps.get(), "All operations should complete"); } @TestCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 43.7K bytes - Click Count (0) -
src/main/java/jcifs/spnego/NegTokenTarg.java
public class NegTokenTarg extends SpnegoToken { /** * Result code indicating unspecified result */ public static final int UNSPECIFIED_RESULT = -1; /** * Result code indicating authentication completed successfully */ public static final int ACCEPT_COMPLETED = 0; /** * Result code indicating authentication is incomplete and additional tokens required */Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 6.9K bytes - Click Count (0) -
src/main/java/jcifs/smb1/smb1/NtStatus.java
*/ public interface NtStatus { /* Don't bother to edit this. Everthing within the interface * block is automatically generated from the ntstatus package. */ /** The operation completed successfully */ int NT_STATUS_SUCCESS = 0x00000000; /** The requested operation was unsuccessful */ int NT_STATUS_UNSUCCESSFUL = 0xC0000001; /** The requested operation is not implemented */Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 13.2K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
return insertAt == 0 } /** * Schedules immediate execution of [Task.tryCancel] on all currently-enqueued tasks. These calls * will not be made until any currently-executing task has completed. Tasks that return true will * be removed from the execution schedule. */ fun cancelAll() { taskRunner.assertLockNotHeld() taskRunner.withLock { if (cancelAllAndDecide()) {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed May 28 23:28:25 GMT 2025 - 7.3K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Connection.kt
* Attempting to create new streams on these allocations will fail. * * Note that an allocation may be released before its stream is completed. This is intended to make * bookkeeping easier for the caller: releasing the allocation as soon as the terminal stream has * been found. But only complete the stream once its data stream has been exhausted. */ interface Connection { /** Returns the route used by this connection. */Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 4.3K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/auth/chain/CommandChain.java
} final int exitValue = currentProcess.exitValue(); if (logger.isInfoEnabled()) { logger.info("Command execution completed for user: username={}, exitCode={}", username, exitValue); } if (logger.isDebugEnabled()) { logger.debug("Process output:\n{}", it.getOutput()); }Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Nov 28 16:29:12 GMT 2025 - 14.4K bytes - Click Count (0) -
src/test/java/jcifs/smb/DosErrorTest.java
// Assert assertNotNull(msgs); assertTrue(msgs.length >= 3, "Expect at least the first 3 entries present"); assertEquals("The operation completed successfully.", msgs[0]); assertEquals("Incorrect function.", msgs[1]); assertEquals("Incorrect function.", msgs[2]); } @TestCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 14 05:31:44 GMT 2025 - 5.9K bytes - Click Count (0) -
compat/maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java
* @param batchMaxSize The maximum batch size delegate should receive (default {@code 500}). * @param blockOnLastEvent Should this listener block on last transfer end (completed or corrupted) block? (default {@code true}). */ public SimplexTransferListener( TransferListener delegate, int queueSize, int batchMaxSize, boolean blockOnLastEvent) {
Created: Sun Apr 05 03:35:12 GMT 2026 - Last Modified: Fri Nov 08 08:49:11 GMT 2024 - 8.4K bytes - Click Count (0) -
cmd/rebalance-admin.go
eta := time.Duration(totalBytesToRebal * float64(elapsed) / float64(ps.Bytes)) if !ps.Info.EndTime.IsZero() { stopTime = ps.Info.EndTime } if !stopTime.IsZero() { // rebalance is stopped or completed elapsed = stopTime.Sub(ps.Info.StartTime) eta = 0 } r.Pools[i].Progress = rebalPoolProgress{ NumObjects: ps.NumObjects, NumVersions: ps.NumVersions, Bytes: ps.Bytes,
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 3.8K bytes - Click Count (0)