import jcifs.CIFSException;

/**
 * Comprehensive tests for default compression service implementation.
 */
public class DefaultCompressionServiceTest {

    private DefaultCompressionService compressionService;
    private byte[] testData;
    private byte[] largeTestData;

    @BeforeEach
    public void setUp() {
        compressionService = new DefaultCompressionService();

 * The DI container automatically sorts the injected strategies by their @Priority annotations.
 */
@Named("strategy-orchestrator")
@Singleton
public class StrategyOrchestrator {

    private final List<UpgradeStrategy> strategies;

    @Inject
    public StrategyOrchestrator(List<UpgradeStrategy> strategies) {
        // DI container automatically sorts strategies by priority (highest first)

    //                                                                           =========
    /** Service for managing scheduled jobs */
    @Resource
    private ScheduledJobService scheduledJobService;
    /** Pager for paginating scheduled job results */
    @Resource
    private SchedulerPager schedulerPager;
    /** Helper for processing scheduled jobs. */
    @Resource
    protected ProcessHelper processHelper;

    //                                                                           =========
    @Resource
    private StemmerOverrideService stemmerOverrideService;
    @Resource
    private StemmerOverridePager stemmerOverridePager;

    // ===================================================================================
    //                                                                               Hook

            SourceSinkFactories.appendingPathCharSinkFactory()));
    suite.addTestSuite(MoreFilesTest.class);
    return suite;
  }

  private static final FileSystem FS = FileSystems.getDefault();

  private static Path root() {
    return FS.getRootDirectories().iterator().next();
  }

  private Path tempDir;

  @Override
  protected void setUp() throws Exception {
    tempDir = Files.createTempDirectory("MoreFilesTest");
  }

    assertThat(forwardingMap.toString()).isEqualTo(hashmap.toString());
  }

  private static <K, V> Map<K, V> wrap(Map<K, V> delegate) {
    return new ForwardingMap<K, V>() {
      @Override
      protected Map<K, V> delegate() {
        return delegate;
      }
    };
  }

  private static @Nullable Object getDefaultValue(TypeToken<?> type) {
    Class<?> rawType = type.getRawType();

import jcifs.internal.util.SMBUtil;

@ExtendWith(MockitoExtension.class)
class Smb2CreateResponseTest {

    // SMB2 header size in bytes
    private static final int SMB2_HEADER_LENGTH = 64;

    /**
     * Build a minimal SMB2 header for a response.
     */
    private static byte[] buildSmb2Header() {
        byte[] header = Arrays.copyOf(SMBUtil.SMB2_HEADER, SMBUtil.SMB2_HEADER.length);

 * DoubleAdder</a>.
 *
 * @author Doug Lea
 * @author Martin Buchholz
 * @since 11.0
 */
public class AtomicDouble extends Number {
  private static final long serialVersionUID = 0L;

  // We would use AtomicLongFieldUpdater, but it has issues on some Android devices.
  private transient AtomicLong value;

  /**
   * Creates a new {@code AtomicDouble} with the given initial value.
   *

 * @param <N> Node parameter type
 * @since 20.0
 */
@Immutable(containerOf = {"N"})
public class ImmutableGraph<N> extends ForwardingGraph<N> {
  @SuppressWarnings("Immutable") // The backing graph must be immutable.
  private final BaseGraph<N> backingGraph;

  ImmutableGraph(BaseGraph<N> backingGraph) {
    this.backingGraph = backingGraph;
  }

  /** Returns an immutable copy of {@code graph}. */

    }

    /** Logger instance for this class. */
    private static final Logger logger = LogManager.getLogger(Crawler.class);

    /** Thread name for web and file system crawling process. */
    private static final String WEB_FS_CRAWLING_PROCESS = "WebFsCrawler";

    /** Thread name for data store crawling process. */
    private static final String DATA_CRAWLING_PROCESS = "DataStoreCrawler";