Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 1,355 for pool (0.04 sec)

  1. android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

       *
       * <p><b>Warning:</b> If the input future does not already implement {@code ListenableFuture}, the
       * returned future will emulate {@link ListenableFuture#addListener} by taking a thread from an
       * internal, unbounded pool at the first call to {@code addListener} and holding it until the
       * future is {@linkplain Future#isDone() done}.
       *
       * <p>Prefer to create {@code ListenableFuture} instances with {@link SettableFuture}, {@link
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  2. manifests/charts/base/files/crd-all.gen.yaml

                                    pool for the upstream service that can be ejected.
                                  format: int32
                                  type: integer
                                minHealthPercent:
                                  description: Outlier detection will be enabled as long
                                    as the associated load balancing pool has at least
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Nov 01 16:23:52 UTC 2024
    - 805K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/connection/ReusePlan.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    package okhttp3.internal.connection
    
    /** Reuse a connection from the pool. */
    internal class ReusePlan(
      val connection: RealConnection,
    ) : RoutePlanner.Plan {
      override val isReady = true
    
      override fun connectTcp() = error("already connected")
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 1K bytes
    - Viewed (0)
  4. src/main/java/jcifs/smb/SmbTransportPoolImpl.java

            }
            throw new TransportException("All connection attempts failed");
        }
    
    
        /**
         * 
         * @param trans
         * @return whether (non-exclusive) connection is in the pool
         */
        public boolean contains ( SmbTransport trans ) {
            synchronized ( this.connections ) {
                cleanup();
                return this.connections.contains(trans);
            }
        }
    
    
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Sun Dec 20 14:09:34 UTC 2020
    - 12.5K bytes
    - Viewed (0)
  5. internal/ioutil/ioutil.go

    )
    
    // aligned sync.Pool's
    var (
    	ODirectPoolLarge = sync.Pool{
    		New: func() interface{} {
    			b := disk.AlignedBlock(LargeBlock)
    			return &b
    		},
    	}
    	ODirectPoolMedium = sync.Pool{
    		New: func() interface{} {
    			b := disk.AlignedBlock(MediumBlock)
    			return &b
    		},
    	}
    	ODirectPoolSmall = sync.Pool{
    		New: func() interface{} {
    			b := disk.AlignedBlock(SmallBlock)
    			return &b
    		},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  6. istioctl/pkg/describe/describe_test.go

       Matching subsets: 
          (Non-matching subsets v1)
       Traffic Policy TLS Mode: ISTIO_MUTUAL
       Policies: load balancer/connection pool/outlier detection
       Port Level Settings:
        8080:
          TLS Mode: DISABLE
          Policies: load balancer/connection pool/outlier detection
    VirtualService: bookinfo
       Route to host "productpage" with weight 30%
       Route to host "productpage2" with weight 20%
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 01 20:04:20 UTC 2024
    - 30.8K bytes
    - Viewed (0)
  7. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvn/resident/DefaultResidentMavenInvoker.java

                    exceptions.add(e);
                }
            }
            if (!exceptions.isEmpty()) {
                InvokerException exception = new InvokerException("Could not cleanly shut down context pool");
                exceptions.forEach(exception::addSuppressed);
                throw exception;
            }
        }
    
        @Override
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  8. mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt

       * simulate late connection pool failures.
       */
      object DisconnectAfterRequest : SocketPolicy
    
      /**
       * Half close connection (InputStream for client) after reading the request but before
       * writing the response. Use this to simulate late connection pool failures.
       */
      object HalfCloseAfterRequest : SocketPolicy
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Tue Jan 23 14:31:42 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  9. docs/metrics/v3.md

    | `minio_cluster_erasure_set_online_drives_count`  | Count of online drives in the erasure set in a pool. <br><br>Type: gauge                                | `pool_id`, `set_id` |
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 02 22:30:11 UTC 2024
    - 45.2K bytes
    - Viewed (0)
  10. common/scripts/metallb-native.yaml

                      allocation for a pool.
                    type: boolean
                  avoidBuggyIPs:
                    default: false
                    description: AvoidBuggyIPs prevents addresses ending with .0 and .255
                      to be used by a pool.
                    type: boolean
                  serviceAllocation:
                    description: AllocateTo makes ip pool allocation to specific namespace
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Feb 23 23:56:31 UTC 2024
    - 63.9K bytes
    - Viewed (0)
Back to top