- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 34 for newBuf (0.19 sec)
-
cmd/erasure-decode.go
newBuf := dst if len(dst) != len(p.readers) { newBuf = make([][]byte, len(p.readers)) } else { for i := range newBuf { newBuf[i] = newBuf[i][:0] } } var newBufLK sync.RWMutex if p.offset+p.shardSize > p.shardFileSize { p.shardSize = p.shardFileSize - p.offset } if p.shardSize == 0 { return newBuf, nil }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 21 14:36:21 UTC 2024 - 9.4K bytes - Viewed (0) -
src/main/java/org/codelibs/core/io/FileUtil.java
Registered: Wed Jun 12 12:50:12 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 9K bytes - Viewed (0) -
src/internal/trace/order.go
return } // Create new buf and copy data over. newBuf := make([]T, len(q.buf)*2) pivot := q.start % len(q.buf) first, last := q.buf[pivot:], q.buf[:pivot] copy(newBuf[:len(first)], first) copy(newBuf[len(first):], last) // Update the queue state. q.start = 0 q.end = len(q.buf) q.buf = newBuf } // pop removes an event from the front of the queue. If the
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 52.4K bytes - Viewed (0) -
cmd/xl-storage.go
// Convert to slice. dirs = dirs[:0] for dir := range foundDirs { dirs = append(dirs, dir) } if xl.data.remove(dirs...) { newBuf, err := xl.AppendTo(metaDataPoolGet()) if err == nil { defer metaDataPoolPut(newBuf) return s.WriteAll(ctx, volume, pathJoin(path, xlStorageFormatFile), buf) } } return nil } func convertAccessError(err, permErr error) error {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 85.3K bytes - Viewed (0) -
security/pkg/server/ca/monitoring.go
var ( errorTag = monitoring.CreateLabel(errorlabel) csrCounts = monitoring.NewSum( "citadel_server_csr_count", "The number of CSRs received by Citadel server.", ) authnErrorCounts = monitoring.NewSum( "citadel_server_authentication_failure_count", "The number of authentication failures.", ) csrParsingErrorCounts = monitoring.NewSum( "citadel_server_csr_parsing_err_count",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 18:32:09 UTC 2024 - 3.3K bytes - Viewed (0) -
pkg/xds/monitoring.go
nodeTag = monitoring.CreateLabel("node") typeTag = monitoring.CreateLabel("type") TotalXDSInternalErrors = monitoring.NewSum( "pilot_total_xds_internal_errors", "Total number of internal XDS errors in pilot.", ) ExpiredNonce = monitoring.NewSum( "pilot_xds_expired_nonce", "Total number of XDS requests with an expired nonce.", )
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 2.9K bytes - Viewed (0) -
src/vendor/golang.org/x/net/dns/dnsmessage/message.go
} func (h *header) unpack(msg []byte, off int) (int, error) { newOff := off var err error if h.id, newOff, err = unpackUint16(msg, newOff); err != nil { return off, &nestedError{"id", err} } if h.bits, newOff, err = unpackUint16(msg, newOff); err != nil { return off, &nestedError{"bits", err} } if h.questions, newOff, err = unpackUint16(msg, newOff); err != nil { return off, &nestedError{"questions", err} }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Mar 09 00:09:40 UTC 2024 - 69K bytes - Viewed (0) -
pilot/pkg/xds/monitoring.go
[]float64{.1, .5, 1, 3, 5, 10, 20, 30}, ) pushContextErrors = monitoring.NewSum( "pilot_xds_push_context_errors", "Number of errors (timeouts) initiating push context.", ) inboundUpdates = monitoring.NewSum( "pilot_inbound_updates", "Total number of updates received by pilot.", ) pilotSDSCertificateErrors = monitoring.NewSum( "pilot_sds_certificate_errors_total",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 6.7K bytes - Viewed (0) -
pkg/kubelet/config/mux_test.go
package config import ( "context" "reflect" "testing" ) func TestConfigurationChannels(t *testing.T) { ctx, cancel := context.WithCancel(context.Background()) defer cancel() mux := newMux(nil) channelOne := mux.ChannelWithContext(ctx, "one") if channelOne != mux.ChannelWithContext(ctx, "one") { t.Error("Didn't get the same muxuration channel back with the same name") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jan 30 20:02:23 UTC 2024 - 2.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/mux/pathrecorder.go
func (m *PathRecorderMux) refreshMuxLocked() { newMux := &pathHandler{ muxName: m.name, pathToHandler: map[string]http.Handler{}, prefixHandlers: []prefixHandler{}, notFoundHandler: http.NotFoundHandler(), } if m.notFoundHandler != nil { newMux.notFoundHandler = m.notFoundHandler } for path, handler := range m.pathToHandler { newMux.pathToHandler[path] = handler }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 12 01:52:15 UTC 2024 - 8.5K bytes - Viewed (0)