- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 1,357 for atomics (0.16 sec)
-
src/cmd/cgo/internal/testcarchive/testdata/libgo4/libgo4.go
pthread_kill(*p, SIGIO); } */ import "C" import ( "os" "os/signal" "sync/atomic" "syscall" ) var sigioCount int32 // Catch SIGIO. // //export GoCatchSIGIO func GoCatchSIGIO() { c := make(chan os.Signal, 1) signal.Notify(c, syscall.SIGIO) go func() { for range c { atomic.AddInt32(&sigioCount, 1) } }() } // Raise SIGIO. // //export GoRaiseSIGIO
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 11:59:56 UTC 2023 - 854 bytes - Viewed (0) -
pilot/pkg/server/instance_test.go
close(c.c) } } type fakeComponent struct { started *atomic.Bool completed *atomic.Bool d time.Duration stop chan struct{} } func newFakeComponent(d time.Duration, stop chan struct{}) *fakeComponent { return &fakeComponent{ started: atomic.NewBool(false), completed: atomic.NewBool(false), d: d, stop: stop, } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 23:02:39 UTC 2024 - 4.1K bytes - Viewed (0) -
test/inline_sync.go
once.Do(small5) // ERROR "inlining call to sync\.\(\*Once\)\.Do" "inlining call to atomic\.\(\*Uint32\)\.Load" } var rwmutex *sync.RWMutex func small8() { // ERROR "can inline small8" // the RUnlock fast path should be inlined rwmutex.RUnlock() // ERROR "inlining call to sync\.\(\*RWMutex\)\.RUnlock" "inlining call to atomic\.\(\*Int32\)\.Add" } func small9() { // ERROR "can inline small9"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 06 21:01:50 UTC 2023 - 1.6K bytes - Viewed (0) -
src/cmd/go/testdata/script/cover_atomic_pkgall.txt
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 19 19:57:03 UTC 2019 - 316 bytes - Viewed (0) -
pilot/pkg/model/test/mockopenidserver.go
log.Infof("Successfully serving on %s", ms.URL) atomic.StoreUint64(&ms.OpenIDHitNum, 0) atomic.StoreUint64(&ms.PubKeyHitNum, 0) ms.server = server return nil } _ = ms.Stop() return errors.New("server failed to start") } // Stop stops he mock server. func (ms *MockOpenIDDiscoveryServer) Stop() error { atomic.StoreUint64(&ms.OpenIDHitNum, 0) atomic.StoreUint64(&ms.PubKeyHitNum, 0)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 09:47:21 UTC 2024 - 9.4K bytes - Viewed (0) -
test/fixedbugs/issue16948.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Sep 01 14:25:46 UTC 2016 - 703 bytes - Viewed (0) -
src/cmd/cgo/internal/test/issue9400_linux.go
import ( "runtime" "runtime/debug" "sync/atomic" "testing" "cmd/cgo/internal/test/issue9400" ) func test9400(t *testing.T) { // We synchronize through a shared variable, so we need two procs defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(2)) // Start signaller atomic.StoreInt32(&issue9400.Baton, 0) go func() { // Wait for RewindAndSetgid for atomic.LoadInt32(&issue9400.Baton) == 0 { runtime.Gosched()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 18 19:55:29 UTC 2023 - 1.7K bytes - Viewed (0) -
internal/config/lambda/target/webhook.go
ID: target.id, ActiveRequests: atomic.LoadInt64(&target.activeRequests), TotalRequests: atomic.LoadInt64(&target.totalRequests), FailedRequests: atomic.LoadInt64(&target.failedRequests), } } // Send - sends an event to the webhook. func (target *WebhookTarget) Send(eventData event.Event) (resp *http.Response, err error) { atomic.AddInt64(&target.activeRequests, 1)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6.7K bytes - Viewed (0) -
platforms/software/testing-base-infrastructure/src/main/java/org/gradle/api/tasks/testing/TestResult.java
*/ long getEndTime(); /** * Returns the total number of atomic tests executed for this test. This will return 1 if this test is itself an * atomic test. * * @return The number of tests, possibly 0 */ long getTestCount(); /** * Returns the number of successful atomic tests executed for this test. * * @return The number of tests, possibly 0 */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 13 20:33:30 UTC 2024 - 3.2K bytes - Viewed (0) -
cmd/metrics-v3-cluster-iam.go
lastSyncTime := atomic.LoadUint64(&globalIAMSys.LastRefreshTimeUnixNano) if lastSyncTime != 0 { m.Set(sinceLastSyncMillis, float64((uint64(time.Now().UnixNano())-lastSyncTime)/uint64(time.Millisecond))) } m.Set(syncFailures, float64(atomic.LoadUint64(&globalIAMSys.TotalRefreshFailures))) m.Set(syncSuccesses, float64(atomic.LoadUint64(&globalIAMSys.TotalRefreshSuccesses))) return nil
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 02 08:20:42 UTC 2024 - 4.5K bytes - Viewed (0)