- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 733 for poop (0.04 sec)
-
src/sync/pool.go
// Get selects an arbitrary item from the [Pool], removes it from the // Pool, and returns it to the caller. // Get may choose to ignore the pool and treat it as empty. // Callers should not assume any relation between values passed to [Pool.Put] and // the values returned by Get. // // If Get would otherwise return nil and p.New is non-nil, Get returns // the result of calling p.New. func (p *Pool) Get() any { if race.Enabled {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 21:14:51 UTC 2024 - 9.4K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/wait/loop.go
// cancelled. The returned error is the error returned by the last condition or the // context error if the context was terminated. // // This is the common loop construct for all polling in the wait package. func loopConditionUntilContext(ctx context.Context, t Timer, immediate, sliding bool, condition ConditionWithContextFunc) error { defer t.Stop() var timeCh <-chan time.Time
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 02:47:00 UTC 2023 - 2.8K bytes - Viewed (0) -
cmd/erasure-server-pool-decom_test.go
name: "Invalid-Decom-Pending-Pool-Removal", expectedErr: false, expectedUpdate: true, }, { meta: nmeta1, pools: reducedPools, name: "Correct-Decom-Pool-Removed", expectedErr: false, expectedUpdate: true, }, { meta: poolMeta{}, // no-pool info available fresh setup. pools: pools,
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jul 03 16:47:40 UTC 2023 - 4.8K bytes - Viewed (0) -
pilot/pkg/status/resourcelock.go
// WorkerQueue implements an expandable goroutine pool which executes at most one concurrent routine per target // resource. Multiple calls to Push() will not schedule multiple executions per target resource, but will ensure that // the single execution uses the latest value. type WorkerQueue interface { // Push a task. Push(target Resource, controller *Controller, context any) // Run the loop until a signal on the context Run(ctx context.Context)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6.4K bytes - Viewed (0) -
src/sync/pool_test.go
t.Fatalf("got %v; want 3", v) } } // Test that Pool does not hold pointers to previously cached resources. func TestPoolGC(t *testing.T) { testPool(t, true) } // Test that Pool releases resources on GC. func TestPoolRelease(t *testing.T) { testPool(t, false) } func testPool(t *testing.T, drain bool) { var p Pool const N = 100 loop: for try := 0; try < 3; try++ {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 8K bytes - Viewed (0) -
src/main/assemblies/files/fess
# -v print fess version, then exit # -D prop set JAVA system property # -X prop set non-standard JAVA system property # --prop=val # --prop val set fess property (i.e. -Des.<prop>=<val>) CDPATH="" SCRIPT="$0" # SCRIPT may be an arbitrarily deep series of symlinks. Loop until we have the concrete path. while [ -h "$SCRIPT" ] ; do ls=`ls -ld "$SCRIPT"`
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Sun Jan 15 06:32:15 UTC 2023 - 5.4K bytes - Viewed (0) -
src/internal/poll/splice_linux.go
// splicePipePool caches pipes to avoid high-frequency construction and destruction of pipe buffers. // The garbage collector will free all pipes in the sync.Pool periodically, thus we need to set up // a finalizer for each pipe to close its file descriptors before the actual GC. var splicePipePool = sync.Pool{New: newPoolPipe} func newPoolPipe() any { // Discard the error which occurred during the creation of pipe buffer,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 02 21:49:26 UTC 2024 - 7.6K bytes - Viewed (0) -
pkg/registry/core/service/allocator/bitmap.go
r.lock.Lock() defer r.lock.Unlock() return r.max - r.count } // Snapshot saves the current state of the pool. func (r *AllocationBitmap) Snapshot() (string, []byte) { r.lock.Lock() defer r.lock.Unlock() return r.rangeSpec, r.allocated.Bytes() } // Restore restores the pool to the previously captured state. func (r *AllocationBitmap) Restore(rangeSpec string, data []byte) error { r.lock.Lock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 25 20:32:40 UTC 2023 - 7.6K bytes - Viewed (0) -
tensorflow/compiler/mlir/lite/stablehlo/transforms/composite_avg_pool.cc
std::array<int, 4> GetPadOpPaddingValues(const TorchAvgPoolData& pool) { int pad_bottom = pool.ph; int pad_right = pool.pw; if (pool.ceil_mode) { const int remaining_bottom = pool.h_in - ((pool.h_out - 1) * pool.sh); const int ceil_pad_bottom = pool.kh - remaining_bottom; pad_bottom = ceil_pad_bottom - pool.ph; const int remaining_right = pool.w_in - ((pool.w_out - 1) * pool.sw);
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue May 28 23:16:05 UTC 2024 - 9.2K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/test/groovy/org/gradle/util/ConfigureUtilTest.groovy
def prop = "prop" def foo = "foo" when: ConfigureUtil.configureByMap(["$prop": 'value'], obj, ["$foo"]) then: def e = thrown(IncompleteInputException) e.missingKeys.contains("foo") when: ConfigureUtil.configureByMap(["$prop": 'value'], obj, ["$prop"]) then: assert obj.prop == 'value' }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 23 17:40:52 UTC 2024 - 4.9K bytes - Viewed (0)