- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 1,106 for Chan (0.15 sec)
-
cmd/perf-tests.go
defer n.Unlock() n.RX = 0 n.RXSample = 0 n.lastToConnect = time.Time{} n.firstToDisconnect = time.Time{} } // Reader to read random data. type netperfReader struct { n uint64 eof chan struct{} buf []byte } func (m *netperfReader) Read(b []byte) (int, error) { select { case <-m.eof: return 0, io.EOF default: } n := copy(b, m.buf) atomic.AddUint64(&m.n, uint64(n))
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Jan 28 18:04:17 GMT 2024 - 11.3K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver.go
} type updateRequest struct { Update []byte Fd *int Resp chan updateResponse } type ZtunnelConnection struct { u *net.UnixConn Updates chan updateRequest } func newZtunnelConnection(u *net.UnixConn) *ZtunnelConnection { return &ZtunnelConnection{u: u, Updates: make(chan updateRequest, 100)} } func (z *ZtunnelConnection) Close() { z.u.Close() }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
internal/grid/stream.go
// All responses *must* be read by the caller until either an error is returned or the channel is closed. // Canceling the context will cause the context cancellation error to be returned. responses <-chan Response cancel context.CancelCauseFunc // 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.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Feb 28 18:05:18 GMT 2024 - 2.8K bytes - Viewed (0) -
internal/http/listener.go
UserTimeout int // this value is expected to be in milliseconds ClientReadTimeout time.Duration // When the net.Conn is idle for more than ReadTimeout duration, we close the connection on the client proactively. ClientWriteTimeout time.Duration // When the net.Conn is idle for more than WriteTimeout duration, we close the connection on the client proactively.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Mar 01 16:00:42 GMT 2024 - 5.8K bytes - Viewed (0) -
prepare_stmt.go
package gorm import ( "context" "database/sql" "database/sql/driver" "errors" "reflect" "sync" ) type Stmt struct { *sql.Stmt Transaction bool prepared chan struct{} prepareErr error } type PreparedStmtDB struct { Stmts map[string]*Stmt PreparedSQL []string Mux *sync.RWMutex ConnPool } func NewPreparedStmtDB(connPool ConnPool) *PreparedStmtDB {
Go - Registered: Sun Apr 28 09:35:09 GMT 2024 - Last Modified: Thu Mar 28 08:47:39 GMT 2024 - 6.4K bytes - Viewed (0) -
cmd/batch-expire.go
// value: image/* # match objects with 'content-type', all values starting with 'image/' // size: // lessThan: "10MiB" # match objects with size less than this value (e.g. 10MiB) // greaterThan: 1MiB # match objects with size greater than this value (e.g. 1MiB) // purge: // # retainVersions: 0 # (default) delete all versions of the object. This option is the fastest.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 21K bytes - Viewed (1) -
guava/src/com/google/common/collect/ForwardingImmutableCollection.java
package com.google.common.collect; import com.google.common.annotations.GwtCompatible; /** * Dummy class that makes the GWT serialization policy happy. It isn't used on the server-side. * * @author Hayward Chan */ @GwtCompatible(emulated = true) @ElementTypesAreNonnullByDefault class ForwardingImmutableCollection { private ForwardingImmutableCollection() {}
Java - Registered: Fri Apr 05 12:43:09 GMT 2024 - Last Modified: Tue Jun 29 19:42:21 GMT 2021 - 972 bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/RegularImmutableSet.java
* limitations under the License. */ package com.google.common.collect; import java.util.Collections; import java.util.Set; /** * GWT emulation of {@link RegularImmutableSet}. * * @author Hayward Chan */ @ElementTypesAreNonnullByDefault final class RegularImmutableSet<E> extends ForwardingImmutableSet<E> { static final RegularImmutableSet<Object> EMPTY = new RegularImmutableSet<Object>(Collections.emptySet());
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Jan 23 18:43:40 GMT 2024 - 1K bytes - Viewed (0) -
internal/s3select/message.go
getProgressFunc func() (int64, int64) bytesReturned int64 payloadBuffer []byte payloadBufferIndex int payloadCh chan *bytes.Buffer finBytesScanned, finBytesProcessed int64 errCh chan []byte doneCh chan struct{} } func (writer *messageWriter) write(data []byte) bool { if _, err := writer.writer.Write(data); err != nil { return false }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue Aug 30 15:26:43 GMT 2022 - 15.2K bytes - Viewed (0) -
cmd/batch-handlers.go
ctx: ctx, objLayer: o, jobCh: make(chan *BatchJobRequest, 10000), workerKillCh: make(chan struct{}, workers), jobCancelers: make(map[string]context.CancelFunc), } jpool.ResizeWorkers(workers) jpool.resume() return jpool } func (j *BatchJobPool) resume() { results := make(chan ObjectInfo, 100) ctx, cancel := context.WithCancel(j.ctx) defer cancel()
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 08 14:11:38 GMT 2024 - 55.2K bytes - Viewed (0)