/** Tests for {@link AbstractFuture} with the cancellation cause system property set */
@AndroidIncompatible // custom classloading

@NullUnmarked
public class AbstractFutureCancellationCauseTest extends TestCase {

  private ClassLoader oldClassLoader;
  private URLClassLoader classReloader;
  private Class<?> settableFutureClass;
  private Class<?> abstractFutureClass;

  @Override

 */

package jcifs.smb1.smb1;

import java.io.UnsupportedEncodingException;
import java.util.Date;

import jcifs.smb1.util.Hexdump;
import jcifs.smb1.util.LogStream;

class SmbComNegotiateResponse extends ServerMessageBlock {

    int dialectIndex;
    SmbTransport.ServerData server;

    SmbComNegotiateResponse(final SmbTransport.ServerData server) {
        this.server = server;
    }

    @Override

 */

package jcifs.smb1.smb1;

import java.util.Enumeration;

import jcifs.smb1.util.LogStream;

abstract class SmbComTransactionResponse extends ServerMessageBlock implements Enumeration {

    // relative to headerStart
    private static final int SETUP_OFFSET = 61;

    private static final int DISCONNECT_TID = 0x01;

{% extends "base.html" %}

{% block announce %}
<div class="announce-wrapper">
  <div id="announce-left">
    <div class="item">
      <a class="announce-link" href="https://x.com/fastapi" target="_blank">
        <span class="twemoji">
          {% include ".icons/fontawesome/brands/x-twitter.svg" %}
        </span> Follow <strong>@fastapi</strong> on <strong>X (Twitter)</strong> to stay updated
      </a>
    </div>
    <div class="item">

 *     com.google.common.util.concurrent.ForwardingBlockingDeque} instead.
 */
@Deprecated
@J2ktIncompatible
@GwtIncompatible
public abstract class ForwardingBlockingDeque<E> extends ForwardingDeque<E>
    implements BlockingDeque<E> {

  /** Constructor for use by subclasses. */
  protected ForwardingBlockingDeque() {}

  @Override
  protected abstract BlockingDeque<E> delegate();

 * Handles responses from network server enumeration operations, parsing server
 * information returned by the NetServerEnum2 transaction in SMB1 protocol.
 *
 * @author mbechler
 *
 */
public class NetServerEnum2Response extends SmbComTransactionResponse {

    private static final Logger log = LoggerFactory.getLogger(NetServerEnum2Response.class);

    class ServerInfo1 implements FileEntry {

        String name;
        int versionMajor;

/**
 * SMB1 Open AndX Response message.
 *
 * This response contains information about the opened file,
 * including file ID, attributes, size, and access permissions.
 */
public class SmbComOpenAndXResponse extends AndXServerMessageBlock implements SmbBasicFileInfo {

    private int fid, fileAttributes, fileDataSize, grantedAccess, fileType, deviceState, action, serverFid;
    private long lastWriteTime;

    /**

import org.codelibs.fess.crawler.rule.Rule;
import org.codelibs.fess.crawler.rule.RuleManager;
import org.dbflute.utflute.core.PlainTestCase;

/**
 * @author shinsuke
 *
 */
public class RuleManagerImplTest extends PlainTestCase {
    public RuleManager ruleManager;

    @Override
    protected void setUp() throws Exception {
        super.setUp();

 * Converts Lucene WildcardQuery objects to OpenSearch QueryBuilder objects,
 * supporting wildcard pattern matching with configurable case sensitivity.
 */
public class WildcardQueryCommand extends QueryCommand {

    /**
     * Default constructor.
     */
    public WildcardQueryCommand() {
        super();
    }

 * optionally process each line with a callback function, and maintain a circular buffer
 * of recent lines for retrieval.
 */
public class InputStreamThread extends Thread {
    /** Logger instance for this class */
    private static final Logger logger = LogManager.getLogger(InputStreamThread.class);

    /** Buffered reader for reading from the input stream */