- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 44 for Disconnected (0.21 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/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) -
cmd/speedtest.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon May 06 09:45:10 UTC 2024 - 9.2K bytes - Viewed (0) -
internal/grid/grid.go
"sync" "time" "github.com/gobwas/ws" "github.com/gobwas/ws/wsutil" ) // ErrDisconnected is returned when the connection to the remote has been lost during the call. var ErrDisconnected = RemoteErr("remote disconnected") const ( // minBufferSize is the minimum buffer size. // Buffers below this is not reused. minBufferSize = 1 << 10 // defaultBufferSize is the default buffer allocation size. defaultBufferSize = 4 << 10
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 6.9K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Range.java
* * <p>The intersection exists if and only if the two ranges are {@linkplain #isConnected * connected}. * * <p>The intersection operation is commutative, associative and idempotent, and its identity * element is {@link Range#all}). * * @throws IllegalArgumentException if {@code isConnected(connectedRange)} is {@code false} */ public Range<C> intersection(Range<C> connectedRange) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 16 17:21:56 UTC 2024 - 27.8K 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) -
cmd/storage-rest-client.go
return client.endpoint.PoolIdx, client.endpoint.SetIdx, client.endpoint.DiskIdx } // Wrapper to restClient.CallWithMethod to handle network errors, in case of network error the connection is disconnected // and a healthcheck routine gets invoked that would reconnect. func (client *storageRESTClient) callGet(ctx context.Context, rpcMethod string, values url.Values, body io.Reader, length int64) (io.ReadCloser, error) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Oct 13 13:07:21 UTC 2024 - 30.2K bytes - Viewed (0)