- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 1,199 for syncAt (0.1 sec)
-
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/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) -
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) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
return sync.get(); } @Override public boolean isDone() { return sync.isDone(); } @Override public boolean isCancelled() { return sync.isCancelled(); } @CanIgnoreReturnValue @Override public boolean cancel(boolean mayInterruptIfRunning) { if (!sync.cancel(mayInterruptIfRunning)) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 09 15:17:25 UTC 2018 - 13.6K 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) -
api/openapi-spec/v3/apis__apps__v1_openapi.json
NotOlderThan\n is interpreted as \"data at least as new as the provided `resourceVersion`\"\n and the bookmark event is send when the state is synced\n to a `resourceVersion` at least as fresh as the one provided by the ListOptions.\n If `resourceVersion` is unset, this is interpreted as \"consistent read\" and the\n bookmark event is send when the state is synced at least to the moment\n when request started being processed.\n- `resourceVersionMatch` set to any other value or unset\n Invalid error...
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 810.7K bytes - Viewed (0) -
src/cmd/trace/testdata/testprog/main.go
package main import ( "fmt" "log" "net" "os" "runtime" "runtime/trace" "sync" "syscall" "time" ) func main() { if err := trace.Start(os.Stdout); err != nil { log.Fatal(err) } // checkExecutionTimes relies on this. var wg sync.WaitGroup wg.Add(2) go cpu10(&wg) go cpu20(&wg) wg.Wait() // checkHeapMetrics relies on this.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 17:15:58 UTC 2024 - 2.5K bytes - Viewed (0) -
test/fixedbugs/bug512.go
// license that can be found in the LICENSE file. // Gccgo did not make a copy of a value receiver when using a // goroutine to call a method. package main import ( "sync" "sync/atomic" ) var wg sync.WaitGroup type S struct { i1, i2 int32 } var done int32 func (s S) Check(v1, v2 int32) { for { if g1 := atomic.LoadInt32(&s.i1); v1 != g1 { panic(g1) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 17 19:15:18 UTC 2021 - 793 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) -
test/fixedbugs/issue9110.go
time.Sleep(1 * time.Millisecond) // pick up top sudog var cond1 sync.Cond var mu1 sync.Mutex cond1.L = &mu1 go func() { mu1.Lock() cond1.Wait() mu1.Unlock() }() time.Sleep(1 * time.Millisecond) // pick up next sudog var cond2 sync.Cond var mu2 sync.Mutex cond2.L = &mu2 go func() { mu2.Lock() cond2.Wait() mu2.Unlock() }()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 02 13:43:18 UTC 2016 - 1.7K bytes - Viewed (0)