Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 52 for synchronously (0.05 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/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)
  6. src/main/java/org/codelibs/fess/sso/entraid/EntraIdAuthenticator.java

        }
    
        /**
         * Updates the user's group and role membership information with lazy loading for parent groups.
         * Direct groups are retrieved synchronously, while parent groups are fetched asynchronously
         * to avoid login delays when users have many nested group memberships.
         * @param user The Entra ID user to update.
         */
        public void updateMemberOf(final EntraIdUser user) {
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Dec 13 02:21:17 UTC 2025
    - 56.7K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

         * DeferredCloser#eventuallyClose(Object, Executor)}.
         *
         * <p>If any such calls specified {@link MoreExecutors#directExecutor()}, those objects will be
         * closed synchronously.
         *
         * <p>Idempotent: objects will be closed at most once.
         */
        public void closeAsync() {
          closingFuture.close();
        }
      }
    
      /**
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Sep 11 13:51:27 UTC 2025
    - 96.9K bytes
    - Viewed (0)
  10. 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}).
       *
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 08 18:55:33 UTC 2025
    - 45.2K bytes
    - Viewed (0)
Back to top