Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 693 for channel (0.05 seconds)

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

  1. guava/src/com/google/common/io/ByteStreams.java

          to.write(buf, 0, r);
          total += r;
        }
        return total;
      }
    
      /**
       * Copies all bytes from the readable channel to the writable channel. Does not close or flush
       * either channel.
       *
       * @param from the readable channel to read from
       * @param to the writable channel to write to
       * @return the number of bytes copied
       * @throws IOException if an I/O error occurs
       */
      @J2ktIncompatible
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Jul 17 15:26:41 GMT 2025
    - 31.1K bytes
    - Click Count (0)
  2. 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)
  3. docs/security/README.md

    ##### Figure 1 - Secure Channel construction
    
    ```
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Feb 26 09:25:50 GMT 2025
    - 13.8K bytes
    - Click Count (0)
  4. cmd/grid.go

    // globalLockGrid is the global lock grid manager.
    var globalLockGrid atomic.Pointer[grid.Manager]
    
    // globalGridStart is a channel that will block startup of grid connections until closed.
    var globalGridStart = make(chan struct{})
    
    // globalLockGridStart is a channel that will block startup of lock grid connections until closed.
    var globalLockGridStart = make(chan struct{})
    
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 16 14:27:42 GMT 2025
    - 3.7K bytes
    - Click Count (0)
  5. 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)
  6. internal/logger/target/kafka/kafka.go

    	if err != nil {
    		atomic.AddInt64(&h.failedMessages, 1)
    		return err
    	}
    	// Delete the event from store.
    	return h.store.Del(key)
    }
    
    // Cancel - cancels the target
    func (h *Target) Cancel() {
    	// If queuestore is configured, cancel it's context to
    	// stop the replay go-routine.
    	if h.store != nil {
    		h.storeCtxCancel()
    	}
    
    	// Set logch to nil and close it.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  7. 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)
  8. internal/grid/handlers.go

    	// responses from the remote server.
    	// Channel will be closed after error or when remote closes.
    	// responses *must* be read to either an error is returned or the channel is closed.
    	responses *Stream
    	newResp   func() Resp
    
    	// Requests sent to the server.
    	// If the handler is defined with 0 incoming capacity this will be nil.
    	// Channel *must* be closed to signal the end of the stream.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 27.7K bytes
    - Click Count (0)
  9. 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)
  10. cmd/metacache-stream.go

    		if err != nil {
    			return err
    		}
    		if w.reuseBlocks || o.reusable {
    			metaDataPoolPut(o.metadata)
    		}
    	}
    
    	return nil
    }
    
    // stream entries to the output.
    // The returned channel should be closed when done.
    // Any error is reported when closing the metacacheWriter.
    func (w *metacacheWriter) stream() (chan<- metaCacheEntry, error) {
    	if w.creator != nil {
    		err := w.creator()
    		w.creator = nil
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed May 07 15:37:12 GMT 2025
    - 19.5K bytes
    - Click Count (0)
Back to Top