- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 587 for blocked (0.17 sec)
-
tensorflow/c/eager/immediate_execution_context.h
DEVICE_PLACEMENT_EXPLICIT = 0, // Copy the tensor to the right device but log a warning. DEVICE_PLACEMENT_WARN = 1, // Silently copy the tensor, which has a performance cost since the operation // will be blocked till the copy completes. This is the default policy. DEVICE_PLACEMENT_SILENT = 2, // Placement policy which silently copies int32 tensors but not other dtypes. DEVICE_PLACEMENT_SILENT_FOR_INT32 = 3, };
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Jul 06 08:34:00 UTC 2023 - 12.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storageversion/manager.go
return fmt.Errorf("couldn't find managed status for %v", gr) } return s.managedStatus[gr].lastErr } // setComplete marks the completion of updating StorageVersions. No write requests need to be blocked anymore. func (s *defaultManager) setComplete() { s.completed.Store(true) } // Completed returns if updating StorageVersions has completed. func (s *defaultManager) Completed() bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 17:47:19 UTC 2023 - 10.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/buffered/buffered.go
// sent to the Sink. Deep copy and send the copy to the queue. event := e.DeepCopy() select { case b.buffer <- event: default: sendErr = fmt.Errorf("audit buffer queue blocked") return true } } return true } func (b *bufferedBackend) String() string { return fmt.Sprintf("%s<%s>", PluginName, b.delegateBackend)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 9.1K bytes - Viewed (0) -
internal/grid/manager.go
Incoming func(n int64) // Record incoming bytes. Outgoing func(n int64) // Record outgoing bytes. BlockConnect chan struct{} // If set, incoming and outgoing connections will be blocked until closed. TraceTo *pubsub.PubSub[madmin.TraceInfo, madmin.TraceType] } // NewManager creates a new grid manager func NewManager(ctx context.Context, o ManagerOptions) (*Manager, error) { found := false
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 17:40:33 UTC 2024 - 9.8K bytes - Viewed (0) -
src/runtime/debug/garbage.go
// // The limit controls the number of operating system threads, not the number // of goroutines. A Go program creates a new thread only when a goroutine // is ready to run but all the existing threads are blocked in system calls, cgo calls, // or are locked to other goroutines due to use of runtime.LockOSThread. // // SetMaxThreads is useful mainly for limiting the damage done by // programs that create an unbounded number of threads. The idea is
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 9.9K bytes - Viewed (0) -
src/cmd/trace/goroutines.go
<td> <a href="/io?name={{.Name}}">graph</a> <a href="/io?name={{.Name}}&raw=1" download="io.profile">(download)</a></td> </tr> <tr> <td>Sync block profile:</td> <td> <a href="/block?name={{.Name}}">graph</a> <a href="/block?name={{.Name}}&raw=1" download="block.profile">(download)</a></td> </tr> <tr> <td>Syscall profile:</td>
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 10.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureBenchmarks.java
abstract <T> Facade<T> newFacade(); } static void awaitWaiting(Thread t) { while (true) { Thread.State state = t.getState(); switch (state) { case RUNNABLE: case BLOCKED: Thread.yield(); break; case WAITING: return; default: throw new AssertionError("unexpected state: " + state); } } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed May 09 15:17:25 UTC 2018 - 13.6K bytes - Viewed (0) -
internal/dsync/dsync_test.go
// non-profitable and allows to confirm that spinning does not do harm. // To achieve this we create excess of goroutines most of which do local work. // These goroutines yield during local work, so that switching from // a blocked goroutine to other goroutines is profitable. // As a matter of fact, this benchmark still triggers some spinning in the mutex. m := NewDRWMutex(ds, "") var acc0, acc1 uint64 b.SetParallelism(4)
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Dec 24 03:49:07 UTC 2022 - 11K bytes - Viewed (0) -
src/cmd/trace/pprof.go
return makeComputePprofFunc(trace.GoWaiting, func(reason string) bool { return reason == "network" }) } // computePprofBlock returns a computePprofFunc that generates blocking pprof-like profile // (time spent blocked on synchronization primitives). func computePprofBlock() computePprofFunc { return makeComputePprofFunc(trace.GoWaiting, func(reason string) bool {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 10.1K bytes - Viewed (0) -
src/runtime/os_netbsd.go
// baroque to remove a signal stack here only to add one in minit, but // it's a simple change that keeps NetBSD working like other OS's. // At this point all signals are blocked, so there is no race. // //go:nosplit func netbsdMstart0() { st := stackt{ss_flags: _SS_DISABLE} sigaltstack(&st, nil) mstart0() } func osinit() { ncpu = getncpu()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 10.1K bytes - Viewed (0)