- Sort Score
- Num 10 results
- Language All
Results 11 - 20 of 693 for channel (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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 = nilCreated: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed May 07 15:37:12 GMT 2025 - 19.5K bytes - Click Count (0)