/**
   * The HTTP <a href="https://datatracker.ietf.org/doc/html/rfc8470">{@code Early-Data}</a> header
   * field name.
   *
   * @since 27.0
   */
  public static final String EARLY_DATA = "Early-Data";

  /** The HTTP {@code Expect} header field name. */
  public static final String EXPECT = "Expect";

func genLine(buf *bytes.Buffer, lineNum, n int, addNewline bool) {
	buf.Reset()
	doCR := lineNum%5 == 0
	if doCR {
		n--
	}
	for i := 0; i < n-1; i++ { // Stop early for \n.
		c := 'a' + byte(lineNum+i)
		if c == '\n' || c == '\r' { // Don't confuse us.
			c = 'N'
		}
		buf.WriteByte(c)
	}
	if addNewline {
		if doCR {
			buf.WriteByte('\r')
		}

// returned by a Split function to indicate that the scanning should stop
// with no error. If the token being delivered with this error is not nil,
// the token is the last token.
//
// The value is useful to stop processing early or when it is necessary to
// deliver a final empty token (which is different from a nil token).
// One could achieve the same behavior with a custom error value but
// providing one here is tidier.

      Executor executor) {
    return AbstractCatchingFuture.createAsync(input, exceptionType, fallback, executor);
  }

  /**
   * Returns a future that delegates to another but will finish early (via a {@link
   * TimeoutException} wrapped in an {@link ExecutionException}) if the specified duration expires.
   *
   * <p>The delegate future is interrupted and cancelled if it times out.
   *

    "linux" : 2644
  }, {
    "testProject" : "mediumSwiftMulti",
    "linux" : 3259
  } ]
}, {
  "scenario" : "org.gradle.performance.regression.corefeature.TaskAvoidancePerformanceTest.help with lazy and eager tasks",
  "durations" : [ {
    "testProject" : "largeJavaMultiProject",
    "linux" : 225
  }, {
    "testProject" : "largeMonolithicJavaProject",
    "linux" : 135
  } ]

		r = r.WithContext(newContext(r, w, handlerName))

		defer logger.AuditLog(r.Context(), w, r, mustGetClaimsFromToken(r))

		// Check if object layer is available, if not return error early.
		if !handlerFlags.Has(noObjLayerFlag) {
			objectAPI := newObjectLayerFn()
			if objectAPI == nil || globalNotificationSys == nil {

}

// migrate config for remote targets by encrypting data if currently unencrypted and kms is configured.
func (b *BucketMetadata) migrateTargetConfig(ctx context.Context, objectAPI ObjectLayer) error {
	var err error
	// early return if no targets or already encrypted
	if len(b.BucketTargetsConfigJSON) == 0 || GlobalKMS == nil || len(b.BucketTargetsConfigMetaJSON) != 0 {
		return nil
	}

  }

  private static <K, V> ImmutableSetMultimap<K, V> copyOf(
      Multimap<? extends K, ? extends V> multimap,
      @Nullable Comparator<? super V> valueComparator) {
    checkNotNull(multimap); // eager for GWT
    if (multimap.isEmpty() && valueComparator == null) {
      return of();
    }

    if (multimap instanceof ImmutableSetMultimap) {

,YAAa,GAGpBO,UAAA,WACE/c,KAAKwc,YAAa,GAGpBQ,gBAAA,WACEhd,KAAKwc,YAAcxc,KAAKwc,Y,EAG1BnZ,OAAA,SAAOjD,GACL,GAAKJ,KAAKwc,WAIV,GAAIpc,EAAO,CACT,IAAM6c,EAAUjd,KAAKuQ,YAAYxP,SAC7BoQ,EAAUrU,UAAEsD,EAAMyN,eAAerL,KAAKya,GAErC9L,IACHA,EAAU,IAAInR,KAAKuQ,YACjBnQ,EAAMyN,cACN7N,KAAKkd,sBAEPpgB,UAAEsD,EAAMyN,eAAerL,KAAKya,EAAS9L,IAGvCA,EAAQwL,eAAeQ,OAAShM,EAAQwL,eAAeQ,MAEnDhM,EAAQiM,uBACVjM,EAAQkM,OAAO,KAAMlM,GAErBA,EAAQmM,OAAO,KAAMnM,OAElB,CACL,GAAIrU,UAAEkD,KAAKud,iBAAiBtb,SAASsJ,IAEnC,YADAvL,KAAKsd,OAAO,KA...

   * OkHttp currently doesn't implement failing the request body stream independently of failing the
   * corresponding response body stream. This is necessary if we want servers to be able to stop
   * inbound data and send an early 400 before the request body completes.
   *
   * This test sends a slow request that is canceled by the server. It expects the response to still
   * be readable after the request stream is canceled.
   */
  @Disabled