Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 62 for Channel (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. 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)
  2. 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)
  3. 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 transport
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 68.9K bytes
    - Click Count (0)
  4. .teamcity/src/main/kotlin/model/CIBuildModel.kt

        val defaultBaselines: String = "",
        val channel: String,
        val extraParameters: String = "",
    ) {
        PER_COMMIT(
            displayName = "Performance Regression Test",
            timeout = 420,
            channel = "commits",
        ),
        PER_DAY(
            displayName = "Slow Performance Regression Test",
            timeout = 420,
            channel = "commits",
        ),
        PER_WEEK(
    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)
  5. 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)
  6. internal/bpool/bpool_test.go

    	}
    
    	bp.Put(b)
    
    	// Check the size of the pool.
    	if uint64(len(bp.c)) != size {
    		t.Fatalf("bytepool size invalid: got %v want %v", len(bp.c), size)
    	}
    
    	// lets drain the buf channel first before we validate invalid buffers.
    	for range size {
    		bp.Get() // discard
    	}
    
    	// Try putting some invalid buffers into pool
    	bp.Put(make([]byte, bp.w, bp.wcap-1)) // wrong capacity is rejected (less)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 2.7K bytes
    - Click Count (0)
  7. src/main/java/jcifs/config/BaseConfiguration.java

        // Multi-channel configuration fields
        /**
         * Whether to use SMB3 multi-channel support for improved performance and redundancy
         */
        protected boolean useMultiChannel;
        /**
         * Maximum number of SMB3 channels to establish per session
         */
        protected int maxChannels;
        /**
         * Channel binding policy: -1=not set, 0=disabled, 1=preferred, 2=required
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 36.5K bytes
    - Click Count (0)
  8. cmd/metrics.go

    			nil, nil),
    		prometheus.GaugeValue,
    		float64(nodesDown),
    	)
    }
    
    // collects healing specific metrics for MinIO instance in Prometheus specific format
    // and sends to given channel
    func healingMetricsPrometheus(ch chan<- prometheus.Metric) {
    	bgSeq, exists := globalBackgroundHealState.getHealSequenceByToken(bgHealingUUID)
    	if !exists {
    		return
    	}
    
    	var dur time.Duration
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Oct 24 04:06:31 GMT 2025
    - 16.7K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/core/io/FileUtil.java

            assertArgumentNotNull("file", file);
    
            final FileInputStream is = InputStreamUtil.create(file);
            try {
                final FileChannel channel = is.getChannel();
                final long fileSize = ChannelUtil.size(channel);
    
                if (fileSize > maxSize) {
    Created: Sat Dec 20 08:55:33 GMT 2025
    - Last Modified: Sat Nov 22 11:21:59 GMT 2025
    - 13.1K bytes
    - Click Count (0)
  10. internal/http/listener.go

    	acceptCh    chan acceptResult // channel where all TCP listeners write accepted connection.
    	ctxDoneCh   <-chan struct{}
    	ctxCanceler context.CancelFunc
    }
    
    // start - starts separate goroutine for each TCP listener.  A valid new connection is passed to httpListener.acceptCh.
    func (listener *httpListener) start() {
    	// Closure to handle listener until httpListener.ctxDoneCh channel is closed.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.8K bytes
    - Click Count (0)
Back to Top