- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 360 for channels (0.23 seconds)
-
src/main/java/jcifs/internal/smb2/multichannel/ChannelLoadBalancer.java
long pending = channel.getRequestsPending(); if (pending < minPending) { minPending = pending; leastLoadedChannel = channel; } } return leastLoadedChannel != null ? leastLoadedChannel : channels.iterator().next(); } private ChannelInfo selectWeightedRandom(Collection<ChannelInfo> channels) {
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
// Create channels with zero scores (failed state) channel1.setState(ChannelState.FAILED); channel2.setState(ChannelState.FAILED); when(mockChannelManager.getHealthyChannels()).thenReturn(Arrays.asList(channel1, channel2)); // Should still select a channel even with zero scoresCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 23 05:11:12 GMT 2025 - 7.7K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/multichannel/Smb2ChannelCapabilities.java
/** * Channel binding is preferred but not required */ public static final int CHANNEL_BINDING_PREFERRED = 1; /** * Channel binding is required */ public static final int CHANNEL_BINDING_REQUIRED = 2; /** * Default maximum number of channels per session */ public static final int DEFAULT_MAX_CHANNELS = 4; /**Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 2.4K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/multichannel/MultiChannelIntegrationTest.java
ChannelInfo channel = new ChannelInfo("test-channel", mockTransport, localNic, remoteNic); channel.setState(ChannelState.ESTABLISHED); // Verify channel properties assertEquals("test-channel", channel.getChannelId()); assertEquals(mockTransport, channel.getTransport()); assertEquals(localNic, channel.getLocalInterface());Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 8.2K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/multichannel/ChannelManagerTest.java
// Remove should not throw exception even if channel doesn't exist assertDoesNotThrow(() -> channelManager.removeChannel(channel)); } @Test void testShutdown() { assertDoesNotThrow(() -> channelManager.shutdown()); // Multiple shutdowns should be safeCreated: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 7.6K bytes - Click Count (0) -
build-tools-internal/src/main/resources/forbidden/es-server-signatures.txt
java.lang.System#gc() @defaultMessage Use Channels.* methods to write to channels. Do not write directly. java.nio.channels.WritableByteChannel#write(java.nio.ByteBuffer) java.nio.channels.FileChannel#write(java.nio.ByteBuffer, long) java.nio.channels.GatheringByteChannel#write(java.nio.ByteBuffer[], int, int) java.nio.channels.GatheringByteChannel#write(java.nio.ByteBuffer[]) java.nio.channels.ReadableByteChannel#read(java.nio.ByteBuffer)
Created: Wed Apr 08 16:19:15 GMT 2026 - Last Modified: Tue Jun 08 16:53:28 GMT 2021 - 7.6K bytes - Click Count (0) -
samples/slack/src/main/java/okhttp3/slack/RtmStartResponse.java
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Oct 23 15:24:22 GMT 2016 - 943 bytes - Click Count (0) -
src/main/java/jcifs/ntlmssp/av/AvChannelBindings.java
*/ package jcifs.ntlmssp.av; /** * NTLMSSP AV pair representing channel binding information for enhanced security. * Used to bind NTLM authentication to specific communication channels. * * @author mbechler */ public class AvChannelBindings extends AvPair { /** * Constructs an AV channel bindings pair * @param channelBindingHash the channel binding hash value */Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 16 01:32:48 GMT 2025 - 1.3K bytes - Click Count (0) -
src/test/java/jcifs/internal/smb2/multichannel/ChannelFailoverTest.java
when(mockLoadBalancer.selectChannel(mockOperation)).thenThrow(new ChannelLoadBalancer.NoAvailableChannelException("No channels")); IOException error = new IOException("Connection failed"); // Should not throw exception even if no alternative channels assertDoesNotThrow(() -> failover.handleFailure(failedChannel, error)); assertEquals(0, failedChannel.getRequestsPending());Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Thu Aug 21 11:13:46 GMT 2025 - 7.7K bytes - Click Count (0) -
ISSUES.md
**Here's why we have this policy:** We want to focus on the work that benefits the whole community, e.g., fixing bugs and adding features. Individual support should be sought on Stack Overflow or other non-GitHub channels. It helps us to
Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Thu Feb 11 22:37:27 GMT 2021 - 606 bytes - Click Count (0)