Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 244 for blocked (0.34 sec)

  1. 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)
  2. src/sync/rwmutex.go

    	return r < 0 && r+rwmutexMaxReaders > 0
    }
    
    // RLocker returns a [Locker] interface that implements
    // the [RWMutex.Lock] and [RWMutex.Unlock] methods by calling rw.RLock and rw.RUnlock.
    func (rw *RWMutex) RLocker() Locker {
    	return (*rlocker)(rw)
    }
    
    type rlocker RWMutex
    
    func (r *rlocker) Lock()   { (*RWMutex)(r).RLock() }
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 21:14:51 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  3. tests/integration/helm/install_test.go

    			framework.
    				NewTest(t).
    				Run(setupInstallation(ambientProfileOverride, true, tt.nsConfig, ""))
    		})
    	}
    }
    
    // TestReleaseChannels tests that non-stable CRDs and fields get blocked
    // by the default ValidatingAdmissionPolicy
    func TestReleaseChannels(t *testing.T) {
    	overrideValuesStr := `
    global:
      hub: %s
      tag: %s
      variant: %q
    profile: stable
    `
    
    	framework.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 09 19:04:51 UTC 2024
    - 7.7K bytes
    - Viewed (0)
  4. src/internal/trace/testdata/testprog/stress-start-stop.go

    // Use of this source code is governed by a BSD-style
    // license that can be found in the LICENSE file.
    
    // Tests a many interesting cases (network, syscalls, a little GC, busy goroutines,
    // blocked goroutines, LockOSThread, pipes, and GOMAXPROCS).
    
    //go:build ignore
    
    package main
    
    import (
    	"bytes"
    	"io"
    	"log"
    	"net"
    	"os"
    	"runtime"
    	"runtime/trace"
    	"sync"
    	"time"
    )
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  5. src/internal/trace/trace_test.go

    			// of entered -> blocked -> runnable -> running. If in the running state
    			// we block, then we have a futile wakeup. Because of the runtime.Gosched
    			// on these specially marked goroutines, we should end up back in runnable
    			// first. If at any point we go to a different state, switch back to entered
    			// and wait for the next time the goroutine blocks.
    			if ev.Kind() != trace.EventStateTransition {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  6. src/internal/trace/testdata/testprog/stacks.go

    	// Now we will do a bunch of things for which we verify stacks later.
    	// It is impossible to ensure that a goroutine has actually blocked
    	// on a channel, in a select or otherwise. So we kick off goroutines
    	// that need to block first in the hope that while we are executing
    	// the rest of the test, they will block.
    	go func() { // func1
    		select {}
    	}()
    	go func() { // func2
    		var c chan int
    		c <- 0
    	}()
    	go func() { // func3
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 18:48:18 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  7. src/runtime/preempt.go

    // Goroutine preemption
    //
    // A goroutine can be preempted at any safe-point. Currently, there
    // are a few categories of safe-points:
    //
    // 1. A blocked safe-point occurs for the duration that a goroutine is
    //    descheduled, blocked on synchronization, or in a system call.
    //
    // 2. Synchronous safe-points occur when a running goroutine checks
    //    for a preemption request.
    //
    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/traceevent.go

    	traceEvGoBlock             // goroutine blocks [timestamp, reason, stack ID]
    	traceEvGoUnblock           // goroutine is unblocked [timestamp, goroutine ID, goroutine seq, stack ID]
    	traceEvGoSyscallBegin      // syscall enter [timestamp, P seq, stack ID]
    	traceEvGoSyscallEnd        // syscall exit [timestamp]
    	traceEvGoSyscallEndBlocked // syscall exit and it blocked at some point [timestamp]
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 08 17:47:01 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  9. src/runtime/sema.go

    // The operations on the inner lists of sudogs with the same address
    // are all O(1). The scanning of the top-level semaRoot list is O(log n),
    // where n is the number of distinct addresses with goroutines blocked
    // on them that hash to the given semaRoot.
    // See golang.org/issue/17953 for a program that worked badly
    // before we introduced the second level of list, and
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 19K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/server/healthz/healthz.go

    func (ping) Name() string {
    	return "ping"
    }
    
    // PingHealthz is a health check that returns true.
    func (ping) Check(_ *http.Request) error {
    	return nil
    }
    
    // LogHealthz returns true if logging is not blocked
    var LogHealthz HealthChecker = &log{}
    
    type log struct {
    	startOnce    sync.Once
    	lastVerified atomic.Value
    }
    
    func (l *log) Name() string {
    	return "log"
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 19:11:24 UTC 2024
    - 10.5K bytes
    - Viewed (0)
Back to top