- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 135 for Queuing (0.12 sec)
-
pkg/printers/internalversion/printers_test.go
Limited: &flowcontrol.LimitedPriorityLevelConfiguration{ NominalConcurrencyShares: 42, LimitResponse: flowcontrol.LimitResponse{ Type: flowcontrol.LimitResponseTypeQueue, Queuing: &flowcontrol.QueuingConfiguration{ Queues: 8, HandSize: 3, QueueLengthLimit: 4, }, }, }, }, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 14:04:15 UTC 2024 - 218.6K bytes - Viewed (0) -
src/main/java/jcifs/smb1/netbios/NodeStatusResponse.java
private NbtAddress queryAddress; private int numberOfNames; private byte[] macAddress; private byte[] stats; NbtAddress[] addressArray; /* It is a little awkward but prudent to pass the quering address * so that it may be included in the list of results. IOW we do * not want to create a new NbtAddress object for this particular * address from which the query is constructed, we want to populate
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 6K bytes - Viewed (0) -
pkg/controller/deployment/progress.go
// transition either to a Complete or to a TimedOut condition. if after < time.Second { logger.V(4).Info("Queueing up deployment for a progress check now", "deployment", klog.KObj(d)) dc.enqueueRateLimited(d) return time.Duration(0) } logger.V(4).Info("Queueing up deployment for a progress check", "deployment", klog.KObj(d), "queueAfter", int(after.Seconds()))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 13 11:00:44 UTC 2023 - 8.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/schedulinggates/scheduling_gates.go
func (pl *SchedulingGates) EventsToRegister() []framework.ClusterEventWithHint { if !pl.enableSchedulingQueueHint { return nil } // When the QueueingHint feature is enabled, // the scheduling queue uses Pod/Update Queueing Hint // to determine whether a Pod's update makes the Pod schedulable or not. // https://github.com/kubernetes/kubernetes/pull/122234 return []framework.ClusterEventWithHint{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 3.2K bytes - Viewed (0) -
src/main/java/jcifs/netbios/NodeStatusResponse.java
private int numberOfNames; private byte[] macAddress; private byte[] stats; NbtAddress[] addressArray; /* * It is a little awkward but prudent to pass the quering address * so that it may be included in the list of results. IOW we do * not want to create a new NbtAddress object for this particular * address from which the query is constructed, we want to populate
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 5.9K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/Dispatcher.java
// second thread can then dispatch to the subscriber it took before the first thread does. // // All this makes me really wonder if there's any value in queueing here at all. A dispatcher // that simply loops through the subscribers and dispatches the event to each would actually // probably provide a stronger order guarantee, though that order would obviously be different
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Dec 15 19:31:54 UTC 2023 - 7.3K bytes - Viewed (0) -
guava/src/com/google/common/eventbus/Dispatcher.java
// second thread can then dispatch to the subscriber it took before the first thread does. // // All this makes me really wonder if there's any value in queueing here at all. A dispatcher // that simply loops through the subscribers and dispatches the event to each would actually // probably provide a stronger order guarantee, though that order would obviously be different
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Dec 15 19:31:54 UTC 2023 - 7.3K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultConditionalExecutionQueue.java
import java.util.LinkedList; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.ReentrantLock; /** * A queueing mechanism that only executes items once certain conditions are reached. */ // TODO This class, DefaultBuildOperationQueue and ExecutionPlan have many of the same
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:40 UTC 2024 - 7.2K bytes - Viewed (0) -
cmd/global-heal.go
madmin.HealOpts{ ScanMode: scanMode, Remove: healDeleteDangling, }) if err != nil { if isErrObjectNotFound(err) || isErrVersionNotFound(err) { // queueing happens across namespace, ignore // objects that are not found. return } result = healEntryFailure(0) healingLogIf(ctx, fmt.Errorf("unable to heal object %s/%s: %w", bucket, entry.name, err))
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 31 14:48:50 UTC 2024 - 15.1K bytes - Viewed (0) -
pkg/scheduler/scheduler_test.go
{Resource: framework.Pod, ActionType: framework.Add}: { {PluginName: fakePod, QueueingHintFn: defaultQueueingHintFn}, // default queueing hint due to disabled feature gate. }, {Resource: framework.Node, ActionType: framework.Add}: { {PluginName: fakeNode, QueueingHintFn: defaultQueueingHintFn}, // default queueing hint due to disabled feature gate. }, {Resource: framework.Node, ActionType: framework.UpdateNodeTaint}: {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 42K bytes - Viewed (0)