- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 65 for newConf (0.11 sec)
-
src/net/http/fcgi/fcgi.go
type conn struct { mutex sync.Mutex rwc io.ReadWriteCloser closeErr error closed bool // to avoid allocations buf bytes.Buffer h header } func newConn(rwc io.ReadWriteCloser) *conn { return &conn{rwc: rwc} } // Close closes the conn if it is not already closed. func (c *conn) Close() error { c.mutex.Lock() defer c.mutex.Unlock() if !c.closed {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 11 18:51:39 UTC 2023 - 5.9K bytes - Viewed (0) -
internal/ringbuffer/ring_buffer.go
// This setting should be called before any Read or Write operation or after a Reset. func (r *RingBuffer) SetBlocking(block bool) *RingBuffer { r.block = block if block { r.readCond = sync.NewCond(&r.mu) r.writeCond = sync.NewCond(&r.mu) } return r } // WithCancel sets a context to cancel the ring buffer. // When the context is canceled, the ring buffer will be closed with the context error.
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 13.3K bytes - Viewed (0) -
src/compress/flate/deflate_test.go
{ "../testdata/e.txt", "2.718281828...", [...]int{100018, 50650, 50960, 51150, 50930, 50790, 50790, 50790, 50790, 50790, 43683}, }, { "../../testdata/Isaac.Newton-Opticks.txt", "Isaac.Newton-Opticks", [...]int{567248, 218338, 198211, 193152, 181100, 175427, 175427, 173597, 173422, 173422, 325240}, }, } func TestDeflateInflateString(t *testing.T) { t.Parallel()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 25.6K bytes - Viewed (0) -
src/net/http/export_test.go
NewLoggingConn = newLoggingConn ExportAppendTime = appendTime ExportRefererForURL = refererForURL ExportServerNewConn = (*Server).newConn ExportCloseWriteAndWait = (*conn).closeWriteAndWait ExportErrRequestCanceled = errRequestCanceled ExportErrRequestCanceledConn = errRequestCanceledConn
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 17 21:11:57 UTC 2024 - 8.7K bytes - Viewed (0) -
src/net/http/fcgi/fcgi_test.go
continue } if !bytes.Equal(content, test.content) { t.Errorf("%s: read wrong content", test.desc) continue } buf.Reset() c := newConn(&nilCloser{buf}) w := newWriter(c, test.recType, test.reqId) if _, err := w.Write(test.content); err != nil { t.Errorf("%s: error writing record: %v", test.desc, err) continue }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 11 18:51:39 UTC 2023 - 10.6K bytes - Viewed (0) -
src/net/http/fcgi/child.go
conn *conn handler http.Handler requests map[uint16]*request // keyed by request ID } func newChild(rwc io.ReadWriteCloser, handler http.Handler) *child { return &child{ conn: newConn(rwc), handler: handler, requests: make(map[uint16]*request), } } func (c *child) serve() { defer c.conn.Close() defer c.cleanUp() var rec record for {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 10.3K bytes - Viewed (0) -
pkg/volume/util/nestedpendingoperations/nestedpendingoperations.go
g := &nestedPendingOperations{ operations: []operation{}, exponentialBackOffOnError: exponentialBackOffOnError, } g.cond = sync.NewCond(&g.lock) return g } type nestedPendingOperations struct { operations []operation exponentialBackOffOnError bool cond *sync.Cond
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 26 01:29:17 UTC 2022 - 12.6K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
// is passed in on stdin. Your plugin may wish to expose its functionality via // runtime args, see CONVENTIONS.md in the CNI spec. type Config struct { types.NetConf // Add plugin-specific flags here PluginLogLevel string `json:"plugin_log_level"` LogUDSAddress string `json:"log_uds_address"` CNIEventAddress string `json:"cni_event_address"`
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 12 16:26:35 UTC 2024 - 10.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/errors/errors.go
// TODO: Get obj details here? Causes: causes, }, Message: message, }} } // NewGone returns an error indicating the item no longer available at the server and no forwarding address is known. // DEPRECATED: Please use NewResourceExpired instead. func NewGone(message string) *StatusError { return &StatusError{metav1.Status{ Status: metav1.StatusFailure, Code: http.StatusGone,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 21 03:41:32 UTC 2022 - 30.5K bytes - Viewed (0) -
src/internal/zstd/zstd_test.go
) // bigData returns the contents of our large test file repeated multiple times. func bigData(t testing.TB) []byte { bigDataOnce.Do(func() { bigDataBytes, bigDataErr = os.ReadFile("../../testdata/Isaac.Newton-Opticks.txt") if bigDataErr == nil { bigDataBytes = bytes.Repeat(bigDataBytes, 20) } }) if bigDataErr != nil { t.Fatal(bigDataErr) } return bigDataBytes }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Nov 17 16:39:21 UTC 2023 - 9.5K bytes - Viewed (0)