Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 29 for Disconnected (0.08 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. 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)
  5. 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)
  6. 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)
  7. 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)
  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. 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)
  10. 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)
Back to top