internal/netif/tap_linux.go

@@ -1,28 +0,0 @@
-//go:build linux
-
-package netif
-
-import (
-	"fmt"
-
-	"git.g3e.fr/syonad/two/internal/netns"
-	"github.com/vishvananda/netlink"
-)
-
-func CreateTap(tapID int, bridgeName, vpcName string) error {
-	name := fmt.Sprintf("tap%d", tapID)
-
-	return netns.Call(vpcName, func() error {
-		tap := &netlink.Tuntap{
-			LinkAttrs: netlink.LinkAttrs{Name: name},
-			Mode:      netlink.TUNTAP_MODE_TAP,
-		}
-		if err := netlink.LinkAdd(tap); err != nil {
-			return err
-		}
-		if err := BridgeSetMaster(name, bridgeName); err != nil {
-			return err
-		}
-		return LinkSetUp(name)
-	})
-}

internal/netif/tap_other.go

@@ -1,9 +0,0 @@
-//go:build !linux
-
-package netif
-
-import "errors"
-
-func CreateTap(_ int, _, _ string) error {
-	return errors.New("netif: tap not supported on this platform")
-}

internal/qmp/send.go

@@ -1,50 +0,0 @@
-package qmp
-
-import (
-	"bufio"
-	"encoding/json"
-	"fmt"
-	"net"
-	"strings"
-)
-
-func Send(socketPath string, commands []string) ([]json.RawMessage, error) {
-	conn, err := net.Dial("unix", socketPath)
-	if err != nil {
-		return nil, fmt.Errorf("qmp dial: %w", err)
-	}
-	defer conn.Close()
-
-	r := bufio.NewReader(conn)
-
-	if _, err := r.ReadString('\n'); err != nil {
-		return nil, fmt.Errorf("qmp read greeting: %w", err)
-	}
-
-	var sb strings.Builder
-	sb.WriteString(`{ "execute": "qmp_capabilities" }`)
-	for _, cmd := range commands {
-		sb.WriteByte('\n')
-		sb.WriteString(cmd)
-	}
-	sb.WriteByte('\n')
-
-	if _, err := fmt.Fprint(conn, sb.String()); err != nil {
-		return nil, fmt.Errorf("qmp write: %w", err)
-	}
-
-	if _, err := r.ReadString('\n'); err != nil {
-		return nil, fmt.Errorf("qmp read capabilities response: %w", err)
-	}
-
-	var results []json.RawMessage
-	for range commands {
-		line, err := r.ReadString('\n')
-		if err != nil {
-			return nil, fmt.Errorf("qmp read response: %w", err)
-		}
-		results = append(results, json.RawMessage(line))
-	}
-
-	return results, nil
-}

internal/vm/start_linux.go

@@ -1,53 +0,0 @@
-//go:build linux
-
-package vm
-
-import (
-	"fmt"
-	"os/exec"
-
-	"git.g3e.fr/syonad/two/internal/netns"
-)
-
-type Config struct {
-	Name       string
-	VpcName    string
-	TapID      int
-	Mac        string
-	VolumePath string
-	Memory     int
-	CPUs       int
-}
-
-func Start(cfg Config) error {
-	memory := cfg.Memory
-	if memory == 0 {
-		memory = 512
-	}
-
-	cpus := cfg.CPUs
-	if cpus == 0 {
-		cpus = 1
-	}
-
-	return netns.Call(cfg.VpcName, func() error {
-		cmd := exec.Command("qemu-system-x86_64",
-			"-enable-kvm",
-			"-cpu", "host",
-			"-m", fmt.Sprintf("%d", memory),
-			"-smp", fmt.Sprintf("%d", cpus),
-			"-serial", fmt.Sprintf("unix:/tmp/%s.sock,server,nowait", cfg.Name),
-			"-monitor", fmt.Sprintf("unix:/tmp/%s.mon-sock,server,nowait", cfg.Name),
-			"-qmp", fmt.Sprintf("unix:/tmp/%s.qmp-sock,server,nowait", cfg.Name),
-			"-display", "none",
-			"-drive", fmt.Sprintf("file=%s,if=virtio", cfg.VolumePath),
-			"-netdev", fmt.Sprintf("tap,id=net0,ifname=tap%d,script=no,downscript=no", cfg.TapID),
-			"-device", fmt.Sprintf("virtio-net-pci,netdev=net0,mac=%s", cfg.Mac),
-			"-daemonize",
-		)
-		if err := cmd.Run(); err != nil {
-			return fmt.Errorf("qemu-system-x86_64: %w", err)
-		}
-		return nil
-	})
-}

internal/vm/start_other.go

@@ -1,14 +0,0 @@
-//go:build !linux
-
-package vm
-
-import "errors"
-
-type Config struct {
-	Name, VpcName, Mac, VolumePath string
-	TapID, Memory, CPUs            int
-}
-
-func Start(cfg Config) error {
-	return errors.New("vm: not supported on this platform")
-}