- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,320 for uatomic (0.19 sec)
-
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) -
cmd/data-scanner.go
scannerCycle = uatomic.NewDuration(dataScannerStartDelay) scannerIdleMode = uatomic.NewInt32(0) // default is throttled when idle scannerExcessObjectVersions = uatomic.NewInt64(100) scannerExcessObjectVersionsTotalSize = uatomic.NewInt64(1024 * 1024 * 1024 * 1024) // 1 TB scannerExcessFolders = uatomic.NewInt64(50000) )
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:43:17 UTC 2024 - 47.6K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
// limitations under the License. package xds import ( "fmt" "strconv" "strings" "sync/atomic" "time" core "github.com/envoyproxy/go-control-plane/envoy/config/core/v3" discovery "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3" uatomic "go.uber.org/atomic" "google.golang.org/grpc/codes" "google.golang.org/grpc/peer" "google.golang.org/grpc/status" "istio.io/api/label"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
pilot/pkg/xds/eds_test.go
// be detected // This is not using adsc, which consumes the events automatically. ads := s.ConnectADS() ads.Request(t, nil) n := nclients wg.Add(n) wgConnect.Add(n) rcvPush := uatomic.NewInt32(0) rcvClients := uatomic.NewInt32(0) for i := 0; i < n; i++ { current := i go func(id int) { defer wg.Done() // Connect and get initial response
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 20:58:47 UTC 2024 - 39.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Atomics.java
import com.google.common.annotations.GwtIncompatible; import java.util.concurrent.atomic.AtomicReference; import java.util.concurrent.atomic.AtomicReferenceArray; import org.checkerframework.checker.nullness.qual.Nullable; /** * Static utility methods pertaining to classes in the {@code java.util.concurrent.atomic} package. * * @author Kurt Alfred Kluever * @since 10.0 */ @GwtIncompatible
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sun Jun 20 10:45:35 UTC 2021 - 2.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Atomics.java
import com.google.common.annotations.GwtIncompatible; import java.util.concurrent.atomic.AtomicReference; import java.util.concurrent.atomic.AtomicReferenceArray; import org.checkerframework.checker.nullness.qual.Nullable; /** * Static utility methods pertaining to classes in the {@code java.util.concurrent.atomic} package. * * @author Kurt Alfred Kluever * @since 10.0 */ @GwtIncompatible
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Sun Jun 20 10:45:35 UTC 2021 - 2.5K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/tools/go/analysis/passes/atomic/atomic.go
) //go:embed doc.go var doc string var Analyzer = &analysis.Analyzer{ Name: "atomic", Doc: analysisutil.MustExtractDoc(doc, "atomic"), URL: "https://pkg.go.dev/golang.org/x/tools/go/analysis/passes/atomic", Requires: []*analysis.Analyzer{inspect.Analyzer}, RunDespiteErrors: true, Run: run, } func run(pass *analysis.Pass) (interface{}, error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 2.3K bytes - Viewed (0) -
src/cmd/vet/testdata/atomic/atomic.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // This file contains tests for the atomic checker. package atomic import "sync/atomic" func AtomicTests() { x := uint64(1) x = atomic.AddUint64(&x, 1) // ERROR "direct assignment to atomic value"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Feb 20 15:46:42 UTC 2019 - 364 bytes - Viewed (0) -
test/codegen/atomics.go
// These tests check that atomic instructions without dynamic checks are // generated for architectures that support them package codegen import "sync/atomic" type Counter struct { count int32 } func (c *Counter) Increment() { // Check that ARm64 v8.0 has both atomic instruction (LDADDALW) and a dynamic check // (for arm64HasATOMICS), while ARM64 v8.1 has only atomic and no dynamic check.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 20:08:06 UTC 2024 - 728 bytes - Viewed (0) -
src/cmd/go/testdata/script/build_output.txt
exists -exec mygofmt ! exists mygofmt.exe ! exists gofmt ! exists gofmt.exe go build sync/atomic ! exists atomic ! exists atomic.exe go build -o myatomic.a sync/atomic exists myatomic.a exec $GOBIN/isarchive myatomic.a ! exists atomic ! exists atomic.a ! exists atomic.exe ! go build -o whatever cmd/gofmt sync/atomic stderr 'multiple packages' -- go.mod -- module m go 1.16 -- x.go --
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 24 21:26:10 UTC 2022 - 1.8K bytes - Viewed (0)