Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 37 for Disconnected (0.1 sec)

  1. 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)
  2. 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)
  3. 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)
  4. cmd/speedtest.go

    			result.Concurrent = concurrency
    
    			select {
    			case ch <- result:
    			case <-ctx.Done():
    				return
    			}
    		}
    
    		for {
    			select {
    			case <-ctx.Done():
    				// If the client got disconnected stop the speedtest.
    				return
    			default:
    			}
    
    			sopts := speedTestOpts{
    				objectSize:      opts.objectSize,
    				concurrency:     concurrency,
    				duration:        opts.duration,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon May 06 09:45:10 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. android/guava-tests/test/com/google/common/collect/TreeRangeMapTest.java

        rangeMap.put(Range.closedOpen(7, 10), 2);
        rangeMap.put(Range.closedOpen(12, 15), 2);
        rangeMap.put(Range.closedOpen(18, 19), 3);
    
        rangeMap.putCoalescing(Range.closedOpen(-5, -4), 0); // disconnected
        rangeMap.putCoalescing(Range.closedOpen(-6, -5), 0); // lower than minimum
    
        rangeMap.putCoalescing(Range.closedOpen(2, 4), 1); // between
        rangeMap.putCoalescing(Range.closedOpen(9, 14), 0); // different value
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sun Oct 06 13:04:03 UTC 2024
    - 29.9K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. cmd/perf-tests.go

    			break
    		}
    		time.Sleep(time.Second)
    	}
    	rx := float64(globalSiteNetPerfRX.RXSample)
    	delta := globalSiteNetPerfRX.firstToDisconnect.Sub(globalSiteNetPerfRX.lastToConnect)
    	// If the first disconnected before the last connected, we likely had a network issue.
    	if delta <= 0 {
    		rx = 0
    		errStr = "detected network disconnections, possibly an unstable network"
    	}
    
    	globalSiteNetPerfRX.Reset()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.8K bytes
    - Viewed (0)
Back to top