Files
bare-operating-system/packages/bare-os-seeder/kernel/bin/timeout
T
Raven Scott 8c3151319d feat(kernel): expand stock image, boot policy, and ecosystem integration
- Stock kernel: boot.policy v2 (maxExecLineDepth, denyEnvKeys, requireProcNodes);
  richer BARE_OS_KERNEL_SELFTEST; example policy and timer drop-in samples
- Protocol: feature bits 28–30, seed RPCs (manifest_hints, peer_health, staging_slot)
- Booter: /proc mirrors, provenance, metrics_live, pear IPC registry, initd DAG,
  suspend/resume wiring, exec budget, shell ${var} expansion, delegate limits,
  telemetry v3 / OTel JSONL, ctx API 1.11.0
- Coreutils: /bin/timeout; seeder Pear/Bare: avoid bare process.env (globalThis.process?.env)
- CI: verify-ctx-api-feature-bits; docs: handbook, developer-guide, kernel-extensions,
  capabilities index, environment appendix, READMEs
2026-04-04 01:41:27 -04:00

155 lines
4.0 KiB
Plaintext

/* BARE_OS_BIN_API 1.0.0 — bump when staged /bin script semantics change (see developer guide). */
/** Shared helpers for drive-resident /bin scripts (prepended before each command). */
function bareStdin(ctx) {
return typeof ctx.shellStdin === 'string' ? ctx.shellStdin : ''
}
/** @param {number} mode @param {'file' | 'directory' | 'symlink'} type */
function bareFormatModeString(mode, type) {
const typeChar = type === 'directory' ? 'd' : type === 'symlink' ? 'l' : '-'
const perm = mode & 0o777
const r = (bit) => (perm & bit ? 'r' : '-')
const w = (bit) => (perm & bit ? 'w' : '-')
const x = (bit) => (perm & bit ? 'x' : '-')
return (
typeChar +
r(0o400) +
w(0o200) +
x(0o100) +
r(0o040) +
w(0o020) +
x(0o010) +
r(0o004) +
w(0o002) +
x(0o001)
)
}
/** @param {number} mtimeMs @param {number} [nowMs] */
function bareFormatLsMtime(mtimeMs, nowMs) {
const now = nowMs != null ? nowMs : Date.now()
const d = new Date(mtimeMs)
const months = [
'Jan',
'Feb',
'Mar',
'Apr',
'May',
'Jun',
'Jul',
'Aug',
'Sep',
'Oct',
'Nov',
'Dec'
]
const mon = months[d.getMonth()]
const day = String(d.getDate()).padStart(2, ' ')
const sixMo = 180 * 24 * 3600 * 1000
if (Math.abs(now - mtimeMs) > sixMo) {
const yr = String(d.getFullYear()).padStart(4, ' ')
return mon + ' ' + day + ' ' + yr
}
const hh = String(d.getHours()).padStart(2, '0')
const mm = String(d.getMinutes()).padStart(2, '0')
return mon + ' ' + day + ' ' + hh + ':' + mm
}
/** @param {number} size */
function barePosixBlocks(size) {
return Math.ceil(Number(size) / 512) || 0
}
/**
* Raw stdout for NUL/binary when **`process.stdout.write`** is missing.
* If **`ctx.bareOsBinWrite(Uint8Array|string)`** is set (tests / host), use it.
* @param {Record<string, unknown>} ctx
* @param {string | Uint8Array} chunk
* @returns {boolean}
*/
function bareOsEmitRaw(ctx, chunk) {
if (typeof ctx.bareOsBinWrite === 'function') {
const b4 = ctx.b4a
const u8 =
typeof chunk === 'string'
? b4 && typeof b4.from === 'function'
? b4.from(chunk)
: new TextEncoder().encode(chunk)
: chunk
ctx.bareOsBinWrite(u8 instanceof Uint8Array ? u8 : new Uint8Array(u8))
return true
}
const w = globalThis.process?.stdout?.write
if (typeof w === 'function') {
w.call(globalThis.process.stdout, chunk)
return true
}
return false
}
async function run(ctx, argv) {
let i = 1
while (i < argv.length) {
const a = argv[i]
if (a === '--') {
i++
break
}
if (a === '-k' || a === '--kill-after') {
i += 2
continue
}
if (a.startsWith('-')) {
ctx.console.error('timeout: unsupported option: ' + a)
ctx.exitCode = 125
return
}
break
}
const durRaw = argv[i]
if (durRaw == null) {
ctx.console.error('usage: timeout DURATION COMMAND [ARG...]')
ctx.exitCode = 125
return
}
const dur = Number.parseFloat(durRaw)
if (!Number.isFinite(dur) || dur < 0) {
ctx.console.error('timeout: invalid duration')
ctx.exitCode = 125
return
}
const cmd = argv.slice(i + 1)
if (!cmd.length) {
ctx.console.error('timeout: missing command')
ctx.exitCode = 125
return
}
const timeoutMs = Math.min(
Math.round(dur * 1000),
24 * 3600 * 1000
)
const ac = new AbortController()
const timer = setTimeout(() => ac.abort(), timeoutMs)
try {
if (typeof ctx.runBinCommand !== 'function') {
ctx.console.error('timeout: runBinCommand is not available')
ctx.exitCode = 125
return
}
await ctx.runBinCommand(cmd, {
signal: ac.signal,
timeoutMs: timeoutMs + 500
})
} catch (e) {
const name = e && /** @type {{ name?: string }} */ (e).name
const msg = String((e && e.message) || e || '')
if (name === 'AbortError' || /abort/i.test(msg)) {
ctx.exitCode = 124
} else {
ctx.exitCode = 1
}
} finally {
clearTimeout(timer)
}
}