errorCounts := make(map[error]int)
	for _, err := range errs {
		if IsErrIgnored(err, ignoredErrs...) {
			continue
		}
		// Errors due to context cancellation may be wrapped - group them by context.Canceled.
		if errors.Is(err, context.Canceled) {
			errorCounts[context.Canceled]++
			continue
		}
		errorCounts[err]++
	}

	max := 0
	for err, count := range errorCounts {
		switch {
		case max < count:

}

func (l *localLocker) ForceUnlock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
	select {
	case <-ctx.Done():
		return false, ctx.Err()
	default:
		l.mutex.Lock()
		defer l.mutex.Unlock()
		if len(args.UID) == 0 {
			for _, resource := range args.Resources {
				lris, ok := l.lockMap[resource]
				if !ok {
					continue
				}
				// Collect uids, so we don't mutate while we delete

import com.google.common.annotations.GwtIncompatible;
import com.google.common.annotations.J2ktIncompatible;
import com.google.common.annotations.VisibleForTesting;
import com.google.common.collect.ImmutableList;
import com.google.j2objc.annotations.J2ObjCIncompatible;
import java.io.File;
import java.io.IOException;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;

 * limitations under the License.
 */

package com.google.common.collect;

import static com.google.common.base.Preconditions.checkNotNull;
import static com.google.common.base.Preconditions.checkState;
import static com.google.common.collect.CollectPreconditions.checkEntryNotNull;
import static com.google.common.collect.CollectPreconditions.checkNonnegative;
import static java.lang.System.arraycopy;

 * limitations under the License.
 */

package com.google.common.collect;

import static com.google.common.base.Preconditions.checkNotNull;
import static com.google.common.base.Preconditions.checkState;
import static com.google.common.collect.CollectPreconditions.checkEntryNotNull;
import static com.google.common.collect.CollectPreconditions.checkNonnegative;
import static java.lang.System.arraycopy;

    assertThat(converter.convert("1.0")).isEqualTo((Float) 1.0f);
    assertThat(converter.convert("0.0")).isEqualTo((Float) 0.0f);
    assertThat(converter.convert("-1.0")).isEqualTo((Float) (-1.0f));
    assertThat(converter.convert("1")).isEqualTo((Float) 1.0f);
    assertThat(converter.convert("0")).isEqualTo((Float) 0.0f);
    assertThat(converter.convert("-1")).isEqualTo((Float) (-1.0f));

    assertThat(converter.convert("1.0")).isEqualTo((Double) 1.0);
    assertThat(converter.convert("0.0")).isEqualTo((Double) 0.0);
    assertThat(converter.convert("-1.0")).isEqualTo((Double) (-1.0));
    assertThat(converter.convert("1")).isEqualTo((Double) 1.0);
    assertThat(converter.convert("0")).isEqualTo((Double) 0.0);
    assertThat(converter.convert("-1")).isEqualTo((Double) (-1.0));

    assertThat(converter.convert("1.0")).isEqualTo((Float) 1.0f);
    assertThat(converter.convert("0.0")).isEqualTo((Float) 0.0f);
    assertThat(converter.convert("-1.0")).isEqualTo((Float) (-1.0f));
    assertThat(converter.convert("1")).isEqualTo((Float) 1.0f);
    assertThat(converter.convert("0")).isEqualTo((Float) 0.0f);
    assertThat(converter.convert("-1")).isEqualTo((Float) (-1.0f));

        } else {
            availableSearcherNameSet = StreamUtil.split(value, ",")
                    .get(stream -> stream.map(String::trim).filter(StringUtil::isNotBlank).collect(Collectors.toUnmodifiableSet()));
        }
        if (logger.isDebugEnabled()) {
            logger.debug("availableSearcherNameSet={}", availableSearcherNameSet);
        }
    }

    @Override

	}

	if config.PropagateUnscoped {
		txConfig.PropagateUnscoped = true
	}

	if config.Context != nil || config.PrepareStmt || config.SkipHooks {
		tx.Statement = tx.Statement.clone()
		tx.Statement.DB = tx
	}

	if config.Context != nil {
		tx.Statement.Context = config.Context
	}

	if config.PrepareStmt {
		var preparedStmt *PreparedStmtDB