Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 56 for Channel (0.15 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/DefaultUpdateCheckManager.java

                    channel.truncate(0);
                    props.store(Channels.newOutputStream(channel), "Last modified on: " + new Date());
    
                    lock.release();
                    lock = null;
    
                    channel.close();
                    channel = null;
                } catch (IOException e) {
                    getLogger()
                            .debug(
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Tue Apr 22 22:13:51 UTC 2025
    - 12.1K bytes
    - Viewed (0)
  8. 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)
  9. 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)
  10. 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)
Back to top