scheduler `#99`

Parent #74Owner #2Flags readSource RPG Core/rpgcore-patched.db

Aliases: scheduler

20 verbs · 33 properties · 0 children

Verbs

Verb Spec Flags Definer Lines

init_for_core this none this rxd #99 12

add this none this rxd #99 16

insert this none this rxd #99 11

assign this none this rxd #99 5

valid_task this none this rxd #99 2

usable_by this none this rxd #99 7

kill_task*s this none this rxd #99 22

job_batch this none this rxd #99 17

do this none this rxd #99 18

kill @unsched*ule any none none rxd #99 42

stop_start this none this rxd #99 15

atrun this none this rxd #99 32

look_self this none this rxd #99 25

get_task_display this none this rxd #99 45

@sched*uler none none none rxd #99 34

is_running this none this rxd #99 7

@reset this any any rd #99 19

schedule schedule_at schedule_every this none this rxd #99 27

do_checkpoint this none this rxd #99 45

@list-ch*eckpoints none none none rxd #99 11

Verb	Spec	Flags	Definer	Lines
`init_for_core`	`this none this`	`rxd`	#99	12
`add`	`this none this`	`rxd`	#99	16
`insert`	`this none this`	`rxd`	#99	11
`assign`	`this none this`	`rxd`	#99	5
`valid_task`	`this none this`	`rxd`	#99	2
`usable_by`	`this none this`	`rxd`	#99	7
`kill_task*s`	`this none this`	`rxd`	#99	22
`job_batch`	`this none this`	`rxd`	#99	17
`do`	`this none this`	`rxd`	#99	18
`kill @unsched*ule`	`any none none`	`rxd`	#99	42
`stop_start`	`this none this`	`rxd`	#99	15
`atrun`	`this none this`	`rxd`	#99	32
`look_self`	`this none this`	`rxd`	#99	25
`get_task_display`	`this none this`	`rxd`	#99	45
`@sched*uler`	`none none none`	`rxd`	#99	34
`is_running`	`this none this`	`rxd`	#99	7
`@reset`	`this any any`	`rd`	#99	19
`schedule schedule_at schedule_every`	`this none this`	`rxd`	#99	27
`do_checkpoint`	`this none this`	`rxd`	#99	45
`@list-ch*eckpoints`	`none none none`	`rxd`	#99	11

Properties

Property Definer Flags Owner Value

lock #99 rc #2 0

task #99 rc #2 0

lock_timeout #99 rc #2 300

tasks #99 rc #2 {}

clearing #99 rc #2 0

dump_interval #99 rc #2 10800

dump_task #99 rc #2 0

checkpoint_sizes #99 rc #2 {}

checkpoint_times #99 rc #2 {}

warehouse #74 r #36 <clear>

Property	Definer	Flags	Owner	Value
`lock`	#99	`rc`	#2	`0`
`task`	#99	`rc`	#2	`0`
`lock_timeout`	#99	`rc`	#2	`300`
`tasks`	#99	`rc`	#2	`{}`
`clearing`	#99	`rc`	#2	`0`
`dump_interval`	#99	`rc`	#2	`10800`
`dump_task`	#99	`rc`	#2	`0`
`checkpoint_sizes`	#99	`rc`	#2	`{}`
`checkpoint_times`	#99	`rc`	#2	`{}`
`warehouse`	#74	`r`	#36	`<clear>`
`help_msg`	#74	`rc`	#2	list of 65 {"Scheduler: The scheduler is designed as a process storage chamber. Verbs which execute with a long period (an hour, a day, etc.) can be stored on the scheduler, without filling up the queued task list. Verbs which need to happen with a certain number of iterations, or infinitely, can be handled by code in the scheduler, reducing the burden on the programmer. The scheduler also accounts for drift in lag, allowing a verb to run at a certain time, every time.", "", "Building Blocks:", "", ":schedule (rel_time,obj,verb[,args])", ":schedule_at (abs_time,obj,verb[,args])", ":schedule_every (rel_time,obj,verb[,args])", "", " \"rel_time\" indicates a time interval from the present moment, that is: a", " relative time, or \"x seconds from now\"", " \"abs_time\" indicates an absolute time, for example: 749069038", " \"obj\" indicates the object on which the verb you will call resides", " \"verb\" is the verb you will be calling", " \"args\" is/are the argument(s) you will use in the verb call.", "", " The \"rel_time\" is a number, given in seconds. The \"obj\" is an object", " number, like #1, the verb is a string, like \"tell\". The \"args\" is a list of", " arguments to be passed, and may be left off. If left off, no arguments will", " be passed.", "", "Examples:", "", ":schedule(35,#11,\"announce_all\",{\"I am here!\"})", " which is equivalent to:", " ;fork(35) #11:announce_all(\"I am here!\"); endfork", "", ":schedule_at(749069497,$fountain,\"start\")", " equals:", " ;fork(time()+6243600) $fountain:start(); endfork", "", ":schedule_every(15,$puppet,\"action\",{\"move\",\"eat\",\"walk\"})", " is fairly close in meaning to:", " [verb code on $puppet]", " ...", " fork (15)", " this:(verb)(\"move\",\"eat\",\"walk\");", " endfork", "", "", "Extra Neat-o's:", "", "The \"object\" parameter in the verb calls above may be substituted with strings. The string will then be passed to the player's eval_cmd_str(), and must return an object number. If the code does not return a valid object number, the scheduled verb will not run.", "", "Also, the \"arguments\" parameter may be left as a simple value (integer, string, whatever), or left off entirely.", "", "Examples:", "", ":schedule_every(35,\"player.location\",\"announce_all\",{\"I am here!\"})", " Every 35 seconds, this verb will announce to the player's current location.", "", ":schedule(35,\"player\",\"tell\",\"Hello from me!\")", " Equivalent to :schedule(35,\"player\",\"tell\",{\"Hello from me!\"})", "", ":schedule(35,\"player\",\"tell\")", " Equivalent to :schedule(35,\"player\",\"tell\",{})", "", "", "Problems:", "", "This is a simplified version of Pascal's scheduler put together by Changeling (geocorona@aol.com). Contact that address with problems.", "Original author: (t_pascal@oxy.edu).", "", "FOR SERVERS COMPILED WITHOUT AUTOMATIC CHECKPOINTING:", ";$scheduler:schedule($scheduler.dump_interval, $scheduler, \"do_checkpoint\")", "====================================================="}
`feature_verbs`	#74	`r`	#36	`{"@sched", "@unsched", "@reset", "@list-ch"}`
`feature_ok`	#74	`r`	#36	`<clear>`
`drop_failed_msg`	#5	`rc`	#2	`<clear>`
`drop_succeeded_msg`	#5	`rc`	#2	`<clear>`
`odrop_failed_msg`	#5	`rc`	#2	`<clear>`
`odrop_succeeded_msg`	#5	`rc`	#2	`<clear>`
`otake_succeeded_msg`	#5	`rc`	#2	`<clear>`
`otake_failed_msg`	#5	`rc`	#2	`<clear>`
`take_succeeded_msg`	#5	`rc`	#2	`<clear>`
`take_failed_msg`	#5	`rc`	#2	`<clear>`
`value_base`	#102	`r`	#2	`<clear>`
`damage_base`	#102	`r`	#2	`<clear>`
`x_loc`	#102	`r`	#36	`<clear>`
`y_loc`	#102	`r`	#36	`<clear>`
`ansi_title`	#102	`r`	#36	`<clear>`
`obvious`	#102	`r`	#36	`<clear>`
`build_help`	#102	`rc`	#2	`<clear>`
`key`	#1	`c`	#2	`0`
`aliases`	#1	`rc`	#2	`{"scheduler"}`
`description`	#1	`rc`	#2	`"A feature object that can execute repetitive verbs, and verbs suspended for long periods."`
`object_size`	#1	`r`	#36	`{23893, -1090650497}`
`html`	#1	`rc`	#2	`<clear>`

help_msg

#74

rc

list of 65

{"Scheduler:  The scheduler is designed as a process storage chamber.  Verbs which execute with a long period (an hour, a day, etc.) can be stored on the scheduler, without filling up the queued task list.  Verbs which need to happen with a certain number of iterations, or infinitely, can be handled by code in the scheduler, reducing the burden on the programmer.  The scheduler also accounts for drift in lag, allowing a verb to run at a certain time, every time.", "", "Building Blocks:", "", ":schedule       (rel_time,obj,verb[,args])", ":schedule_at    (abs_time,obj,verb[,args])", ":schedule_every (rel_time,obj,verb[,args])", "", "  \"rel_time\" indicates a time interval from the present moment, that is: a", " relative time, or \"x seconds from now\"", "  \"abs_time\" indicates an absolute time, for example: 749069038", "  \"obj\" indicates the object on which the verb you will call resides", "  \"verb\" is the verb you will be calling", "  \"args\" is/are the argument(s) you will use in the verb call.", "", "  The \"rel_time\" is a number, given in seconds.  The \"obj\" is an object", " number, like #1, the verb is a string, like \"tell\".  The \"args\" is a list of", " arguments to be passed, and may be left off.  If left off, no arguments will", " be passed.", "", "Examples:", "", ":schedule(35,#11,\"announce_all\",{\"I am here!\"})", "   which is equivalent to:", "   ;fork(35) #11:announce_all(\"I am here!\"); endfork", "", ":schedule_at(749069497,$fountain,\"start\")", "   equals:", "   ;fork(time()+6*24*3600) $fountain:start(); endfork", "", ":schedule_every(15,$puppet,\"action\",{\"move\",\"eat\",\"walk\"})", "   is fairly close in meaning to:", "   [verb code on $puppet]", "      ...", "   fork (15)", "     this:(verb)(\"move\",\"eat\",\"walk\");", "   endfork", "", "", "Extra Neat-o's:", "", "The \"object\" parameter in the verb calls above may be substituted with strings.  The string will then be passed to the player's eval_cmd_str(), and must return an object number.  If the code does not return a valid object number, the scheduled verb will not run.", "", "Also, the \"arguments\" parameter may be left as a simple value (integer, string, whatever), or left off entirely.", "", "Examples:", "", ":schedule_every(35,\"player.location\",\"announce_all\",{\"I am here!\"})", "  Every 35 seconds, this verb will announce to the player's current location.", "", ":schedule(35,\"player\",\"tell\",\"Hello from me!\")", "  Equivalent to :schedule(35,\"player\",\"tell\",{\"Hello from me!\"})", "", ":schedule(35,\"player\",\"tell\")", "  Equivalent to :schedule(35,\"player\",\"tell\",{})", "", "", "Problems:", "", "This is a simplified version of Pascal's scheduler put together by Changeling (geocorona@aol.com). Contact that address with problems.", "Original author: (t_pascal@oxy.edu).", "", "FOR SERVERS COMPILED WITHOUT AUTOMATIC CHECKPOINTING:", ";$scheduler:schedule($scheduler.dump_interval, $scheduler, \"do_checkpoint\")", "====================================================="}

feature_verbs #74 r #36 {"@sched", "@unsched", "@reset", "@list-ch"}

feature_ok #74 r #36 <clear>

drop_failed_msg #5 rc #2 <clear>

drop_succeeded_msg #5 rc #2 <clear>

odrop_failed_msg #5 rc #2 <clear>

odrop_succeeded_msg #5 rc #2 <clear>

otake_succeeded_msg #5 rc #2 <clear>

otake_failed_msg #5 rc #2 <clear>

take_succeeded_msg #5 rc #2 <clear>

take_failed_msg #5 rc #2 <clear>

value_base #102 r #2 <clear>

damage_base #102 r #2 <clear>

x_loc #102 r #36 <clear>

y_loc #102 r #36 <clear>

ansi_title #102 r #36 <clear>

obvious #102 r #36 <clear>

build_help #102 rc #2 <clear>

key #1 c #2 0

aliases #1 rc #2 {"scheduler"}

description #1 rc #2 "A feature object that can execute repetitive verbs, and verbs suspended for long periods."

object_size #1 r #36 {23893, -1090650497}

html #1 rc #2 <clear>

Ancestry

#1 Root Class
- #102 subthing
  - #5 generic thing
    #74 Generic Feature Object
    #99 scheduler

Ancestors (nearest first): #74 Generic Feature Object → #5 generic thing → #102 subthing → #1 Root Class

Children: none

Call graph

Source

`init_for_core`

Spec this none thisFlags rxdOwner #2Definer #99

Referenced by

none

Source

1if (($code_utils:verb_location() == this) && caller_perms().wizard)
2this.task = 0;
3this.clearing = 0;
4this.lock = 0;
5this.lock_timeout = 300;
6this.tasks = {};
7this.dump_interval = 10800;
8this.dump_task = 0;
9this.checkpoint_sizes = {};
10this.checkpoint_times = {};
11endif
12pass(@args);

`add`

Spec this none thisFlags rxdOwner #2Definer #99

Referenced by

#99:insert line 5: this:add

Source

1"  :add(time,t_id,data)  =>  inserts task on the task-list, in ascending order";
2if ((caller != this) && (!caller_perms().wizard))
3return E_PERM;
4endif
5if (length(args) < 3)
6return E_ARGS;
7elseif (!$recycler:valid(args[3][3]))
8return E_INVARG;
9endif
10time = call_function("tonum", args[1]);
11i = 1;
12len = length(tasks = this.tasks);
13while ((i <= len) && (this.tasks[i][1] <= time))
14i = i + 1;
15endwhile
16this.tasks = listinsert(tasks, args, i);

`insert`

Spec this none thisFlags rxdOwner #2Definer #99

Referenced by

#99:atrun line 21: this:insert
#99:schedule line 26: this:insert

Source

1"  :insert(time,t_id,data)  =>  Updates tasks in the list, starting :atrun if necessary";
2if ((caller != this) && (!caller_perms().wizard))
3return E_PERM;
4endif
5if (typeof(ret = this:add(@args)) == ERR)
6return ret;
7endif
8if (((call_function("tonum", args[1]) < this.lock) || (!(this.lock && this.task))) || (time() > (this.lock + this.lock_timeout)))
9this:stop_start();
10endif
11return ret;

`assign`

Spec this none thisFlags rxdOwner #2Definer #99

Referenced by

#99:schedule line 22: this:assign

Source

1while ($list_utils:iassoc(n = random($maxint), this.tasks, 2))
2"Do nothing";
3endwhile
4"N is now unique..";
5return n;

`valid_task`

Spec this none thisFlags rxdOwner #2Definer #99

Referenced by

#6:@ping line 7: $scheduler:valid_task
#6:_ping line 3: $scheduler:valid_task
#6:@unping line 1: $scheduler:valid_task
#71:move_players_home line 6: $scheduler:valid_task
#71:@begin line 10: $scheduler:valid_task
#71:@begin line 18: $scheduler:valid_task
#91:_release line 5: $scheduler:valid_task
#99:kill_task*s line 10: this:valid_task
#99:do_checkpoint line 5: this:valid_task
#104:queue_attack line 40: $scheduler:valid_task
#107:tell line 14: $scheduler:valid_task
#107:_release line 4: $scheduler:valid_task
#107:@start line 8: $scheduler:valid_task
#116:@start line 8: $scheduler:valid_task
#116:ask line 50: $scheduler:valid_task
#127:turn line 13: $scheduler:valid_task
#127:_ignite line 2: $scheduler:valid_task
#127:light line 12: $scheduler:valid_task
#136:rot_away line 16: $scheduler:valid_task
#138:breed line 22: $scheduler:valid_task
#138:cull line 5: $scheduler:valid_task

Source

1"    :valid_task(taskid)  =>  true if taskid is in the current task-list";
2return args ? $list_utils:iassoc(call_function("tonum", args[1]), this.tasks, 2) | E_ARGS;

`usable_by`

Spec this none thisFlags rxdOwner #2Definer #99

Referenced by

#99:kill_task*s line 2: this:usable_by
#99:kill line 3: this:usable_by
#99:look_self line 1: this:usable_by
#99:schedule line 7: this:usable_by

Source

1"    :usable_by(whom)  =>  1 | 0";
2"This verb should return true if who has permission to use this";
3if (args)
4return args[1].programmer;
5else
6return E_ARGS;
7endif

`kill_task*s`

Spec this none thisFlags rxdOwner #2Definer #99

Referenced by

none

Source

1"  :kill_task*s(t_id[s])  =>  returns number of tasks killed";
2if (!this:usable_by(caller_perms()))
3return E_PERM;
4endif
5if (args)
6t_ids = (typeof(args[1]) == LIST) ? args[1] | {args[1]};
7reset = 0;
8killed = 0;
9for t_id in (t_ids)
10if ((task = this:valid_task(call_function("tonum", t_id))) && $perm_utils:controls(caller_perms(), this.tasks[task][3][7]))
11this.tasks = listdelete(this.tasks, task);
12killed = killed + 1;
13endif
14reset = ((reset || task) == 1) ? 1 | 0;
15endfor
16if (reset)
17this:stop_start();
18endif
19return killed;
20else
21return E_ARGS;
22endif

`job_batch`

Spec this none thisFlags rxdOwner #2Definer #99

Referenced by

#99:atrun line 11: this:job_batch

Source

1"  :job_batch(time)  =>  returns a list of tasks due for time, taking them off the queue.";
2if ((caller != this) && (!caller_perms().wizard))
3return E_PERM;
4endif
5if (args)
6time = call_function("tonum", args[1]);
7for x in [1..l = length(t = this.tasks)]
8if (t[x][1] > time)
9this.tasks = t[x..l];
10return t[1..x - 1];
11endif
12endfor
13this.tasks = {};
14return t;
15else
16return E_ARGS;
17endif

`do`

Spec this none thisFlags rxdOwner #2Definer #99

Referenced by

#99:atrun line 14: this:do

Source

1"Does the verb given args == {#obj,\"verb\",{args},#player,#permissions}";
2"The #obj argument may be given as a string which is then eval()'d";
3"This verb is a potential security hole!  Guard this one closely.";
4if ((caller == this) && caller_perms().wizard)
5if (length(args) < 5)
6return E_ARGS;
7else
8player = args[4];
9set_task_perms(args[5]);
10if (typeof(object = args[1]) == STR)
11e = player:eval_cmd_string(object)[1..2];
12object = (e[1] && (typeof(e[2]) == OBJ)) ? e[2] | $nothing;
13endif
14`object:(args[2])(@args[3]) ! E_VERBNF => "object must be garbage now"';
15endif
16else
17return $error:raise(E_PERM);
18endif

`kill @unsched*ule`

Spec any none noneFlags rxdOwner #2Definer #99

Referenced by

none

Source

1"kill [task_id]";
2"Unceremoniously kills the specified task. Wizards may also \"@unsched *\" (kill all tasks), or \"@unsched garbage\" (kill all tasks on recycled objects).";
3if (!this:usable_by(player))
4player:tell("Permission denied.");
5return;
6endif
7n = length(dobjstr);
8if (!n)
9player:tell("You must supply a task id to kill.");
10return;
11endif
12if ((dobjstr == "*") && player.wizard)
13if ($command_utils:yes_or_no("Kill all tasks?"))
14dobjstr = "&%&";
15n = 0;
16else
17player:tell("Kill aborted.");
18return;
19endif
20elseif (dobjstr == "*")
21player:tell("Only administrators may kill all tasks.");
22return;
23elseif ((dobjstr == "garbage") && player.wizard)
24ids = {};
25for task in (this.tasks)
26id = task[2];
27if ((parent(task[3][3]) == $garbage) || (!valid(task[3][3])))
28ids = listappend(ids, id);
29endif
30endfor
31killed = this:kill_tasks(ids);
32return player:tell("Killed ", tostr(killed), " task", (killed == 1) ? "." | "s.");
33endif
34ids = {};
35for task in (this.tasks)
36id = task[2];
37if ((dobjstr in {tostr(id), "&%&"}) && $perm_utils:controls(player, task[3][7]))
38ids = listappend(ids, id);
39endif
40endfor
41killed = this:kill_tasks(ids);
42player:tell("Killed ", tostr(killed), " task", (killed == 1) ? "." | "s.");

`stop_start`

Spec this none thisFlags rxdOwner #2Definer #99

Referenced by

#99:insert line 9: this:stop_start
#99:kill_task*s line 17: this:stop_start
#99:@reset line 16: this:stop_start

Source

1"  :stop_start([seconds])  =>  Kill the old :atrun verb, and restart at the new time";
2"   Optional arg for length of time until restart. Defaults to 0 seconds.";
3if ((caller != this) && (!caller_perms().wizard))
4return E_PERM;
5endif
6`kill_task(this.task) ! E_INVARG';
7this.clearing = 1;
8delay = 0;
9if (args)
10delay = toint(args[1]);
11endif
12fork (delay)
13this.clearing = 0;
14this:atrun();
15endfork

`atrun`

Spec this none thisFlags rxdOwner #2Definer #99

Referenced by

#99:stop_start line 14: this:atrun
#99:atrun line 27: this:atrun

Source

1"The guts of the scheduler.  Handles jobs.";
2if ((caller != this) && (!caller_perms().wizard))
3return E_PERM;
4elseif (this.clearing)
5return "wait a few seconds for multiple atruns to clear. See this:stop_start.";
6elseif ((this.task != task_id()) && (this.task in $list_utils:slice(queued_tasks())))
7kill_task(this.task);
8endif
9this.task = task_id();
10this.lock = time = time();
11for task in (this:job_batch(time))
12info = task[3];
13fork (0)
14this:do(@info[3..7]);
15endfork
16if ((freq = info[1]) > 1)
17freq = freq - 1;
18endif
19if (freq != 1)
20info[8][4] = time = time();
21this:insert((time + info[2]) - ((time - info[8][1]) % info[2]), task[2], info);
22endif
23endfor
24this.lock = (this.tasks && (time() < (this.lock + this.lock_timeout))) ? this.tasks[1][1] | 0;
25if (this.lock)
26fork task (max(0, this.lock - time()))
27this:atrun();
28endfork
29this.task = task;
30else
31this.task = 0;
32endif

`look_self`

Spec this none thisFlags rxdOwner #2Definer #99

Referenced by

none

Source

1if (!this:usable_by(player))
2return 0;
3endif
4tasks = this.tasks;
5if (tasks)
6su = $string_utils;
7player:tell("Job ID      Start Time            Player         Verb (* = forever)");
8player:tell(su:space(79, "-"));
9for task in (tasks)
10if ($perm_utils:controls(player, task[3][7]) || $perm_utils:controls(player, task[3][6]))
11temp = su:left(tostr(task[2]), 12, " ");
12temp = (temp + ctime(task[1])[5..24]) + "  ";
13temp = temp + su:left(task[3][6].name, 14, " ");
14if (task[3][1] < 1)
15temp = temp + "* ";
16endif
17temp = ((temp + tostr(task[3][3])) + ":") + task[3][4];
18temp = temp + su:print(task[3][5]);
19player:tell(temp);
20endif
21endfor
22player:tell(su:space(79, "-"));
23else
24player:tell("No jobs scheduled on ", this.name, ".");
25endif

`get_task_display`

Spec this none thisFlags rxdOwner #2Definer #99

Referenced by

#99:@sched*uler line 20: this:get_task_display

Source

1":get_task_display()";
2"==> returns the output to be displayed by $scheduler:@sched.";
3"Written by Firesong (#337)@Weyrmount";
4su = $string_utils;
5running = this:is_running();
6line = su:space(79, "-");
7header = {line};
8header = {@header, "  Scheduler status       : " + tostr(running ? "The scheduler is currently running." | "The scheduler seems to have been stopped.")};
9header = {@header, "  Current system time    : " + tostr(ctime())};
10header = {@header, "  Tasks waiting in queue : " + tostr(length(this.tasks))};
11string = su:space(max(5, 79 - length(string = "Task running in.."))) + string;
12header = {@header, string};
13header = {@header, line};
14retval = {};
15for task in ($scheduler.tasks)
16if ($perm_utils:controls(player, task[3][7]) || $perm_utils:controls(player, task[3][6]))
17next_fire = task[1];
18task_id = task[2];
19interations = task[3][1];
20interval = task[3][2];
21object = task[3][3];
22verb = task[3][4];
23vargs = task[3][5];
24owner = task[3][6];
25task_started = task[3][8][1];
26perms = task[3][8][3];
27last_fired = task[3][8][4];
28"...";
29varg_str = (varg_str = su:print(vargs))[2..length(varg_str) - 1];
30time_str = $time_utils:english_time(next_fire - time());
31line1 = ((((("Verb  : " + tostr(object)) + ":") + tostr(verb)) + "(") + varg_str) + ")";
32spaces = max(5, 79 - (length(line1) + length(time_str)));
33line1 = (line1 + su:space(spaces)) + time_str;
34perm_str = "Perms : " + tostr((perms == $no_one) ? "$NO_ONE" | su:nn(perms));
35task_str = "Task ID : " + tostr(task_id);
36spaces = max(1, 50 - length(perm_str));
37line2 = (perm_str + su:space(spaces)) + task_str;
38owner_str = "Player: " + su:nn(owner);
39spaces = max(1, 50 - length(owner_str));
40line3 = (owner_str + su:space(spaces)) + (interval ? ("Interval: " + tostr(interval)) + " seconds" | "Interval: Will not run again");
41retval = {@retval, line1, line2, line3, line};
42((ticks_left() < 4000) || (seconds_left() < 2)) && suspend(5);
43endif
44endfor
45return {header, retval};

`@sched*uler`

Spec none none noneFlags rxdOwner #2Definer #99

Referenced by

none

Source

1":@sched*uler()   <-- A Feature Verb to diplay an alternate task list on the scheduler.";
2"";
3"Sample output:";
4"";
5"[SCHEDULER] Browse Mode";
6"";
7"The Scheduler is currently ticking away";
8"  Tasks waiting in queue : 31";
9"  Current system time    : Tue Apr  9 18:38:09 1996 HDT";
10"";
11"                                                                   Running in..";
12"-------------------------------------------------------------------------------";
13"Verb  : #280:DO_check_kids()                                          8 seconds";
14"Perms : Firesong (#337)                           Task ID : 1300241341";
15"Player: Firesong (#337)                           Interval: 60 seconds";
16"-------------------------------------------------------------------------------";
17"Done..";
18"";
19"Written by Firesong (#337)@Weyrmount";
20info = this:get_task_display();
21"...Display header info...";
22player:tell_lines(info[1]);
23"...Display task info...";
24if (info[2])
25for line in (info[2])
26player:tell(line);
27((ticks_left() < 4000) || (seconds_left() < 2)) && suspend(5);
28endfor
29player:tell("Done..");
30elseif (player.wizard)
31player:tell("There are no tasks running on the scheduler.");
32else
33player:tell("You don't have any tasks running on the scheduler.");
34endif

`is_running`

Spec this none thisFlags rxdOwner #2Definer #99

Referenced by

#99:get_task_display line 5: this:is_running

Source

1":is_running()   <-- Called by :get_task_display";
2"Returns:";
3"  --> 0 The scheduler is not running (no valid task)";
4"  --> 1 The scheduler's master firing task is currently running";
5cu = $code_utils;
6running = cu:task_valid(this.task);
7return running;

`@reset`

Spec this any anyFlags rdOwner #2Definer #99

Referenced by

none

Source

1"@reset <scheduler> [in <seconds>] => stops scheduler, the restarts it in so many seconds. Default is 5 seconds.";
2if (!player.wizard)
3player:tell("Permission denied.  Contact an administrator.");
4return;
5endif
6delay = 5;
7if (iobjstr)
8delay = toint(iobjstr);
9endif
10player:tell("Resetting in ", delay, " seconds.");
11for task in (queued_tasks())
12if (task[7] == "atrun")
13kill_task(task[1]);
14endif
15endfor
16this:stop_start(delay);
17fork (delay)
18player:tell("Done.");
19endfork

`schedule schedule_at schedule_every`

Spec this none thisFlags rxdOwner #2Definer #99

Referenced by

#6:_ping line 4: $scheduler:schedule
#62:keep_clean line 24: $scheduler:schedule
#71:scheduled_cleanup line 15: $scheduler:schedule
#71:object_scrub line 10: $scheduler:schedule
#71:@begin line 15: $scheduler:schedule
#71:@begin line 24: $scheduler:schedule
#71:knock_em_homers line 8: $scheduler:schedule
#80:schedule_measurement_task line 6: $scheduler:schedule
#91:_release line 5: $scheduler:schedule_every
#91:roll_against line 60: $scheduler:schedule
#98:knock_em_homers line 8: $scheduler:schedule
#99:do_checkpoint line 8: this:schedule
#104:queue_attack line 41: $scheduler:schedule
#104:battle_check line 4: $scheduler:schedule
#104:battle_check line 7: $scheduler:schedule
#104:dig line 17: $scheduler:schedule
#107:rot_away line 7: $scheduler:schedule
#107:_release line 4: $scheduler:schedule_every
#107:die line 22: $scheduler:schedule
#107:plan_next_move line 5: $scheduler:schedule
#108:notify line 4: $scheduler:schedule
#116:@start line 18: $scheduler:schedule_every
#127:_ignite line 8: $scheduler:schedule
#129:learn line 9: $scheduler:schedule
#136:rot_away line 9: $scheduler:schedule
#138:breed line 23: $scheduler:schedule
#138:cull line 8: $scheduler:schedule

Source

1"  :schedule(interval,object,\"verb\"[,{[arguments]}[,player[,perms]])]";
2"  :schedule_at(time,object,\"verb\"[,{[arguments]}[,player[,perms]])]";
3"  :schedule_every(interval,object,\"verb\"[,{[arguments]}[,player[,perms]])]";
4"Schedules an event guarenteed to occur sometime after the interval has expired.  Returns a psuedo task id suitable for :kill_task() if successful, error otherwise.  Remember, the scheduler will try to adjust for drift.";
5"Example:  (at the end of a verb) fork (300) this:(verb)(x,y,z); endfork";
6"Becomes:  (outside the verb, probably from eval) :schedule_every(300,this,verb,{x,y,z})";
7if (!this:usable_by(caller_perms()))
8return E_PERM;
9elseif ((len = length(args)) < 3)
10return E_ARGS;
11elseif ((verb == "schedule_at") && (time() > args[1]))
12return E_INVARG;
13endif
14vargs = (len > 3) ? (typeof(args[4]) == LIST) ? args[4] | {args[4]} | {};
15if ((len > 4) && caller_perms().wizard)
16pl = args[5];
17perm = {@args, cp = caller_perms()}[6];
18else
19pl = player;
20perm = cp = caller_perms();
21endif
22tid = this:assign();
23time = (verb == "schedule_at") ? args[1] | (time() + args[1]);
24iters = (verb == "schedule_every") ? 0 | 1;
25INT = (verb == "schedule_every") ? args[1] | 0;
26this:insert(time, tid, {iters, INT, @args[2..3], vargs, pl, perm, {time(), caller, cp, 0}});
27return tid;

`do_checkpoint`

Spec this none thisFlags rxdOwner #2Definer #99

Referenced by

none

Source

1"Only use this if your server doesn't do automatic checkpoints";
2if ((!caller_perms().wizard) || (!player.wizard))
3raise(E_PERM);
4else
5if (this:valid_task(this.dump_task))
6this:kill_task(this.dump_task);
7endif
8this.dump_task = this:schedule(this.dump_interval, this, "do_checkpoint");
9this.checkpoint_times = (length(this.checkpoint_times) > 10) ? {@this.checkpoint_times[2..$], time()} | {@this.checkpoint_times, time()};
10starttime = time();
11for p in (connected_players())
12if (p.wizard)
13p:notify(("*** Checkpoint started " + ctime()) + ".");
14endif
15endfor
16dump_database();
17checks = 120;
18size = db_disk_size();
19try
20while (`db_disk_size() == size ! ANY => 1' && (checks > 1))
21checks = checks - 1;
22suspend(1);
23endwhile
24except v (ANY)
25"no biggie.";
26endtry
27try
28"This is a doublecheck that makes sure the db size has stabilized. If the first check was correct, only adds 2 seconds to the task.";
29size = db_disk_size();
30suspend(2);
31while (db_disk_size() != size)
32suspend(2);
33size = db_disk_size();
34endwhile
35except v (ANY)
36"no biggie.";
37endtry
38endtime = time() - starttime;
39for p in (connected_players())
40if (p.wizard)
41p:notify(((("*** Checkpoint finished " + ctime()) + ".  Elapsed time: ") + $time_utils:english_time(endtime)) + ".");
42endif
43endfor
44return this.checkpoint_sizes = (length(this.checkpoint_sizes) > 10) ? {@this.checkpoint_sizes[2..$], db_disk_size()} | {@this.checkpoint_sizes, db_disk_size()};
45endif

`@list-ch*eckpoints`

Spec none none noneFlags rxdOwner #2Definer #99

Referenced by

none

Source

1"Usage:  @list-checkpoints";
2"Lists the data saved for the last 10 checkpoints.";
3if (this.checkpoint_times)
4player:tell("     Time             Size");
5player:tell("  -----------       --------");
6for i in [1..length(this.checkpoint_times)]
7player:tell(ctime(this.checkpoint_times[i])[5..19], "   ", $string_utils:right($string_utils:group_number(this.checkpoint_sizes[i]), 11));
8endfor
9else
10player:tell("No checkpoint data.");
11endif

scheduler #99

Verbs

Properties

Ancestry

Call graph

Source

init_for_core

Referenced by

Source

add

Referenced by

Source

insert

Referenced by

Source

assign

Referenced by

Source

valid_task

Referenced by

Source

usable_by

Referenced by

Source

kill_task*s

Referenced by

Source

job_batch

Referenced by

Source

do

Referenced by

Source

kill @unsched*ule

Referenced by

Source

stop_start

Referenced by

Source

atrun

Referenced by

Source

look_self

Referenced by

Source

get_task_display

Referenced by

Source

@sched*uler

Referenced by

Source

is_running

Referenced by

Source

@reset

Referenced by

Source

schedule schedule_at schedule_every

Referenced by

Source

do_checkpoint

Referenced by

Source

@list-ch*eckpoints

Referenced by

Source

scheduler `#99`

`init_for_core`

`add`

`insert`

`assign`

`valid_task`

`usable_by`

`kill_task*s`

`job_batch`

`do`

`kill @unsched*ule`

`stop_start`

`atrun`

`look_self`

`get_task_display`

`@sched*uler`

`is_running`

`@reset`

`schedule schedule_at schedule_every`

`do_checkpoint`

`@list-ch*eckpoints`