- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 52 for Disconnected (0.09 sec)
-
guava/src/com/google/common/collect/RangeSet.java
import java.util.NoSuchElementException; import java.util.Set; import javax.annotation.CheckForNull; /** * A set comprising zero or more {@linkplain Range#isEmpty nonempty}, {@linkplain * Range#isConnected(Range) disconnected} ranges of type {@code C}. * * <p>Implementations that choose to support the {@link #add(Range)} operation are required to * ignore empty ranges and coalesce connected ranges. For example: * * <pre>{@code
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 22 21:19:52 UTC 2024 - 10.2K bytes - Viewed (0) -
src/main/java/jcifs/util/transport/Transport.java
return i; } /* * state values * 0 - not connected * 1 - connecting * 2 - run connected * 3 - connected * 4 - error * 5 - disconnecting * 6 - disconnected/invalid */ protected volatile int state = 0; protected String name = "Transport" + id++; private volatile Thread thread; private volatile TransportException te;
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Nov 01 18:12:21 UTC 2020 - 24.1K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTreeImpl.java
protected void finalize () throws Throwable { if ( isConnected() && this.usageCount.get() != 0 ) { log.warn("Tree was not properly released"); } } /** * * @return whether the tree is connected */ public boolean isConnected () { return this.tid != -1 && this.session.isConnected() && this.connectionState.get() == 2; } /**
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Thu Jan 05 13:06:39 UTC 2023 - 29.6K bytes - Viewed (0) -
internal/http/check_port_linux.go
"net" "syscall" "time" ) // CheckPortAvailability - check if given host and port is already in use. // Note: The check method tries to listen on given port and closes it. // It is possible to have a disconnected client in this tiny window of time. func CheckPortAvailability(host, port string, opts TCPOptions) (err error) { lc := &net.ListenConfig{ Control: func(network, address string, c syscall.RawConn) error {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 03 21:12:25 UTC 2023 - 1.9K bytes - Viewed (0) -
internal/http/check_port_others.go
import ( "context" "net" "time" ) // CheckPortAvailability - check if given host and port is already in use. // Note: The check method tries to listen on given port and closes it. // It is possible to have a disconnected client in this tiny window of time. func CheckPortAvailability(host, port string, opts TCPOptions) (err error) { lc := &net.ListenConfig{} ctx, cancel := context.WithTimeout(context.Background(), time.Second)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 03 21:12:25 UTC 2023 - 1.5K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTreeConnection.java
try ( SmbSessionImpl session = getSession() ) { if ( isConnected() ) { try ( SmbTransportImpl transport = session.getTransport() ) { if ( transport.isDisconnected() || transport.getRemoteHostName() == null ) { /* * Tree/session thinks it is connected but transport disconnected * under it, reset tree to reflect the truth.
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Tue Jul 07 10:50:16 UTC 2020 - 31K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportInternal.java
* @return whether the transport has the given capability * @throws SmbException */ boolean hasCapability ( int cap ) throws SmbException; /** * @return whether the transport has been disconnected */ boolean isDisconnected (); /** * @param hard * @param inuse * @return whether the connection was in use * @throws IOException */
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 3K bytes - Viewed (0) -
docs/features/calls.md
## Retrying Requests Sometimes connections fail: either a pooled connection was stale and disconnected, or the webserver itself couldn’t be reached. OkHttp will retry the request with a different route if one is available. ## [Calls](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-call/)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 3.9K bytes - Viewed (0) -
internal/grid/connection.go
return } if debugPrint { fmt.Println(c.Local, "Disconnected. Attempting to reconnect.") } } } func (c *Connection) disconnected() { c.outgoing.Range(func(key uint64, client *muxClient) bool { if !client.stateless { client.cancelFn(ErrDisconnected) } return true }) if debugReqs { fmt.Println(c.String(), "Disconnected. Clearing outgoing.") } c.outgoing.Clear()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 46.7K bytes - Viewed (0) -
internal/rest/client.go
return } if c.HealthCheckFn() { if atomic.CompareAndSwapInt32(&c.connected, offline, online) { now := time.Now() disconnected := now.Sub(c.LastConn()) logger.Event(context.Background(), "healthcheck", "Client '%s' re-connected in %s", c.url.String(), disconnected) atomic.StoreInt64(&c.lastConn, now.UnixNano()) } return } attempt++ time.Sleep(backOff(attempt)) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 26 12:55:01 UTC 2024 - 14.7K bytes - Viewed (0)