Search Options

Results per page
Sort
Preferred Languages
Advance

Results 131 - 140 of 212 for peak (0.03 sec)

  1. CHANGELOG.md

        for a graceful shutdown before it performs an abrupt shutdown.
    
     *  Fix: Honor `RequestBody.isOneShot()` in `MultipartBody`
    
     *  Fix in `okhttp-coroutines`: Don't leak response bodies in `executeAsync()`. We had a bug where
        we didn't call `Response.close()` if the coroutine was canceled before its response was
        returned.
    
     *  Upgrade: [Okio 3.9.0][okio_3_9_0].
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Thu Apr 18 01:31:39 UTC 2024
    - 21.4K bytes
    - Viewed (0)
  2. cmd/s3-zip-handlers.go

    	archiveTypeMetadataKey = ReservedMetadataPrefixLower + "archive-type" // "x-minio-internal-archive-type"
    	archiveInfoMetadataKey = ReservedMetadataPrefixLower + "archive-info" // "x-minio-internal-archive-info"
    
    	// Peek into a zip archive
    	xMinIOExtract = "x-minio-extract"
    )
    
    // splitZipExtensionPath splits the S3 path to the zip file and the path inside the zip:
    //
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  3. cmd/admin-heal-ops.go

    		h.currentStatus.Summary = healFinishedStatus
    		h.mutex.Unlock()
    
    		// drain traverse channel so the traversal
    		// go-routine does not leak.
    		go func() {
    			// Eventually the traversal go-routine closes
    			// the channel and returns, so this go-routine
    			// itself will not leak.
    			<-h.traverseAndHealDoneCh
    		}()
    	}
    }
    
    func (h *healSequence) queueHealTask(source healSource, healType madmin.HealItemType) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  4. docs/tr/docs/async.md

    Bu "aşkınla fast food burgerleri" senaryosunda, çok fazla bekleme olduğu için 🕙, eşzamanlı bir sisteme sahip olmak çok daha mantıklı ⏸🔀⏯.
    
    Web uygulamalarının çoğu için durum böyledir.
    
    Pek çok kullanıcı var, ama sunucunuz pek de iyi olmayan bir bağlantı ile istek atmalarını bekliyor.
    
    Ve sonra yanıtların geri gelmesi için tekrar 🕙 bekliyor
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Tue Aug 06 04:48:30 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  5. docs/en/docs/contributing.md

    * Review those pull requests, requesting changes or approving them. For the languages I don't speak, I'll wait for several others to review the translation before merging.
    
    /// tip
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Aug 25 02:44:06 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/ImmutableSetMultimap.java

    import com.google.errorprone.annotations.DoNotCall;
    import com.google.errorprone.annotations.concurrent.LazyInit;
    import com.google.j2objc.annotations.RetainedWith;
    import com.google.j2objc.annotations.Weak;
    import java.io.IOException;
    import java.io.InvalidObjectException;
    import java.io.ObjectInputStream;
    import java.io.ObjectOutputStream;
    import java.util.Collection;
    import java.util.Comparator;
    import java.util.Map;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 26.2K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/internal/connection/ConnectionPoolTest.kt

        allocateAndLeakAllocation(poolApi, c1)
        awaitGarbageCollection()
        assertThat(pool.closeConnections(100L)).isEqualTo(0L)
        assertThat(c1.calls).isEmpty()
    
        // Can't allocate once a leak has been detected.
        assertThat(c1.noNewExchanges).isTrue()
      }
    
      @Test fun interruptStopsThread() {
        val realTaskRunner = TaskRunner.INSTANCE
        val pool =
          factory.newConnectionPool(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jun 22 16:06:35 UTC 2024
    - 12.8K bytes
    - Viewed (0)
  8. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ImmutableSortedSet.java

                  && ((RegularImmutableSortedSet) result).isSubset;
          if (!isSubset) {
            // Only return the original copy if this immutable sorted set isn't
            // a subset of another, to avoid memory leak.
            return result;
          }
        }
        return copyOfInternal(comparator, elements.iterator());
      }
    
      private static <E> ImmutableSortedSet<E> copyOfInternal(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Aug 19 16:21:24 UTC 2024
    - 15.5K bytes
    - Viewed (0)
  9. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

      }
    
      /**
       * Prunes any leaked calls and then returns the number of remaining live calls on [connection].
       * Calls are leaked if the connection is tracking them but the application code has abandoned
       * them. Leak detection is imprecise and relies on garbage collection.
       */
      private fun pruneAndGetAllocationCount(
        connection: RealConnection,
        now: Long,
      ): Int {
        connection.lock.assertHeld()
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  10. android/guava-testlib/src/com/google/common/collect/testing/AbstractIteratorTester.java

          if (source.isEmpty()) {
            throw PermittedMetaException.NSEE;
          }
    
          destination.push(source.pop());
          stackWithLastReturnedElementAtTop = destination;
          return destination.peek();
        }
    
        private void throwIfInvalid(IteratorFeature methodFeature) {
          if (!features.contains(methodFeature)) {
            if (stackWithLastReturnedElementAtTop == null) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 20.6K bytes
    - Viewed (0)
Back to top