- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 587 for blocked (0.14 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/mutating_work_estimator.go
// if currently unoccupied seats would allow for dispatching some // other requests in the meantime // As a consequence of these, the wider the request, the more capacity // will effectively be blocked and unused during dispatching and // executing this request. // // To mitigate the impact of it, we're capping the maximum number of // seats that can be assigned to a given request. Thanks to it:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 19:26:52 UTC 2023 - 6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller_test.go
}() // Start controller wg.Add(1) go func() { defer wg.Done() stopReason := myController.Run(testContext) require.ErrorIs(t, stopReason, context.Canceled) }() // The controller is blocked because the reconcile function sends on an // unbuffered channel. require.False(t, myController.HasSynced()) // Wait for all enqueued reconciliations require.NoError(t, waitForReconcile(initialObject))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 12 18:58:24 UTC 2024 - 16.1K bytes - Viewed (0) -
src/cmd/trace/threadgen.go
start = ctx.startTime } // Write down that we've entered a syscall. Note: we might have no P here // if we're in a cgo callback or this is a transition from GoUndetermined // (i.e. the G has been blocked in a syscall). gs.syscallBegin(start, ev.Thread(), ev.Stack()) } // Note down the goroutine transition. _, inMarkAssist := gs.activeRanges["GC mark assist"]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 5.7K bytes - Viewed (0) -
src/runtime/pprof/pprof.go
// the program began (including garbage-collected bytes). // // # Block profile // // The block profile tracks time spent blocked on synchronization primitives, // such as [sync.Mutex], [sync.RWMutex], [sync.WaitGroup], [sync.Cond], and // channel send/receive/select. // // Stack traces correspond to the location that blocked (for example, // [sync.Mutex.Lock]). //
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 30 17:52:17 UTC 2024 - 30.6K bytes - Viewed (0) -
test/closedchan.go
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // Test close(c), receive of closed channel. // // TODO(rsc): Doesn't check behavior of close(c) when there // are blocked senders/receivers. package main import "os" var failed bool type Chan interface { Send(int) Nbsend(int) bool Recv() (int) Nbrecv() (int, bool) Recv2() (int, bool)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Feb 17 04:48:57 UTC 2012 - 5.8K bytes - Viewed (0) -
api/maven-api-settings/src/main/mdo/settings.mdo
@since Maven 3. </description> </field> <field> <name>blocked</name> <version>1.2.0+</version> <type>boolean</type> <defaultValue>false</defaultValue> <description> <![CDATA[ Whether this mirror should be blocked from any download request but fail the download process, explaining why.
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Sat Feb 17 18:40:11 UTC 2024 - 33.3K bytes - Viewed (0) -
src/runtime/traceruntime.go
tl.eventWriter(traceGoRunning, traceProcRunning).commit(traceEvGCMarkAssistEnd) } // GoCreate emits a GoCreate event. func (tl traceLocker) GoCreate(newg *g, pc uintptr, blocked bool) { newg.trace.setStatusTraced(tl.gen) ev := traceEvGoCreate if blocked { ev = traceEvGoCreateBlocked } tl.eventWriter(traceGoRunning, traceProcRunning).commit(ev, traceArg(newg.goid), tl.startPC(pc), tl.stack(2)) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:31:00 UTC 2024 - 25.7K bytes - Viewed (0) -
testing/internal-testing/src/test/groovy/org/gradle/test/fixtures/concurrent/ConcurrentSpecTest.groovy
thread.block() worker.runLater(action2) } then: instant.action2Completed < instant.action1Completed } def "can use instants to test that a method blocks until action is complete"() { Worker worker = new Worker(executor) given: def action = { thread.block() instant.actionCompleted }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 8.7K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/BlockingHttpServer.java
* Waits for the request to be received and blocked. */ void waitUntilBlocked(); /** * Unblock the request. */ void release(); } /** * Allows the test to synchronise with and unblock requests. */ public interface BlockingHandler { /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 21.7K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
} else { onlineServers++ } mu.Unlock() }(clnt) } wg.Wait() select { case <-ctx.Done(): return ctx.Err() default: // Sleep and stagger to avoid blocked CPU and thundering // herd upon start up sequence. time.Sleep(25*time.Millisecond + time.Duration(rand.Int63n(int64(100*time.Millisecond)))) retries++
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 7.5K bytes - Viewed (0)