Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for balancer (0.32 sec)

  1. src/test/java/jcifs/internal/smb2/multichannel/ChannelManagerTest.java

            assertDoesNotThrow(() -> channelManager.shutdown());
        }
    
        @Test
        void testLoadBalancerAccess() {
            ChannelLoadBalancer balancer = channelManager.getLoadBalancer();
            assertNotNull(balancer);
    
            // Should return same instance
            assertSame(balancer, channelManager.getLoadBalancer());
        }
    
        @Test
        void testChannelFailureHandling() throws UnknownHostException {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 7.6K bytes
    - Viewed (0)
  2. src/main/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancer.java

    import jcifs.internal.smb2.io.Smb2WriteRequest;
    
    /**
     * Load balancer for SMB3 Multi-Channel connections
     */
    public class ChannelLoadBalancer {
    
        private final ChannelManager manager;
        private LoadBalancingStrategy strategy;
        private final AtomicInteger roundRobinCounter;
    
        /**
         * Create channel load balancer
         *
         * @param manager channel manager
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  3. docs/smb3-features/03-multi-channel-design.md

        manager.addChannel(channel2);
        
        // 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);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 39.6K bytes
    - Viewed (0)
  4. src/main/java/jcifs/internal/smb2/multichannel/ChannelManager.java

         *
         * @return true if enabled
         */
        public boolean isUseMultiChannel() {
            return multiChannelEnabled;
        }
    
        /**
         * Get the load balancer
         *
         * @return load balancer instance
         */
        public ChannelLoadBalancer getLoadBalancer() {
            return loadBalancer;
        }
    
        /**
         * Get all channels
         *
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 20K bytes
    - Viewed (0)
  5. src/test/java/jcifs/internal/smb2/multichannel/MultiChannelIntegrationTest.java

            // Note: isUseMultiChannel() checks if actual multi-channel is negotiated with server
            // In mock environment, this will be false until we mock successful negotiation
    
            // Verify load balancer is initialized
            assertNotNull(channelManager.getLoadBalancer());
        }
    
        @Test
        void testNetworkInterfaceInfo() throws Exception {
            // Test NetworkInterfaceInfo creation and scoring
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

     *           // Services have been initialized and are healthy, start accepting requests...
     *         }
     *         public void failure(Service service) {
     *           // Something failed, at this point we could log it, notify a load balancer, or take
     *           // some other action.  For now we will just exit.
     *           System.exit(1);
     *         }
     *       },
     *       MoreExecutors.directExecutor());
     *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 33.2K bytes
    - Viewed (0)
  7. CHANGELOG/CHANGELOG-1.29.md

    unauthenticated. The mitigation may be disabled by setting the `UnauthenticatedHTTP2DOSMitigation` feature gate to `false` (it is enabled by default). An API server fronted by an L7 load balancer that already mitigates these http/2 attacks may choose to disable the kube-apiserver mitigation to avoid disrupting load balancer -> kube-apiserver connections if http/2 requests from multiple clients share the same backend connection. An API server on a private network may opt to disable the kube-apiserver mitigation...
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Wed Mar 12 00:36:01 UTC 2025
    - 429.6K bytes
    - Viewed (1)
  8. CHANGELOG/CHANGELOG-1.31.md

    - Windows Kubeproxy will use the update load balancer API for load balancer updates, instead of the previous delete and create APIs.
    Registered: Fri Sep 05 09:05:11 UTC 2025
    - Last Modified: Wed Aug 13 19:49:57 UTC 2025
    - 429.6K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/ds/DataStoreFactory.java

        }
    
        /**
         * Returns an array of available data store names discovered from plugin JAR files.
         * This method implements a time-based caching mechanism that refreshes the list
         * every 60 seconds to balance performance with up-to-date plugin discovery.
         *
         * @return array of data store names sorted alphabetically, never null
         */
        public String[] getDataStoreNames() {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 8.4K bytes
    - Viewed (0)
  10. guava/src/com/google/common/math/BigIntegerMath.java

       * if {@code n == 0}.
       *
       * <p><b>Warning:</b> the result takes <i>O(n log n)</i> space, so use cautiously.
       *
       * <p>This uses an efficient binary recursive algorithm to compute the factorial with balanced
       * multiplies. It also removes all the 2s from the intermediate products (shifting them back in at
       * the end).
       *
       * @throws IllegalArgumentException if {@code n < 0}
       */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 18.8K bytes
    - Viewed (0)
Back to top