private static final Logger logger = LogManager.getLogger(FessApiFailureHook.class);

    // ===================================================================================
    //                                                                          Definition
    //                                                                          ==========
    protected static final int HTTP_BAD_REQUEST = 400;

     */
    public static final int SMB2_SESSION_FLAGS_IS_GUEST = 0x1;

    /**
     * Session flag indicating this is a null/anonymous session
     */
    public static final int SMB2_SESSION_FLAGS_IS_NULL = 0x2;

    /**
     * Session flag indicating data encryption is required for this session
     */
    public static final int SMB2_SESSION_FLAG_ENCRYPT_DATA = 0x4;

public class DefaultCompressionService implements CompressionService {

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

    // Configuration constants
    private static final int MIN_COMPRESSION_SIZE = 512; // 512 bytes minimum
    private static final int MAX_COMPRESSION_SIZE = 1024 * 1024; // 1MB maximum
    private static final int COMPRESSION_LEVEL = Deflater.DEFAULT_COMPRESSION;

 * limitations under the License.
 */

package com.google.common.util.concurrent;

import static com.google.common.truth.Truth.assertThat;
import static com.google.common.truth.Truth.assertWithMessage;
import static java.util.concurrent.Executors.newSingleThreadExecutor;
import static java.util.concurrent.TimeUnit.MILLISECONDS;
import static org.junit.Assert.assertThrows;

import com.google.common.testing.TearDown;

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

    /** Property key for SMB authentications configuration. */
    public static final String SMB_AUTHENTICATIONS_PROPERTY = "smbAuthentications";

    /** Property key for SMB allowed SID entries. */
    public static final String SMB_ALLOWED_SID_ENTRIES = "smbAllowedSidEntries";

        public boolean hasRule(Rule rule) {
            return rules.contains(rule);
        }
    }

    /**
     * Simple test rule implementation
     */
    public static class TestRule implements Rule {
        private static final long serialVersionUID = 1L;
        private final String ruleId;
        private final boolean matchResult;
        private final ResponseProcessor responseProcessor;

import org.junit.jupiter.api.Nested;
import org.junit.jupiter.api.Test;

import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertFalse;
import static org.junit.jupiter.api.Assertions.assertNotNull;
import static org.junit.jupiter.api.Assertions.assertTrue;
import static org.mockito.Mockito.mock;
import static org.mockito.Mockito.when;

/**

        // NOP
    }

    /**
     * Field name for session ID.
     */
    public static final String SESSION_ID = "sessionId";

    /**
     * Field name for filter type.
     */
    public static final String FILTER_TYPE = "filterType";

    /**
     * Field name for URL.
     */
    public static final String URL = "url";

    /**
     * The unique identifier for this URL filter.
     */

 */

package jcifs.smb1.smb1;

import java.io.UnsupportedEncodingException;

class NetServerEnum2 extends SmbComTransaction {

    static final int SV_TYPE_ALL = 0xFFFFFFFF;
    static final int SV_TYPE_DOMAIN_ENUM = 0x80000000;

    static final String[] DESCR = { "WrLehDO\u0000B16BBDz\u0000", "WrLehDz\u0000B16BBDz\u0000", };

    String domain, lastName = null;
    int serverTypes;

 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package com.google.common.collect;

import static com.google.common.base.Preconditions.checkNotNull;

import com.google.common.annotations.GwtCompatible;
import com.google.common.annotations.GwtIncompatible;
import com.google.common.annotations.J2ktIncompatible;