log.error("Error in witness notification listener", e);
                    }
                }
            }
        }
    }

    /**
     * Determines if a notification should be delivered to a registration.
     *
     * @param registration the registration
     * @param notification the notification
     * @return true if the notification should be delivered

import jcifs.smb.SID;
import jcifs.util.Hexdump;

/**
 * An Access Control Entry (ACE) is an element in a security descriptor
 * such as those associated with files and directories. The Windows OS
 * determines which users have the necessary permissions to access objects
 * based on these entries.
 * <p>
 * To fully understand the information exposed by this class a description

        return fessConfig.getFesenHttpUrl();
    }

    /**
     * Gets the application type from the environment variable FESS_APP_TYPE.
     * This is used to determine the deployment environment (e.g., "docker").
     *
     * @return the application type string, or empty string if not set
     */
    public static String getAppType() {

     * hashcode.
     */

    @Override
    public int hashCode() {
        return this.address;
    }

    /**
     * Determines if this address is equal two another. Only the IP Addresses
     * are compared. Similar to the {@link #hashCode} method, the comparison
     * is based on the integer IP address and not the string representation.
     */

            throw new IOException("Connection not established");
        }

        try {
            socket.setSoTimeout(timeout);

            // First, read the header to determine message size
            ByteBuffer headerBuffer = ByteBuffer.allocate(4);
            while (headerBuffer.hasRemaining()) {
                int read = socketChannel.read(headerBuffer);
                if (read < 0) {

## Reporting Violations

          if (toSkip == 0L) break
          source.skip(toSkip)
        }
        source.skip(crlfDashDashBoundary.size.toLong())
      }

      // Read either \r\n or --\r\n to determine if there is another part.
      var whitespace = false
      afterBoundaryLoop@while (true) {
        when (source.select(afterBoundaryOptions)) {
          0 -> {
            // "\r\n": We've found a new part.

   */
  public String join(Iterable<?> parts) {
    /*
     * If we can quickly determine how many elements there are likely to be, then we can use the
     * fastest possible implementation, which delegates to the array overload of String.join.
     *
     * In theory, we can quickly determine the size of any Collection. However, thanks to

        }
        throw new CrawlingAccessException("Failed FTP request: " + client.getReplyString().trim());
    }

    /**
     * Determines the character set for the given file.
     * Currently returns the default charset configured for this client.
     *
     * @param file The file to determine the charset for
     * @return The character set name
     */
    protected String getCharSet(final File file) {
        return charset;

import java.util.Map;
import org.jspecify.annotations.Nullable;

/**
 * A {@link UnicodeEscaper} that uses an array to quickly look up replacement characters for a given
 * code point. An additional safe range is provided that determines whether code points without
 * specific replacements are to be considered safe and left unescaped or should be escaped in a
 * general way.
 *