Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 181 - 190 of 355 for selector (0.05 seconds)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RouteSelector.kt

            }
    
          for (inetAddress in orderedAddresses) {
            mutableInetSocketAddresses += InetSocketAddress(inetAddress, socketPort)
          }
        }
      }
    
      /** A set of selected Routes. */
      class Selection(
        val routes: List<Route>,
      ) {
        private var nextRouteIndex = 0
    
        operator fun hasNext(): Boolean = nextRouteIndex < routes.size
    
        operator fun next(): Route {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Oct 08 03:50:05 GMT 2025
    - 7.3K bytes
    - Click Count (2)
  2. src/test/java/jcifs/internal/smb2/rdma/RdmaProviderFactoryTest.java

     */
    public class RdmaProviderFactoryTest {
    
        @Test
        public void testCreateProviderAuto() {
            RdmaProvider provider = RdmaProviderFactory.createProvider("auto");
            assertNotNull(provider, "Auto provider selection should return a provider");
            assertTrue(provider.isAvailable(), "Returned provider should be available");
        }
    
        @Test
        public void testCreateProviderTcp() {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  3. src/main/java/jcifs/smb/MultiChannelManager.java

            }
    
            ChannelInfo selected = channelGroup.selectChannel(loadBalancingStrategy);
            if (selected != null && selected.isHealthy()) {
                totalRequests.incrementAndGet();
                selected.incrementConnections();
                log.debug("Selected channel {} for session {} (active connections: {})", selected.getChannelId(), sessionId,
                        selected.getActiveConnections());
            }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 20.5K bytes
    - Click Count (0)
  4. docs/integrations/veeam/README.md

    - Follow the on screen wizard
    
    - On the Capacity Tier screen, check the box to Extend scale-out backup repository capacity with object storage checkbox and select the object storage. If you want to be able to test backup data immediately after a job is run, under the object storage selection, check the "Copy" box and uncheck the "Move" box.
    
    ### Create a backup job
    
    #### Backup Virtual Machines with Veeam Backup and Replication
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 5.5K bytes
    - Click Count (0)
  5. docs/smb3-features/03-multi-channel-design.md

        
        // Test load balancer selection
        ChannelLoadBalancer balancer = new ChannelLoadBalancer(manager);
        
        // Large transfer should prefer high-bandwidth channel
        Smb2ReadRequest largeRead = new Smb2ReadRequest();
        largeRead.setLength(10485760);  // 10MB
        
        ChannelInfo selected = balancer.selectChannel(largeRead);
        assertEquals(channel2, selected);  // Should select 10Gbps channel
    }
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 02:53:50 GMT 2025
    - 39.6K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java

     *
     * <p>On different platforms AggregateFutureState uses different strategies for its core
     * synchronization primitives. The strategies are all implemented as subtypes of AtomicHelper and
     * the strategy is selected in the static initializer of AggregateFutureState. This is convenient
     * and performant but introduces some testing difficulties. This test exercises the two fallback
     * strategies.
     *
     * <ul>
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 6.7K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java

     * primitives. The strategies are all implemented as subtypes of AtomicHelper and the strategy is
     * selected in the static initializer of AbstractFuture. This is convenient and performant but
     * introduces some testing difficulties. This test exercises the fallback strategies.
     *
     * <p>To force selection of our fallback strategies, we load {@link AbstractFuture} (and all of
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 8.3K bytes
    - Click Count (0)
  8. guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java

     * primitives. The strategies are all implemented as subtypes of AtomicHelper and the strategy is
     * selected in the static initializer of AbstractFuture. This is convenient and performant but
     * introduces some testing difficulties. This test exercises the fallback strategies.
     *
     * <p>To force selection of our fallback strategies, we load {@link AbstractFuture} (and all of
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 7.4K bytes
    - Click Count (0)
  9. src/main/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancer.java

         */
        public void setStrategy(LoadBalancingStrategy strategy) {
            this.strategy = strategy;
        }
    
        /**
         * Select a channel for the given message
         *
         * @param message SMB message to send
         * @return selected channel
         * @throws NoAvailableChannelException if no healthy channels available
         */
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  10. src/test/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancerTest.java

            when(mockChannelManager.getHealthyChannels()).thenReturn(Arrays.asList(channel1, channel2));
    
            // Should still select a channel even with zero scores
            ChannelInfo selected = loadBalancer.selectChannel(mockMessage);
            assertTrue(Arrays.asList(channel1, channel2).contains(selected));
        }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 23 05:11:12 GMT 2025
    - 7.7K bytes
    - Click Count (0)
Back to Top