Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 46 for synchronously (3.84 sec)

  1. 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
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 14:16:22 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  2. 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()) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 11.6K bytes
    - Viewed (0)
  3. 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);
                    }
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 26.6K bytes
    - Viewed (0)
  4. 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;
        /**
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 02:21:31 UTC 2025
    - 22.9K bytes
    - Viewed (0)
  5. 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;
        }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  6. 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;
        }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  7. 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).
    Registered: Tue Dec 30 11:13:12 UTC 2025
    - Last Modified: Sun Dec 08 15:34:47 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  8. 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)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Apr 04 13:49:12 UTC 2025
    - 16.2K bytes
    - Viewed (0)
  9. 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 the
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 23 01:35:55 UTC 2025
    - 22.1K bytes
    - Viewed (0)
  10. 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
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 42.2K bytes
    - Viewed (1)
Back to top