Процессы WASM

Запись process.wasm создаёт постоянный изолированный WASM-актор в хосте процессов Wippy. Один экземпляр модуля живёт всё время существования PID, сохраняет состояние гостя между сообщениями и участвует в порождении, мониторинге, обмене сообщениями и контролируемом завершении.

Классификация: справочник конфигурации и жизненного цикла процесса. Блоки с бинарниками предполагают внешнюю сборку компонента и принадлежащие приложению записи файловой системы, хоста процессов, окружения и политик. Хеши-заполнители нужно заменить точным дайджестом бинарника.

Конфигурация записи

entries:
  - name: wasm_binaries
    kind: fs.directory
    directory: ./wasm

  - name: compute_worker
    kind: process.wasm
    fs: myns:wasm_binaries
    path: /worker.wasm
    hash: sha256:292b796376f8b4cc360acf2ea6b82d1084871c3607a079f30b446da8e5c984a4
    method: run
    imports:
      - wippy:actor
      - wasi:io
      - wasi:poll
    options:
      limits:
        memory_bytes: 67108864
      mailbox:
        capacity: 128
        bytes: 8388608
        message_bytes: 1048576

Поля конфигурации

Акторы WASM с состоянием

Для component guest импорт wippy:actor предоставляет текущий PID и его ограниченный mailbox. Интерфейс wippy:actor/process@0.1.0 включает:

Сообщение содержит PID отправителя, topic и до 16 payload. Форматы payload — bytes, UTF-8 text и UTF-8 json. Отправка авторизуется как process.send для целевого PID. Некорректные, слишком большие сообщения и сообщения сверх ёмкости mailbox отклоняются до передачи гостю.

Обычно guest экспортирует долгоживущую функцию run:

package example:worker;

world worker {
  import wippy:actor/process@0.1.0;
  import wasi:io/poll@0.2.8;
  export run: func() -> result<_, string>;
}

В run вызывайте receive() в цикле, обновляйте состояние guest и отвечайте через send() на message.from. Возврат из run завершает процесс.

Управление актором

Постоянные лимиты ресурсов и mailbox задаются внутри options:

options:
  worker_class: wasm
  limits:
    memory_bytes: 67108864
    host_buffer_bytes: 8388608
    asyncify_stack_bytes: 65536
    max_execution_ms: 0
    max_open_sockets: 16
    socket_timeout_ms: 30000
  mailbox:
    capacity: 128
    bytes: 8388608
    message_bytes: 1048576

mailbox.message_bytes не может превышать mailbox.bytes. Ёмкость также должна укладываться в минимальный учёт 256 байт на сообщение. Неизвестные поля и недопустимые значения приводят к отклонению записи.

CLI-команды

Зарегистрируйте WASM-процесс как именованную команду с помощью meta.command:

  - name: greet
    kind: process.wasm
    meta:
      command:
        name: greet
        short: Greet someone via WASM
    fs: myns:wasm_binaries
    path: /component.wasm
    hash: sha256:...
    method: greet

Запуск:

wippy run greet

Список доступных команд:

wippy run list

Для работы CLI-команд необходим terminal.host — именно он является хостом процессов, выполняющим команду.

Жизненный цикл процесса

WASM-процессы следуют модели жизненного цикла Init/Step/Close:

1. Init - Модуль инстанцируется, входные аргументы захватываются
2. Step - На первом шаге модуль инстанцируется и запускается. Последующие шаги продвигают операции, связанные с диспетчером; синхронное выполнение может завершиться на первом шаге.
3. Close - Ресурсы экземпляра освобождаются

Порождение из Lua

Порождение WASM-процесса с мониторингом завершения:

local errors = require("errors")

-- Spawn with monitoring
local pid, err = process.spawn_monitored(
    "myns:compute_worker",   -- entry ID
    "myns:processes",        -- process host
    6, 7                     -- arguments passed to the WASM function
)

if err then
    return nil, err
end

-- Wait for the process to complete
local events = process.events()
    local event, open = events:receive()
    if not open then return nil, errors.new("process event channel closed") end
    if event.kind == process.event.EXIT and event.from == pid then
        local result = event.result.value  -- return value from the WASM function
        return result, event.result.error
    end

Асинхронное выполнение

WASM-акторы могут уступать управление на операциях хоста, которые среда выполнения передаёт через диспетчер: приём и отправка сообщений mailbox, polling, часы, сокеты, DNS, потоки файловой системы и исходящий HTTP. Планировщик приостанавливает процесс до завершения операции, а затем возобновляет тот же экземпляр гостя:

  - name: http_worker
    kind: process.wasm
    fs: myns:wasm_binaries
    path: /http_worker.wasm
    hash: sha256:...
    method: run
    imports:
      - wasi:io
      - wasi:cli
      - wasi:http
    wasi:
      env:
        - id: myns:api_url
          name: API_URL
          required: true

Механизм yield/resume прозрачен для asyncify-модуля core или компонента, использующего поддерживаемые pollable-интерфейсы.

Конфигурация WASI

Процессы поддерживают ту же конфигурацию WASI, что и функции:

  - name: file_processor
    kind: process.wasm
    fs: myns:wasm_binaries
    path: /processor.wasm
    hash: sha256:...
    method: process
    imports:
      - wasi:cli
      - wasi:io
      - wasi:clocks
      - wasi:filesystem
    wasi:
      args: ["--input", "/data/input.csv"]
      cwd: "/app"
      env:
        - id: myns:output_format
          name: OUTPUT_FORMAT
      mounts:
        - fs: myns:input_data
          guest: /data
          read_only: true
        - fs: myns:output_dir
          guest: /output

См. также

• Обзор - Обзор среды выполнения WebAssembly
• Функции - Конфигурация функций WASM
• Хост-функции - Доступные хост-интерфейсы
• Модель процессов - Жизненный цикл процессов
• Супервизия - Деревья супервизии процессов