Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 167 for blocked (0.6 sec)

  1. src/cmd/trace/gstate.go

    // and orthogonal to syscallEnd; both must be called if the syscall blocked. This sets up an instant
    // to emit a flow event from, indicating explicitly that this goroutine was unblocked by the system.
    func (gs *gState[R]) blockedSyscallEnd(ts trace.Time, stack trace.Stack, ctx *traceContext) {
    	name := "exit blocked syscall"
    	gs.setStartCause(ts, name, trace.SyscallP, stack)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  2. src/crypto/tls/quic.go

    	defer c.handshakeMutex.Lock()
    	// Send on blockedc to notify the QUICConn that the handshake is blocked.
    	// Exported methods of QUICConn wait for the handshake to become blocked
    	// before returning to the user.
    	select {
    	case c.quic.blockedc <- struct{}{}:
    	case <-c.quic.cancelc:
    		return c.sendAlertLocked(alertCloseNotify)
    	}
    	// The QUICConn reads from signalc to notify us that the handshake may
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 17:23:54 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  3. src/runtime/time.go

    	if !t.isChan || t.blocked == 0 {
    		badTimer()
    	}
    	t.blocked--
    	if t.blocked == 0 && t.state&timerHeaped != 0 && t.state&timerZombie == 0 {
    		// Last goroutine that was blocked on this timer.
    		// Mark for removal from heap but do not clear t.when,
    		// so that we know what time it is still meant to trigger.
    		t.state |= timerZombie
    		t.ts.zombies.Add(1)
    	}
    	t.unlock()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Mar 29 14:36:24 UTC 2024
    - 37.5K bytes
    - Viewed (0)
  4. src/cmd/vendor/golang.org/x/text/unicode/norm/composition.go

    		// is safe.
    		if ii.combinesBackward() {
    			cccB := b[k-1].ccc
    			cccC := ii.ccc
    			blocked := false // b[i] blocked by starter or greater or equal CCC?
    			if cccB == 0 {
    				s = k - 1
    			} else {
    				blocked = s != k-1 && cccB >= cccC
    			}
    			if !blocked {
    				combined := combine(rb.runeAt(s), rb.runeAt(i))
    				if combined != 0 {
    					rb.assignRune(s, combined)
    					continue
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Jan 24 13:01:26 UTC 2024
    - 14.1K bytes
    - Viewed (0)
  5. src/net/net.go

    listed in /etc/resolv.conf, or it can use a cgo-based resolver that calls C
    library routines such as getaddrinfo and getnameinfo.
    
    On Unix the pure Go resolver is preferred over the cgo resolver, because a blocked DNS
    request consumes only a goroutine, while a blocked C call consumes an operating system thread.
    When cgo is available, the cgo-based resolver is used instead under a variety of
    conditions: on systems that do not let programs make direct DNS requests (OS X),
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  6. src/runtime/netpoll.go

    	pd := pollcache.alloc()
    	lock(&pd.lock)
    	wg := pd.wg.Load()
    	if wg != pdNil && wg != pdReady {
    		throw("runtime: blocked write on free polldesc")
    	}
    	rg := pd.rg.Load()
    	if rg != pdNil && rg != pdReady {
    		throw("runtime: blocked read on free polldesc")
    	}
    	pd.fd = fd
    	if pd.fdseq.Load() == 0 {
    		// The value 0 is special in setEventErr, so don't use it.
    		pd.fdseq.Store(1)
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 19:57:43 UTC 2024
    - 20.7K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher_test.go

    	// May sure that the watch will not be blocked on Stop.
    	for i := 0; i < maxRetriesToProduceTheRaceCondition; i++ {
    		w = newCacheWatcher(0, filter, forget, storage.APIObjectVersioner{}, time.Now(), false, schema.GroupResource{Resource: "pods"}, "")
    		go w.Stop()
    		select {
    		case <-done:
    		case <-time.After(time.Second):
    			t.Fatal("stop is blocked when the timer is fired concurrently")
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 09:20:10 UTC 2024
    - 22.9K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

      private static final long SMALL_TIMEOUT_MILLIS = 10;
    
      /** How long to wait when determining that a thread is blocked if we expect it to be blocked. */
      private static final long EXPECTED_HANG_DELAY_MILLIS = 75;
    
      /**
       * How long to wait when determining that a thread is blocked if we DON'T expect it to be blocked.
       */
      private static final long UNEXPECTED_HANG_DELAY_MILLIS = 10000;
    
      /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 29 16:29:37 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  9. src/internal/trace/oldtrace.go

    		// blocked.
    		blocked := false
    		it.events.All()(func(nev *oldtrace.Event) bool {
    			if nev.G != ev.G {
    				return true
    			}
    			// After an EvGoSysCall, the next event on the same G will either be
    			// EvGoSysBlock to denote a blocking syscall, or some other event
    			// (or the end of the trace) if the syscall didn't block.
    			if nev.Type == oldtrace.EvGoSysBlock {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 17.2K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

      private static final long SMALL_TIMEOUT_MILLIS = 10;
    
      /** How long to wait when determining that a thread is blocked if we expect it to be blocked. */
      private static final long EXPECTED_HANG_DELAY_MILLIS = 75;
    
      /**
       * How long to wait when determining that a thread is blocked if we DON'T expect it to be blocked.
       */
      private static final long UNEXPECTED_HANG_DELAY_MILLIS = 10000;
    
      /**
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Wed May 29 16:29:37 UTC 2024
    - 27.1K bytes
    - Viewed (0)
Back to top