void ensureConnected_throwsIOException() throws Exception {
        doThrow(new java.io.IOException("connect failed")).when(transport).ensureConnected();
        java.io.IOException ex = assertThrows(java.io.IOException.class, () -> transport.ensureConnected());
        assertTrue(ex.getMessage().contains("connect"));
        verify(transport).ensureConnected();
    }

        this.setInstanceFollowRedirects(this.connection.getInstanceFollowRedirects());
    }

    @Override
    public void connect() throws IOException {
        if (this.connected) {
            return;
        }
        this.connection.connect();
        this.connected = true;
    }

    private void handshake() {
        if (this.handshakeComplete) {
            return;
        }
        try {

      )
    assertContent("A", response)
    val connect1 = server.takeRequest()
    assertThat(connect1.requestLine).isEqualTo("CONNECT android.com:443 HTTP/1.1")
    assertThat(connect1.headers["Proxy-Authorization"]).isNull()
    val connect2 = server.takeRequest()
    assertThat(connect2.requestLine).isEqualTo("CONNECT android.com:443 HTTP/1.1")
    assertThat(connect2.headers["Proxy-Authorization"])

import okhttp3.Route

/**
 * A denylist of failed routes to avoid when creating a new connection to a target address. This is
 * used so that OkHttp can learn from its mistakes: if there was a failure attempting to connect to
 * a specific IP address or proxy server, that failure is remembered and alternate routes are
 * preferred.
 */
class RouteDatabase {
  private val _failedRoutes = mutableSetOf<Route>()

 *     possible for shared exchanges to make requests to different host names! See
 *     [RealConnection.isEligible] for details.
 *
 *  3. Attempt plans from prior connect attempts for this call. These occur as either follow-ups to
 *     failed connect attempts (such as trying the next [ConnectionSpec]), or as attempts that lost
 *     a race in fast follow-up.
 *

    }

    /**
     * Check if connection is established and ready for use
     *
     * @return true if connection is connected/established, false otherwise
     */
    public boolean isConnected() {
        return state == RdmaConnectionState.CONNECTED || state == RdmaConnectionState.ESTABLISHED;
    }

    /**
     * Read data from RDMA connection
     *

    class SamrConnect2Tests {

        @Test
        @DisplayName("Should construct with correct parameters and opnum")
        void testConstructorAndOpnum() {
            // When: Creating connect2 message
            samr.SamrConnect2 message = new samr.SamrConnect2("system", 123, mockPolicyHandle);

            // Then: Should have correct values
            assertEquals(0x39, message.getOpnum());

                        /*
                         * Some pipes may require that the hostname in the tree connect
                         * be the netbios name. So if we have the netbios server name
                         * from the NTLMSSP type 2 message, and the share is IPC$, we
                         * assert that the tree connect path uses the netbios hostname.
                         */

        return this;
    }

    /**
     * Connects to the URL and executes the request.
     *
     * @param actionListener the action listener for handling the response
     * @param exceptionListener the exception listener for handling exceptions
     */
    public void connect(final Consumer<HttpURLConnection> actionListener, final Consumer<Exception> exceptionListener) {

## **2. Prerequisites**

- Install Hortonworks Distribution using this [guide.](https://docs.hortonworks.com/HDPDocuments/Ambari-2.7.1.0/bk_ambari-installation/content/ch_Installing_Ambari.html)