- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 387 for connectat (0.8 sec)
-
maven-compat/pom.xml
<artifactId>wagon-file</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.apache.maven.resolver</groupId> <artifactId>maven-resolver-connector-basic</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.apache.maven.resolver</groupId> <artifactId>maven-resolver-transport-wagon</artifactId>
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed May 22 14:07:09 UTC 2024 - 5.3K bytes - Viewed (0) -
pilot/pkg/xds/discovery.go
} // Shutdown shuts down DiscoveryServer components. func (s *DiscoveryServer) Shutdown() { s.closeJwksResolver() s.pushQueue.ShutDown() } // Clients returns all currently connected clients. This method can be safely called concurrently, // but care should be taken with the underlying objects (ie model.Proxy) to ensure proper locking.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 20:21:09 UTC 2024 - 19K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/bootstrap/DaemonOutputConsumer.java
@SuppressWarnings("DefaultCharset") public void start() { if (processStdOutput == null) { throw new IllegalStateException("Cannot start consuming daemon output because streams have not been connected first."); } LOGGER.debug("Starting consuming the daemon process output."); // Wait for the process' stdout to indicate that the process has been started successfully
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:38 UTC 2024 - 2.7K bytes - Viewed (0) -
guava/src/com/google/common/collect/Range.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 27.8K bytes - Viewed (0) -
analysis/analysis-api/src/org/jetbrains/kotlin/analysis/api/symbols/markers/markers.kt
/** * A marker interface for symbols which could potentially be `expect` or `actual`. For more details about `expect` and `actual` * declarations, see [documentation](https://kotlinlang.org/docs/multiplatform-connect-to-apis.html). */ public interface KaPossibleMultiplatformSymbol : KaSymbol { /** * Returns true if the declaration is a platform-specific implementation in a multiplatform project. */
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Wed May 22 06:28:34 UTC 2024 - 1.8K bytes - Viewed (0) -
cmd/storage-interface.go
// of this function is to know if the "drive" has "format.json" or not // if it has a "format.json" then is it correct "format.json" or not. IsOnline() bool // Returns the last time this disk (re)-connected LastConn() time.Time // Indicates if disk is local or not. IsLocal() bool // Returns hostname if disk is remote. Hostname() string // Returns the entire endpoint. Endpoint() Endpoint
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 5K bytes - Viewed (0) -
pkg/adsc/adsc.go
} a.mutex.RUnlock() err := a.Run() if err != nil { // TODO: fix reconnect time.AfterFunc(a.cfg.BackoffPolicy.NextBackOff(), a.reconnect) } } func (a *ADSC) handleRecv() { // We connected, so reset the backoff if a.cfg.BackoffPolicy != nil { a.cfg.BackoffPolicy.Reset() } for { var err error msg, err := a.stream.Recv() if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 05 22:18:49 UTC 2024 - 35K bytes - Viewed (0) -
src/runtime/write_err_android.go
msg := []byte("runtime: cannot create a socket for logging\x00") write(2, unsafe.Pointer(&msg[0]), int32(len(msg))) exit(2) } errno := connect(fd, unsafe.Pointer(&logdAddr), int32(unsafe.Sizeof(logdAddr))) if errno < 0 { msg := []byte("runtime: cannot connect to /dev/socket/logdw\x00") write(2, unsafe.Pointer(&msg[0]), int32(len(msg))) // TODO(hakim): or should we just close fd and hope for better luck next time?
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 27 18:23:49 UTC 2024 - 4.7K bytes - Viewed (0) -
src/net/http/httptest/server.go
// requests) and new connections (those which connected // but never sent a request). StateNew connections are // super rare and have only been seen (in // previously-flaky tests) in the case of // socket-late-binding races from the http Client // dialing this server and then getting an idle // connection before the dial completed. There is thus // a connected connection in StateNew with no
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 17:26:10 UTC 2024 - 10.7K bytes - Viewed (0) -
platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/ConfigurationCacheStandardStreamsIntegrationTest.groovy
""" } def withStdInContents(String message) { executer.withStdinPipe(new PipedOutputStream() { @Override synchronized void connect(PipedInputStream snk) throws IOException { super.connect(snk) write(message.bytes) close() } }) } String makeTask(Map<String, String> args, String taskName) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat Jun 08 11:29:25 UTC 2024 - 8.6K bytes - Viewed (0)