- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 134 for channel2 (0.05 sec)
-
src/main/java/org/codelibs/core/nio/ChannelUtil.java
assertArgumentNotNull("channel", channel); try { return channel.size(); } catch (final IOException e) { throw new IORuntimeException(e); } } /** * Reads the contents of the file channel into a byte buffer. * * @param channel * The file channel. Must not be {@literal null}. * @param buffer
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 5.6K bytes - Viewed (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());
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 7.7K bytes - Viewed (0) -
docs/SMB3_IMPLEMENTATION_PLAN.md
- [ ] Create channel synchronization mechanism - [ ] Implement channel failure detection - [ ] Add automatic channel recovery - [ ] Create channel performance monitoring #### 3.3 Integration Points - Modify `SmbTransportPool` for multiple connections per session - Update `SmbSession` for multi-channel awareness - Enhance `SmbTransport` for channel management --- ### Phase 4: Directory Leasing
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 10.7K bytes - Viewed (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; /**
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 2.4K bytes - Viewed (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 */
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 1.3K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/multichannel/LoadBalancingStrategy.java
/** * Load balancing strategies for multi-channel connections */ public enum LoadBalancingStrategy { /** * Round-robin selection through available channels */ ROUND_ROBIN, /** * Select the least busy channel based on pending operations */ LEAST_LOADED, /** * Weighted random selection based on channel scores */ WEIGHTED_RANDOM, /**
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 1.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache2/FileOperator.kt
import java.io.IOException import java.nio.channels.FileChannel import okio.Buffer /** * Read and write a target file. Unlike Okio's built-in `Okio.source(java.io.File file)` and `Okio.sink(java.io.File file)` * this class offers: * * * **Read/write:** read and write using the same operator. * * **Random access:** access any position within the file. * * **Shared channels:** read and write a file channel that's shared between
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 2.4K bytes - Viewed (0) -
guava/src/com/google/common/io/ByteStreams.java
* <ol> * <li>Use sendfile(2) or equivalent. Requires that both the input channel and the output * channel have their own file descriptors. Generally this only happens when both channels * are files or sockets. This performs zero copies - the bytes never enter userspace. * <li>Use mmap(2) or equivalent. Requires that either the input channel or the output channel
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Jul 17 15:26:41 UTC 2025 - 31.1K bytes - Viewed (0) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainServerSocketFactory.java
return endpoint; } @Override public Socket accept() throws IOException { try { UnixSocketChannel channel = serverSocketChannel.accept(); return new TunnelingUnixSocket(path, channel, endpoint); } catch (ClosedChannelException e) { SocketException exception = new SocketException(); exception.initCause(e); throw exception; }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Feb 12 16:33:52 UTC 2019 - 3.1K bytes - Viewed (0) -
src/test/java/jcifs/config/MultiChannelConfigurationTest.java
import jcifs.CIFSException; /** * Unit tests for Multi-Channel configuration properties */ class MultiChannelConfigurationTest { @Test void testDefaultMultiChannelSettings() throws CIFSException { PropertyConfiguration config = new PropertyConfiguration(new Properties()); assertTrue(config.isUseMultiChannel(), "Multi-channel should be enabled by default");
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 8.3K bytes - Viewed (0)