Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 105 for writes (0.11 sec)

  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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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
    - 64.1K bytes
    - Viewed (0)
  9. src/runtime/mgc.go

    //    (from _GCoff), enabling the write barrier, enabling mutator
    //    assists, and enqueueing root mark jobs. No objects may be
    //    scanned until all Ps have enabled the write barrier, which is
    //    accomplished using STW.
    //
    //    b. Start the world. From this point, GC work is done by mark
    //    workers started by the scheduler and by assists performed as
    //    part of allocation. The write barrier shades both the
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 62K bytes
    - Viewed (0)
  10. configure.py

        if python_lib_path in python_paths:
          write_action_env_to_bazelrc('PYTHONPATH', environ_cp.get('PYTHONPATH'))
    
      # Write tools/python_bin_path.sh
      with open(
          os.path.join(_TF_WORKSPACE_ROOT, 'tools', 'python_bin_path.sh'),
          'w') as f:
        f.write('export PYTHON_BIN_PATH="{}"'.format(python_bin_path))
    
    
    def reset_tf_configure_bazelrc():
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Mon Jun 10 04:32:44 UTC 2024
    - 53.8K bytes
    - Viewed (0)
Back to top