Skip to content

Commit d59aa72

Browse files
committed
Simplify name of 'scheduleNewThread...'
1 parent 3c0f01e commit d59aa72

File tree

4 files changed

+10
-10
lines changed

4 files changed

+10
-10
lines changed

rt/src/Scheduler.mts

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -111,11 +111,11 @@ export class Scheduler implements SchedulerInterface {
111111
}
112112

113113
/** Create a new thread `t` for the given function to be evaluated and schedule it. */
114-
scheduleNewThreadAtLevel (f: () => any,
115-
arg: any,
116-
pc: Level,
117-
block: Level,
118-
tType: ThreadType = ThreadType.Other)
114+
scheduleNewThread(f: () => any,
115+
arg: any,
116+
pc: Level,
117+
block: Level,
118+
tType: ThreadType = ThreadType.Other)
119119
{
120120
// Create a new process ID at the given level.
121121
const pid = tType === ThreadType.System ? SYSTEM_PROCESS_STRING : uuidv4();

rt/src/SchedulerInterface.mts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@ export interface SchedulerInterface {
77

88
resetScheduler(): void;
99

10-
scheduleNewThreadAtLevel(fun: () => any, arg: any, pc: Level, block: Level): LVal;
10+
scheduleNewThread(fun: () => any, arg: any, pc: Level, block: Level): LVal;
1111
scheduleThread(t: Thread): void;
1212

1313
blockThread(t: Thread): void;

rt/src/builtins/spawn.mts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@ export function BuiltinSpawn<TBase extends Constructor<UserRuntimeZero>>(Base: T
2727
let spawnLocal = (arg) => {
2828
// debug ("scheduled rt_spawn ", arg.fun);
2929

30-
let newPid = __sched.scheduleNewThreadAtLevel(
30+
let newPid = __sched.scheduleNewThread(
3131
arg,
3232
__unit, // [arg.env, __unit],
3333
// arg.namespace,

rt/src/runtimeMonitored.mts

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -134,7 +134,7 @@ async function spawnFromRemote(jsonObj, fromNode) {
134134
const lf = await DS.deserialize(nodeLev, jsonObj);
135135
const f = lf.val;
136136
const newPid =
137-
__sched.scheduleNewThreadAtLevel(
137+
__sched.scheduleNewThread(
138138
f
139139
, __unit //[f.env, __unit]
140140
// , f.namespace
@@ -441,14 +441,14 @@ export async function start(f) {
441441
new LVal ( new Record([ ["authority", mainAuthority],
442442
["options", __unit]]),
443443
levels.BOT);
444-
__sched.scheduleNewThreadAtLevel(__service['service']
444+
__sched.scheduleNewThread(__service['service']
445445
, service_arg
446446
, levels.TOP
447447
, levels.BOT
448448
, ThreadType.System);
449449
}
450450

451-
__sched.scheduleNewThreadAtLevel(
451+
__sched.scheduleNewThread(
452452
() => f.main({__dataLevel:levels.BOT})
453453
, mainAuthority
454454
, levels.BOT

0 commit comments

Comments
 (0)