Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 978 for syncs (0.1 sec)

  1. 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)
  2. 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)
  3. 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)
  4. src/runtime/atomic_pointer.go

    }
    
    // Like above, but implement in terms of sync/atomic's uintptr operations.
    // We cannot just call the runtime routines, because the race detector expects
    // to be able to intercept the sync/atomic forms but not the runtime forms.
    
    //go:linkname sync_atomic_StoreUintptr sync/atomic.StoreUintptr
    func sync_atomic_StoreUintptr(ptr *uintptr, new uintptr)
    
    //go:linkname sync_atomic_StorePointer sync/atomic.StorePointer
    //go:nosplit
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 4K bytes
    - Viewed (0)
  5. src/internal/pkgbits/encoder.go

    	// marker. A negative value means sync markers are omitted.
    	syncFrames int
    }
    
    // SyncMarkers reports whether pw uses sync markers.
    func (pw *PkgEncoder) SyncMarkers() bool { return pw.syncFrames >= 0 }
    
    // NewPkgEncoder returns an initialized PkgEncoder.
    //
    // syncFrames is the number of caller frames that should be serialized
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Aug 10 23:26:58 UTC 2022
    - 9.6K bytes
    - Viewed (0)
  6. platforms/documentation/docs/src/snippets/java-feature-variant/requiring-features-external/tests/runtimeClasspath.out

    org.mongodb:bson:3.9.1
    +--- org.mongodb:mongodb-driver-core:3.9.1
    |    \--- org.mongodb:mongodb-driver-sync:3.9.1
    |         \--- org.gradle.demo:producer:1.0
    |              \--- runtimeClasspath
    \--- org.mongodb:mongodb-driver-sync:3.9.1 (*)
    
    org.mongodb:mongodb-driver-core:3.9.1
      Variant runtime:
        | Attribute Name                 | Provided     | Requested    |
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Nov 27 17:53:42 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  7. src/cmd/vendor/golang.org/x/tools/go/analysis/passes/testinggoroutine/testinggoroutine.go

    			r := c.region
    			if asyncs[r] == nil {
    				regions = append(regions, r)
    			}
    			asyncs[r] = append(asyncs[r], c)
    		}
    	}
    
    	// Collect all of the go callee() and t.Run(name, callee) extents.
    	inspect.Nodes([]ast.Node{
    		(*ast.FuncDecl)(nil),
    		(*ast.GoStmt)(nil),
    		(*ast.CallExpr)(nil),
    	}, func(node ast.Node, push bool) bool {
    		if !push {
    			return false
    		}
    		switch node := node.(type) {
    		case *ast.FuncDecl:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Apr 02 02:20:05 UTC 2024
    - 7.8K bytes
    - Viewed (0)
  8. src/archive/zip/register.go

    type Decompressor func(r io.Reader) io.ReadCloser
    
    var flateWriterPool sync.Pool
    
    func newFlateWriter(w io.Writer) io.WriteCloser {
    	fw, ok := flateWriterPool.Get().(*flate.Writer)
    	if ok {
    		fw.Reset(w)
    	} else {
    		fw, _ = flate.NewWriter(w, 5)
    	}
    	return &pooledFlateWriter{fw: fw}
    }
    
    type pooledFlateWriter struct {
    	mu sync.Mutex // guards Close and Write
    	fw *flate.Writer
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Oct 13 18:36:46 UTC 2023
    - 3.7K bytes
    - Viewed (0)
  9. operator/pkg/cache/cache_test.go

    						}, nil, nil),
    					},
    					Mu: &sync.RWMutex{},
    				},
    			},
    			objCacheRemovalKey: "cache-foo-key",
    			removalKey:         "obj-foo-key",
    			expectedCache: ObjectCache{
    				Cache: map[string]*object.K8sObject{
    					"dont-touch-me-key": object.NewK8sObject(&unstructured.Unstructured{
    						Object: make(map[string]any),
    					}, nil, nil),
    				},
    				Mu: &sync.RWMutex{},
    			},
    		},
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jan 20 18:46:12 UTC 2023
    - 5.3K bytes
    - Viewed (0)
  10. src/internal/trace/testdata/testprog/stacks.go

    	c2 := make(chan int)
    	go func() { // func6
    		select {
    		case <-c1:
    		case <-c2:
    		}
    	}()
    	var mu sync.Mutex
    	mu.Lock()
    	go func() { // func7
    		mu.Lock()
    		mu.Unlock()
    	}()
    	var wg sync.WaitGroup
    	wg.Add(1)
    	go func() { // func8
    		wg.Wait()
    	}()
    	cv := sync.NewCond(&sync.Mutex{})
    	go func() { // func9
    		cv.L.Lock()
    		cv.Wait()
    		cv.L.Unlock()
    	}()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 2.4K bytes
    - Viewed (0)
Back to top