forest-uris.xqy

xquery version "1.0-ml";
(:
 : Copyright (c) 2011-2013 Michael Blakeley. All Rights Reserved.
 :
 : Licensed under the Apache License, Version 2.0 (the "License");
 : you may not use this file except in compliance with the License.
 : You may obtain a copy of the License at
 :
 : http://www.apache.org/licenses/LICENSE-2.0
 :
 : Unless required by applicable law or agreed to in writing, software
 : distributed under the License is distributed on an "AS IS" BASIS,
 : WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 : See the License for the specific language governing permissions and
 : limitations under the License.
 :
 : The use of the Apache License does not indicate that this project is
 : affiliated with the Apache Software Foundation.
 :
 :)

import module namespace trb="com.blakeley.task-rebalancer"
  at "lib-trb.xqy" ;

(: This code is designed to minimize FLWOR expressions,
 : and maximize streaming.
 : With no tasks to spawn, this checks URIS at 20-80 k/sec,
 : depending on CPU speed and whether or not the URI lexicon is warm.
 :)

(: the forest to rebalance :)
declare variable $FOREST as xs:unsignedLong external ;

declare variable $TARGETS as xs:unsignedLong+ := trb:database-forests() ;

declare variable $INDEX as xs:integer := (index-of($TARGETS, $FOREST), -1)[1] ;

declare variable $LIMIT as xs:integer external ;

declare variable $RESPAWN as xs:boolean external ;

xdmp:log(
  text {
    '[forest-uris.xqy]', xdmp:forest-name($FOREST), $INDEX, $LIMIT, $RESPAWN },
  'debug'),
trb:spawn(
  'forest-uris.xqy',
  $FOREST,
  $INDEX,
  xdmp:forest-status($FOREST),
  $TARGETS,
  $RESPAWN,
  $LIMIT)

(: forest-uris.xqy :)