Monnet - Code Search

src/main/java/jcifs/smb1/http/NtlmHttpURLConnection.java

        super(connection.getURL());
        this.connection = connection;
        requestProperties = new HashMap();
    }

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

    private void handshake() throws IOException {
        if (handshakeComplete) return;
        doHandshake();

Java

- Registered: Sun May 05 00:10:10 GMT 2024

- Last Modified: Fri Mar 22 20:39:42 GMT 2019

- 20.4K bytes

- Viewed (0)

github.com/istio/istio

istioctl/pkg/writer/compare/testdata/configdump.json

      "version_info": "2024-03-04T08:37:44Z/4",
      "dynamic_listeners": [
        {
          "name": "connect_terminate",
          "active_state": {
            "listener": {
              "@type": "type.googleapis.com/envoy.config.listener.v3.Listener",
              "name": "connect_terminate",
              "address": {
                "socket_address": {
                  "address": "0.0.0.0",

Json

- Registered: Wed May 08 22:53:08 GMT 2024

- Last Modified: Tue Mar 12 10:02:09 GMT 2024

- 52K bytes

- Viewed (0)

github.com/istio/istio

istioctl/pkg/writer/compare/testdata/configdump_diff.json

      "version_info": "2024-03-04T08:37:44Z/4",
      "dynamic_listeners": [
        {
          "name": "connect_terminate",
          "active_state": {
            "listener": {
              "@type": "type.googleapis.com/envoy.config.listener.v3.Listener",
              "name": "connect_terminate",
              "address": {
                "socket_address": {
                  "address": "0.0.0.0",

Json

- Registered: Wed May 08 22:53:08 GMT 2024

- Last Modified: Tue Mar 12 10:02:09 GMT 2024

- 51.6K bytes

- Viewed (1)

github.com/apache/maven

maven-core/src/test/resources/org/apache/maven/extension/test-extension-repo/org/apache/maven/wagon/wagon-provider-api/1.0-beta-2/wagon-provider-api-1.0-beta-2.jar

authentication.AuthenticationInfo getAuthenticationInf(); public void connect(repository.Repository) throws ConnectionException, authentication.AuthenticationExcept; public void connect(repository.Repository, proxy.ProxyInfo) throws ConnectionException, authentication.AuthenticationExcept; public void connect(repository.Repository, authentication.AuthenticationInfo) throws ConnectionException, authentication.AuthenticationExcept; public void connect(repository.Repository, authentication.AuthenticationInfo, proxy.ProxyInfo)...

internal/dsync/dsync-client_test.go

type ReconnectRESTClient struct {
	u    *url.URL
	rest *rest.Client
}

// newClient constructs a ReconnectRESTClient object with addr and endpoint initialized.
// It _doesn't_ connect to the remote endpoint. See Call method to see when the
// connect happens.
func newClient(endpoint string) NetLocker {
	u, err := url.Parse(endpoint)
	if err != nil {
		panic(err)
	}

	tr := &http.Transport{

Go

- Registered: Sun May 05 19:28:20 GMT 2024

- Last Modified: Thu Jan 20 17:36:09 GMT 2022

- 4.4K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/smb1/smb1/SmbSession.java

                /* 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.
                 */
                tcax.path = "\\\\" + netbiosName + "\\IPC$";

Java

- Registered: Sun May 05 00:10:10 GMT 2024

- Last Modified: Fri Mar 22 21:10:40 GMT 2019

- 18.6K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/graph/BaseGraph.java

  /**
   * Returns true if the edges in this graph are directed. Directed edges connect a {@link
   * EndpointPair#source() source node} to a {@link EndpointPair#target() target node}, while
   * undirected edges connect a pair of nodes to each other.
   */
  boolean isDirected();

  /**
   * Returns true if this graph allows self-loops (edges that connect a node to itself). Attempting

Java

- Registered: Fri Apr 26 12:43:10 GMT 2024

- Last Modified: Mon Jan 22 17:29:38 GMT 2024

- 8.8K bytes

- Viewed (0)

github.com/codelibs/jcifs

src/main/java/jcifs/util/transport/Transport.java

        }

    }


    /*
     * Build a connection. Only one thread will ever call this method at
     * any one time. If this method throws an exception or the connect timeout
     * expires an encapsulating TransportException will be thrown from connect
     * and the transport will be in error.
     */

    protected abstract void doConnect () throws Exception;


    /*

Java

- Registered: Sun May 05 00:10:10 GMT 2024

- Last Modified: Sun Nov 01 18:12:21 GMT 2020

- 24.1K bytes

- Viewed (0)

github.com/square/okhttp

okhttp/src/main/kotlin/okhttp3/EventListener.kt

 *
 *  * call ([callStart], [callEnd], [callFailed])
 *    * proxy selection ([proxySelectStart], [proxySelectEnd])
 *    * dns ([dnsStart], [dnsEnd])
 *    * connect ([connectStart], [connectEnd], [connectFailed])
 *      * secure connect ([secureConnectStart], [secureConnectEnd])
 *    * connection held ([connectionAcquired], [connectionReleased])
 *      * request ([requestFailed])

Plain Text

- Registered: Fri May 03 11:42:14 GMT 2024

- Last Modified: Mon Jan 08 01:13:22 GMT 2024

- 15.2K bytes

- Viewed (0)

github.com/tiangolo/fastapi

tests/test_tutorial/test_websockets/test_tutorial001.py

    assert response.status_code == 200, response.text
    assert b"<!DOCTYPE html>" in response.content


def test_websocket():
    with pytest.raises(WebSocketDisconnect):
        with client.websocket_connect("/ws") as websocket:
            message = "Message one"
            websocket.send_text(message)
            data = websocket.receive_text()
            assert data == f"Message text was: {message}"

Python

- Registered: Sun Apr 28 07:19:10 GMT 2024

- Last Modified: Fri Jul 10 09:08:19 GMT 2020

- 822 bytes

- Viewed (0)

Search Options