- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 175 for Established (0.19 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/MessagingClient.java
*/ @ServiceScope(Scope.Global.class) public interface MessagingClient { /** * Creates a connection to the given address. Blocks until the connection has been established. * * @param address The address to connect to. */ ObjectConnection getConnection(Address address);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 17 00:47:05 UTC 2024 - 1.1K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/controller/status/naming_controller.go
// which we had if we set Established to true here. establishedCondition := apiextensionsv1.CustomResourceDefinitionCondition{ Type: apiextensionsv1.Established, Status: apiextensionsv1.ConditionFalse, Reason: "NotAccepted", Message: "not all names are accepted", } if old := apiextensionshelpers.FindCRDCondition(in, apiextensionsv1.Established); old != nil { establishedCondition = *old }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 13.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/change_test.go
case watch.Added, watch.Modified, watch.Deleted: // all expected default: t.Errorf("unexpected watch event: %#v", event) } } }(i) } // Let all the established watches soak request loops soak time.Sleep(5 * time.Second) // Update CRD and ensure that all watches are gracefully terminated. updateCRD() drained := make(chan struct{}) go func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:59:03 UTC 2024 - 5.2K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/ConnectCompletion.java
package org.gradle.internal.remote.internal; import org.gradle.internal.serialize.StatefulSerializer; /** * A builder that allows a {@link Connection} to be created once the underlying transport with the peer has been * established. */ public interface ConnectCompletion { /** * Creates the connection. Uses the specified serializer for all messages. * * @return The serializer to use. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.1K bytes - Viewed (0) -
src/cmd/nm/doc.go
// D data segment symbol // d static data segment symbol // B bss segment symbol // b static bss segment symbol // C constant address // U referenced but undefined symbol // // Following established convention, the address is omitted for undefined // symbols (type U). // // The options control the printed output: // // -n // an alias for -sort address (numeric), // for compatibility with other nm commands
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 11 16:34:30 UTC 2022 - 1.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/MessagingServer.java
@ServiceScope(Scope.Global.class) public interface MessagingServer { /** * Creates an endpoint that peers can connect to. Assigns an arbitrary address. * * @param action The action to execute when a connection has been established. * @return The local address of the endpoint, for the peer to connect to. */ ConnectionAcceptor accept(Action<ObjectConnection> action);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 17 00:47:05 UTC 2024 - 1.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/OutgoingConnector.java
@ServiceScope(Scope.Global.class) public interface OutgoingConnector { /** * Creates a connection to the given address. Blocks until the connection with the peer has been established. * * @throws ConnectException when there is nothing listening on the remote address. */ ConnectCompletion connect(Address destinationAddress) throws ConnectException;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 17 00:47:05 UTC 2024 - 1.2K bytes - Viewed (0) -
tools/istio-iptables/pkg/validation/validator.go
Config *Config } type Client struct { Config *Config } func (validator *Validator) Run() error { log.Infof("Starting iptables validation. This check verifies that iptables rules are properly established for the network.") s := Service{ validator.Config, } sError := make(chan error, 1) sTimer := time.NewTimer(s.Config.ProbeTimeout) defer sTimer.Stop() go func() { sError <- s.Run() }()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Nov 01 04:37:36 UTC 2023 - 5.5K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/MessageHubBackedObjectConnection.java
} @Override public <T> void addIncoming(Class<T> type, final T instance) { if (connection != null) { throw new GradleException("Cannot add incoming message handler after connection established."); } // we don't want to add core classloader explicitly here. if (type.getClassLoader() != getClass().getClassLoader()) { methodParamClassLoaders.add(type.getClassLoader()); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 7.5K bytes - Viewed (0) -
VULNERABILITY_REPORT.md
- The project / component that contains the reported vulnerability. - A description of the vulnerability. In particular, the type of the reported vulnerability and how it might be exploited. Alternatively, a well-established vulnerability identifier, e.g. CVE number, can be used instead. Based on the description mentioned above, a MinIO engineer or security team member investigates: - Whether the reported vulnerability exists.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Feb 12 00:51:25 UTC 2022 - 1.5K bytes - Viewed (0)