Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 54 for defBlock (0.26 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. src/runtime/proc.go

    		// scheduler state, so we didn't gcstopm in findRunnable, but
    		// also don't want to allow new goroutines to run.
    		//
    		// Deadlock here rather than in the findRunnable loop so if
    		// findRunnable is stuck in a loop we don't perturb that
    		// either.
    		lock(&deadlock)
    		lock(&deadlock)
    	}
    
    	// This thread is going to run a goroutine and is not spinning anymore,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 207.5K bytes
    - Viewed (0)
  9. src/runtime/mgc.go

    	lock(&sched.deferlock)
    	// disconnect cached list before dropping it on the floor,
    	// so that a dangling ref to one entry does not pin all of them.
    	var d, dlink *_defer
    	for d = sched.deferpool; d != nil; d = dlink {
    		dlink = d.link
    		d.link = nil
    	}
    	sched.deferpool = nil
    	unlock(&sched.deferlock)
    }
    
    // Timing
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 62K bytes
    - Viewed (0)
  10. src/runtime/coro.go

    			gnext = next.ptr()
    			break
    		}
    	}
    
    	// Check if we're switching to ourselves. This case is able to break our
    	// thread-lock invariants and an unbuffered channel implementation of
    	// coroswitch would deadlock. It's clear that this case should just not
    	// work.
    	if gnext == gp {
    		throw("coroswitch of a goroutine to itself")
    	}
    
    	// Emit the trace event after getting gnext but before changing curg.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 19:09:18 UTC 2024
    - 7.4K bytes
    - Viewed (0)
Back to top