Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 52 for Disconnected (0.09 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. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top