*/

package jcifs.smb1.smb1;

import jcifs.smb1.Config;

class SmbComReadAndX extends AndXServerMessageBlock {

    private static final int BATCH_LIMIT = Config.getInt("jcifs.smb1.smb.client.ReadAndX.Close", 1);

    private long offset;
    private int fid;

    private final int openTimeout;
    int maxCount, minCount, remaining;

    SmbComReadAndX() {
        super(null);

 */

package jcifs.smb1.smb1;

import jcifs.smb1.util.Hexdump;

class Trans2FindNext2 extends SmbComTransaction {

    private final int sid, informationLevel;
    private int resumeKey;
    private final int flags;
    private String filename;

    Trans2FindNext2(final int sid, final int resumeKey, final String filename) {
        this.sid = sid;
        this.resumeKey = resumeKey;

    return doAssertThrows(
        expectedThrowable,
        () -> {
          runnable.run();
          return null;
        },
        /* userPassedSupplier= */ false);
  }

  private static <T extends Throwable> T doAssertThrows(
      Class<T> expectedThrowable, ThrowingSupplier supplier, boolean userPassedSupplier) {
    checkNotNull(expectedThrowable);
    checkNotNull(supplier);

 *
 * @author Adomas Paltanavicius
 */
@NullUnmarked
public class JoinerBenchmark {

  private static final String DELIMITER_STRING = ",";
  private static final char DELIMITER_CHARACTER = ',';

  private static final Joiner JOINER_ON_STRING = Joiner.on(DELIMITER_STRING);
  private static final Joiner JOINER_ON_CHARACTER = Joiner.on(DELIMITER_CHARACTER);

  @Param({"3", "30", "300"})
  int count;

     */
    public static final int DEFAULT_HTTP_PORT = 80;

    /**
     * Default constructor for SMB1 HTTP URL handler.
     */
    public Handler() {
    }

    private static final Map PROTOCOL_HANDLERS = new HashMap();

    private static final String HANDLER_PKGS_PROPERTY = "java.protocol.handler.pkgs";

    /**
     * Vendor-specific default packages.  If no packages are specified in

class AbstractCIFSContextTest {

    private TestAbstractCIFSContext context;

    @Mock
    private Credentials mockCredentials;

    @BeforeEach
    void setUp() {
        MockitoAnnotations.openMocks(this);
        context = new TestAbstractCIFSContext(mockCredentials);
    }

    // Concrete implementation for testing AbstractCIFSContext

 */
public class FtpAuthentication {
    private static final Logger logger = LogManager.getLogger(FtpAuthentication.class);

    /**
     * Constructs a new FtpAuthentication.
     */
    public FtpAuthentication() {
        // Default constructor
    }

    private String server;

    private int port;

    private String username;

    private String password;

    /**

              .createTestSuite());
    }
    return derivedSuites;
  }

  private static final class ReserializedCollectionGenerator<E>
      implements TestCollectionGenerator<E> {
    final OneSizeTestContainerGenerator<Collection<E>, E> gen;

    private ReserializedCollectionGenerator(OneSizeTestContainerGenerator<Collection<E>, E> gen) {
      this.gen = gen;
    }

    @Override

 *
 * @author Sven Mawson
 */
@NullUnmarked
@GwtIncompatible
@J2ktIncompatible
public class ListenableFutureTester {

  private final ExecutorService exec;
  private final ListenableFuture<?> future;
  private final CountDownLatch latch;

  public ListenableFutureTester(ListenableFuture<?> future) {
    this.exec = newCachedThreadPool();
    this.future = checkNotNull(future);

/**
 * Checks source files for correct file permissions.
 */
public abstract class FilePermissionsTask extends DefaultTask {

    private final ProjectLayout projectLayout;

    /**
     * A pattern set of which files should be checked.
     */
    private final PatternFilterable filesFilter = new PatternSet()
        // we always include all source files, and exclude what should not be checked
        .include("**")