- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 105 for bufr (0.06 sec)
-
cmd/bitrot.go
// it with the actual file size. if left != bitrotShardFileSize(partSize, shardSize, algo) { return errFileCorrupt } bufp := xioutil.ODirectPoolSmall.Get().(*[]byte) defer xioutil.ODirectPoolSmall.Put(bufp) for left > 0 { // Read expected hash... h.Reset() n, err := io.ReadFull(r, hashBuf) if err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 7.6K bytes - Viewed (0) -
maven-embedder/src/main/java/org/apache/maven/cli/MavenCli.java
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Feb 28 23:31:59 UTC 2024 - 72.6K bytes - Viewed (0) -
internal/handlers/forwarder.go
type bufPool struct { sz int pool sync.Pool } func (b *bufPool) Put(buf []byte) { if cap(buf) < b.sz || cap(buf) > b.sz*2 { // Buffer too small or will likely leak memory after being expanded. // Drop it. return } b.pool.Put(&buf) } func (b *bufPool) Get() []byte { bufp := b.pool.Get().(*[]byte) return (*bufp)[:b.sz] } func newBufPool(sz int) httputil.BufferPool {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Apr 07 05:42:10 UTC 2023 - 5.6K bytes - Viewed (0) -
internal/ioutil/ioutil.go
} var written int64 for { buf := alignedBuf if totalSize > 0 { remaining := totalSize - written if remaining < int64(len(buf)) { buf = buf[:remaining] } } nr, err := io.ReadFull(r, buf) eof := errors.Is(err, io.EOF) || errors.Is(err, io.ErrUnexpectedEOF) if err != nil && !eof { return written, err } buf = buf[:nr] var ( n int un int
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 10.2K bytes - Viewed (0) -
cmd/erasure-multipart.go
// Add input readahead. // We use 2 buffers, so we always have a full buffer of input. pool := globalBytePoolCap.Load() bufA := pool.Get() bufB := pool.Get() defer pool.Put(bufA) defer pool.Put(bufB) ra, err := readahead.NewReaderBuffer(data, [][]byte{bufA[:fi.Erasure.BlockSize], bufB[:fi.Erasure.BlockSize]}) if err == nil { toEncode = ra defer ra.Close() } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 44.8K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/windows/service.go
//sys ChangeServiceConfig2(service Handle, infoLevel uint32, info *byte) (err error) = advapi32.ChangeServiceConfig2W //sys QueryServiceConfig2(service Handle, infoLevel uint32, buff *byte, buffSize uint32, bytesNeeded *uint32) (err error) = advapi32.QueryServiceConfig2W
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 10.3K bytes - Viewed (0) -
tensorflow/compiler/jit/pjrt_tensor_buffer_util.h
// memory. It also owns the PjRtBuffer. If output_tensor does not use // PjRtTensorBuffer and the opaque device memory is the same, update the // output_tensor->buf_ so that the same device memory will not be double-free. // Otherwise a new Tensor will be created with the PjRtTensorBuffer. // // TODO(b/289001822): Create a unit test to cover this function.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Sep 14 18:14:47 UTC 2023 - 2.3K bytes - Viewed (0) -
tensorflow/compiler/jit/pjrt_tensor_buffer_util.cc
auto* tensor_buffer = new PjRtTensorBuffer( opaque_device_memory, expected_size, std::move(pjrt_buffer)); if (ShouldReuseTensor(opaque_device_memory, expected_size, output_tensor)) { output_tensor->buf_ = tensor_buffer; return absl::OkStatus(); } Tensor result(dtype, shape, tensor_buffer); tensor_buffer->Unref(); *output_tensor = result; return absl::OkStatus(); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Sep 14 18:14:47 UTC 2023 - 3.5K bytes - Viewed (0) -
src/syscall/zsyscall_windows.go
} func formatMessage(flags uint32, msgsrc uintptr, msgid uint32, langid uint32, buf []uint16, args *byte) (n uint32, err error) { var _p0 *uint16 if len(buf) > 0 { _p0 = &buf[0] } r0, _, e1 := Syscall9(procFormatMessageW.Addr(), 7, uintptr(flags), uintptr(msgsrc), uintptr(msgid), uintptr(langid), uintptr(unsafe.Pointer(_p0)), uintptr(len(buf)), uintptr(unsafe.Pointer(args)), 0, 0) n = uint32(r0) if n == 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 11:49:46 UTC 2024 - 56.3K bytes - Viewed (1) -
tensorflow/c/tf_tensor_internal.h
}; namespace tensorflow { class TensorCApi { public: static TensorBuffer* Buffer(const Tensor& tensor) { return tensor.buf_; } static Tensor MakeTensor(TF_DataType type, const TensorShape& shape, TensorBuffer* buf) { return Tensor(static_cast<DataType>(type), shape, buf); } }; // Allocates tensor data buffer using specified allocator. // `operation` is a name for this operation.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Aug 24 20:38:55 UTC 2023 - 4.6K bytes - Viewed (0)