}

    boolean logoff(boolean inError, boolean inUse) {
        boolean wasInUse = false;
        try (SmbTransportImpl trans = getTransport()) {
            synchronized (trans) {
                if (!this.connectionState.compareAndSet(2, 3)) { // not-connected
                    return false;
                }

                if (log.isDebugEnabled()) {

    }
    return numOfBytesRead;
  }

  /**
   * mark() is not supported for HashingInputStream
   *
   * @return {@code false} always
   */
  @Override
  public boolean markSupported() {
    return false;
  }

  /** mark() is not supported for HashingInputStream */
  @Override
  public void mark(int readlimit) {}

  /**

    /**
     * Check if the personality is "maven3".
     */
    public static boolean mavenMaven3Personality(@Nullable Map<String, ?> userProperties) {
        return doGet(userProperties, Constants.MAVEN_MAVEN3_PERSONALITY, false);
    }

    /**
     * Check if the consumer POM feature is active.
     */
    public static boolean consumerPom(@Nullable Map<String, ?> userProperties) {

     * 4. We expect the client thread's interrupt state to be false.
     * 5. The client thread again makes a blocking call to get().
     * 6. Now the result becomes available.
     * 7. We expect get() to return this result.
     * 8. We expect the test thread's interrupt state to be false.
     */
    InterruptionUtil.requestInterruptIn(200, MILLISECONDS);

    assertFalse(Thread.interrupted());

      gradleProperties[Constants.BUNDLE_VERSION] = bundleVersion.get()
    }

    // Do not capture 'task' in gradleProperties to avoid serialization issues

    try {
      Builder(Processor(gradleProperties, false)).use { builder ->
        val temporaryBndFile = File.createTempFile("bnd", ".bnd", temporaryDir)
        IO.writer(temporaryBndFile).use { writer ->
          val bndFileVal = bndfile.asFile.getOrNull()

			sizeFilter: BatchJobSizeFilter{
				UpperBound: 10 << 20,
				LowerBound: 1 << 20,
			},
			want: false,
		},
		{
			// 11MiB > 10 MiB -> out of range from right
			objSize: 11 << 20,
			sizeFilter: BatchJobSizeFilter{
				UpperBound: 10 << 20,
				LowerBound: 1 << 20,
			},
			want: false,
		},
		{
			//  2MiB < 10MiB -> in range
			objSize: 2 << 20,
			sizeFilter: BatchJobSizeFilter{

   * data section was empty. Any number of calls to [Callback.onRetryChange] may occur while
   * processing an event.
   *
   * @return false when EOF is reached
   */
  @Throws(IOException::class)
  fun processNextEvent(): Boolean {
    var id = lastId
    var type: String? = null
    val data = Buffer()

    while (true) {

     * Checks whether there is a next page available.
     *
     * @return true if a next page exists, false otherwise
     */
    public boolean isExistNextPage() {
        return existNextPage;
    }

    /**
     * Checks whether there is a previous page available.
     *
     * @return true if a previous page exists, false otherwise
     */
    public boolean isExistPrevPage() {
        return existPrevPage;
    }

     * @see jcifs.SmbTreeHandle#isSameTree(jcifs.SmbTreeHandle)
     */
    @Override
    public boolean isSameTree(final SmbTreeHandle th) {
        if (!(th instanceof SmbTreeHandleImpl)) {
            return false;
        }
        return this.treeConnection.isSame(((SmbTreeHandleImpl) th).treeConnection);
    }

    @Override
    public int getSendBufferSize() throws SmbException {

        context.indent();

        if (options.all().orElse(false)) {
            context.info("all: true (applying all available upgrades)");
        }

        if (options.modelVersion().isPresent()) {
            context.info("modelVersion: " + options.modelVersion().get());
        }

        if (options.plugins().orElse(false)) {
            context.info("plugins: true");
        }