- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 349 for connectat (0.68 sec)
-
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/SingleUseDaemonClient.java
private static final Logger LOGGER = Logging.getLogger(SingleUseDaemonClient.class); private final DocumentationRegistry documentationRegistry; public SingleUseDaemonClient( DaemonConnector connector, OutputEventListener outputEventListener, ExplainingSpec<DaemonContext> compatibilitySpec, InputStream buildStandardInput, GlobalUserInputReceiver userInput,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:54:56 UTC 2024 - 3.1K bytes - Viewed (0) -
pilot/pkg/networking/core/waypoint.go
// ConnectTerminate is the name for the resources associated with the termination of HTTP CONNECT. ConnectTerminate = "connect_terminate" // MainInternalName is the name for the resources associated with the main (non-tunnel) internal listener. MainInternalName = "main_internal" // ConnectOriginate is the name for the resources associated with the origination of HTTP CONNECT. ConnectOriginate = "connect_originate"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 3.8K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/repositories/transport/RepositoryTransportFactory.java
import org.gradle.internal.resource.ExternalResourceName; import org.gradle.internal.resource.cached.CachedExternalResourceIndex; import org.gradle.internal.resource.connector.ResourceConnectorFactory; import org.gradle.internal.resource.connector.ResourceConnectorSpecification; import org.gradle.internal.resource.local.FileResourceRepository; import org.gradle.internal.resource.transfer.ExternalResourceConnector;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Mar 25 14:54:57 UTC 2024 - 11.4K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r56/TestLauncherDebugTestsCrossVersionTest.groovy
org.junit.Assert.assertEquals(1, 1); } } """ } def "build fails if debugger is not ready"() { setup: // port is assigned but not connected def port = jdwpClient.port when: withConnection { connection -> connection.newTestLauncher() .withJvmTestClasses("example.MyTest")
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 16 10:10:39 UTC 2024 - 3.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/CallConnectionUser.kt
} override fun removePlanToCancel(connectPlan: ConnectPlan) { call.plansToCancel -= connectPlan } override fun updateRouteDatabaseAfterSuccess(route: Route) { call.client.routeDatabase.connected(route) } override fun connectStart(route: Route) { eventListener.connectStart(call, route.socketAddress, route.proxy) poolConnectionListener.connectStart(route, call) }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Mar 06 17:33:38 UTC 2024 - 3.6K bytes - Viewed (0) -
internal/event/target/nats.go
if !filepath.IsAbs(n.QueueDir) { return errors.New("queueDir path should be absolute") } } return nil } // To obtain a nats connection from args. func (n NATSArgs) connectNats() (*nats.Conn, error) { connOpts := []nats.Option{nats.Name("Minio Notification"), nats.MaxReconnects(-1)} if n.Username != "" && n.Password != "" { connOpts = append(connOpts, nats.UserInfo(n.Username, n.Password)) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 12.8K bytes - Viewed (0) -
platforms/software/resources-http/src/main/java/org/gradle/internal/resource/transport/http/HttpResourcesServices.java
import org.gradle.internal.authentication.DefaultDigestAuthentication; import org.gradle.internal.authentication.DefaultHttpHeaderAuthentication; import org.gradle.internal.resource.connector.ResourceConnectorFactory; import org.gradle.internal.service.Provides; import org.gradle.internal.service.ServiceRegistration; import org.gradle.internal.service.ServiceRegistrationProvider;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 3.1K bytes - Viewed (0) -
pkg/xds/server.go
} func (conn *Connection) Peer() string { return conn.peerAddr } func (conn *Connection) SetID(id string) { conn.conID = id } func (conn *Connection) ConnectedAt() time.Time { return conn.connectedAt } func (conn *Connection) Stop() { close(conn.stop) } func (conn *Connection) MarkInitialized() { close(conn.initialized) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K bytes - Viewed (0) -
tensorflow/compiler/mlir/tf2xla/internal/passes/tpu_sharding_identification_pass.cc
mlir::Operation* NullUnlessSharded(PartitionedOp op) { return op.get_XlaSharding() ? op : nullptr; } // Returns a TPUPartitionedInput op connected to a `tf_device.cluster_func` // operand value if it has an XLA sharding. If value is a resource type then // TPUPartitionedInput op will be connected to a ReadVariable op that feeds into // a `tf_device.cluster_func`. mlir::Operation* GetXlaShardingFromOperand(Value value) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Apr 30 02:01:13 UTC 2024 - 28.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/AbstractRangeSetTest.java
assertEquals(!rangeSet.asDescendingSetOfRanges().iterator().hasNext(), rangeSet.isEmpty()); List<Range<C>> asRanges = ImmutableList.copyOf(rangeSet.asRanges()); // test that connected ranges are coalesced for (int i = 0; i + 1 < asRanges.size(); i++) { Range<C> range1 = asRanges.get(i); Range<C> range2 = asRanges.get(i + 1); assertFalse(range1.isConnected(range2)); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 20:09:59 UTC 2024 - 2.6K bytes - Viewed (0)