Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 1,357 for atomics (0.16 sec)

  1. src/runtime/mbitmap.go

    }
    
    // setMarked sets the marked bit in the markbits, atomically.
    func (m markBits) setMarked() {
    	// Might be racing with other updates, so use atomic update always.
    	// We used to be clever here and use a non-atomic update in certain
    	// cases, but it's not worth the risk.
    	atomic.Or8(m.bytep, m.mask)
    }
    
    // setMarkedNonAtomic sets the marked bit in the markbits, non-atomically.
    func (m markBits) setMarkedNonAtomic() {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 00:18:55 UTC 2024
    - 60K bytes
    - Viewed (0)
  2. src/runtime/atomic_pointer.go

    	if writeBarrier.enabled {
    		atomicwb(ptr, new)
    	}
    	if goexperiment.CgoCheck2 {
    		cgoCheckPtrWrite(ptr, new)
    	}
    	return atomic.Casp1(ptr, old, new)
    }
    
    // Like above, but implement in terms of sync/atomic's uintptr operations.
    // We cannot just call the runtime routines, because the race detector expects
    // to be able to intercept the sync/atomic forms but not the runtime forms.
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 4K bytes
    - Viewed (0)
  3. src/sync/atomic/atomic_test.go

    		runtime.GC()
    
    		err := recover()
    		want := "unaligned 64-bit atomic operation"
    		if err == nil {
    			t.Errorf("%s did not panic", name)
    		} else if s, _ := err.(string); s != want {
    			t.Errorf("%s: wanted panic %q, got %q", name, want, err)
    		}
    	}()
    	f()
    }
    
    func TestUnaligned64(t *testing.T) {
    	// Unaligned 64-bit atomics on 32-bit systems are
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:37:29 UTC 2024
    - 71.4K bytes
    - Viewed (0)
  4. src/runtime/pprof/pprof_test.go

    				SetGoroutineLabels(WithLabels(ctx, Labels("churn-i", fmt.Sprint(i))))
    				atomic.AddInt64(&count, 1)
    				if i == 0 {
    					ready.Done()
    				}
    				if ctx.Err() == nil {
    					go churn(i + 1)
    				}
    			}
    			go func() {
    				churn(0)
    			}()
    			ready.Wait()
    
    			fn(b)
    			b.ReportMetric(float64(atomic.LoadInt64(&count))/float64(b.N), "concurrent_launches/op")
    		}
    	}
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 18:42:28 UTC 2024
    - 68.8K bytes
    - Viewed (0)
  5. src/runtime/proc.go

    	// only via lockextra/unlockextra.
    	//
    	// Can't be atomic.Pointer[m] because we use an invalid pointer as a
    	// "locked" sentinel value. M's on this list remain visible to the GC
    	// because their mp.curg is on allgs.
    	extraM atomic.Uintptr
    	// Number of M's in the extraM list.
    	extraMLength atomic.Uint32
    	// Number of waiters in lockextra.
    	extraMWaiters atomic.Uint32
    
    	// Number of extra M's in use by threads.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 207.5K bytes
    - Viewed (0)
  6. pilot/pkg/xds/discovery_test.go

    // limitations under the License.
    
    package xds
    
    import (
    	"context"
    	"fmt"
    	"reflect"
    	"sync"
    	"sync/atomic"
    	"testing"
    	"time"
    
    	discovery "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3"
    	uatomic "go.uber.org/atomic"
    	"google.golang.org/grpc"
    
    	"istio.io/istio/pilot/pkg/model"
    	"istio.io/istio/pkg/config/schema/kind"
    	"istio.io/istio/pkg/test/util/retry"
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 00:26:45 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  7. src/internal/cpu/cpu_arm.go

    		{Name: "vfpv4", Feature: &ARM.HasVFPv4},
    		{Name: "idiva", Feature: &ARM.HasIDIVA},
    		{Name: "v7atomics", Feature: &ARM.HasV7Atomics},
    	}
    
    	// HWCAP feature bits
    	ARM.HasVFPv4 = isSet(HWCap, hwcap_VFPv4)
    	ARM.HasIDIVA = isSet(HWCap, hwcap_IDIVA)
    	// lpae is required to make the 64-bit instructions LDRD and STRD (and variants) atomic.
    	// See ARMv7 manual section B1.6.
    	// We also need at least a v7 chip, for the DMB instruction.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Oct 31 20:38:55 UTC 2023
    - 1.3K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/AtomicLongMap.java

        outer:
        while (true) {
          AtomicLong atomic = map.get(key);
          if (atomic == null) {
            atomic = map.putIfAbsent(key, new AtomicLong(delta));
            if (atomic == null) {
              return delta;
            }
            // atomic is now non-null; fall through
          }
    
          while (true) {
            long oldValue = atomic.get();
            if (oldValue == 0L) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 01 16:15:01 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  9. src/cmd/compile/internal/ir/func_test.go

    			pkg: `foo`,
    			sym: "Bar[go.shape.struct { sync/atomic._ sync/atomic.noCopy; sync/atomic._ sync/atomic.align64; sync/atomic.v uint64 }]",
    		},
    		{
    			in:  `example%2ecom.Bar[go.shape.struct { sync/atomic._ sync/atomic.noCopy; sync/atomic._ sync/atomic.align64; sync/atomic.v uint64 }]`,
    			pkg: `example%2ecom`,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Oct 13 13:56:32 UTC 2023
    - 2.2K bytes
    - Viewed (0)
  10. src/cmd/compile/internal/ssagen/ssa.go

    	alias("internal/runtime/atomic", "Xchguintptr", "internal/runtime/atomic", "Xchg64", p8...)
    
    	// Aliases for atomic add operations
    	alias("internal/runtime/atomic", "Xaddint32", "internal/runtime/atomic", "Xadd", all...)
    	alias("internal/runtime/atomic", "Xaddint64", "internal/runtime/atomic", "Xadd64", all...)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 19:44:43 UTC 2024
    - 284.9K bytes
    - Viewed (0)
Back to top