* @return the txn_buf
     */
    public byte[] releaseBuffer() {
        final byte[] buf = this.txn_buf;
        this.txn_buf = null;
        return buf;
    }

    /**
     * Gets the transaction subcommand
     * @return the subCommand
     */
    public final byte getSubCommand() {
        return this.subCommand;
    }

    /**
     * Sets the transaction subcommand

        return child != null ? child.textContentTrimmed() : null;
    }

    /**
     * Gets the list of plugin upgrades to apply.
     */
    public static List<PluginUpgrade> getPluginUpgrades() {
        return PLUGIN_UPGRADES;
    }

    /**
     * Gets or creates the cached Maven 4 session.
     */
    private Session getSession() {
        if (session == null) {

        }
        connected = false;
    }

    /**
     * Gets the thread pool from the underlying client.
     *
     * @return The thread pool.
     */
    @Override
    public ThreadPool threadPool() {
        return client.threadPool();
    }

    /**
     * Gets the admin client for cluster and index operations.
     *
     * @return The admin client.
     */

                }
            }
        }

        /*
         * MNG-4312: We neither have reserved all of the above magic expressions nor is their set fixed/well-known (it
         * gets occasionally extended by newer Maven versions). This imposes the risk for existing plugins to
         * unintentionally use such a magic expression for an ordinary property. So here we check whether we

            }
            break;
        default:
            break;
        }
        return OptionalEntity.empty();
    }

    /**
     * Gets a duplicate host entity from the form, setting audit fields.
     *
     * @param form the form containing duplicate host data
     * @return optional duplicate host entity with audit fields set
     */

        }

        extractData.putValue("row_count", String.valueOf(rows.size()));

        return extractData;
    }

    /**
     * Gets the character set from parameters or uses the default.
     *
     * @param params the parameters
     * @return the character set
     */
    protected Charset getCharset(final Map<String, String> params) {

                updateFileIfChanged();
            } catch (Exception e) {
                logError("Error updating file", e);
            }
        }

        return true;
    }

    /**
     * Gets the fully qualified class name for a type element, including handling inner classes.
     *
     * @param typeElement the type element to get the class name for
     * @return the fully qualified class name
     */

                crawler.stop();
            }
        }
    }

    /**
     * Gets the total execution time for index updates.
     *
     * @return the total execution time in milliseconds
     */
    public long getExecuteTime() {
        return executeTime;
    }

    /**
     * Gets the list of crawler session IDs being processed.
     *
     * @return the list of session IDs
     */

        // OEM flag should not be set when default is Unicode
        assertFalse((unicodeType1.getFlags() & NtlmFlags.NTLMSSP_NEGOTIATE_OEM) != 0);

        // When OEM flag is passed, it gets OR'd with default flags
        // Since mockConfig.isUseUnicode() returns true, default flags include UNICODE
        assertTrue((oemType1.getFlags() & NtlmFlags.NTLMSSP_NEGOTIATE_OEM) != 0);

   */
  @AndroidIncompatible
  public void testTaskThrowsError() throws Exception {
    class MyError extends Error {}
    CyclicBarrier barrier = new CyclicBarrier(2);
    // we need to make sure the error gets thrown on a different thread.
    ExecutorService service = newSingleThreadExecutor();
    try {
      SequentialExecutor executor = new SequentialExecutor(service);
      Runnable errorTask =
          new Runnable() {