Compare commits
2
Commits
master
...
70d7eafe76
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
70d7eafe76 | ||
|
|
a6ff6536dc |
@@ -75,15 +75,6 @@ let
|
|||||||
packages = with pkgs; [ tmux ] ++ packages;
|
packages = with pkgs; [ tmux ] ++ packages;
|
||||||
miscProperties = self._sshpiperRegister routingInfo;
|
miscProperties = self._sshpiperRegister routingInfo;
|
||||||
};
|
};
|
||||||
|
|
||||||
kvmTrait = {
|
|
||||||
containerConfig =
|
|
||||||
{ pkgs, ... }:
|
|
||||||
{
|
|
||||||
users.users.runner.extraGroups = [ "kvm" ];
|
|
||||||
environment.systemPackages = [ pkgs.qemu_kvm ];
|
|
||||||
};
|
|
||||||
};
|
|
||||||
in
|
in
|
||||||
{
|
{
|
||||||
ssh-admin = mkSsh {
|
ssh-admin = mkSsh {
|
||||||
@@ -126,32 +117,27 @@ in
|
|||||||
ssh-generic = mkSsh {
|
ssh-generic = mkSsh {
|
||||||
name = "ssh-generic";
|
name = "ssh-generic";
|
||||||
net.access = [ { to = "@internet"; } ];
|
net.access = [ { to = "@internet"; } ];
|
||||||
|
# /dev/kvm keeps its host ownership, so the kvm gid must not be shifted.
|
||||||
|
isolation.privateUsers = "identity";
|
||||||
resources = {
|
resources = {
|
||||||
fs."/home/runner/data" = {
|
fs."/home/runner/data" = {
|
||||||
hostPath = "${data}/ssh/generic";
|
hostPath = "${data}/ssh/generic";
|
||||||
isReadOnly = false;
|
isReadOnly = false;
|
||||||
};
|
};
|
||||||
|
devices = [ "/dev/kvm" ];
|
||||||
mem = "16G";
|
mem = "16G";
|
||||||
cpu = 65;
|
cpu = 65;
|
||||||
};
|
};
|
||||||
traits = [ kvmTrait ];
|
packages = with pkgs; [ qemu_kvm ];
|
||||||
isolation.allowedDevices = [
|
traits = [
|
||||||
{
|
{
|
||||||
node = "/dev/kvm";
|
containerConfig =
|
||||||
modifier = "rw";
|
{ config, ... }:
|
||||||
|
{
|
||||||
|
users.groups.kvm.gid = config.ids.gids.kvm;
|
||||||
|
users.users.runner.extraGroups = [ "kvm" ];
|
||||||
|
};
|
||||||
}
|
}
|
||||||
{
|
|
||||||
node = "/dev/vhost-net";
|
|
||||||
modifier = "rw";
|
|
||||||
}
|
|
||||||
{
|
|
||||||
node = "/dev/net/tun";
|
|
||||||
modifier = "rwm";
|
|
||||||
}
|
|
||||||
];
|
|
||||||
isolation.additionalCapabilities = [
|
|
||||||
"CAP_NET_ADMIN"
|
|
||||||
"CAP_MKNOD"
|
|
||||||
];
|
];
|
||||||
routingInfo = [
|
routingInfo = [
|
||||||
{
|
{
|
||||||
|
|||||||
@@ -221,6 +221,15 @@ rec {
|
|||||||
`resources.fs`
|
`resources.fs`
|
||||||
: Bind mounts, keyed by mount point.
|
: Bind mounts, keyed by mount point.
|
||||||
|
|
||||||
|
`resources.devices`
|
||||||
|
: Host device nodes to expose, as paths, added to the unit's
|
||||||
|
`DeviceAllow=`. nspawn populates a handful of privileged devices
|
||||||
|
(`/dev/kvm`, `/dev/net/tun`, ...) into the container's own `/dev` once
|
||||||
|
the cgroup allows it, and silently skips ones the host doesn't have -
|
||||||
|
no `resources.fs` bind mount needed. Nodes keep their host ownership,
|
||||||
|
so a consumer inside needs `isolation.privateUsers = "identity"` for
|
||||||
|
the owning gid to mean anything.
|
||||||
|
|
||||||
`isolation.nixDaemon`
|
`isolation.nixDaemon`
|
||||||
: Whether the Nix daemon and CLI are available inside the container.
|
: Whether the Nix daemon and CLI are available inside the container.
|
||||||
|
|
||||||
@@ -228,17 +237,6 @@ rec {
|
|||||||
: systemd-nspawn user namespacing; see `--private-users=` in
|
: systemd-nspawn user namespacing; see `--private-users=` in
|
||||||
systemd-nspawn(1). Bind mounts always go through idmapped `--bind`.
|
systemd-nspawn(1). Bind mounts always go through idmapped `--bind`.
|
||||||
|
|
||||||
`isolation.allowedDevices`
|
|
||||||
: List of `{ node; modifier; }` host devices to grant the container's
|
|
||||||
cgroup access to; see `containers.<name>.allowedDevices` in the NixOS
|
|
||||||
manual. nspawn bind-mounts a handful of devices (`/dev/kvm`,
|
|
||||||
`/dev/net/tun`, ...) into the container itself once the cgroup allows it -
|
|
||||||
this doesn't need a matching `resources.fs` bind mount.
|
|
||||||
|
|
||||||
`isolation.additionalCapabilities`
|
|
||||||
: Extra Linux capabilities granted to the container; see
|
|
||||||
`containers.<name>.additionalCapabilities` in the NixOS manual.
|
|
||||||
|
|
||||||
`miscProperties`
|
`miscProperties`
|
||||||
: Arbitrary data attached to the result. Used for cross-container discovery
|
: Arbitrary data attached to the result. Used for cross-container discovery
|
||||||
via `collectContainers`.
|
via `collectContainers`.
|
||||||
@@ -281,10 +279,9 @@ rec {
|
|||||||
cpuQuota = "${toString (cpu * 100)}%";
|
cpuQuota = "${toString (cpu * 100)}%";
|
||||||
memoryMax = resources.mem or "512M";
|
memoryMax = resources.mem or "512M";
|
||||||
bindMounts = resources.fs or { };
|
bindMounts = resources.fs or { };
|
||||||
|
devices = resources.devices or [ ];
|
||||||
allowsNixDaemon = isolation.nixDaemon or false;
|
allowsNixDaemon = isolation.nixDaemon or false;
|
||||||
privateUsers = isolation.privateUsers or "pick";
|
privateUsers = isolation.privateUsers or "pick";
|
||||||
allowedDevices = isolation.allowedDevices or [ ];
|
|
||||||
additionalCapabilities = isolation.additionalCapabilities or [ ];
|
|
||||||
|
|
||||||
allowInternet = hasInternetAccess access;
|
allowInternet = hasInternetAccess access;
|
||||||
allBindMounts = builtins.foldl' (acc: t: acc // (t.resources.fs or { })) { } traits // bindMounts;
|
allBindMounts = builtins.foldl' (acc: t: acc // (t.resources.fs or { })) { } traits // bindMounts;
|
||||||
@@ -376,17 +373,13 @@ rec {
|
|||||||
hostAddr
|
hostAddr
|
||||||
bindMountHostPaths
|
bindMountHostPaths
|
||||||
includedInTests
|
includedInTests
|
||||||
|
devices
|
||||||
;
|
;
|
||||||
bindMounts = allBindMounts;
|
bindMounts = allBindMounts;
|
||||||
kind = "nspawn";
|
kind = "nspawn";
|
||||||
miscProperties = flattenMiscProp self miscProperties;
|
miscProperties = flattenMiscProp self miscProperties;
|
||||||
nixosContainer = {
|
nixosContainer = {
|
||||||
inherit
|
inherit autoStart privateUsers;
|
||||||
autoStart
|
|
||||||
privateUsers
|
|
||||||
allowedDevices
|
|
||||||
additionalCapabilities
|
|
||||||
;
|
|
||||||
bindMounts = { };
|
bindMounts = { };
|
||||||
extraFlags = bindMountExtraFlags;
|
extraFlags = bindMountExtraFlags;
|
||||||
privateNetwork = true;
|
privateNetwork = true;
|
||||||
@@ -521,6 +514,7 @@ rec {
|
|||||||
;
|
;
|
||||||
inherit needsGateway;
|
inherit needsGateway;
|
||||||
bindMountHostPaths = map (s: s.source) shares;
|
bindMountHostPaths = map (s: s.source) shares;
|
||||||
|
devices = [ ];
|
||||||
kind = "vm";
|
kind = "vm";
|
||||||
miscProperties = flattenMiscProp self miscProperties;
|
miscProperties = flattenMiscProp self miscProperties;
|
||||||
microvmConfig = {
|
microvmConfig = {
|
||||||
@@ -957,6 +951,7 @@ rec {
|
|||||||
startLimitBurst = 5;
|
startLimitBurst = 5;
|
||||||
startLimitIntervalSec = 120;
|
startLimitIntervalSec = 120;
|
||||||
unitConfig.RequiresMountsFor = c.bindMountHostPaths;
|
unitConfig.RequiresMountsFor = c.bindMountHostPaths;
|
||||||
|
serviceConfig.DeviceAllow = map (d: "${d} rw") c.devices;
|
||||||
};
|
};
|
||||||
|
|
||||||
# the host end of a link, for both kinds. nixos-containers only configures
|
# the host end of a link, for both kinds. nixos-containers only configures
|
||||||
@@ -1316,6 +1311,7 @@ rec {
|
|||||||
HOST_ADDR = ${pyDict pyStr (lib.mapAttrs (_: c: c.hostAddr) autoStartTestContainers)}
|
HOST_ADDR = ${pyDict pyStr (lib.mapAttrs (_: c: c.hostAddr) autoStartTestContainers)}
|
||||||
IFACE = ${pyDict pyStr (lib.mapAttrs (_: c: c.iface) autoStartTestContainers)}
|
IFACE = ${pyDict pyStr (lib.mapAttrs (_: c: c.iface) autoStartTestContainers)}
|
||||||
KIND = ${pyDict pyStr (lib.mapAttrs (_: c: c.kind) autoStartTestContainers)}
|
KIND = ${pyDict pyStr (lib.mapAttrs (_: c: c.kind) autoStartTestContainers)}
|
||||||
|
DEVICES = ${pyDict pyList (lib.mapAttrs (_: c: c.devices) autoStartTestContainers)}
|
||||||
# only nspawn guests can be entered with nsenter; a vm has no host-side
|
# only nspawn guests can be entered with nsenter; a vm has no host-side
|
||||||
# netns, so every probe that runs *inside* a guest is limited to these
|
# netns, so every probe that runs *inside* a guest is limited to these
|
||||||
enterable = [c for c in included if KIND[c] == "nspawn"]
|
enterable = [c for c in included if KIND[c] == "nspawn"]
|
||||||
|
|||||||
@@ -27,6 +27,7 @@ if TYPE_CHECKING:
|
|||||||
HOST_ADDR: dict[str, str] = {}
|
HOST_ADDR: dict[str, str] = {}
|
||||||
IFACE: dict[str, str] = {}
|
IFACE: dict[str, str] = {}
|
||||||
KIND: dict[str, str] = {}
|
KIND: dict[str, str] = {}
|
||||||
|
DEVICES: dict[str, list[str]] = {}
|
||||||
EDGES: list[tuple[str, str, list[int], list[int]]] = []
|
EDGES: list[tuple[str, str, list[int], list[int]]] = []
|
||||||
SSH_KEY: str = ""
|
SSH_KEY: str = ""
|
||||||
SSH_OPTS: str = ""
|
SSH_OPTS: str = ""
|
||||||
@@ -55,6 +56,11 @@ def container_pid(name):
|
|||||||
return server.succeed(f"machinectl show {name} -p Leader --value").strip()
|
return server.succeed(f"machinectl show {name} -p Leader --value").strip()
|
||||||
|
|
||||||
|
|
||||||
|
def ct_cmd(name, cmd):
|
||||||
|
pid = container_pid(name)
|
||||||
|
return f"{NSENTER} --mount=/proc/{pid}/ns/mnt --root=/proc/{pid}/root -- {SH} -c '{cmd}'"
|
||||||
|
|
||||||
|
|
||||||
def net_cmd(name, cmd):
|
def net_cmd(name, cmd):
|
||||||
pid = container_pid(name)
|
pid = container_pid(name)
|
||||||
return f"{NSENTER} --net=/proc/{pid}/ns/net -- {cmd}"
|
return f"{NSENTER} --net=/proc/{pid}/ns/net -- {cmd}"
|
||||||
@@ -323,3 +329,27 @@ with subtest("(functional): published ports follow the container's lifetime"):
|
|||||||
server.succeed("systemctl start container@nginx")
|
server.succeed("systemctl start container@nginx")
|
||||||
server.wait_for_unit("container@nginx.service")
|
server.wait_for_unit("container@nginx.service")
|
||||||
internet.wait_until_succeeds(ext_connect(80), timeout=30)
|
internet.wait_until_succeeds(ext_connect(80), timeout=30)
|
||||||
|
|
||||||
|
with subtest("(functional): declared devices are usable in-container"):
|
||||||
|
for name, devices in DEVICES.items():
|
||||||
|
for dev in devices:
|
||||||
|
if server.execute(f"test -e {dev}")[0] != 0:
|
||||||
|
# host lacks the device (e.g. /dev/kvm without nested
|
||||||
|
# virtualization, as in this test's own VM) - nspawn skips
|
||||||
|
# populating it in-container, so there's nothing to check.
|
||||||
|
continue
|
||||||
|
# opened, not stat'd: without DeviceAllow= the node is still visible
|
||||||
|
server.succeed(ct_cmd(name, f"exec 3<> {dev}"))
|
||||||
|
|
||||||
|
|
||||||
|
with subtest("(isolation): devices reach only the container that declared them"):
|
||||||
|
for name in enterable:
|
||||||
|
for dev in {d for ds in DEVICES.values() for d in ds} - set(DEVICES.get(name, [])):
|
||||||
|
server.fail(ct_cmd(name, f"test -e {dev}"))
|
||||||
|
|
||||||
|
|
||||||
|
with subtest("(isolation): identity uid mapping keeps the user namespace"):
|
||||||
|
for name in (n for n, ds in DEVICES.items() if ds):
|
||||||
|
host_ns = server.succeed("readlink /proc/1/ns/user").strip()
|
||||||
|
ct_ns = server.succeed(f"readlink /proc/{container_pid(name)}/ns/user").strip()
|
||||||
|
assert host_ns != ct_ns, f"{name} shares the host user namespace"
|
||||||
|
|||||||
Reference in New Issue
Block a user