the queue-draining loop drains the queues in the order specified by this class and consults this method before going on to drain the next queue . the method determines the skew of the queue the loop is about to drain : it is the difference between its watermark and the bottom watermark i.e. , that of the first queue in the draining order . the policy will signal to stop draining if : some data was already drained and the queue has exceeded the configured `` priority draining '' skew threshold , or the queue has exceeded the configured maxskew and theconfigured policy is not to force-advance the watermark . concode_field_sep long maxSkew concode_elem_sep boolean forceAdvanceWm concode_elem_sep long priorityDrainingThreshold concode_elem_sep int[] drainOrderToQIdx concode_elem_sep long[] queueWms concode_field_sep long topObservedWm concode_elem_sep int toQueueIndex concode_elem_sep boolean observeWm concode_elem_sep long bottomObservedWm concode_elem_sep int findNewDrainPos concode_elem_sep void forceAdvanceWmIfConfigured concode_elem_sep boolean adjustDrainingOrder concode_elem_sep int findCurrentDrainPos
boolean function ( int arg0 , boolean arg1 ) { long loc0 = subtractClamped ( queueWms [ arg0 ] , queueWms [ drainOrderToQIdx [ 0 ] ] ) ; return ( arg1 && loc0 > priorityDrainingThreshold ) || ( ! forceAdvanceWm && loc0 > maxSkew ) ; }