Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 32 for simultaneously (0.12 seconds)

  1. docs/recipes.md

    Use an HTTP POST to send a request body to a service. This example posts a markdown document to a web service that renders markdown as HTML. Because the entire request body is in memory simultaneously, avoid posting large (greater than 1 MiB) documents using this API.
    
    === ":material-language-kotlin: Kotlin"
        ```kotlin
          private val client = OkHttpClient()
    
          fun run() {
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sat Aug 30 17:01:12 GMT 2025
    - 47.8K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt

     * Since connections may be reused, the proxy selection, DNS, and connect events may not be present
     * for a call. In future releases of OkHttp these events may also occur concurrently to permit
     * multiple routes to be attempted simultaneously.
     *
     * Events and sequences of events may be repeated for retries and follow-ups.
     *
     * All event methods must execute fast, without external locking, cannot throw exceptions, attempt
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Oct 07 21:03:04 GMT 2025
    - 24.9K bytes
    - Click Count (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Stream.kt

       * The reason why this stream was closed, or null if it closed normally or has not yet been
       * closed.
       *
       * If there are multiple reasons to abnormally close this stream (such as both peers closing it
       * near-simultaneously) then this is the first reason known to this peer.
       */
      internal var errorCode: ErrorCode? = null
        get() = withLock { field }
    
      /** The exception that explains [errorCode]. Null if no exception was provided. */
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Mon Jul 07 18:57:05 GMT 2025
    - 22.4K bytes
    - Click Count (0)
  4. cmd/batch-expire.go

    				delete(deleteMarkerCountMap, lastDel.Name)
    			}
    		}
    		// send down filtered entries to be deleted using
    		// DeleteObjects method
    		if len(toDel) > 10 { // batch up to 10 objects/versions to be expired simultaneously.
    			xfer := make([]expireObjInfo, len(toDel))
    			copy(xfer, toDel)
    			select {
    			case expireCh <- xfer:
    				toDel = toDel[:0] // resetting toDel
    			case <-ctx.Done():
    				done = true
    			}
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Apr 22 11:16:32 GMT 2025
    - 23K bytes
    - Click Count (0)
  5. LICENSE

    otherwise) that contradict the conditions of this License, they do not
    excuse you from the conditions of this License.  If you cannot convey a
    covered work so as to satisfy simultaneously your obligations under this
    License and any other pertinent obligations, then as a consequence you may
    not convey it at all.  For example, if you agree to terms that obligate you
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Apr 23 18:58:53 GMT 2021
    - 33.7K bytes
    - Click Count (0)
  6. doc/go_mem.html

    reads of a variable in one goroutine can be guaranteed to
    observe values produced by writes to the same variable in a different goroutine.
    </p>
    
    
    <h3 id="advice">Advice</h3>
    
    <p>
    Programs that modify data being simultaneously accessed by multiple goroutines
    must serialize such access.
    </p>
    
    <p>
    To serialize access, protect the data with channel operations or other synchronization primitives
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Aug 05 15:41:37 GMT 2025
    - 26.6K bytes
    - Click Count (0)
  7. cmd/erasure-server-pool.go

    	case <-ctx.Done():
    		mu.Lock()
    		if firstErr == nil {
    			firstErr = ctx.Err()
    		}
    		defer mu.Unlock()
    	}
    	return firstErr
    }
    
    // MakeBucket - creates a new bucket across all serverPools simultaneously
    // even if one of the sets fail to create buckets, we proceed all the successful
    // operations.
    func (z *erasureServerPools) MakeBucket(ctx context.Context, bucket string, opts MakeBucketOptions) error {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  8. cmd/testdata/xl-meta-merge.zip

    Guide](https://min.io/docs/minio/linux/reference/minio-mc.html#quickstart) for further instructions. ## Upgrading MinIO Upgrades require zero downtime in MinIO, all upgrades are non-disruptive, all transactions on MinIO are atomic. So upgrading all the servers simultaneously is the recommended way to upgrade MinIO. > NOTE: requires internet access to update directly from <https://dl.min.io>, optionally you can host any mirrors at <https://my-artifactory.example.com/minio/> - For deployments that installed the MinIO...
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Mar 08 17:50:48 GMT 2024
    - 30.2K bytes
    - Click Count (0)
  9. docs/changelogs/changelog_3x.md

     *  **OkHttp now supports duplex calls over HTTP/2.** With normal HTTP calls the request must finish
        before the response starts. With duplex, request and response bodies are transmitted
        simultaneously. This can be used to implement interactive conversations within a single HTTP
        call.
    
        Create duplex calls by overriding the new `RequestBody.isDuplex()` method to return true.
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Sun Feb 06 14:55:54 GMT 2022
    - 50.8K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/cache/LocalCacheMapComputeTest.java

        cache.put(key, "1");
        // simultaneous update for same key, some null, some non-null
        doParallelCacheOp(
            count,
            n -> {
              cache.asMap().compute(key, (k, v) -> n % 2 == 0 ? v + delimiter + n : null);
            });
        assertThat(cache.size()).isAtMost(1);
      }
    
      public void testCompute() {
        cache.put(key, "1");
        // simultaneous deletion
        doParallelCacheOp(
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Sep 30 22:03:28 GMT 2025
    - 7K bytes
    - Click Count (0)
Back to Top