- Sort Score
- Num 10 results
- Language All
Results 181 - 190 of 355 for selector (0.07 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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 ofCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 8.3K bytes - Click Count (0) -
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 ofCreated: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 7.4K bytes - Click Count (0) -
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) -
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)