}
    
    public HandleGuid(byte[] bytes) {
        if (bytes.length != 16) {
            throw new IllegalArgumentException("GUID must be 16 bytes");
        }
        ByteBuffer bb = ByteBuffer.wrap(bytes);
        long mostSig = bb.getLong();
        long leastSig = bb.getLong();
        this.guid = new UUID(mostSig, leastSig);
    }
    
    public byte[] toBytes() {
        ByteBuffer bb = ByteBuffer.allocate(16);

            return false;
        }
    }
    
    public byte[] encode() {
        // Encode for FSCTL_QUERY_NETWORK_INTERFACE_INFO response
        byte[] buffer = new byte[152];  // Fixed size structure
        
        // InterfaceIndex (4 bytes)
        writeInt4(buffer, 0, interfaceIndex);
        
        // Capability (4 bytes)
        writeInt4(buffer, 4, capability);
        

                final byte[] userSessionKey = hmac.digest();

                if ((getFlags() & NTLMSSP_NEGOTIATE_KEY_EXCH) != 0) {
                    masterKey = new byte[16];
                    RANDOM.nextBytes(masterKey);

                    final byte[] exchangedKey = new byte[16];
                    final RC4 rc4 = new RC4(userSessionKey);

        byte[] dst = new byte[150];
        int bytesWritten = netServerEnum2.writeParametersWireFormat(dst, 0);

        // Verify subcommand
        assertEquals(SmbComTransaction.NET_SERVER_ENUM3 & 0xFF, (dst[0] & 0xFF) | ((dst[1] & 0xFF) << 8));

        // Verify description
        byte[] descr = NetServerEnum2.DESCR[1].getBytes("ASCII");
        byte[] writtenDescr = new byte[descr.length];

  @Throws(IOException::class)
  override fun onReadMessage(text: String) {
    listener.onMessage(this, text)
  }

  @Throws(IOException::class)
  override fun onReadMessage(bytes: ByteString) {
    listener.onMessage(this, bytes)
  }

  @Synchronized override fun onReadPing(payload: ByteString) {
    // Don't respond to pings after we've failed or sent the close frame.

      throws IOException {
    byte[] bytes = decoded.getBytes(UTF_8);
    try (InputStream decodingStream = encoding.decodingStream(new StringReader(encoded))) {
      for (int i = 0; i < bytes.length; i++) {
        assertThat(decodingStream.read()).isEqualTo(bytes[i] & 0xFF);
      }
      assertThat(decodingStream.read()).isEqualTo(-1);
    }
  }

            // Wipe input
            Arrays.fill(input, (byte) 0);
        }

        return derived;
    }

    /**
     * Generate a random key
     *
     * @param length key length in bytes
     * @return random key bytes
     */
    public byte[] generateRandomKey(int length) {
        checkNotClosed();

        byte[] key = new byte[length];
        secureRandom.nextBytes(key);

  static TestSuite suiteForBytes(
      CharSourceFactory factory, byte[] bytes, String name, String desc, boolean slice) {
    TestSuite suite = suiteForString(factory, new String(bytes, UTF_8), name, desc);
    ByteSourceFactory byteSourceFactory = SourceSinkFactories.asByteSourceFactory(factory);
    suite.addTest(
        ByteSourceTester.suiteForBytes(
            byteSourceFactory, bytes, name + ".asByteSource[Charset]", desc, slice));
    return suite;

        this.timeout100Ns = SMBUtil.readInt4(buffer, bufferIndex) & 0xFFFFFFFFL; // Timeout (4 bytes, 100-ns intervals, unsigned)
        this.flags = SMBUtil.readInt4(buffer, bufferIndex + 4); // Flags (4 bytes)
        return 8;
    }

    /**
     * Get the timeout value in 100-nanosecond intervals (raw wire format)
     * @return the timeout in 100-nanosecond intervals
     */
    public long getTimeout100Ns() {

    }

    @Test
    void testReadInt4() {
        byte[] src = new byte[] { (byte) 0x78, (byte) 0x56, (byte) 0x34, (byte) 0x12, // 0x12345678
                (byte) 0xFF, (byte) 0xFF, (byte) 0xFF, (byte) 0xFF, // 0xFFFFFFFF
                (byte) 0x00, (byte) 0x00, (byte) 0x00, (byte) 0x00, // 0x00000000
                (byte) 0xEF, (byte) 0xCD, (byte) 0xAB, (byte) 0x89 // 0x89ABCDEF
        };