mirror of
https://github.com/kata-containers/kata-containers.git
synced 2025-08-02 00:02:01 +00:00
ca477a18b6
This commit updates the headers in the Go source files to adhere to the new guidelines in the CONTRIBUTING.md file. Signed-off-by: Mark Ryan <mark.d.ryan@intel.com>
86 lines
2.5 KiB
Go
86 lines
2.5 KiB
Go
/*
|
|
// Copyright contributors to the Virtual Machine Manager for Go project
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 (the "License");
|
|
// you may not use this file except in compliance with the License.
|
|
// You may obtain a copy of the License at
|
|
//
|
|
// http://www.apache.org/licenses/LICENSE-2.0
|
|
//
|
|
// Unless required by applicable law or agreed to in writing, software
|
|
// distributed under the License is distributed on an "AS IS" BASIS,
|
|
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
// See the License for the specific language governing permissions and
|
|
// limitations under the License.
|
|
*/
|
|
|
|
package qemu_test
|
|
|
|
import (
|
|
"time"
|
|
|
|
"context"
|
|
|
|
"github.com/intel/govmm/qemu"
|
|
)
|
|
|
|
func Example() {
|
|
params := make([]string, 0, 32)
|
|
|
|
// Rootfs
|
|
params = append(params, "-drive", "file=/tmp/image.qcow2,if=virtio,aio=threads,format=qcow2")
|
|
// Network
|
|
params = append(params, "-net", "nic,model=virtio", "-net", "user")
|
|
// kvm
|
|
params = append(params, "-enable-kvm", "-cpu", "host")
|
|
// qmp socket
|
|
params = append(params, "-daemonize", "-qmp", "unix:/tmp/qmp-socket,server,nowait")
|
|
// resources
|
|
params = append(params, "-m", "370", "-smp", "cpus=2")
|
|
|
|
// LaunchCustomQemu should return as soon as the instance has launched as we
|
|
// are using the --daemonize flag. It will set up a unix domain socket
|
|
// called /tmp/qmp-socket that we can use to manage the instance.
|
|
_, err := qemu.LaunchCustomQemu(context.Background(), "", params, nil, nil, nil)
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
// This channel will be closed when the instance dies.
|
|
disconnectedCh := make(chan struct{})
|
|
|
|
// Set up our options. We don't want any logging or to receive any events.
|
|
cfg := qemu.QMPConfig{}
|
|
|
|
// Start monitoring the qemu instance. This functon will block until we have
|
|
// connect to the QMP socket and received the welcome message.
|
|
q, _, err := qemu.QMPStart(context.Background(), "/tmp/qmp-socket", cfg, disconnectedCh)
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
// This has to be the first command executed in a QMP session.
|
|
err = q.ExecuteQMPCapabilities(context.Background())
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
|
|
// Let's try to shutdown the VM. If it hasn't shutdown in 10 seconds we'll
|
|
// send a quit message.
|
|
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
|
|
err = q.ExecuteSystemPowerdown(ctx)
|
|
cancel()
|
|
if err != nil {
|
|
err = q.ExecuteQuit(context.Background())
|
|
if err != nil {
|
|
panic(err)
|
|
}
|
|
}
|
|
|
|
q.Shutdown()
|
|
|
|
// disconnectedCh is closed when the VM exits. This line blocks until this
|
|
// event occurs.
|
|
<-disconnectedCh
|
|
}
|