- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 736 for block64 (0.16 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) -
internal/lock/lock_test.go
case <-locked: t.Error("unexpected unblocking") case <-time.After(100 * time.Millisecond): } // unlock if err = dupl.Close(); err != nil { t.Fatal(err) } // the previously blocked routine should be unblocked select { case <-locked: case <-time.After(1 * time.Second): t.Error("unexpected blocking") }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 19 18:05:16 UTC 2022 - 3.6K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/functional_control_flow_to_cfg.cc
// ... // Block* orig_block_head = op_inst->getBlock(); Block* orig_block_tail = orig_block_head->splitBlock(op); Block* cond_block = builder.createBlock(orig_block_tail); Block* body_block = builder.createBlock(orig_block_tail); // Set argument types for the cond_block to be same as the types of the // condition function and argument types for the other two blocks to be same
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Jan 13 11:42:59 UTC 2023 - 12.2K bytes - Viewed (0) -
src/os/signal/signal_linux_test.go
"syscall" "testing" "time" ) const prSetKeepCaps = 8 // This test validates that syscall.AllThreadsSyscall() can reliably // reach all 'm' (threads) of the nocgo runtime even when one thread // is blocked waiting to receive signals from the kernel. This monitors // for a regression vs. the fix for #43149. func TestAllThreadsSyscallSignals(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 28 18:17:57 UTC 2021 - 1.1K bytes - Viewed (0) -
src/cmd/go/internal/lockedfile/internal/filelock/filelock_test.go
}() select { case <-done: t.Fatalf("%s unexpectedly did not block", desc) return nil case <-time.After(quiescent): t.Logf("%s is blocked (as expected)", desc) return func(t *testing.T) { t.Helper() select { case <-time.After(probablyStillBlocked): t.Fatalf("%s is unexpectedly still blocked", desc) case <-done: } } } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Apr 06 22:37:50 UTC 2023 - 4K 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) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/WorkerLeaseService.java
* the locks upon completion. Blocks until the specified locks can be obtained. */ <T> T withLocks(Collection<? extends ResourceLock> locks, Factory<T> factory); /** * Runs a given {@link Runnable} while the specified locks are being held, releasing * the locks upon completion. Blocks until the specified locks can be obtained. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 06:02:18 UTC 2024 - 3.4K bytes - Viewed (0) -
src/cmd/compile/internal/ssa/func.go
f.freeValues = v } // NewBlock allocates a new Block of the given kind and places it at the end of f.Blocks. func (f *Func) NewBlock(kind BlockKind) *Block { var b *Block if f.freeBlocks != nil { b = f.freeBlocks f.freeBlocks = b.succstorage[0].b b.succstorage[0].b = nil } else { ID := f.bid.get() if int(ID) < len(f.Cache.blocks) { b = &f.Cache.blocks[ID] b.ID = ID } else {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 19:44:43 UTC 2024 - 25.8K bytes - Viewed (0) -
.github/workflows/notify-on-rc-for-manual-test.yml
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 02 09:13:16 UTC 2024 - 1K bytes - Viewed (0)