* its comparator (which might be the element that was just added). This is different from
 * conventional bounded queues, which either block or reject new elements when full.
 *
 * <p>This implementation is based on the <a
 * href="http://portal.acm.org/citation.cfm?id=6621">min-max heap</a> developed by Atkinson, et al.
 * Unlike many other double-ended priority queues, it stores elements in a single array, as compact

                this.ntlmsspFlags, this.auth.isGuest() || !this.auth.isAnonymous());
    }

    /**
     * Creates a Type 1 (negotiation) message to initiate NTLM authentication.
     * @param token unused in this implementation
     * @return the Type 1 message bytes
     */
    protected byte[] makeNegotiate(final byte[] token) {

    void testNullMaximumVersion() {
        // Given
        when(mockConfig.getMaximumVersion()).thenReturn(null);

        // When/Then - Should throw NPE based on actual implementation
        assertThrows(NullPointerException.class, () -> {
            new Smb2NegotiateRequest(mockConfig, 0);
        });
    }

    @Test
    @DisplayName("Should properly align buffer writes")

    assertCollectionSize(map.entrySet(), size);
    assertCollectionSize(map.values(), size);
  }

  @SuppressWarnings("IterablesSizeOfCollection") // we are testing our iterator implementation
  private void assertCollectionSize(Collection<?> collection, int size) {
    assertThat(collection.size()).isEqualTo(size);
    if (size > 0) {
      assertThat(collection.isEmpty()).isFalse();
    } else {

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.crawler.entity;

import org.codelibs.core.beans.util.BeanUtil;
import org.codelibs.fess.crawler.Constants;

/**
 * Implementation of the {@link AccessResult} interface.
 *
 * @param <IDTYPE> the type of the identifier for the access result
 */
public class AccessResultImpl<IDTYPE> implements AccessResult<IDTYPE> {

    /**

import com.google.common.cache.CacheBuilder;
import com.google.common.cache.CacheLoader;
import com.google.common.cache.LoadingCache;

import jakarta.annotation.PostConstruct;

/**
 * OpenSearchUrlFilterService is an implementation of {@link UrlFilterService} for OpenSearch.
 */
public class OpenSearchUrlFilterService extends AbstractCrawlerService implements UrlFilterService {

    /**
     * Field name for filter type.
     */

/**
 * Test class for SmbComTransaction
 */
class SmbComTransactionTest {

    @Mock
    private Configuration mockConfig;

    private TestSmbComTransaction transaction;

    // Test implementation of abstract SmbComTransaction
    private static class TestSmbComTransaction extends SmbComTransaction {
        private int setupWireFormatReturn = 0;
        private int parametersWireFormatReturn = 0;

import java.io.DataInput;
import java.io.DataInputStream;
import java.io.EOFException;
import java.io.FilterInputStream;
import java.io.IOException;
import java.io.InputStream;

/**
 * An implementation of {@link DataInput} that uses little-endian byte ordering for reading {@code
 * short}, {@code int}, {@code float}, {@code double}, and {@code long} values.
 *

import java.io.InvalidObjectException;
import java.io.ObjectInputStream;
import java.io.Serializable;
import java.util.Collection;
import org.jspecify.annotations.Nullable;

/**
 * An implementation of {@link ContiguousSet} that contains one or more elements.
 *
 * @author Gregory Kick
 */
@GwtCompatible
@SuppressWarnings("rawtypes") // https://github.com/google/guava/issues/989

    private FileFsSizeInformation fileFsSizeInfo;

    @BeforeEach
    void setUp() {
        fileFsSizeInfo = new FileFsSizeInformation();
    }

    @Nested
    @DisplayName("Interface Implementation Tests")
    class InterfaceImplementationTests {

        @Test
        @DisplayName("Should implement AllocInfo interface")
        void shouldImplementAllocInfo() {