- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 310 for queuesa (0.12 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt
delayNanos: Long, ) { lock.assertHeld() val queue = task.queue!! check(queue.activeTask === task) val cancelActiveTask = queue.cancelActiveTask queue.cancelActiveTask = false queue.activeTask = null busyQueues.remove(queue) if (delayNanos != -1L && !cancelActiveTask && !queue.shutdown) { queue.scheduleAndDecide(task, delayNanos, recurrence = true) }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 10.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go
// qsCompleter holds the QueueSetCompleter derived from `config` // and `queues`. qsCompleter fq.QueueSetCompleter // The QueueSet for this priority level. // Never nil. queues fq.QueueSet // quiescing==true indicates that this priority level should be // removed when its queues have all drained. quiescing bool // number of goroutines between Controller::Match and calling the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 48.8K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/endpointslicemirroring_controller.go
cKey, quit := c.queue.Get() if quit { return false } defer c.queue.Done(cKey) err := c.syncEndpoints(logger, cKey) c.handleErr(logger, err, cKey) return true } func (c *Controller) handleErr(logger klog.Logger, err error, key string) { if err == nil { c.queue.Forget(key) return } if c.queue.NumRequeues(key) < maxRetries {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 06 23:18:31 UTC 2024 - 20.1K bytes - Viewed (0) -
staging/src/k8s.io/api/flowcontrol/v1/types.go
type QueuingConfiguration struct { // `queues` is the number of queues for this priority level. The // queues exist independently at each apiserver. The value must be // positive. Setting it to 1 effectively precludes // shufflesharding and thus makes the distinguisher method of // associated flow schemas irrelevant. This field has a default // value of 64. // +optional Queues int32 `json:"queues" protobuf:"varint,1,opt,name=queues"`
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 23 17:42:49 UTC 2024 - 31.1K bytes - Viewed (0) -
internal/grid/connection.go
} case toSend = <-c.outQueue: if len(toSend) == 0 { continue } } if len(queue) < maxMergeMessages && queueSize+len(toSend) < writeBufferSize-1024 && len(c.outQueue) > 0 { queue = append(queue, toSend) queueSize += len(toSend) continue } c.outMessages.Add(int64(len(queue) + 1)) if c.outgoingBytes != nil { c.outgoingBytes(int64(len(toSend) + queueSize)) }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 44.8K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DefaultDaemonConnection.java
// 3. Stop receiving incoming messages. Blocks until the receive thread has finished. This will notify the stdin and receive queues to signal end of input. // 4. Stop the receive queue, to unblock any threads blocked in receive(). // 5. Stop handling stdin. Blocks until the handler has finished. Discards any queued input. CompositeStoppable.stoppable(disconnectQueue, connection, executor, receiveQueue, stdinQueue, cancelQueue).stop();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 16K bytes - Viewed (0) -
pkg/controller/endpointslice/endpointslice_controller.go
// onServiceDelete removes the Service Selector from the cache and queues the Service for processing. func (c *Controller) onServiceDelete(obj interface{}) { key, err := controller.KeyFunc(obj) if err != nil { utilruntime.HandleError(fmt.Errorf("Couldn't get key for object %+v: %v", obj, err)) return } c.serviceQueue.Add(key) } // onEndpointSliceAdd queues a sync for the relevant Service for a sync if the
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 08:33:32 UTC 2024 - 23.6K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultConditionalExecutionQueue.java
* the thread pool is full of work items that are waiting on other queued work items. The queued work items cannot execute * because the thread pool is already full with their parent work items. We use expand() to allow the thread pool to temporarily * expand when work items have to wait on other work. The thread pool will shrink below max workers again once the queue is * drained. */ private void expand(boolean force) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:40 UTC 2024 - 7.2K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/range_allocator.go
err := func(logger klog.Logger, obj interface{}) error { // We call Done here so the workNodeQueue knows we have finished // processing this item. We also must remember to call Forget if we // do not want this work item being re-queued. For example, we do // not call Forget if a transient error occurs, instead the item is // put back on the queue and attempted again after a back-off
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 16.2K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
// A pod added with a deletion timestamp should decrement deletions, not creations. manager.addPod(logger, &pod) queueRS, _ := manager.queue.Get() if queueRS != rsKey { t.Fatalf("Expected to find key %v in queue, found %v", rsKey, queueRS) } manager.queue.Done(rsKey) podExp, exists, err := manager.expectations.GetExpectations(rsKey) if !exists || err != nil || !podExp.Fulfilled() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0)