- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 51 for synchronously (0.08 seconds)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Dispatcher.kt
* was run [asynchronously][Call.enqueue] or [synchronously][Call.execute]. Asynchronous calls * become idle after the [onResponse][Callback.onResponse] or [onFailure][Callback.onFailure] * callback has returned. Synchronous calls become idle once [execute()][Call.execute] returns. * This means that if you are doing synchronous calls the network layer will not truly be idle
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Oct 07 14:16:22 GMT 2025 - 9.9K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java
SmbTransport testTransport = manager.createTransport(failedChannel.getLocalInterface(), failedChannel.getRemoteInterface()); if (testTransport == null) { // No recovery possible, remove synchronously removeChannel(failedChannel); return; } // Recovery might be viable, attempt it with pre-created transport if (state.shouldRetry()) {
Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 11.6K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/create/Smb2CreateRequest.java
*/ public static final int FILE_NO_IMTERMEDIATE_BUFFERING = 0x8; /** * All operations on the file are performed synchronously with alerts */ public static final int FILE_SYNCHRONOUS_IO_ALERT = 0x10; /** * All operations on the file are performed synchronously without alerts */ public static final int FILE_SYNCHRONOUS_IO_NONALERT = 0x20; /**Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 02:21:31 GMT 2025 - 22.9K bytes - Click Count (0) -
src/main/java/jcifs/audit/SecurityAuditLogger.java
// Add MDC context efficiently addMdcContext(entry.context); // Process asynchronously or synchronously based on configuration if (asyncLogging && !shutdown) { if (!logQueue.offer(entry)) { // Queue is full, log synchronously as fallback processLogEntry(entry); returnAuditEntry(entry); }Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 26.6K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java
* another thread or the worker task has cleared the count and set the state. * * <p>When {@link #executor} is a directExecutor(), the value written to * {@code workerRunningState} will be available synchronously, and behaviour will be * deterministic. */ @SuppressWarnings("GuardedBy") boolean alreadyMarkedQueued = workerRunningState != QUEUING; if (alreadyMarkedQueued) { return; }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sun Dec 22 03:38:46 GMT 2024 - 10.6K bytes - Click Count (0) -
cmd/global-heal.go
objInfo := fi.ToObjectInfo(bucket, object, versioned) evt := evalActionFromLifecycle(ctx, *lc, lr, rcfg, objInfo) switch { case evt.Action.DeleteRestored(): // if restored copy has expired,delete it synchronously applyExpiryOnTransitionedObject(ctx, newObjectLayerFn(), objInfo, evt, lcEventSrc_Heal) return false case evt.Action.Delete(): globalExpiryState.enqueueByDays(objInfo, evt, lcEventSrc_Heal)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Apr 04 13:49:12 GMT 2025 - 16.2K bytes - Click Count (0) -
lib/wasm/wasm_exec.js
add: (a, b) => a + b, callExport: testCallExport, }, gojs: { // Go's SP does not change as long as no Go code is running. Some operations (e.g. calls, getters and setters) // may synchronously trigger a Go event handler. This makes Go code get executed in the middle of the imported // function. A goroutine can switch to a new stack if the current stack is too small (see morestack function).Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Sun Dec 08 15:34:47 GMT 2024 - 16.6K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
// interact poorly with the reentrancy-avoiding behavior of this executor - when the operation // before the cancelled future completes, it will synchronously complete both the newFuture // from the cancelled operation and its own. This can cause one runnable to queue two tasks, // breaking the invariant this method relies on to iteratively run the next task after theCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Tue Sep 23 01:35:55 GMT 2025 - 22.1K bytes - Click Count (0) -
cmd/erasure-server-pool-decom.go
objInfo := fi.ToObjectInfo(bucket, object, versioned) evt := evalActionFromLifecycle(ctx, *lc, lr, rcfg, objInfo) switch { case evt.Action.DeleteRestored(): // if restored copy has expired, delete it synchronously applyExpiryOnTransitionedObject(ctx, z, objInfo, evt, lcEventSrc_Decom) return false case evt.Action.Delete(): globalExpiryState.enqueueByDays(objInfo, evt, lcEventSrc_Decom) return true
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 42.2K bytes - Click Count (1) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
* {@code delegate} has begun to reject execution, the previously submitted tasks may never run, * despite not throwing a RejectedExecutionException synchronously with the call to {@code * execute}. If this behaviour is problematic, use an Executor with a single thread (e.g. {@link * Executors#newSingleThreadExecutor}). *Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 45.6K bytes - Click Count (0)