- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 2,460 for syncs (0.04 sec)
-
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) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/r65/ToolingApiShutdownCrossVersionSpec.groovy
} """.stripIndent() def sync = server.expectAndBlock("waiting") def resultHandler = new TestResultHandler() when: def connector = toolingApi.connector() ProjectConnection connection = connector.connect() def query = connection.model(EclipseProject) query.get(resultHandler) sync.waitForAllPendingCalls(resultHandler)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 16 10:10:39 UTC 2024 - 11.5K bytes - Viewed (0) -
src/cmd/vet/testdata/copylock/copylock.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jul 26 21:34:18 UTC 2021 - 333 bytes - Viewed (0) -
platforms/software/resources-sftp/src/integTest/groovy/org/gradle/integtests/resolve/resource/sftp/SftpClientReuseIntegrationTest.groovy
${coordinator.callFromBuild('sync')} } dependsOn firstUse } task reuseClient(type: SftpTask) { credentials = creds dependsOn block } """ sftpServer.expectLstat("/") def sync = coordinator.expectAndBlock('sync') when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 12 19:38:08 UTC 2023 - 3K bytes - Viewed (0) -
pilot/pkg/xds/debug.go
return false } userIP, _ := netip.ParseAddr(ip) return userIP.IsLoopback() } // Syncz dumps the synchronization status of all Envoys connected to this Pilot instance func (s *DiscoveryServer) Syncz(w http.ResponseWriter, req *http.Request) { namespace := req.URL.Query().Get("namespace") syncz := make([]SyncStatus, 0) for _, con := range s.SortedClients() { node := con.proxy
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 39.5K bytes - Viewed (0) -
src/runtime/race/testdata/cgo_test_main.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. package main /* int sync; void Notify(void) { __sync_fetch_and_add(&sync, 1); } void Wait(void) { while(__sync_fetch_and_add(&sync, 0) == 0) {} } */ import "C" func main() { data := 0 go func() { data = 1 C.Notify() }() C.Wait() _ = data
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Sep 08 04:08:51 UTC 2014 - 415 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/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)