* Creates an {@link java.io.InputStream} for reading bytes from a file on
     * an SMB server addressed by the <code>url</code> parameter. See {@link
     * jcifs.smb1.smb1.SmbFile} for a detailed description and examples of the smb
     * URL syntax.
     *
     * @param url An smb URL string representing the file to read from
     */

    /**
     * Creates an input stream for reading from the specified SMB URL
     *

        final String normalizedWord = normalizer.normalize(elevateWord.getElevateWord(), "");
        final List<String> normalizedReadings =
                elevateWord.getReadings().stream().map(reading -> normalizer.normalize(reading, "")).collect(Collectors.toList());
        final ElevateWord normalized = new ElevateWord(normalizedWord, elevateWord.getBoost(), normalizedReadings, elevateWord.getFields(),

import okio.ByteString
import okio.ByteString.Companion.decodeHex
import okio.FileSystem
import okio.Path
import okio.Path.Companion.toOkioPath
import okio.buffer
import okio.source

/**
 * Utilities for reading HPACK tests.
 */
object HpackJsonUtil {
  @Suppress("unused")
  private val MOSHI =
    Moshi
      .Builder()
      .add(
        object : Any() {

            }, this::asEditHtml);
        }
        if (form.segmentation != null && form.reading != null && form.segmentation.split(" ").length != form.reading.split(" ").length) {
            throwValidationError(messages -> {
                messages.addErrorsInvalidKuromojiSegmentation("segmentation", form.segmentation, form.reading);
            }, this::asEditHtml);
        }
    }

        if (length > 24 + getStandardLeaseSize()) {
            int scopeOrdinal = SMBUtil.readInt4(buffer, dataOffset);
            this.cacheScope = DirectoryCacheScope.values()[scopeOrdinal];
            dataOffset += 4;

            this.maxCacheAge = SMBUtil.readInt8(buffer, dataOffset);
            dataOffset += 8;

            int flags = SMBUtil.readInt4(buffer, dataOffset);

        assertEquals(0x0001, SMBUtil.readInt2(buffer, 0));

        // Test with FS_SIZE_INFO (3)
        trans2QueryFSInfo = new Trans2QueryFSInformation(config, FileSystemInformation.FS_SIZE_INFO);
        buffer = new byte[10];
        trans2QueryFSInfo.writeParametersWireFormat(buffer, 0);
        assertEquals(0x0103, SMBUtil.readInt2(buffer, 0));
    }

    @Test

        final int start = bufferIndex;
        final int nalgos = SMBUtil.readInt2(buffer, bufferIndex);
        final int nsalt = SMBUtil.readInt2(buffer, bufferIndex + 2);
        bufferIndex += 4;

        this.hashAlgos = new int[nalgos];
        for (int i = 0; i < nalgos; i++) {
            this.hashAlgos[i] = SMBUtil.readInt2(buffer, bufferIndex);
            bufferIndex += 2;
        }

  ) {
  }

  /**
   * No further calls to this listener will be made.
   */
  open fun onClosed(eventSource: EventSource) {
  }

  /**
   * Invoked when an event source has been closed due to an error reading from or writing to the
   * network. Incoming events may have been lost. No further calls to this listener will be made.
   */
  open fun onFailure(
    eventSource: EventSource,
    t: Throwable?,

        // Verify structure size (should be 24)
        assertEquals(24, SMBUtil.readInt2(buffer, offset));

        // Verify Reserved1 (2 bytes at offset+2, should be 0)
        assertEquals(0, SMBUtil.readInt2(buffer, offset + 2));

        // Verify Reserved2 (4 bytes at offset+4, should be 0)
        assertEquals(0, SMBUtil.readInt4(buffer, offset + 4));

        final int structureSize = SMBUtil.readInt2(buffer, bufferIndex);
        if (structureSize != 9) {
            throw new SMBProtocolDecodingException("Expected structureSize = 9");
        }

        final int bufferOffset = SMBUtil.readInt2(buffer, bufferIndex + 2) + getHeaderStart();
        bufferIndex += 4;
        final int bufferLength = SMBUtil.readInt4(buffer, bufferIndex);
        bufferIndex += 4;