}
  }

  @Throws(FileNotFoundException::class)
  private fun newJournalWriter(): BufferedSink {
    val fileSink = fileSystem.appendingSink(journalFile)
    val faultHidingSink =
      FaultHidingSink(fileSink) {
        assertLockHeld()
        hasJournalErrors = true
      }
    return faultHidingSink.buffer()
  }

  @Throws(IOException::class)
  private fun readJournalLine(line: String) {

import org.mockito.MockedStatic;
import org.mockito.Mockito;
import org.mockito.junit.jupiter.MockitoExtension;

import jcifs.pac.PACDecodingException;

/**
 * Unit tests for the KerberosTicket class.
 */
@ExtendWith(MockitoExtension.class)
class KerberosTicketTest {

    @Mock
    private KerberosKey kerberosKey;

    private KerberosKey[] keys;

    private static final String SERVER_REALM = "EXAMPLE.COM";

   * hashCode()} on the set values so that set tests on unhashable objects can suppress it with
   * {@code FeatureSpecificTestSuiteBuilder.suppressing()}.
   */
  @J2ktIncompatible
  @GwtIncompatible // reflection
  public static Method[] getHashCodeMethods() {
    return new Method[] {
      getMethod(SetHashCodeTester.class, "testHashCode"),

    withLock {
      successCount++
    }
  }

  @Throws(IOException::class)
  fun start() {
    idleAtNs = System.nanoTime()
    if (protocol == Protocol.HTTP_2 || protocol == Protocol.H2_PRIOR_KNOWLEDGE) {
      startHttp2()
    }
  }

  @Throws(IOException::class)
  private fun startHttp2() {
    javaNetSocket.soTimeout = 0 // HTTP/2 connection timeouts are set per-stream.

 * implementation and a Mockito mock to verify interactions.
 */
@ExtendWith(MockitoExtension.class)
public class SmbBasicFileInfoTest {

    /**
     * Simple concrete implementation used for testing return values.
     */
    private static class TestInfo implements SmbBasicFileInfo {
        private final int attributes;
        private final long createTime;

 * hint for further adapters to process.
 *
 * Types like ANY and CHOICE that don't have a consistent tag cannot use this.
 */
internal data class BasicDerAdapter<T>(
  private val name: String,
  /** The tag class this adapter expects, or -1 to match any tag class. */
  val tagClass: Int,
  /** The tag this adapter expects, or -1 to match any tag. */
  val tag: Long,
  /** Encode and decode the value once tags are handled. */

 * }
 * </pre>
 *
 * <p>Note: This class is not thread-safe. Each thread should create its own instance of XPathAPI.</p>
 *
 * @see javax.xml.xpath.XPath
 * @see javax.xml.xpath.XPathFactory
 * @see javax.xml.xpath.XPathExpressionException
 */
public class XPathAPI {

    private final XPath xPath;

    /**
     * Creates a new XPathAPI instance.
     */

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

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

        StandardCrawlerContainer container = new StandardCrawlerContainer().singleton("sitemapsHelper", SitemapsHelper.class)//
                .singleton("sitemapsRule", SitemapsRule.class)//

import org.slf4j.LoggerFactory;

import jcifs.CIFSException;
import jcifs.spnego.NegTokenInit;

/**
 * This class used to provide Kerberos feature when setup GSSContext.
 *
 * @author Shun
 */
class Kerb5Context implements SSPContext {

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

    private static final ASN1ObjectIdentifier KRB5_MECH_OID;

import static org.junit.jupiter.api.Assertions.assertTrue;

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

/**
 * Test class for RuntimeCIFSException functionality
 */
@DisplayName("RuntimeCIFSException Tests")
class RuntimeCIFSExceptionTest extends BaseTest {

    @Test
    @DisplayName("Should create RuntimeCIFSException with default constructor")
    void testDefaultConstructor() {