Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 20 for Disconnected (0.08 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java

                try {
                    client.close();
                } catch (final OpenSearchException e) {
                    logger.warn("Failed to close client.", e);
                }
                logger.info("Disconnected to {}", address);
            }
            connected = false;
        }
    
        @Override
        public ThreadPool threadPool() {
            return client.threadPool();
        }
    
        @Override
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Nov 07 04:44:10 UTC 2024
    - 19.9K bytes
    - Viewed (0)
  6. cmd/peer-rest-client.go

    				return nil
    			}
    			gridConn.Store(gc)
    			return gc
    		},
    	}
    }
    
    // Wrapper to restClient.Call to handle network errors, in case of network error the connection is marked disconnected
    // permanently. The only way to restore the connection is at the xl-sets layer by xlsets.monitorAndConnectEndpoints()
    // after verifying format.json
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 09 16:58:30 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  7. cmd/erasure-sets.go

    				globalLocalDrivesMu.Unlock()
    			}
    			s.erasureDisksMu.Unlock()
    		}(endpoint)
    	}
    
    	wg.Wait()
    }
    
    // monitorAndConnectEndpoints this is a monitoring loop to keep track of disconnected
    // endpoints by reconnecting them and making sure to place them into right position in
    // the set topology, this monitoring happens at a given monitoring interval.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 27 10:41:37 UTC 2024
    - 37K bytes
    - Viewed (1)
  8. cmd/erasure-multipart.go

    			// An in-quorum errFileNotFound means that client stream
    			// prematurely closed and we do not find any xl.meta or
    			// part.1's - in such a scenario we must return as if client
    			// disconnected. This means that erasure.Encode() CreateFile()
    			// did not do anything.
    			return pi, IncompleteBody{Bucket: bucket, Object: object}
    		}
    
    		return pi, toObjectErr(err, minioMetaMultipartBucket, partPath)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  9. cmd/api-errors.go

    		HTTPStatusCode: http.StatusServiceUnavailable,
    	},
    	ErrClientDisconnected: {
    		Code:           "ClientDisconnected",
    		Description:    "Client disconnected before response was ready",
    		HTTPStatusCode: 499, // No official code, use nginx value.
    	},
    	ErrTooManyRequests: {
    		Code:           "TooManyRequests",
    		Description:    "Please reduce your request rate",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 92.1K bytes
    - Viewed (0)
  10. cmd/erasure-object.go

    			// An in-quorum errFileNotFound means that client stream
    			// prematurely closed and we do not find any xl.meta or
    			// part.1's - in such a scenario we must return as if client
    			// disconnected. This means that erasure.Encode() CreateFile()
    			// did not do anything.
    			return ObjectInfo{}, IncompleteBody{Bucket: bucket, Object: object}
    		}
    		return ObjectInfo{}, toObjectErr(err, bucket, object)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
Back to top