- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 587 for blocked (0.31 sec)
-
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) -
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) -
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) -
src/runtime/runtime2.go
preemptoff string // if != "", keep curg running on this m locks int32 dying int32 profilehz int32 spinning bool // m is out of work and is actively looking for work blocked bool // m is blocked on a note newSigstack bool // minit on C thread called sigaltstack printlock int8 incgo bool // m is executing a cgo call isextra bool // m is an extra m
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:57:37 UTC 2024 - 47.9K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoExecutor.java
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Feb 28 23:31:09 UTC 2024 - 20.7K bytes - Viewed (0) -
src/runtime/signal_unix.go
} } // blockableSig reports whether sig may be blocked by the signal mask. // We never want to block the signals marked _SigUnblock; // these are the synchronous signals that turn into a Go panic. // We never want to block the preemption signal if it is being used. // In a Go program--not a c-archive/c-shared--we never want to block // the signals marked _SigKill or _SigThrow, as otherwise it's possible
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 16:04:54 UTC 2024 - 45K bytes - Viewed (0)