Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 121 for writes (0.1 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. android/guava/src/com/google/common/util/concurrent/Futures.java

      //    visible to done(). This is because there is no happens before edge between the write and a
      //    (hypothetical) unsafe read by our caller. Note: adding 'volatile' does not fix this issue,
      //    it would just add an edge such that if done() observed non-null, then it would also
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 59.6K bytes
    - Viewed (0)
Back to top