Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 965 for concurrently (0.24 sec)

  1. docs/changelogs/changelog_4x.md

        strictly ASCII. This issue is tracked as [CVE-2021-0341].
    
    
    ## Version 4.9.1
    
    _2021-01-30_
    
     *  Fix: Work around a crash in Android 10 and 11 that may be triggered when two threads
        concurrently close an SSL socket. This would have appeared in crash logs as
        `NullPointerException: bio == null`.
    
    
    ## Version 4.9.0
    
    _2020-09-11_
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Apr 17 13:25:31 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

    import java.util.Set;
    import java.util.concurrent.CancellationException;
    import java.util.concurrent.ConcurrentMap;
    import java.util.concurrent.atomic.AtomicInteger;
    import java.util.concurrent.atomic.AtomicReferenceArray;
    import java.util.concurrent.locks.ReentrantLock;
    import org.jspecify.annotations.NullUnmarked;
    import org.jspecify.annotations.Nullable;
    
    /**
     * The concurrent hash map implementation built by {@link MapMaker}.
     *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 90K bytes
    - Viewed (0)
  3. cmd/erasure-server-pool.go

    	}
    
    	if opts.DataMovement {
    		objInfo, err = z.serverPools[pinfo.Index].DeleteObject(ctx, bucket, object, opts)
    		objInfo.Name = decodeDirObject(object)
    		return objInfo, err
    	}
    
    	// Delete concurrently in all server pools with read quorum error for unversioned objects.
    	if len(noReadQuorumPools) > 0 && !opts.Versioned && !opts.VersionSuspended {
    		return z.deleteObjectFromAllPools(ctx, bucket, object, opts, noReadQuorumPools)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  4. cmd/admin-heal-ops.go

    	// The time of the last scan/heal activity
    	lastHealActivity time.Time
    
    	// Holds the request-info for logging
    	ctx context.Context
    
    	// used to lock this structure as it is concurrently accessed
    	mutex sync.RWMutex
    }
    
    // NewHealSequence - creates healSettings, assumes bucket and
    // objPrefix are already validated.
    func newHealSequence(ctx context.Context, bucket, objPrefix, clientAddr string,
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 25.4K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/collect/Iterables.java

       * @throws NoSuchElementException if the iterable is empty
       */
      @ParametricNullness
      public static <T extends @Nullable Object> T getLast(Iterable<T> iterable) {
        // TODO(kevinb): Support a concurrently modified collection?
        if (iterable instanceof List) {
          List<T> list = (List<T>) iterable;
          if (list.isEmpty()) {
            throw new NoSuchElementException();
          }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 43.6K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/OkHttpClient.kt

     */
    package okhttp3
    
    import java.net.Proxy
    import java.net.ProxySelector
    import java.net.Socket
    import java.time.Duration
    import java.util.Random
    import java.util.concurrent.ExecutorService
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.TimeUnit.MILLISECONDS
    import javax.net.SocketFactory
    import javax.net.ssl.HostnameVerifier
    import javax.net.ssl.SSLSocketFactory
    import javax.net.ssl.X509TrustManager
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon May 05 16:01:00 UTC 2025
    - 51.7K bytes
    - Viewed (0)
  7. guava/src/com/google/common/collect/Iterables.java

       * @throws NoSuchElementException if the iterable is empty
       */
      @ParametricNullness
      public static <T extends @Nullable Object> T getLast(Iterable<T> iterable) {
        // TODO(kevinb): Support a concurrently modified collection?
        if (iterable instanceof List) {
          List<T> list = (List<T>) iterable;
          if (list.isEmpty()) {
            throw new NoSuchElementException();
          }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 43.3K bytes
    - Viewed (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

    import java.time.Duration
    import java.util.Arrays
    import java.util.concurrent.BlockingQueue
    import java.util.concurrent.CountDownLatch
    import java.util.concurrent.Executors
    import java.util.concurrent.LinkedBlockingQueue
    import java.util.concurrent.SynchronousQueue
    import java.util.concurrent.TimeUnit
    import java.util.concurrent.TimeoutException
    import java.util.concurrent.atomic.AtomicReference
    import javax.net.ssl.SSLException
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 73.4K bytes
    - Viewed (0)
  9. cmd/bucket-handlers.go

    		// wrote to disk - since that amounts to "copying" from a "copy"
    		// instead of "copying" from source, we need the stream to be seekable
    		// to ensure that we can make fan-out calls concurrently.
    		buf := bytebufferpool.Get()
    		defer func() {
    			buf.Reset()
    			bytebufferpool.Put(buf)
    		}()
    
    		md5w := md5.New()
    
    		// Maximum allowed fan-out object size.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.9K bytes
    - Viewed (0)
  10. docs/contribute/concurrency.md

    Concurrency
    ===========
    
    This document describes the concurrency considerations for http/2 connections and the connection pool within OkHttp.
    
    ## HTTP/2 Connections
    
    The HttpURLConnection API is a blocking API. You make a blocking write to send a request, and a blocking read to receive the response.
    
    #### Blocking APIs
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sun Feb 06 16:35:36 UTC 2022
    - 7K bytes
    - Viewed (0)
Back to top