- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 355 for remSign (0.12 sec)
-
src/internal/poll/copy_file_range_linux.go
const maxCopyFileRangeRound = 1 << 30 // CopyFileRange copies at most remain bytes of data from src to dst, using // the copy_file_range system call. dst and src must refer to regular files. func CopyFileRange(dst, src *FD, remain int64) (written int64, handled bool, err error) { if !isKernelVersionGE53() { return 0, false, nil } for remain > 0 { max := remain if max > maxCopyFileRangeRound { max = maxCopyFileRangeRound }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 04 17:40:10 UTC 2024 - 3.9K bytes - Viewed (0) -
src/crypto/cipher/ctr.go
ctr: bytes.Clone(iv), out: make([]byte, 0, bufSize), outUsed: 0, } } func (x *ctr) refill() { remain := len(x.out) - x.outUsed copy(x.out, x.out[x.outUsed:]) x.out = x.out[:cap(x.out)] bs := x.b.BlockSize() for remain <= len(x.out)-bs { x.b.Encrypt(x.out[remain:], x.ctr) remain += bs // Increment counter for i := len(x.ctr) - 1; i >= 0; i-- { x.ctr[i]++ if x.ctr[i] != 0 { break
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 13 17:09:47 UTC 2023 - 2.2K bytes - Viewed (0) -
src/net/splice_linux.go
// // If spliceFrom returns handled == false, it has performed no work. func spliceFrom(c *netFD, r io.Reader) (written int64, err error, handled bool) { var remain int64 = 1<<63 - 1 // by default, copy until EOF lr, ok := r.(*io.LimitedReader) if ok { remain, r = lr.N, lr.R if remain <= 0 { return 0, nil, true } } var s *netFD switch v := r.(type) { case *TCPConn: s = v.fd case tcpConnWithoutWriteTo:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 1.7K bytes - Viewed (0) -
src/os/readfrom_linux_test.go
srcfd int remain int64 written int64 handled bool err error original func(dst, src *poll.FD, remain int64) (int64, bool, error) } func (h *spliceFileHook) install() { h.original = *PollSpliceFile *PollSpliceFile = func(dst, src *poll.FD, remain int64) (int64, bool, error) { h.called = true h.dstfd = dst.Sysfd h.srcfd = src.Sysfd h.remain = remain
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 20.3K bytes - Viewed (0) -
src/internal/poll/splice_linux.go
if err != nil { return 0, false, err } defer putPipe(p) var inPipe, n int for err == nil && remain > 0 { max := maxSpliceSize if int64(max) > remain { max = int(remain) } inPipe, err = spliceDrain(p.wfd, src, max) // The operation is considered handled if splice returns no // error, or an error other than EINVAL. An EINVAL means the // kernel does not support splice for the socket type of src.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 7.6K bytes - Viewed (0) -
src/net/splice_linux_test.go
} type spliceHook struct { called bool dstfd int srcfd int remain int64 written int64 handled bool err error original func(dst, src *poll.FD, remain int64) (int64, bool, error) } func (h *spliceHook) install() { h.original = pollSplice pollSplice = func(dst, src *poll.FD, remain int64) (int64, bool, error) { h.called = true h.dstfd = dst.Sysfd
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 14.5K bytes - Viewed (0) -
cmd/service.go
// For each call, unfreezeServices must be called once. func freezeServices() { // Use atomics for globalServiceFreeze, so we can read without locking. // We need a lock since we are need the 2 atomic values to remain in sync. globalServiceFreezeMu.Lock() // If multiple calls, first one creates channel. globalServiceFreezeCnt++ if globalServiceFreezeCnt == 1 { globalServiceFreeze.Store(make(chan struct{})) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Feb 28 07:02:14 UTC 2024 - 3.8K bytes - Viewed (0) -
src/encoding/binary/binary_test.go
}) if allocs != 0 { t.Fatalf("Expected no allocations, got %v", allocs) } }) } } type byteSliceReader struct { remain []byte } func (br *byteSliceReader) Read(p []byte) (int, error) { n := copy(p, br.remain) br.remain = br.remain[n:] return n, nil } func BenchmarkReadSlice1000Int32s(b *testing.B) { bsr := &byteSliceReader{} slice := make([]int32, 1000)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 19:16:18 UTC 2024 - 25.4K bytes - Viewed (0) -
internal/ioutil/ioutil.go
} buf = buf[:nr] var ( n int un int nw int64 ) remain := len(buf) % DirectioAlignSize if remain == 0 { // buf is aligned for directio write() n, err = w.Write(buf) nw = int64(n) } else { if remain < len(buf) { n, err = w.Write(buf[:len(buf)-remain]) if err != nil { return written, err } nw = int64(n) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 10.2K bytes - Viewed (0) -
analysis/analysis-api/src/org/jetbrains/kotlin/analysis/api/types/KtTypeMappingMode.kt
/** * kotlin.Int is mapped to Ljava/lang/Integer; * No projections allowed in immediate arguments */ SUPER_TYPE, /** * Similar to [SUPER_TYPE], except for that Kotlin collections remain as-is. */ SUPER_TYPE_KOTLIN_COLLECTIONS_AS_IS, /** * When method return type should be boxed (e.g., kotlin.Int to Ljava/lang/Integer;) */ RETURN_TYPE_BOXED, /**
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Wed May 22 06:28:34 UTC 2024 - 1.3K bytes - Viewed (0)