- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 71 for defBlock (0.21 sec)
-
src/runtime/crash_test.go
testCrashHandler(t, false) } func testDeadlock(t *testing.T, name string) { // External linking brings in cgo, causing deadlock detection not working. testenv.MustInternalLink(t, false) output := runTestProg(t, "testprog", name) want := "fatal error: all goroutines are asleep - deadlock!\n" if !strings.HasPrefix(output, want) { t.Fatalf("output does not start with %q:\n%s", want, output) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 19:46:10 UTC 2024 - 27K bytes - Viewed (0) -
src/runtime/mklockrank.go
// select. "hchan": true, // Multiple hchanLeafs are acquired in hchan.sortkey() order in // syncadjustsudogs(). "hchanLeaf": true, // The point of the deadlock lock is to deadlock. "deadlock": true, } func main() { flagO := flag.String("o", "", "write to `file` instead of stdout") flagDot := flag.Bool("dot", false, "emit graphviz output instead of Go") flag.Parse()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 9.1K bytes - Viewed (0) -
platforms/core-runtime/logging/src/main/java/org/gradle/internal/logging/console/ProgressBar.java
Future<?> ignored = deadlockPreventer.submit(new Runnable() { @Override public void run() { // do not do this directly or a deadlock happens // to prevent that deadlock, execute it separately in another thread LOGGER.warn("More progress was logged than there should be ({} > {})", current, total); } }); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 5.7K bytes - Viewed (0) -
src/runtime/panic.go
mp := acquirem() pp := mp.p.ptr() if len(pp.deferpool) == 0 && sched.deferpool != nil { lock(&sched.deferlock) for len(pp.deferpool) < cap(pp.deferpool)/2 && sched.deferpool != nil { d := sched.deferpool sched.deferpool = d.link d.link = nil pp.deferpool = append(pp.deferpool, d) } unlock(&sched.deferlock) } if n := len(pp.deferpool); n > 0 { d = pp.deferpool[n-1] pp.deferpool[n-1] = nil
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 43.8K bytes - Viewed (0) -
src/sync/once.go
// arguments to a function to be invoked by Do: // // config.once.Do(func() { config.init(filename) }) // // Because no call to Do returns until the one call to f returns, if f causes // Do to be called, it will deadlock. // // If f panics, Do considers it to have returned; future calls of Do return // without calling f. func (o *Once) Do(f func()) { // Note: Here is an incorrect implementation of Do: //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 2.5K bytes - Viewed (0) -
pkg/kube/krt/fetch.go
ff := func(o []Event[T], initialSync bool) { f(slices.Map(o, castEvent[T, any]), initialSync) } // Skip calling all the existing state for secondary dependencies, otherwise we end up with a deadlock due to // rerunning the same collection's recomputation at the same time (once for the initial event, then for the initial registration). c.RegisterBatch(ff, false) }) // Now we can do the real fetching
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 23:33:56 UTC 2024 - 2.6K bytes - Viewed (0) -
src/runtime/time_fake.go
func time_now() (sec int64, nsec int32, mono int64) { return faketime / 1e9, int32(faketime % 1e9), faketime } // write is like the Unix write system call. // We have to avoid write barriers to avoid potential deadlock // on write calls. // //go:nowritebarrierrec func write(fd uintptr, p unsafe.Pointer, n int32) int32 { if !(fd == 1 || fd == 2) { // Do an ordinary write. return write1(fd, p, n) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:15:13 UTC 2024 - 2.5K bytes - Viewed (0) -
src/runtime/preempt.go
// the current M (if any) must be in a preemptible state. This // prevents deadlocks where two goroutines attempt to suspend each // other and both are in non-preemptible states. There are other ways // to resolve this deadlock, but this seems simplest. // // TODO(austin): What if we instead required this to be called from a // user goroutine? Then we could deschedule the goroutine while
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 15:41:45 UTC 2024 - 15.1K bytes - Viewed (0) -
src/runtime/rwmutex.go
const rwmutexMaxReaders = 1 << 30 // rlock locks rw for reading. func (rw *rwmutex) rlock() { // The reader must not be allowed to lose its P or else other // things blocking on the lock may consume all of the Ps and // deadlock (issue #20903). Alternatively, we could drop the P // while sleeping. acquireLockRankAndM(rw.readRank) lockWithRankMayAcquire(&rw.rLock, getLockRank(&rw.rLock)) if rw.readerCount.Add(1) < 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 22 14:29:04 UTC 2024 - 5K bytes - Viewed (0) -
src/runtime/os_windows.go
// CreateThread may fail if called // concurrently with ExitProcess. If this // happens, just freeze this thread and let // the process exit. See issue #18253. lock(&deadlock) lock(&deadlock) } print("runtime: failed to create new OS thread (have ", mcount(), " already; errno=", getlasterror(), ")\n") throw("runtime.newosproc") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 22:55:25 UTC 2024 - 41.5K bytes - Viewed (0)