override fun isOutputShutdown(): Boolean = delegate!!.isOutputShutdown

  @Throws(SocketException::class)
  override fun setReuseAddress(reuse: Boolean) {
    delegate!!.reuseAddress = reuse
  }

  @Throws(SocketException::class)
  override fun getReuseAddress(): Boolean = delegate!!.reuseAddress

  @Throws(SocketException::class)

     * @param content the message to log
     * @param error the error that caused this log
     */
    void debug(CharSequence content, Throwable error);

    /**
     * Sends an exception to the user in the <b>debug</b> error level.
     * The stack trace for this exception will be output when this error level is enabled.
     *
     * @param error the error that caused this log
     */
    void debug(Throwable error);

     *
     * @return a buffer from the cache, or a new one
     */
    byte[] getBuffer();

    /**
     * Return a buffer to the cache
     *
     * @param buf the buffer to return to the cache for reuse
     */
    void releaseBuffer(byte[] buf);

    }

    @Test
    @DisplayName("Test reset functionality")
    void testReset() {
        // Reset should not throw exception
        assertDoesNotThrow(() -> transaction.reset());

        // Transaction should be ready for reuse
        assertTrue(transaction.hasMoreElements());
    }

    @Test
    @DisplayName("Test reset with key and lastName")
    void testResetWithKeyAndLastName() {

 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package okhttp3.internal.connection

/** Reuse a connection from the pool. */
internal class ReusePlan(
  val connection: RealConnection,
) : RoutePlanner.Plan {
  override val isReady = true

  override fun connectTcp() = error("already connected")

                            log.debug("Cannot reuse, signing enforced on connection " + conn);
                        }
                        continue;
                    }

                    if (!conn.getNegotiateResponse().canReuse(tc, forceSigning)) {
                        if (log.isTraceEnabled()) {
                            log.trace("Cannot reuse, different config " + conn);
                        }

        this.problems = new ArrayList<>();
        if (problems != null) {
            this.problems.addAll(problems);
        }
    }

    /**
     * Gets the problems that caused this exception.
     *
     * @return The problems that caused this exception, never {@code null}.
     */
    public List<Problem> getProblems() {
        return problems;
    }

    private static String toMessage(List<Problem> problems) {

        assertEquals(expected, NbtException.getErrorString(NbtException.ERR_NAM_SRVC, unknown));
    }

    @ParameterizedTest(name = "session error {1} -\\u003e {2}")
    @CsvSource({ "-1,Connection refused", "0x80,Not listening on called name", "0x81,Not listening for calling name",
            "0x82,Called name not present", "0x83,Called name present, but insufficient resources", "0x8F,Unspecified error",

     * The abort flag is set to false by default.
     *
     * @param url the URL where the crawling error occurred
     * @param message the error message
     * @param cause the underlying exception that caused this error
     */
    public DataStoreCrawlingException(final String url, final String message, final Throwable cause) {
        this(url, message, cause, false);
    }

    /**

 *  New: `Request.Builder.cacheUrlOverride()` customizes the cache key used for a request. This can
    be used to make canonical URLs for the cache that omit insignificant query parameters or other
    irrelevant data.

    This feature may be used with `POST` requests to cache their responses. In such cases the
    request body is not used to determine the cache key, so you must manually add cache-relevant