- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 601 for syncAt (0.27 sec)
-
src/cmd/cgo/internal/test/testx.c
void lockOSThreadC(void) { lockOSThreadCallback(); } void issue7978c(uint32_t *sync) { while(__atomic_load_n(sync, __ATOMIC_SEQ_CST) != 0) ; __atomic_add_fetch(sync, 1, __ATOMIC_SEQ_CST); while(__atomic_load_n(sync, __ATOMIC_SEQ_CST) != 2) ; issue7978cb(); __atomic_add_fetch(sync, 1, __ATOMIC_SEQ_CST); while(__atomic_load_n(sync, __ATOMIC_SEQ_CST) != 6) ; } void f7665(void) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 12:00:02 UTC 2023 - 582 bytes - Viewed (0) -
src/runtime/race/testdata/rwmutex_test.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package race_test import ( "sync" "testing" "time" ) func TestRaceMutexRWMutex(t *testing.T) { var mu1 sync.Mutex var mu2 sync.RWMutex var x int16 = 0 _ = x ch := make(chan bool, 2) go func() { mu1.Lock() defer mu1.Unlock() x = 1 ch <- true }() go func() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Nov 03 22:09:38 UTC 2017 - 2.1K bytes - Viewed (0) -
pkg/kube/controllers/example_test.go
// This is typically only needed for leader election controllers, as otherwise the controller lifecycle // is typically the same as the informer. c.pods.ShutdownHandlers() } // HasSynced asserts we have "synced", meaning we have processed the initial state. func (c *Controller) HasSynced() bool { // We could check `c.pods` as well, but it is redundant due to the Run() implementation. // Instead, just check `c.queue`.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7K bytes - Viewed (0) -
src/cmd/cgo/internal/test/issue9400/asm_mipsx.s
// will clobber the test pattern created by the caller ADDU $(1024*8), R29 // Ask signaller to setgid MOVW $1, R1 SYNC MOVW R1, ·Baton(SB) SYNC // Wait for setgid completion loop: SYNC MOVW ·Baton(SB), R1 OR R2, R2, R2 // hint that we're in a spin loop BNE R1, loop SYNC // Restore stack ADDU $(-1024*8), R29
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 12:00:02 UTC 2023 - 663 bytes - Viewed (0) -
src/cmd/cgo/internal/test/issue9400/asm_mips64x.s
#include "textflag.h" #define SYNC WORD $0xf TEXT ·RewindAndSetgid(SB),NOSPLIT|NOFRAME,$0-0 // Rewind stack pointer so anything that happens on the stack // will clobber the test pattern created by the caller ADDV $(1024*8), R29 // Ask signaller to setgid MOVW $1, R1 SYNC MOVW R1, ·Baton(SB) SYNC // Wait for setgid completion loop: SYNC MOVW ·Baton(SB), R1
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Dec 15 21:57:36 UTC 2023 - 691 bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/metrics/metrics.go
var ( // EndpointsAddedPerSync tracks the number of endpoints added on each // Endpoints sync. EndpointsAddedPerSync = metrics.NewHistogramVec( &metrics.HistogramOpts{ Subsystem: EndpointSliceMirroringSubsystem, Name: "endpoints_added_per_sync", Help: "Number of endpoints added on each Endpoints sync", StabilityLevel: metrics.ALPHA, Buckets: metrics.ExponentialBuckets(2, 2, 15), },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 06 19:43:35 UTC 2020 - 5.2K bytes - Viewed (0) -
src/cmd/go/testdata/script/work_sync_toolchain.txt
go work init ./m1_22_0 ./m1_22_1 grep '^go 1.50$' go.work ! grep toolchain go.work # work sync with older modules should leave go 1.50 in the go.work. go work sync cat go.work grep '^go 1.50$' go.work ! grep toolchain go.work # work sync with newer modules should update go 1.21 -> 1.22.1 and toolchain -> go1.22.9 in go.work env TESTGO_VERSION=go1.21 env TESTGO_VERSION_SWITCH=switch
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Jun 03 21:13:11 UTC 2023 - 1.6K bytes - Viewed (0) -
pkg/volume/metrics_cached.go
return md.resultError }) return md.resultMetrics, md.resultError } // Copied from sync.Once but we don't want to cache the results if there is an // error type cacheOnce struct { m sync.Mutex done uint32 } // Copied from sync.Once but we don't want to cache the results if there is an // error func (o *cacheOnce) cache(f func() error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 16 11:12:06 UTC 2022 - 1.9K bytes - Viewed (0) -
pkg/kube/krt/testing.go
c.(internalCollection[O]).dump() } type TestingDummyContext struct{} func (t TestingDummyContext) _internalHandler() { } func (t TestingDummyContext) registerDependency(d *dependency, s Syncer, f func(f erasedEventHandler)) { } func (t TestingDummyContext) name() string { return "testing" } var ( _ registerDependency = TestingDummyContext{} _ HandlerContext = TestingDummyContext{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 1.1K bytes - Viewed (0) -
src/cmd/link/internal/ld/outbuf.go
// backed buffer that will get synced to disk. // - Munmap the output file // // And finally, it provides a mechanism by which you can multithread the // writing of output files. This mechanism is accomplished by copying a OutBuf, // and using it in the thread/goroutine. // // Parallel OutBuf is intended to be used like: // // func write(out *OutBuf) { // var wg sync.WaitGroup // for i := 0; i < 10; i++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue May 17 19:51:29 UTC 2022 - 8.1K bytes - Viewed (0)