return 1.0;
        }
        return (double) totalSuccesses.get() / total;
    }

    /**
     * Check if circuit breaker allows requests
     *
     * @return true if requests are allowed
     */
    public boolean allowsRequests() {
        State current = evaluateState();
        return current != State.OPEN;
    }

    /**
     * Get the circuit breaker name
     *

saveddir=`pwd`

MAVEN_HOME=`dirname "$PRG"`/..

# make it fully qualified
MAVEN_HOME=`cd "$MAVEN_HOME" && pwd`

cd "$saveddir"

CLASSWORLDS_CONF="$MAVEN_HOME/bin/m2.conf"

# For Cygwin and MinGW, ensure paths are in Unix format before anything is touched
if $cygwin || $mingw ; then
  [ -n "$JAVA_HOME" ] &&
    JAVA_HOME=`cygpath --unix "$JAVA_HOME"`
fi

if [ -n "$JAVA_HOME" ] ; then
  if [ -x "$JAVA_HOME/jre/sh/java" ] ; then

        assertEquals((byte) 'S', SMBUtil.SMB_HEADER[1]);
        assertEquals((byte) 'M', SMBUtil.SMB_HEADER[2]);
        assertEquals((byte) 'B', SMBUtil.SMB_HEADER[3]);

        // Verify remaining bytes are zeros
        for (int i = 4; i < 24; i++) {
            assertEquals((byte) 0x00, SMBUtil.SMB_HEADER[i]);
        }
    }

    @Test
    void testSMB2Header() {
        assertNotNull(SMBUtil.SMB2_HEADER);

func (p *scannerMetrics) getCurrentPaths() []string {
	var res []string
	prefix := globalLocalNodeName + "/"
	p.currentPaths.Range(func(key, value any) bool {
		// We are a bit paranoid, but better miss an entry than crash.
		name, ok := key.(string)
		if !ok {
			return true
		}
		obj, ok := value.(*currentPathTracker)
		if !ok {
			return true
		}

	ctx, cancel := context.WithTimeout(context.Background(), testDefaultTimeout)
	defer cancel()

	// we need to do this so that the user has a policy before authentication.
	// ldap user accounts without policies are denied access in sftp.
	policy := "mypolicy"
	policyBytes := []byte(`{
 "Version": "2012-10-17",
 "Statement": [
  {
   "Effect": "Allow",
   "Action": [
    "s3:PutObject",
    "s3:GetObject",

        assertEquals("http://example.com/%7Bid%7D", result);
    }

    @Test
    public void test_encodeUrl_unicodeChars() {
        // Non-ASCII characters are percent-encoded; encoding depends on request context
        String result = DocumentUtil.encodeUrl("http://example.com/\u00D6sterreich");
        assertEquals("http://example.com/%D6sterreich", result);
    }

    @Test

/**
 * Unit tests for {@link HashCode}.
 *
 * @author Dimitris Andreou
 * @author Kurt Alfred Kluever
 */
@NullUnmarked
public class HashCodeTest extends TestCase {
  // note: asInt(), asLong() are in little endian
  private static final ImmutableList<ExpectedHashCode> expectedHashCodes =
      ImmutableList.of(
          new ExpectedHashCode(
              new byte[] {

        };
        ComponentUtil.setFessConfig(mockConfig);

        try {
            // Add multiple conditions for same field (like in fess_thumbnail.xml)
            // When same key is added multiple times, patterns are combined with |
            generator.addCondition("mimetype", "image/jpeg");
            generator.addCondition("mimetype", "image/png");
            generator.addCondition("mimetype", "image/svg" + "\\" + "+xml");

import java.util.SortedMap;
import java.util.SortedSet;
import org.jspecify.annotations.Nullable;

/**
 * Synchronized collection views. The returned synchronized collection views are serializable if the
 * backing collection and the mutex are serializable.
 *
 * <p>If {@code null} is passed as the {@code mutex} parameter to any of this class's top-level

type ObjectKey struct {
	Lit *LiteralString `parser:" \"[\" @LitString \"]\""`
	ID  *Identifier    `parser:"| \".\" @@"`
}

// QuotedIdentifier is a type for parsed strings that are double
// quoted.
type QuotedIdentifier string

// Capture interface used by participle
func (qi *QuotedIdentifier) Capture(values []string) error {
	// Remove enclosing quotes
	n := len(values[0])