- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 192 for blocked (0.12 sec)
-
platforms/core-execution/execution-e2e-tests/src/integTest/groovy/org/gradle/integtests/ParallelProjectExecutionIntegrationTest.groovy
tasks.getByPath(':b:pingC').dependsOn([':b:pingA', ':b:pingB']) """ expect: //project a and b are both executed even though alphabetically more important task is blocked blockingServer.expectConcurrent(':b:pingB', ':a:pingA') blockingServer.expect(':b:pingA') blockingServer.expect(':b:pingC') run 'b:pingC' }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Mar 04 10:15:40 UTC 2024 - 4.9K bytes - Viewed (0) -
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) -
platforms/core-runtime/client-services/src/main/java/org/gradle/internal/daemon/client/clientinput/DaemonClientInputForwarder.java
) { this.userInput = userInput; // Use a single reader thread, and make it a daemon thread so that it does not block process shutdown // In most cases, we try to cleanly shut down all threads. However, in this case it is difficult to disconnect a thread blocked trying to read from the // process' stdin, so use a daemon thread instead. executor = Executors.newSingleThreadExecutor(r -> {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:53:31 UTC 2024 - 5.8K bytes - Viewed (0) -
src/internal/trace/parser.go
EvGoBlock = 20 // goroutine blocks [timestamp, stack] EvGoUnblock = 21 // goroutine is unblocked [timestamp, goroutine id, seq, stack] EvGoBlockSend = 22 // goroutine blocks on chan send [timestamp, stack] EvGoBlockRecv = 23 // goroutine blocks on chan recv [timestamp, stack] EvGoBlockSelect = 24 // goroutine blocks on select [timestamp, stack]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:31:04 UTC 2024 - 4.7K bytes - Viewed (0) -
test/chan/select3.go
time.Sleep(10 * time.Millisecond) } c <- always // f blocked always }() if <-c != signal { panic(signal + " block") } } func main() { const async = 1 // asynchronous channels var nilch chan int closedch := make(chan int) close(closedch) // sending/receiving from a nil channel blocks testBlock(always, func() { nilch <- 7 }) testBlock(always, func() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Jul 08 02:10:12 UTC 2017 - 4.1K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/api/DaemonStateControl.java
* Requests that a running build be canceled. Note that this method does NOT block until the operation has been cancelled. */ void requestCancel(); /** * Communicates a request for build cancellation. Note that this method blocks until the operation has been cancelled. * * <p>If any long running command is currently running, this method does block for certain time to give chance to perform cancellation, and if the command
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun May 05 22:24:02 UTC 2024 - 3.6K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/RecordedRequest.kt
* Returns the name of the server the client requested via the SNI (Server Name Indication) * attribute in the TLS handshake. Unlike the rest of the HTTP exchange, this name is sent in * cleartext and may be monitored or blocked by a proxy or other middlebox. */ val handshakeServerNames: List<String> init { if (socket is SSLSocket) { try { this.handshake = socket.session.handshake()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 3.8K bytes - Viewed (0) -
pkg/registry/scheduling/rest/storage_scheduling.go
if err == nil || apierrors.IsAlreadyExists(err) { klog.Infof("created PriorityClass %s with value %v", pc.Name, pc.Value) continue } // ServiceUnavailble error is returned when the API server is blocked by storage version updates if apierrors.IsServiceUnavailable(err) { klog.Infof("going to retry, unable to create PriorityClass %s: %v", pc.Name, err) return false, nil } return false, err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 23 18:36:33 UTC 2022 - 4.7K bytes - Viewed (0) -
src/net/mptcpsock_linux_test.go
t.Error("outgoing connection is not an MPTCP proto") } } func canCreateMPTCPSocket() bool { // We want to know if we can create an MPTCP socket, not just if it is // available (mptcpAvailable()): it could be blocked by the admin fd, err := syscall.Socket(syscall.AF_INET, syscall.SOCK_STREAM, _IPPROTO_MPTCP) if err != nil { return false } syscall.Close(fd) return true }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jul 11 00:36:57 UTC 2023 - 4.1K bytes - Viewed (0) -
src/sync/waitgroup.go
state atomic.Uint64 // high 32 bits are counter, low 32 bits are waiter count. sema uint32 } // Add adds delta, which may be negative, to the [WaitGroup] counter. // If the counter becomes zero, all goroutines blocked on [WaitGroup.Wait] are released. // If the counter goes negative, Add panics. // // Note that calls with a positive delta that occur when the counter is zero
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 4K bytes - Viewed (0)