Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 52 for Disconnected (0.08 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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. 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)
  8. cni/pkg/nodeagent/ztunnelserver.go

    }
    
    func (c *connMgr) LatestConn() *ZtunnelConnection {
    	c.mu.Lock()
    	defer c.mu.Unlock()
    	return c.latestConn
    }
    
    func (c *connMgr) deleteConn(conn *ZtunnelConnection) {
    	log.Debug("ztunnel disconnected")
    	c.mu.Lock()
    	defer c.mu.Unlock()
    	delete(c.connectionSet, conn)
    	if c.latestConn == conn {
    		c.latestConn = nil
    	}
    	ztunnelConnected.RecordInt(int64(len(c.connectionSet)))
    }
    
    // this is used in tests
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Jul 29 16:08:35 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  9. src/main/java/jcifs/Configuration.java

         * 
         * If enabled, SmbFile instances starting with their first use will hold a reference to their tree.
         * This means that trees/sessions/connections won't be idle-disconnected even if there are no other active
         * references (currently executing code, file descriptors).
         * 
         * Depending on the usage scenario, this may have some benefit as there won't be any delays for restablishing these
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Thu Jan 05 13:06:39 UTC 2023
    - 18K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/graph/AbstractNetworkTest.java

        addEdge(N1, N2, E12);
        assertThat(network.edges()).containsExactly(E12);
      }
    
      @Test
      public void edges_noEdges() {
        assertThat(network.edges()).isEmpty();
        // Network with no edges, given disconnected nodes
        addNode(N1);
        addNode(N2);
        assertThat(network.edges()).isEmpty();
      }
    
      @Test
      public void incidentEdges_oneEdge() {
        addEdge(N1, N2, E12);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Jan 22 17:29:38 UTC 2024
    - 32.7K bytes
    - Viewed (0)
Back to top