- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 49 for mp (0.34 sec)
-
src/runtime/print.go
func printlock() { mp := getg().m mp.locks++ // do not reschedule between printlock++ and lock(&debuglock). mp.printlock++ if mp.printlock == 1 { lock(&debuglock) } mp.locks-- // now we know debuglock is held and holding up mp.locks for us. } func printunlock() { mp := getg().m mp.printlock-- if mp.printlock == 0 { unlock(&debuglock) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jan 20 03:27:26 UTC 2023 - 5.9K bytes - Viewed (0) -
src/image/draw/clip_test.go
for _, c := range clipTests { dst := dst0.SubImage(c.dr).(*image.RGBA) src := src0.SubImage(c.sr).(*image.RGBA) r, sp, mp := c.r, c.sp, c.mp if c.nilMask { clip(dst, &r, src, &sp, nil, nil) } else { clip(dst, &r, src, &sp, mask0.SubImage(c.mr), &mp) } // Check that the actual results equal the expected results. if !c.r0.Eq(r) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Jul 20 18:07:05 UTC 2023 - 4.4K bytes - Viewed (0) -
maven-plugin-api/src/test/java/org/apache/maven/plugin/descriptor/PluginDescriptorBuilderTest.java
Parameter mp = md.getParameters().get(0); assertEquals("finalName", mp.getName()); assertEquals("jarName", mp.getAlias()); assertEquals("java.lang.String", mp.getType()); assertEquals("java.lang.String", mp.getImplementation()); assertTrue(mp.isEditable()); assertFalse(mp.isRequired());
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Nov 17 15:51:47 UTC 2023 - 5.4K bytes - Viewed (0) -
src/runtime/coro.go
locked := gp.lockedm != 0 if c.mp != nil || locked { if mp != c.mp || mp.lockedInt != c.lockedInt || mp.lockedExt != c.lockedExt { print("coro: got thread ", unsafe.Pointer(mp), ", want ", unsafe.Pointer(c.mp), "\n") print("coro: got lock internal ", mp.lockedInt, ", want ", c.lockedInt, "\n") print("coro: got lock external ", mp.lockedExt, ", want ", c.lockedExt, "\n")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 19:09:18 UTC 2024 - 7.4K bytes - Viewed (0) -
test/fixedbugs/issue29329.go
} func (ls LineString) Clone() LineString { ps := MultiPoint(ls) return LineString(ps.Clone()) } type MultiPoint []Point func (mp MultiPoint) Clone() MultiPoint { if mp == nil { return nil } points := make([]Point, len(mp)) copy(points, mp) return MultiPoint(points) } func F1() { cases := []struct { threshold float64 length int }{ {0.1, 1118}, {0.5, 257},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:25 UTC 2023 - 1.9K bytes - Viewed (0) -
src/runtime/os_openbsd.go
return -1 } } } //go:nosplit func semawakeup(mp *m) { atomic.Xadd(&mp.waitsemacount, 1) ret := thrwakeup(uintptr(unsafe.Pointer(&mp.waitsemacount)), 1) if ret != 0 && ret != _ESRCH { // semawakeup can be called on signal stack. systemstack(func() { print("thrwakeup addr=", &mp.waitsemacount, " sem=", mp.waitsemacount, " ret=", ret, "\n") }) } } func osinit() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 6.2K bytes - Viewed (0) -
src/runtime/lock_sema.go
// // func semacreate(mp *m) // Create a semaphore for mp, if it does not already have one. // // func semasleep(ns int64) int32 // If ns < 0, acquire m's semaphore and return 0. // If ns >= 0, try to acquire m's semaphore for at most ns nanoseconds. // Return 0 if the semaphore was acquired, -1 if interrupted or timed out. // // func semawakeup(mp *m) // Wake up mp, which is or will soon be sleeping on its semaphore.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 6.8K bytes - Viewed (0) -
internal/mountinfo/mountinfo_linux_test.go
t.Fatalf("expected 3 mounts, got %d", len(mounts)) } mp := mountInfo{"/dev/0", "/path/to/0", "type0", []string{"flags"}, "0", "0"} if !mountPointsEqual(mounts[0], mp) { t.Errorf("got unexpected MountPoint[0]: %#v", mounts[0]) } mp = mountInfo{"/dev/1", "/path/to/1", "type1", []string{"flags"}, "1", "1"} if !mountPointsEqual(mounts[1], mp) { t.Errorf("got unexpected mountInfo[1]: %#v", mounts[1]) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 18 07:03:17 UTC 2024 - 7.3K bytes - Viewed (0) -
src/runtime/export_unix_test.go
// a non-zero byte to w, WaitForSigusr1 returns immediately with -1, -1. func WaitForSigusr1(r, w int32, ready func(mp *M)) (int64, int64) { lockOSThread() // Make sure we can receive SIGUSR1. unblocksig(_SIGUSR1) waitForSigusr1.rdpipe = r waitForSigusr1.wrpipe = w mp := getg().m testSigusr1 = waitForSigusr1Callback ready(mp) // Wait for the signal. We use a pipe rather than a note // because write is always async-signal-safe.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat May 20 21:27:51 UTC 2023 - 2.3K bytes - Viewed (0) -
src/runtime/lock_js.go
id := scheduleTimeoutEvent(delay) mp := acquirem() notes[n] = gp notesWithTimeout[n] = noteWithTimeout{gp: gp, deadline: deadline} releasem(mp) gopark(nil, nil, waitReasonSleep, traceBlockSleep, 1) clearTimeoutEvent(id) // note might have woken early, clear timeout mp = acquirem() delete(notes, n) delete(notesWithTimeout, n) releasem(mp) return n.key == note_woken }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 21:02:20 UTC 2023 - 7.3K bytes - Viewed (0)