Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 244 for blocked (1.2 sec)

  1. platforms/core-runtime/internal-instrumentation-api/src/main/java/org/gradle/internal/instrumentation/api/annotations/ToBeReplacedByLazyProperty.java

     */
    @Retention(RetentionPolicy.CLASS)
    @Target({ElementType.METHOD})
    public @interface ToBeReplacedByLazyProperty {
    
        /**
         * Additional comment, e.g. why upgrade of a property is blocked.
         */
        String comment() default "";
    
        /**
         * Link to a GitHub issue if it exists.
         */
        String issue() default "";
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 22 09:58:15 UTC 2024
    - 1.2K bytes
    - Viewed (0)
  2. src/cmd/trace/goroutinegen.go

    	}
    
    	if from == trace.GoWaiting {
    		// Goroutine unblocked.
    		gs.unblock(ev.Time(), ev.Stack(), ev.Goroutine(), ctx)
    	}
    	if from == trace.GoNotExist && to == trace.GoRunnable {
    		// Goroutine was created.
    		gs.created(ev.Time(), ev.Goroutine(), ev.Stack())
    	}
    	if from == trace.GoSyscall && to != trace.GoRunning {
    		// Exiting blocked syscall.
    		gs.syscallEnd(ev.Time(), true, ctx)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. 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)
  6. src/cmd/vendor/golang.org/x/sync/semaphore/semaphore.go

    		if next == nil {
    			break // No more waiters blocked.
    		}
    
    		w := next.Value.(waiter)
    		if s.size-s.cur < w.n {
    			// Not enough tokens for the next waiter.  We could keep going (to try to
    			// find a waiter with a smaller request), but under load that could cause
    			// starvation for large requests; instead, we leave all remaining waiters
    			// blocked.
    			//
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 03 02:38:00 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  7. src/crypto/rand/rand_plan9.go

    		r.mu.Unlock()
    		return 0, err
    	}
    	var (
    		counter uint64
    		block   [aes.BlockSize]byte
    	)
    	inc := func() {
    		counter++
    		if counter == 0 {
    			panic("crypto/rand counter wrapped")
    		}
    		byteorder.LePutUint64(block[:], counter)
    	}
    	blockCipher.Encrypt(r.key[:aes.BlockSize], block[:])
    	inc()
    	blockCipher.Encrypt(r.key[aes.BlockSize:], block[:])
    	inc()
    	r.mu.Unlock()
    
    	n = len(b)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 13 18:57:38 UTC 2024
    - 1.8K 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/sync/mutex.go

    // relation at all.
    //
    // [the Go memory model]: https://go.dev/ref/mem
    type Mutex struct {
    	state int32
    	sema  uint32
    }
    
    // A Locker represents an object that can be locked and unlocked.
    type Locker interface {
    	Lock()
    	Unlock()
    }
    
    const (
    	mutexLocked = 1 << iota // mutex is locked
    	mutexWoken
    	mutexStarving
    	mutexWaiterShift = iota
    
    	// Mutex fairness.
    	//
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  10. 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)
Back to top