- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 73 for Channel (0.05 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: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 8.2K bytes - Click Count (0) -
src/main/java/jcifs/smb/MultiChannelManager.java
return new ArrayList<>(channels); } public void addChannel(ChannelInfo channel) { channels.add(channel); if (primaryChannel == null) { primaryChannel = channel; } } public void removeChannel(ChannelInfo channel) { channels.remove(channel);
Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 20.5K bytes - Click Count (0) -
src/test/java/jcifs/smb/MultiChannelManagerBasicTest.java
// This should fail because localhost doesn't support SMB multi-channel // but the method should not throw NullPointerException try { method.invoke(multiChannelManager, localhost, loopback); // If it doesn't throw, that's unexpected for localhost fail("Expected CIFSException for localhost multi-channel attempt"); } catch (java.lang.reflect.InvocationTargetException e) {Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 4K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/SocketChannelTest.kt
} @Test fun testHttp(socketMode: SocketMode = burstValues(Channel, Standard)) { testConnection(socketMode) } @Test fun testHttps( provider: Provider = Provider.JSSE, protocol: Protocol = burstValues(HTTP_1_1, HTTP_2), tlsVersion: TlsVersion = burstValues(TLS_1_3, TLS_1_2), socketMode: SocketMode = burstValues(Channel, Standard),
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Nov 01 12:18:11 GMT 2025 - 7.9K bytes - Click Count (0) -
src/main/java/jcifs/Configuration.java
*/ int getMaxChannels(); /** * Channel binding policy * * Property {@code jcifs.smb.client.channelBindingPolicy} (String, default "preferred") * Values: "disabled", "preferred", "required" * * @return channel binding policy */ int getChannelBindingPolicy(); /** * Load balancing strategy for multi-channel *Created: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 25.4K bytes - Click Count (0) -
src/main/java/jcifs/smb/SmbSessionImpl.java
// Handle potential multi-channel failure if (isUseMultiChannel() && trans != this.transport) { ChannelInfo channel = channelManager.getChannelForTransport(trans); if (channel != null) { channelManager.handleChannelFailure(channel, e); // Retry with primary transportCreated: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 68.9K bytes - Click Count (0) -
cmd/iam-etcd-store.go
if !ok { time.Sleep(1 * time.Second) // Upon an error on watch channel // re-init the watch channel. goto outerLoop } if err := watchResp.Err(); err != nil { iamLogIf(ctx, err) // log and retry. time.Sleep(1 * time.Second) // Upon an error on watch channel // re-init the watch channel. goto outerLoop } for _, event := range watchResp.Events {Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 13.9K bytes - Click Count (0) -
.teamcity/src/main/kotlin/model/CIBuildModel.kt
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Wed Nov 05 13:00:26 GMT 2025 - 27.5K bytes - Click Count (0) -
doc/go_spec.html
<p> A send statement sends a value on a channel. The channel expression must be of <a href="#Channel_types">channel type</a>, the channel direction must permit send operations, and the type of the value to be sent must be <a href="#Assignability">assignable</a> to the channel's element type. </p> <pre class="ebnf"> SendStmt = Channel "<-" Expression . Channel = Expression . </pre> <p>
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Dec 02 23:07:19 GMT 2025 - 286.5K bytes - Click Count (1) -
internal/grid/muxclient.go
} return err == nil } // responseCh is the channel to that goes to the requester. // internalResp is the channel that comes from the server. func (m *muxClient) handleTwowayResponses(responseCh chan<- Response, internalResp <-chan Response) { defer func() { m.parent.deleteMux(false, m.MuxID) // addErrorNonBlockingClose will close the response channel. xioutil.SafeClose(responseCh) }()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 15.9K bytes - Click Count (0)