- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 56 for Channel (0.15 sec)
-
docs/smb3-features/03-multi-channel-design.md
handleChannelFailure(channel, e); } } // Check error rate if (channel.getErrorRate() > 0.1) { log.warn("High error rate on channel {}: {}", channel.getChannelId(), channel.getErrorRate()); // Consider removing channel }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 39.6K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelManager.java
*/ public ChannelInfo getChannelForTransport(SmbTransport transport) { return channels.values().stream().filter(c -> c.getTransport() == transport).findFirst().orElse(null); } /** * Remove a channel * * @param channel channel to remove */ public void removeChannel(ChannelInfo channel) { channels.remove(channel.getChannelId());
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 20K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelInfo.java
private final AtomicLong errors; // Channel binding private byte[] bindingHash; private boolean isPrimary; // Pending operations private final List<CommonServerMessageBlock> pendingOperations; /** * Create channel information * * @param channelId unique channel identifier * @param transport SMB transport for this channel * @param localInterface local network interface
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 10.6K bytes - Viewed (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);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 31 08:00:57 UTC 2025 - 20.5K bytes - Viewed (0) -
src/main/java/jcifs/internal/smb2/multichannel/ChannelFailover.java
} catch (Exception e) { log.warn("Failed to recover channel {}: {}", channel.getChannelId(), e.getMessage()); // Schedule next retry or remove handleFailure(channel, e); } } private void removeChannel(ChannelInfo channel) { log.info("Removing failed channel {} after max retries", channel.getChannelId());
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 21 11:13:46 UTC 2025 - 11.6K 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) -
compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultUpdateCheckManager.java
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Tue Apr 22 22:13:51 UTC 2025 - 12.1K bytes - Viewed (0) -
doc/go_mem.html
use a synchronization mechanism such as a lock or channel communication to establish a relative ordering. </p> <h3 id="chan">Channel communication</h3> <p> Channel communication is the main method of synchronization between goroutines. Each send on a particular channel is matched to a corresponding receive from that channel, usually in a different goroutine. </p> <p class="rule">
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Tue Aug 05 15:41:37 UTC 2025 - 26.6K 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/Relay.kt
} val fileOperator = FileOperator(file!!.channel) fileOperator.write(0, header, FILE_HEADER_SIZE) } @Throws(IOException::class) private fun writeMetadata(upstreamSize: Long) { val metadataBuffer = Buffer() metadataBuffer.write(metadata) val fileOperator = FileOperator(file!!.channel)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 17:15:47 UTC 2025 - 11.8K bytes - Viewed (0)