- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 90 for unlock2 (0.29 sec)
-
src/runtime/mgcpacer.go
out = gcController.setMemoryLimit(in) if in < 0 || out == in { // If we're just checking the value or not changing // it, there's no point in doing the rest. unlock(&mheap_.lock) return } gcControllerCommit() unlock(&mheap_.lock) }) return out } func readGOMEMLIMIT() int64 { p := gogetenv("GOMEMLIMIT") if p == "" || p == "off" { return maxInt64 }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 55.4K bytes - Viewed (0) -
platforms/documentation/docs/src/snippets/native-binaries/google-test/groovy/libs/googleTest/1.7.0/include/gtest/internal/gtest-port.h
// Acquires this mutex. void Lock() { GTEST_CHECK_POSIX_SUCCESS_(pthread_mutex_lock(&mutex_)); owner_ = pthread_self(); has_owner_ = true; } // Releases this mutex. void Unlock() { // Since the lock is being released the owner_ field should no longer be // considered valid. We don't protect writing to has_owner_ here, as it's
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Nov 27 17:53:42 UTC 2023 - 67.2K bytes - Viewed (0) -
testing/performance/src/templates/native-dependents-resources/googleTest/libs/googleTest/1.7.0/include/gtest/internal/gtest-port.h
// Acquires this mutex. void Lock() { GTEST_CHECK_POSIX_SUCCESS_(pthread_mutex_lock(&mutex_)); owner_ = pthread_self(); has_owner_ = true; } // Releases this mutex. void Unlock() { // Since the lock is being released the owner_ field should no longer be // considered valid. We don't protect writing to has_owner_ here, as it's
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 67.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/fairqueuing/queueset/queueset_test.go
var errsLock sync.Mutex expectQNCount := func(fn int, inQueue bool, expect int32) { if a := atomic.LoadInt32(queueNoteCounts[fn][inQueue]); a != expect { errsLock.Lock() defer errsLock.Unlock() fatalErrs = append(fatalErrs, fmt.Sprintf("Got %d calls to queueNoteFn%d(%v), expected %d", a, fn, inQueue, expect)) } } expectQNCounts := func(fn int, expectF, expectT int32) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 26 12:55:23 UTC 2023 - 58.4K bytes - Viewed (0) -
subprojects/diagnostics/src/main/resources/org/gradle/api/tasks/diagnostics/htmldependencyreport/jquery.jstree.js
var rslt, func = val, args = Array.prototype.slice.call(arguments), evnt = new $.Event("before.jstree"), rlbk = false; if(this.data.core.locked === true && i !== "unlock" && i !== "is_locked") { return; } // Check if function belongs to the included plugins of this instance do { if(func && func.plugin && $.inArray(func.plugin, this._get_settings().plugins) !== -1) { break; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Nov 04 09:03:42 UTC 2021 - 49.5K bytes - Viewed (0) -
src/internal/trace/order.go
// N.B. No context to validate. Basically anything can unblock // a goroutine (e.g. sysmon). o.queue.push(Event{table: evt, ctx: curCtx, base: *ev}) return curCtx, true, nil } func (o *ordering) advanceGoSwitch(ev *baseEvent, evt *evTable, m ThreadID, gen uint64, curCtx schedCtx) (schedCtx, bool, error) { // GoSwitch and GoSwitchDestroy represent a trio of events: // - Unblock of the goroutine to switch to.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 52.4K bytes - Viewed (0) -
src/cmd/dist/build.go
} func startInstall(dir string) chan struct{} { installedMu.Lock() ch := installed[dir] if ch == nil { ch = make(chan struct{}) installed[dir] = ch go runInstall(dir, ch) } installedMu.Unlock() return ch } // runInstall installs the library, package, or binary associated with pkg, // which is relative to $GOROOT/src. func runInstall(pkg string, ch chan struct{}) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon May 20 18:34:40 UTC 2024 - 54K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/unix/syscall_zos_s390x.go
p := &b[cap(b)-1] m.Lock() defer m.Unlock() m.active[p] = b return b, nil } func (m *mmapper) Munmap(data []byte) (err error) { if len(data) == 0 || len(data) != cap(data) { return EINVAL } // Find the base of the mapping. p := &data[cap(data)-1] m.Lock() defer m.Unlock() b := m.active[p] if b == nil || &b[0] != &data[0] {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 16:12:58 UTC 2024 - 84.4K bytes - Viewed (0) -
src/net/http/httputil/reverseproxy_test.go
backendURL, err := url.Parse(backend.URL) if err != nil { t.Fatal(err) } var ( mu sync.Mutex log []string ) addLog := func(event string) { mu.Lock() defer mu.Unlock() log = append(log, event) } rp := NewSingleHostReverseProxy(backendURL) const size = 1234 rp.BufferPool = bufferPool{ get: func() []byte { addLog("getBuf") return make([]byte, size)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 54.6K bytes - Viewed (0) -
src/syscall/zsyscall_darwin_arm64.go
} return } func libc_msync_trampoline() //go:cgo_import_dynamic libc_msync msync "/usr/lib/libSystem.B.dylib" // THIS FILE IS GENERATED BY THE COMMAND AT THE TOP; DO NOT EDIT func Munlock(b []byte) (err error) { var _p0 unsafe.Pointer if len(b) > 0 { _p0 = unsafe.Pointer(&b[0]) } else { _p0 = unsafe.Pointer(&_zero) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Nov 27 21:34:30 UTC 2023 - 51.7K bytes - Viewed (0)