- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 466 for blocked (0.34 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) -
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) -
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) -
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) -
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) -
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) -
tensorflow/compiler/mlir/tensorflow/ir/tf_device_ops.td
regions inside ParallelExecute op is blocked until all inputs to all regions are materialized and ops following ParallelExecute op are blocked until all regions are executed. }]; let results = (outs Variadic<AnyType>:$execute_outputs ); let regions = (region VariadicRegion<SizedRegion<1>>:$regions); let extraClassDeclaration = [{ Block& GetRegionBlockWithIndex(unsigned index);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Jan 23 23:53:20 UTC 2024 - 14.8K bytes - Viewed (0)