- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 157 for channel1 (0.03 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/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/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/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) -
src/builtin/builtin.go
func clear[T ~[]Type | ~map[Type]Type1](t T) // The close built-in function closes a channel, which must be either // bidirectional or send-only. It should be executed only by the sender, // never the receiver, and has the effect of shutting down the channel after // the last sent value is received. After the last value has been received // from a closed channel c, any receive from c will succeed without
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Mon Dec 30 23:59:23 UTC 2024 - 12.8K 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) -
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) -
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)