- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 54 for newOff (0.17 sec)
-
src/internal/coverage/slicewriter/slicewriter.go
return offset, nil case io.SeekCurrent: newoff := sws.off + offset if newoff != sws.off && (newoff < 0 || newoff > int64(len(sws.payload))) { return 0, fmt.Errorf("invalid seek: new offset %d (out of range [0 %d]", newoff, len(sws.payload)) } sws.off += offset return sws.off, nil case io.SeekEnd: newoff := int64(len(sws.payload)) + offset if newoff != sws.off && (newoff < 0 || newoff > int64(len(sws.payload))) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 26 12:44:26 UTC 2023 - 2.5K bytes - Viewed (0) -
src/internal/coverage/slicereader/slicereader.go
} r.off = offset return offset, nil case io.SeekCurrent: newoff := r.off + offset if newoff < 0 || newoff > int64(len(r.b)) { return 0, fmt.Errorf("invalid seek: new offset %d (out of range [0 %d]", newoff, len(r.b)) } r.off = newoff return r.off, nil case io.SeekEnd: newoff := int64(len(r.b)) + offset if newoff < 0 || newoff > int64(len(r.b)) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 23 11:36:28 UTC 2023 - 2.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_source_test.go
return nil } func (fp *FakePolicy) DeepCopyObject() runtime.Object { // totally fudged deepcopy newFP := &FakePolicy{} *newFP = *fp return newFP } func (fb *FakeBinding) DeepCopyObject() runtime.Object { // totally fudged deepcopy newFB := &FakeBinding{} *newFB = *fb return newFB
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 6.2K bytes - Viewed (0) -
cmd/config-migrate.go
} // Move to latest. cfg.Version = "33" newCfg := newServerConfig() config.SetRegion(newCfg, cfg.Region) storageclass.SetStorageClass(newCfg, cfg.StorageClass) for k, loggerArgs := range cfg.Logger.HTTP { logger.SetLoggerHTTP(newCfg, k, loggerArgs) } for k, auditArgs := range cfg.Logger.AuditWebhook { logger.SetLoggerHTTPAudit(newCfg, k, auditArgs) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.4K bytes - Viewed (0) -
internal/config/browser/browser.go
} // Update Updates browser with new config func (browseCfg *Config) Update(newCfg Config) { configLock.Lock() defer configLock.Unlock() browseCfg.CSPPolicy = newCfg.CSPPolicy browseCfg.HSTSSeconds = newCfg.HSTSSeconds browseCfg.HSTSIncludeSubdomains = newCfg.HSTSIncludeSubdomains browseCfg.HSTSPreload = newCfg.HSTSPreload browseCfg.ReferrerPolicy = newCfg.ReferrerPolicy }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.8K bytes - Viewed (1) -
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/crypto/cipher/ofb.go
cipher []byte out []byte outUsed int } // NewOFB returns a [Stream] that encrypts or decrypts using the block cipher b // in output feedback mode. The initialization vector iv's length must be equal // to b's block size. func NewOFB(b Block, iv []byte) Stream { blockSize := b.BlockSize() if len(iv) != blockSize { panic("cipher.NewOFB: IV length must equal block size") } bufSize := streamBufferSize
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 13 17:09:47 UTC 2023 - 1.6K bytes - Viewed (0) -
src/syscall/net_wasip1.go
} func StopIO(fd int) error { return ENOSYS } func Listen(fd int, backlog int) error { return ENOSYS } func Accept(fd int) (int, Sockaddr, error) { var newfd int32 errno := sock_accept(int32(fd), 0, unsafe.Pointer(&newfd)) return int(newfd), nil, errnoErr(errno) } func Connect(fd int, sa Sockaddr) error { return ENOSYS } func Recvfrom(fd int, p []byte, flags int) (n int, from Sockaddr, err error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 25 00:12:41 UTC 2023 - 1.8K bytes - Viewed (0) -
src/crypto/cipher/cfb.go
// size. func NewCFBEncrypter(block Block, iv []byte) Stream { return newCFB(block, iv, false) } // NewCFBDecrypter returns a [Stream] which decrypts with cipher feedback mode, // using the given [Block]. The iv must be the same length as the [Block]'s block // size. func NewCFBDecrypter(block Block, iv []byte) Stream { return newCFB(block, iv, true) } func newCFB(block Block, iv []byte, decrypt bool) Stream {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 13 17:09:47 UTC 2023 - 2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/allocator_test.go
} for i := initialSize; i > 0; i = i / 10 { newBuff := target.Allocate(uint64(i)) if cap(newBuff) < initialSize { t.Fatalf("allocator is now allowed to shrink memory") } if len(newBuff) != i { t.Fatalf("unexpected length of the buffer, expected: %v, got: %v", i, len(newBuff)) } } } func TestAllocatorZero(t *testing.T) { target := &Allocator{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 23 13:38:29 UTC 2022 - 2.4K bytes - Viewed (0)