connectat - Code Search

platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/ReportDaemonStatusClient.java

    public ReportDaemonStatusClient(DaemonRegistry daemonRegistry, DaemonConnector connector, IdGenerator<UUID> idGenerator, DocumentationRegistry documentationRegistry) {
        Preconditions.checkNotNull(daemonRegistry, "DaemonRegistry must not be null");
        Preconditions.checkNotNull(connector, "DaemonConnector must not be null");
        Preconditions.checkNotNull(idGenerator, "IdGenerator must not be null");

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Mon Dec 11 13:37:56 UTC 2023

- 5K bytes

- Viewed (0)

github.com/google/guava

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

          + "so it cannot be reused to connect the following nodes: %s.";
  static final String MULTIPLE_EDGES_CONNECTING =
      "Cannot call edgeConnecting() when parallel edges exist between %s and %s. Consider calling "
          + "edgesConnecting() instead.";
  static final String PARALLEL_EDGES_NOT_ALLOWED =
      "Nodes %s and %s are already connected by a different edge. To construct a graph "

Registered: Wed Jun 12 16:38:11 UTC 2024

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

- 3.1K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/ReportDaemonStatusClientTest.groovy

    DaemonRegistry registry = Mock(DaemonRegistry)
    DaemonConnector connector = Mock(DaemonConnector)
    DaemonClientConnection connection = Mock(DaemonClientConnection)
    DocumentationRegistry documentationRegistry = Mock(DocumentationRegistry)
    def idGenerator = new UUIDGenerator()
    def client = new ReportDaemonStatusClient(registry, connector, idGenerator, documentationRegistry)

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Fri Sep 22 09:29:13 UTC 2023

- 4.7K bytes

- Viewed (0)

github.com/istio/istio

pkg/istio-agent/xds_proxy_delta.go

}

func (p *XdsProxy) sendDeltaHealthRequest(req *discovery.DeltaDiscoveryRequest) {
	p.connectedMutex.Lock()
	// Immediately send if we are currently connected.
	if p.connected != nil && p.connected.deltaRequestsChan != nil {
		p.connected.deltaRequestsChan.Put(req)
	}
	// Otherwise place it as our initial request for new connections
	p.initialDeltaHealthRequest = req
	p.connectedMutex.Unlock()
}

Registered: Fri Jun 14 15:00:06 UTC 2024

- Last Modified: Thu Apr 04 20:29:08 UTC 2024

- 11.7K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/jvm/testing-jvm/src/integTest/groovy/org/gradle/testing/testsuites/dependencies/TestSuitesKotlinDSLDependenciesIntegrationTest.groovy

                assert(!testCompileClasspathFileNames.contains("mysql-connector-java-8.0.26.jar")) { "runtimeOnly dependency" }
                assert(testRuntimeClasspathFileNames.containsAll(listOf("commons-lang3-3.11.jar", "guava-30.1.1-jre.jar", "mysql-connector-java-8.0.26.jar")))
                assert(!testRuntimeClasspathFileNames.contains("servlet-api-3.0-alpha-1.jar")) { "compileOnly dependency" }

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Mon Mar 11 16:25:08 UTC 2024

- 45.8K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r63/DistributionChecksumCrossVersionSpec.groovy

        }
        file('gradle/wrapper/gradle-wrapper.properties') << 'distributionSha256Sum=bad'

        when:
        def connector = this.connector()
        connector.useBuildDistribution()
        withConnection(connector) { ProjectConnection connection ->
            connection.newBuild().forTasks("help").run()
        }

        then:
        def e = thrown(GradleConnectionException)

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Thu May 16 10:10:39 UTC 2024

- 1.8K bytes

- Viewed (0)

github.com/istio/istio

pilot/pkg/autoregistration/controller_test.go

			// ensure the entry is connected
			checkNonAutoRegisteredEntryOrFail(t, store, weB, c1.instanceID)
			// disconnect (associated with original connect, not the reconnect)
			c1.OnDisconnect(makeConn(p, origConnTime))
			// ensure the entry is connected
			checkNonAutoRegisteredEntryOrFail(t, store, weB, c1.instanceID)
		})
		t.Run("different instance: disconnect then connect", func(t *testing.T) {
			// disconnect

Registered: Fri Jun 14 15:00:06 UTC 2024

- Last Modified: Tue Apr 16 00:00:36 UTC 2024

- 31.4K bytes

- Viewed (0)

github.com/gradle/gradle

platforms/software/resources/src/main/java/org/gradle/internal/resource/transfer/UrlExternalResource.java

        } catch (URISyntaxException e) {
            throw UncheckedException.throwAsUncheckedException(e);
        }
        UrlExternalResource connector = new UrlExternalResource();
        return new AccessorBackedExternalResource(new ExternalResourceName(uri), connector, connector, connector, false);
    }

    @Nullable
    @Override

Registered: Wed Jun 12 18:38:38 UTC 2024

- Last Modified: Thu Oct 12 19:38:08 UTC 2023

- 4.2K bytes

- Viewed (0)

github.com/apache/maven

maven-core/src/test/java/org/apache/maven/repository/TestRepositoryConnector.java

import org.eclipse.aether.repository.RemoteRepository;
import org.eclipse.aether.spi.connector.ArtifactDownload;
import org.eclipse.aether.spi.connector.ArtifactUpload;
import org.eclipse.aether.spi.connector.MetadataDownload;
import org.eclipse.aether.spi.connector.MetadataUpload;
import org.eclipse.aether.spi.connector.RepositoryConnector;
import org.eclipse.aether.transfer.ArtifactNotFoundException;

Registered: Wed Jun 12 09:55:16 UTC 2024

- Last Modified: Thu May 02 16:33:18 UTC 2024

- 5.5K bytes

- Viewed (0)

github.com/codelibs/fess

src/main/java/org/codelibs/fess/FessBoot.java

        public void setupServerConfigIfNeeds(final BootLogger logger, final Tomcat server, final Connector connector,
                final Properties props, final List<String> readConfigList) {
            if (props == null) {
                return;
            }
            super.setupServerConfigIfNeeds(logger, server, connector, props, readConfigList);
            doSetupServerConfig(logger, props, "SSLEnabled", value -> {

Registered: Wed Jun 12 13:08:18 UTC 2024

- Last Modified: Thu Feb 22 01:37:57 UTC 2024

- 7.7K bytes

- Viewed (0)

Search Options