- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 121 for writes (0.1 sec)
-
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
// inner handler writes header and then let the request time out. w.WriteHeader(http.StatusBadRequest) <-callerRoundTripDoneCh // we expect the timeout handler to have timed out this request by now and any attempt // to write to the response should return a http.ErrHandlerTimeout error. _, innerHandlerWriteErr := w.Write([]byte("foo")) reqHandlerErrCh <- innerHandlerWriteErr
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
src/cmd/cgo/gcc.go
// type conversions. If so, then in the general case it writes // // _cgoIndexNN := a // _cgoNN := &cgoIndexNN[i] // with type conversions, if any // // to sb, and writes // // _cgoCheckPointer(_cgoNN, _cgoIndexNN) // // to sbCheck, and returns true. If a is a simple variable or field reference, // it writes // // _cgoIndexNN := &a //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 15:50:06 UTC 2024 - 97K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFuture.java
/** Non-volatile write of the thread to the {@link Waiter#thread} field. */ abstract void putThread(Waiter waiter, Thread newValue); /** Non-volatile write of the waiter to the {@link Waiter#next} field. */ abstract void putNext(Waiter waiter, @CheckForNull Waiter newValue); /** Performs a CAS operation on the {@link #waiters} field. */ abstract boolean casWaiters(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 63.1K bytes - Viewed (1) -
guava/src/com/google/common/util/concurrent/AbstractFuture.java
/** Non-volatile write of the thread to the {@link Waiter#thread} field. */ abstract void putThread(Waiter waiter, Thread newValue); /** Non-volatile write of the waiter to the {@link Waiter#next} field. */ abstract void putNext(Waiter waiter, @CheckForNull Waiter newValue); /** Performs a CAS operation on the {@link #waiters} field. */ abstract boolean casWaiters(
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 62.8K bytes - Viewed (1) -
src/cmd/go/internal/modload/init.go
if !dirty && cfg.CmdName != "mod tidy" { // The go.mod file has the same semantic content that it had before // (but not necessarily the same exact bytes). // Don't write go.mod, but write go.sum in case we added or trimmed sums. // 'go mod init' shouldn't write go.sum, since it will be incomplete. if cfg.CmdName != "mod init" {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jun 06 18:36:30 UTC 2024 - 69.8K bytes - Viewed (0) -
pkg/controller/disruption/disruption_test.go
// DisruptionsAllowed to 1. // (B) As the DisruptionController attempts this write, we will evict the // remaining 2 pods and update DisruptionsAllowed to 0. (The real eviction // handler would allow this because it still sees DisruptionsAllowed=2.) // (C) If the DisruptionController writes DisruptionsAllowed=1 despite the // resource conflict error, then there is a bug. func TestUpdatePDBStatusRetries(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 50K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/debug.go
if cap(buf) < len(buf)+20 { b := make([]byte, len(buf), 20+cap(buf)*2) copy(b, buf) buf = b } writeAt := len(buf) buf = buf[0 : len(buf)+ctxt.Arch.PtrSize] writePtr(ctxt, buf[writeAt:], word) return buf } // Write a pointer-sized uint to the beginning of buf. func writePtr(ctxt *obj.Link, buf []byte, word uint64) { switch ctxt.Arch.PtrSize { case 4:
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 19:44:43 UTC 2024 - 58.4K bytes - Viewed (0) -
cmd/xl-storage.go
defer xioutil.ODirectPoolLarge.Put(bufp) } var written int64 if odirectEnabled { written, err = xioutil.CopyAligned(diskHealthWriter(ctx, w), r, *bufp, fileSize, w) } else { written, err = io.CopyBuffer(diskHealthWriter(ctx, w), r, *bufp) } if err != nil { w.Close() return err } if written < fileSize && fileSize >= 0 { w.Close() return errLessData
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 85.3K bytes - Viewed (0) -
src/runtime/mheap.go
// span is used. // // Reads and writes are atomic. pageInUse [pagesPerArena / 8]uint8 // pageMarks is a bitmap that indicates which spans have any // marked objects on them. Like pageInUse, only the bit // corresponding to the first page in each span is used. // // Writes are done atomically during marking. Reads are
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:31:00 UTC 2024 - 78K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 59.6K bytes - Viewed (0)