Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for Disconnected (0.07 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. guava-tests/test/com/google/common/collect/ImmutableRangeMapTest.java

        }
      }
    
      public void testOverlapRejection() {
        for (Range<Integer> range1 : RANGES) {
          for (Range<Integer> range2 : RANGES) {
            boolean expectRejection =
                range1.isConnected(range2) && !range1.intersection(range2).isEmpty();
            ImmutableRangeMap.Builder<Integer, Integer> builder = ImmutableRangeMap.builder();
            builder.put(range1, 1).put(range2, 2);
            try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/collect/ImmutableRangeMapTest.java

        }
      }
    
      public void testOverlapRejection() {
        for (Range<Integer> range1 : RANGES) {
          for (Range<Integer> range2 : RANGES) {
            boolean expectRejection =
                range1.isConnected(range2) && !range1.intersection(range2).isEmpty();
            ImmutableRangeMap.Builder<Integer, Integer> builder = ImmutableRangeMap.builder();
            builder.put(range1, 1).put(range2, 2);
            try {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb/SmbTreeHandleImpl.java

            return this.treeConnection.hasCapability(cap);
        }
    
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.SmbTreeHandle#isConnected()
         */
        @Override
        public boolean isConnected () {
            return this.treeConnection.isConnected();
        }
    
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.SmbTreeHandle#getConfig()
         */
        @Override
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Jul 01 13:12:10 UTC 2018
    - 8.9K bytes
    - Viewed (0)
  10. okhttp-testing-support/src/main/kotlin/okhttp3/DelegatingSSLSocket.kt

        return delegate!!.remoteSocketAddress
      }
    
      override fun isBound(): Boolean {
        return delegate!!.isBound
      }
    
      override fun isConnected(): Boolean {
        return delegate!!.isConnected
      }
    
      override fun isClosed(): Boolean {
        return delegate!!.isClosed
      }
    
      @Throws(IOException::class)
      override fun bind(localAddr: SocketAddress) {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 7.9K bytes
    - Viewed (0)
Back to top