Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for clearPendingOperations (0.17 sec)

  1. src/main/java/jcifs/internal/smb2/multichannel/ChannelInfo.java

            return pendingOperations.remove(operation);
        }
    
        /**
         * Clear all pending operations
         */
        public void clearPendingOperations() {
            pendingOperations.clear();
        }
    
        /**
         * Calculate channel score for load balancing (higher is better)
         *
         * @return channel score
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 10.6K bytes
    - Viewed (0)
  2. src/test/java/jcifs/internal/smb2/multichannel/ChannelInfoTest.java

            assertTrue(channelInfo.removePendingOperation(mockOperation));
            assertEquals(0, channelInfo.getRequestsPending());
    
            channelInfo.addPendingOperation(mockOperation);
            channelInfo.clearPendingOperations();
            assertEquals(0, channelInfo.getRequestsPending());
        }
    
        @Test
        void testScoring() {
            channelInfo.setState(ChannelState.ESTABLISHED);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 7.4K bytes
    - Viewed (0)
  3. src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java

            List<CommonServerMessageBlock> operationsCopy = List.copyOf(pendingOps);
    
            // Clear the failed channel's pending operations first
            failedChannel.clearPendingOperations();
    
            // Redistribute to healthy channels
            for (CommonServerMessageBlock op : operationsCopy) {
                try {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 21 11:13:46 UTC 2025
    - 11.6K bytes
    - Viewed (0)
Back to top