Hyper初步分析

 
docker run centos:7 /bin/echo 'Hello world'

 
hyper run centos:7 /bin/echo 'Hello world'

if boot.Bios != "" && boot.Cbfs != "" {
	params = append(params,
		"-drive", fmt.Sprintf("if=pflash,file=%s,readonly=on", boot.Bios),
		"-drive", fmt.Sprintf("if=pflash,file=%s,readonly=on", boot.Cbfs))
} else if boot.Bios != "" {
	params = append(params,
		"-bios", boot.Bios,
		"-kernel", boot.Kernel, "-initrd", boot.Initrd, "-append", "\"console=ttyS0 panic=1 no_timer_check\"")
} else if boot.Cbfs != "" {
	params = append(params,
		"-drive", fmt.Sprintf("if=pflash,file=%s,readonly=on", boot.Cbfs))
} else {
	params = append(params,
		"-kernel", boot.Kernel, "-initrd", boot.Initrd, "-append", "\"console=ttyS0 panic=1 no_timer_check\"")
}

[root@localhost hyper]# ll -h
total 145M
-rwxr-xr-x. 1 root root  64K Aug 31 02:52 bios-qboot.bin
-rw-r--r--. 1 root root 4.0M Aug 31 02:52 cbfs-qboot.rom
-rw-r--r--. 1 root root  10G Sep  1 22:39 data
drwxr-xr-x. 2 root root 4.0K Sep  1 22:39 hyper.db
-rwx------. 1 root root 859K Aug 31 02:52 hyper-initrd.img
-rw-r--r--. 1 root root 3.0M Aug 31 02:52 kernel
-rw-r--r--. 1 root root 128M Sep  1 22:39 metadata

[root@localhost xd]# cpio -div < hyper-initrd 
.
lib
lib/x86_64-linux-gnu
lib/x86_64-linux-gnu/libc.so.6
init
lib64
lib64/ld-linux-x86-64.so.2
4103 blocks

qemu-system-x86_64 -machine pc-i440fx-2.0,accel=kvm,usb=off -global kvm-pit.lost_tick_policy=discard -cpu host 
-drive if=pflash,file=/var/lib/hyper/bios-qboot.bin,readonly=on -drive if=pflash,file=/var/lib/hyper/cbfs-qboot.rom,readonly=on 
-realtime mlock=off -no-user-config -nodefaults -no-hpet -rtc base=utc,driftfix=slew -no-reboot -display none -boot strict=on -m 128 -smp 1 
-qmp unix:/var/run/hyper/vm-vMaTbveMPS/qmp.sock,server,nowait 
-serial unix:/var/run/hyper/vm-vMaTbveMPS/console.sock,server,nowait 
-device virtio-serial-pci,id=virtio-serial0,bus=pci.0,addr=0x2 
-device virtio-scsi-pci,id=scsi0,bus=pci.0,addr=0x3 
-chardev socket,id=charch0,path=/var/run/hyper/vm-vMaTbveMPS/hyper.sock,server,nowait 
-device virtserialport,bus=virtio-serial0.0,nr=1,chardev=charch0,id=channel0,name=sh.hyper.channel.0 
-chardev socket,id=charch1,path=/var/run/hyper/vm-vMaTbveMPS/tty.sock,server,nowait 
-device virtserialport,bus=virtio-serial0.0,nr=2,chardev=charch1,id=channel1,name=sh.hyper.channel.1 
-fsdev local,id=virtio9p,path=/var/run/hyper/vm-vMaTbveMPS/share_dir,security_model=none 
-device virtio-9p-pci,fsdev=virtio9p,mount_tag=share_dir

static int hyper_channel_handle(struct hyper_event *de, uint32_t len)
{
	struct hyper_buf *buf = &de->rbuf;
	struct hyper_pod *pod = de->ptr;
	uint32_t type = 0;
	int i, ret = 0;

	for (i = 0; i < buf->get; i++)
		fprintf(stdout, "%0x ", buf->data[i]);

	type = hyper_get_be32(buf->data);

	fprintf(stdout, "\n %s, type %" PRIu32 ", len %" PRIu32 "\n",
		__func__, type, len);

	pod->type = type;
	switch (type) {
	case STARTPOD:
		ret = hyper_start_pod((char *)buf->data + 8, len - 8);
		hyper_print_uptime();
		break;
	case STOPPOD:
		ret = hyper_stop_pod(pod);
		break;
	case DESTROYPOD:
		fprintf(stdout, "get DESTROYPOD message\n");
		hyper_shutdown(pod);
		return 0;
	case EXECCMD:
		ret = hyper_exec_cmd((char *)buf->data + 8, len - 8);
		break;
	case PING:
	case GETPOD:
		break;
	case READY:
		ret = hyper_rescan();
		break;
	case WINSIZE:
		ret = hyper_set_win_size((char *)buf->data + 8, len - 8);
		break;
	default:
		ret = -1;
		break;
	}

	if (ret < 0)
		hyper_send_type(de->fd, ERROR);
	else
		hyper_send_type(de->fd, ACK);

	return 0;
}

static int hyper_ttyfd_handle(struct hyper_event *de, uint32_t len)
{
	struct hyper_buf *rbuf = &de->rbuf;
	struct hyper_pod *pod = de->ptr;
	struct hyper_exec *exec;
	struct hyper_buf *wbuf;
	uint64_t seq = 0;
	int size;

	seq = hyper_get_be64(rbuf->data);

	dprintf(stdout, "\n%s seq %" PRIu64", len %" PRIu32"\n", __func__, seq, len - 12);

	exec = hyper_find_exec_by_seq(pod, seq);
	if (exec == NULL) {
		wbuf = &de->wbuf;
		fprintf(stderr, "can't find exec whose seq is %" PRIu64 "\n", seq);

		/* goodbye */
		if (wbuf->get + 12 > wbuf->size)
			return 0;

		hyper_set_be64(wbuf->data + wbuf->get, seq);
		hyper_set_be32(wbuf->data + wbuf->get + 8, 12);
		wbuf->get += 12;

		if (hyper_modify_event(ctl.efd, de, EPOLLIN | EPOLLOUT) < 0) {
			fprintf(stderr, "modify ctl tty event to in & out failed\n");
			return -1;
		}

		return 0;
	}

	dprintf(stdout, "find exec %s pid %d, seq is %" PRIu64 "\n",
		exec->id ? exec->id : "pod", exec->pid, exec->seq);
	wbuf = &exec->e.wbuf;

	size = wbuf->size - wbuf->get;
	if (size == 0)
		return 0;

	/* Data may lost since pts buffer is full. do not allow one exec pts occupy all
	 * of the tty buff. */
	if (size > (len - 12))
		size = (len - 12);

	if (size > 0) {
		memcpy(wbuf->data + wbuf->get, rbuf->data + 12, size);
		wbuf->get += size;
		if (hyper_modify_event(ctl.efd, &exec->e, EPOLLIN | EPOLLOUT) < 0) {
			fprintf(stderr, "modify exec pts event to in & out failed\n");
			return -1;
		}
	}

	return 0;
}