this.valid = true;
    }

    /**
     * Get the underlying buffer
     *
     * @return memory buffer
     * @throws IllegalStateException if memory region has been invalidated
     */
    public ByteBuffer getBuffer() {
        if (!valid) {
            throw new IllegalStateException("Memory region invalidated");
        }
        return buffer;
    }

    /**
     * Get local memory key

  }

  @SuppressWarnings("CatchingUnchecked") // sneaky checked exception
  private static void closeAll(BaseStream<?, ?>[] toClose) {
    // If one of the streams throws an exception, continue closing the others, then throw the
    // exception later. If more than one stream throws an exception, the later ones are added to the
    // first as suppressed exceptions. We don't catch Error on the grounds that it should be allowed

            this.manager = manager;
        }

        public T get() {
            if (closed) {
                throw new IllegalStateException("Resource has been closed: " + resourceId);
            }
            return resource;
        }

        @Override
        public void close() throws Exception {
            if (closed) {
                return;
            }

            try {

        // Test with offset pointing outside array bounds (should throw ArrayIndexOutOfBoundsException)
        buffer.putShort(0, (short) 1);
        buffer.putShort(2, (short) 1);
        buffer.putInt(4, data.length + 1); // Invalid offset
        assertThrows(ArrayIndexOutOfBoundsException.class, () -> NtlmMessage.readSecurityBuffer(data, 0),
                "Should throw ArrayIndexOutOfBoundsException for invalid offset.");
    }

  @SuppressLint("NewApi")
  override fun afterEach(context: ExtensionContext) {
    val failure = context.executionException.orElseGet { null }

    if (uncaughtException != null) {
      throw failure + AssertionError("uncaught exception thrown during test", uncaughtException)
    }

    if (context.isFlaky()) {
      logEvents()
    }

    LogManager.getLogManager().reset()

    var result: Throwable? = failure

      Throwable cause = e.getCause();
      if (policy.isExpectedType(cause)) {
        return;
      }
      throw new AssertionError(
          String.format(
              "wrong exception thrown from %s when passing null to %s parameter at index %s.%n"
                  + "Full parameters: %s%n"
                  + "Actual exception message: %s",
              invokable,

  }

  @J2ktIncompatible
  private void writeObject(ObjectOutputStream stream) throws IOException {
    stream.defaultWriteObject();
    stream.writeInt(size());
    for (E e : this) {
      stream.writeObject(e);
    }
  }

  @SuppressWarnings("unchecked")
  @J2ktIncompatible
  private void readObject(ObjectInputStream stream) throws IOException, ClassNotFoundException {
    stream.defaultReadObject();

     *
     * @param directoryPath parent directory path
     * @param fileInfo cached file information
     * @return SmbFile instance
     * @throws IOException on error
     */
    private SmbFile createSmbFileFromCache(String directoryPath, DirectoryCacheEntry.FileInfo fileInfo) throws IOException {
        String filePath = directoryPath;
        if (!filePath.endsWith("/")) {
            filePath += "/";
        }

  }

  /**
   * Returns an optional charset for the value of the charset parameter if it is specified.
   *
   * @throws IllegalStateException if multiple charset values have been set for this media type
   * @throws IllegalCharsetNameException if a charset value is present, but illegal
   * @throws UnsupportedCharsetException if a charset value is present, but no support is available
   *     in this instance of the Java virtual machine

                throw new JobProcessingException(out.toString());
            }
            ComponentUtil.getPopularWordHelper().clearCache();
        } catch (final JobProcessingException e) {
            throw e;
        } catch (final Exception e) {
            throw new JobProcessingException("ThumbnailGenerator Process terminated.", e);
        } finally {