- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 255 for Sleeping (0.3 sec)
-
pkg/kubelet/status/state/state_checkpoint.go
type stateCheckpoint struct { mux sync.RWMutex cache State checkpointManager checkpointmanager.CheckpointManager checkpointName string } // NewStateCheckpoint creates new State for keeping track of pod resource allocations with checkpoint backend func NewStateCheckpoint(stateDir, checkpointName string) (State, error) { checkpointManager, err := checkpointmanager.NewCheckpointManager(stateDir) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 13 00:16:44 UTC 2023 - 6.9K bytes - Viewed (0) -
src/crypto/internal/boring/bcache/cache.go
// is, the cache is lossy, and the loss happens at the start of each GC. // This means that clients need to be able to cope with cache entries // disappearing, but it also means that clients don't need to worry about // cache entries keeping the keys from being collected. type Cache[K, V any] struct { // The runtime atomically stores nil to ptable at the start of each GC. ptable atomic.Pointer[cacheTable[K, V]] }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Aug 18 00:30:19 UTC 2022 - 4.4K bytes - Viewed (0) -
CONTRIBUTING.md
code is a great way to give something back to the open source community. Before you dig right into the code, there are a few guidelines that we need contributors to follow so that we can have a chance of keeping on top of things. Some of the ideas are documented in the [Maven Wiki][maven-wiki] which might be interesting to read and for further discussion. Getting Started ---------------
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Sun Oct 10 09:48:27 UTC 2021 - 4.7K bytes - Viewed (0) -
src/go/ast/example_test.go
f, err := parser.ParseFile(fset, "src.go", src, parser.ParseComments) if err != nil { panic(err) } // Create an ast.CommentMap from the ast.File's comments. // This helps keeping the association between comments // and AST nodes. cmap := ast.NewCommentMap(fset, f, f.Comments) // Remove the first variable declaration from the list of declarations. for i, decl := range f.Decls {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 15 21:44:50 UTC 2024 - 6.1K bytes - Viewed (0) -
cmd/metacache-bucket.go
// Test on a copy // cleanup is the only one deleting caches. caches, _ := b.cloneCaches() for id, cache := range caches { if !cache.worthKeeping() { b.debugf("cache %s not worth keeping", id) remove[id] = struct{}{} continue } if cache.id != id { logger.Info("cache ID mismatch %s != %s", id, cache.id) remove[id] = struct{}{} continue }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6.6K bytes - Viewed (0) -
src/unique/handle.go
} m := ma.(*uniqueMap[T]) // Keep around any values we allocate for insertion. There // are a few different ways we can race with other threads // and create values that we might discard. By keeping // the first one we make around, we can avoid generating // more than one per racing thread. var ( toInsert *T // Keep this around to keep it alive. toInsertWeak weak.Pointer[T] )
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 16:01:55 UTC 2024 - 5.3K bytes - Viewed (0) -
tensorflow/compiler/mlir/quantization/common/attrs_and_constraints.td
"AreSplatValuesEqual<"# type #">($0, $1)">>; // Returns defining op of this value. def GetDefiningOp : NativeCodeCall<"$0.getDefiningOp()">; // Clones an operation with new operands while keeping attributes. def CloneOpWithReplacedOperands : NativeCodeCall< "CloneOpWithReplacedOperands(" "$_builder, $0, llvm::SmallVector<Value>{$1...}).front()">;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Mar 08 04:55:44 UTC 2024 - 6.7K bytes - Viewed (0) -
maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java
import org.slf4j.LoggerFactory; import static java.util.Objects.requireNonNull; /** * A {@link TransferListener} implementation that wraps another delegate {@link TransferListener} but makes it run * on single thread, keeping the listener logic simple. This listener also blocks on last transfer event to allow * output to perform possible cleanup. It spawns a daemon thread to consume queued events that may fall in even * concurrently. *
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 20:50:56 UTC 2024 - 8.4K bytes - Viewed (0) -
pkg/controller/volume/pvprotection/pv_protection_controller.go
// PV should be deleted. Check if it's used and remove finalizer if // it's not. isUsed := c.isBeingUsed(pv) if !isUsed { return c.removeFinalizer(ctx, pv) } logger.V(4).Info("Keeping PV because it is being used", "PV", klog.KRef("", pvName)) } if protectionutil.NeedToAddFinalizer(pv, volumeutil.PVProtectionFinalizer) { // PV is not being deleted -> it should have the finalizer. The
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 6.4K bytes - Viewed (0) -
src/cmd/go/internal/lockedfile/lockedfile.go
// the lock but may not do so promptly: callers must ensure that all locked // files are closed before exiting. type File struct { osFile closed bool } // osFile embeds a *os.File while keeping the pointer itself unexported. // (When we close a File, it must be the same file descriptor that we opened!) type osFile struct { *os.File } // OpenFile is like os.OpenFile, but returns a locked file.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Oct 20 18:41:18 UTC 2020 - 5.1K bytes - Viewed (0)