// SPDX-License-Identifier: GPL-2.0 /* * Copyright 2020-2021 Amazon.com, Inc. or its affiliates. All Rights Reserved.
*/
/** * DOC: Sample flow of using the ioctl interface provided by the Nitro Enclaves (NE) * kernel driver. * * Usage * ----- * * Load the nitro_enclaves module, setting also the enclave CPU pool. The * enclave CPUs need to be full cores from the same NUMA node. CPU 0 and its * siblings have to remain available for the primary / parent VM, so they * cannot be included in the enclave CPU pool. * * See the cpu list section from the kernel documentation. * https://www.kernel.org/doc/html/latest/admin-guide/kernel-parameters.html#cpu-lists * * insmod drivers/virt/nitro_enclaves/nitro_enclaves.ko * lsmod * * The CPU pool can be set at runtime, after the kernel module is loaded. * * echo <cpu-list> > /sys/module/nitro_enclaves/parameters/ne_cpus * * NUMA and CPU siblings information can be found using: * * lscpu * /proc/cpuinfo * * Check the online / offline CPU list. The CPUs from the pool should be * offlined. * * lscpu * * Check dmesg for any warnings / errors through the NE driver lifetime / usage. * The NE logs contain the "nitro_enclaves" or "pci 0000:00:02.0" pattern. * * dmesg * * Setup hugetlbfs huge pages. The memory needs to be from the same NUMA node as * the enclave CPUs. * * https://www.kernel.org/doc/html/latest/admin-guide/mm/hugetlbpage.html * * By default, the allocation of hugetlb pages are distributed on all possible * NUMA nodes. Use the following configuration files to set the number of huge * pages from a NUMA node: * * /sys/devices/system/node/node<X>/hugepages/hugepages-2048kB/nr_hugepages * /sys/devices/system/node/node<X>/hugepages/hugepages-1048576kB/nr_hugepages * * or, if not on a system with multiple NUMA nodes, can also set the number * of 2 MiB / 1 GiB huge pages using * * /sys/kernel/mm/hugepages/hugepages-2048kB/nr_hugepages * /sys/kernel/mm/hugepages/hugepages-1048576kB/nr_hugepages * * In this example 256 hugepages of 2 MiB are used. * * Build and run the NE sample. * * make -C samples/nitro_enclaves clean * make -C samples/nitro_enclaves * ./samples/nitro_enclaves/ne_ioctl_sample <path_to_enclave_image> * * Unload the nitro_enclaves module. * * rmmod nitro_enclaves * lsmod
*/
/** * NE_DEV_NAME - Nitro Enclaves (NE) misc device that provides the ioctl interface.
*/ #define NE_DEV_NAME "/dev/nitro_enclaves"
/** * NE_POLL_WAIT_TIME - Timeout in seconds for each poll event.
*/ #define NE_POLL_WAIT_TIME (60) /** * NE_POLL_WAIT_TIME_MS - Timeout in milliseconds for each poll event.
*/ #define NE_POLL_WAIT_TIME_MS (NE_POLL_WAIT_TIME * 1000)
/** * NE_SLEEP_TIME - Amount of time in seconds for the process to keep the enclave alive.
*/ #define NE_SLEEP_TIME (300)
/** * NE_DEFAULT_NR_VCPUS - Default number of vCPUs set for an enclave.
*/ #define NE_DEFAULT_NR_VCPUS (2)
/** * NE_MIN_MEM_REGION_SIZE - Minimum size of a memory region - 2 MiB.
*/ #define NE_MIN_MEM_REGION_SIZE (2 * 1024 * 1024)
/** * NE_DEFAULT_NR_MEM_REGIONS - Default number of memory regions of 2 MiB set for * an enclave.
*/ #define NE_DEFAULT_NR_MEM_REGIONS (256)
/** * NE_IMAGE_LOAD_HEARTBEAT_CID - Vsock CID for enclave image loading heartbeat logic.
*/ #define NE_IMAGE_LOAD_HEARTBEAT_CID (3) /** * NE_IMAGE_LOAD_HEARTBEAT_PORT - Vsock port for enclave image loading heartbeat logic.
*/ #define NE_IMAGE_LOAD_HEARTBEAT_PORT (9000) /** * NE_IMAGE_LOAD_HEARTBEAT_VALUE - Heartbeat value for enclave image loading.
*/ #define NE_IMAGE_LOAD_HEARTBEAT_VALUE (0xb7)
/** * struct ne_user_mem_region - User space memory region set for an enclave. * @userspace_addr: Address of the user space memory region. * @memory_size: Size of the user space memory region.
*/ struct ne_user_mem_region { void *userspace_addr;
size_t memory_size;
};
/** * ne_create_vm() - Create a slot for the enclave VM. * @ne_dev_fd: The file descriptor of the NE misc device. * @slot_uid: The generated slot uid for the enclave. * @enclave_fd : The generated file descriptor for the enclave. * * Context: Process context. * Return: * * 0 on success. * * Negative return value on failure.
*/ staticint ne_create_vm(int ne_dev_fd, unsignedlong *slot_uid, int *enclave_fd)
{ int rc = -EINVAL;
*enclave_fd = ioctl(ne_dev_fd, NE_CREATE_VM, slot_uid);
if (*enclave_fd < 0) {
rc = *enclave_fd; switch (errno) { case NE_ERR_NO_CPUS_AVAIL_IN_POOL: {
printf("Error in create VM, no CPUs available in the NE CPU pool\n");
break;
}
default:
printf("Error in create VM [%m]\n");
}
return rc;
}
return 0;
}
/** * ne_poll_enclave_fd() - Thread function for polling the enclave fd. * @data: Argument provided for the polling function. * * Context: Process context. * Return: * * NULL on success / failure.
*/ void *ne_poll_enclave_fd(void *data)
{ int enclave_fd = *(int *)data; struct pollfd fds[1] = {}; int i = 0; int rc = -EINVAL;
printf("Running from poll thread, enclave fd %d\n", enclave_fd);
/* Keep on polling until the current process is terminated. */ while (1) {
printf("[iter %d] Polling ...\n", i);
rc = poll(fds, 1, NE_POLL_WAIT_TIME_MS); if (rc < 0) {
printf("Error in poll [%m]\n");
return NULL;
}
i++;
if (!rc) {
printf("Poll: %d seconds elapsed\n",
i * NE_POLL_WAIT_TIME);
continue;
}
printf("Poll received value 0x%x\n", fds[0].revents);
if (fds[0].revents & POLLHUP) {
printf("Received POLLHUP\n");
return NULL;
}
if (fds[0].revents & POLLNVAL) {
printf("Received POLLNVAL\n");
return NULL;
}
}
return NULL;
}
/** * ne_alloc_user_mem_region() - Allocate a user space memory region for an enclave. * @ne_user_mem_region: User space memory region allocated using hugetlbfs. * * Context: Process context. * Return: * * 0 on success. * * Negative return value on failure.
*/ staticint ne_alloc_user_mem_region(struct ne_user_mem_region *ne_user_mem_region)
{ /** * Check available hugetlb encodings for different huge page sizes in * include/uapi/linux/mman.h.
*/
ne_user_mem_region->userspace_addr = mmap(NULL, ne_user_mem_region->memory_size,
PROT_READ | PROT_WRITE,
MAP_PRIVATE | MAP_ANONYMOUS |
MAP_HUGETLB | MAP_HUGE_2MB, -1, 0); if (ne_user_mem_region->userspace_addr == MAP_FAILED) {
printf("Error in mmap memory [%m]\n");
return -1;
}
return 0;
}
/** * ne_load_enclave_image() - Place the enclave image in the enclave memory. * @enclave_fd : The file descriptor associated with the enclave. * @ne_user_mem_regions: User space memory regions allocated for the enclave. * @enclave_image_path : The file path of the enclave image. * * Context: Process context. * Return: * * 0 on success. * * Negative return value on failure.
*/ staticint ne_load_enclave_image(int enclave_fd, struct ne_user_mem_region ne_user_mem_regions[], char *enclave_image_path)
{ unsignedchar *enclave_image = NULL; int enclave_image_fd = -1;
size_t enclave_image_size = 0;
size_t enclave_memory_size = 0; unsignedlong i = 0;
size_t image_written_bytes = 0; struct ne_image_load_info image_load_info = {
.flags = NE_EIF_IMAGE,
}; struct stat image_stat_buf = {}; int rc = -EINVAL;
size_t temp_image_offset = 0;
for (i = 0; i < NE_DEFAULT_NR_MEM_REGIONS; i++)
enclave_memory_size += ne_user_mem_regions[i].memory_size;
rc = stat(enclave_image_path, &image_stat_buf); if (rc < 0) {
printf("Error in get image stat info [%m]\n");
return rc;
}
enclave_image_size = image_stat_buf.st_size;
if (enclave_memory_size < enclave_image_size) {
printf("The enclave memory is smaller than the enclave image size\n");
return -ENOMEM;
}
rc = ioctl(enclave_fd, NE_GET_IMAGE_LOAD_INFO, &image_load_info); if (rc < 0) { switch (errno) { case NE_ERR_NOT_IN_INIT_STATE: {
printf("Error in get image load info, enclave not in init state\n");
break;
}
case NE_ERR_INVALID_FLAG_VALUE: {
printf("Error in get image load info, provided invalid flag\n");
break;
}
default:
printf("Error in get image load info [%m]\n");
}
return rc;
}
printf("Enclave image offset in enclave memory is %lld\n",
image_load_info.memory_offset);
enclave_image_fd = open(enclave_image_path, O_RDONLY); if (enclave_image_fd < 0) {
printf("Error in open enclave image file [%m]\n");
return enclave_image_fd;
}
enclave_image = mmap(NULL, enclave_image_size, PROT_READ,
MAP_PRIVATE, enclave_image_fd, 0); if (enclave_image == MAP_FAILED) {
printf("Error in mmap enclave image [%m]\n");
if (image_written_bytes == enclave_image_size) break;
}
munmap(enclave_image, enclave_image_size);
close(enclave_image_fd);
return 0;
}
/** * ne_set_user_mem_region() - Set a user space memory region for the given enclave. * @enclave_fd : The file descriptor associated with the enclave. * @ne_user_mem_region : User space memory region to be set for the enclave. * * Context: Process context. * Return: * * 0 on success. * * Negative return value on failure.
*/ staticint ne_set_user_mem_region(int enclave_fd, struct ne_user_mem_region ne_user_mem_region)
{ struct ne_user_memory_region mem_region = {
.flags = NE_DEFAULT_MEMORY_REGION,
.memory_size = ne_user_mem_region.memory_size,
.userspace_addr = (__u64)ne_user_mem_region.userspace_addr,
}; int rc = -EINVAL;
rc = ioctl(enclave_fd, NE_SET_USER_MEMORY_REGION, &mem_region); if (rc < 0) { switch (errno) { case NE_ERR_NOT_IN_INIT_STATE: {
printf("Error in set user memory region, enclave not in init state\n");
break;
}
case NE_ERR_INVALID_MEM_REGION_SIZE: {
printf("Error in set user memory region, mem size not multiple of 2 MiB\n");
break;
}
case NE_ERR_INVALID_MEM_REGION_ADDR: {
printf("Error in set user memory region, invalid user space address\n");
break;
}
case NE_ERR_UNALIGNED_MEM_REGION_ADDR: {
printf("Error in set user memory region, unaligned user space address\n");
break;
}
case NE_ERR_MEM_REGION_ALREADY_USED: {
printf("Error in set user memory region, memory region already used\n");
break;
}
case NE_ERR_MEM_NOT_HUGE_PAGE: {
printf("Error in set user memory region, not backed by huge pages\n");
break;
}
case NE_ERR_MEM_DIFFERENT_NUMA_NODE: {
printf("Error in set user memory region, different NUMA node than CPUs\n");
break;
}
case NE_ERR_MEM_MAX_REGIONS: {
printf("Error in set user memory region, max memory regions reached\n");
break;
}
case NE_ERR_INVALID_PAGE_SIZE: {
printf("Error in set user memory region, has page not multiple of 2 MiB\n");
break;
}
case NE_ERR_INVALID_FLAG_VALUE: {
printf("Error in set user memory region, provided invalid flag\n");
break;
}
default:
printf("Error in set user memory region [%m]\n");
}
return rc;
}
return 0;
}
/** * ne_free_mem_regions() - Unmap all the user space memory regions that were set * aside for the enclave. * @ne_user_mem_regions: The user space memory regions associated with an enclave. * * Context: Process context.
*/ staticvoid ne_free_mem_regions(struct ne_user_mem_region ne_user_mem_regions[])
{ unsignedint i = 0;
for (i = 0; i < NE_DEFAULT_NR_MEM_REGIONS; i++)
munmap(ne_user_mem_regions[i].userspace_addr,
ne_user_mem_regions[i].memory_size);
}
/** * ne_add_vcpu() - Add a vCPU to the given enclave. * @enclave_fd : The file descriptor associated with the enclave. * @vcpu_id: vCPU id to be set for the enclave, either provided or * auto-generated (if provided vCPU id is 0). * * Context: Process context. * Return: * * 0 on success. * * Negative return value on failure.
*/ staticint ne_add_vcpu(int enclave_fd, unsignedint *vcpu_id)
{ int rc = -EINVAL;
rc = ioctl(enclave_fd, NE_ADD_VCPU, vcpu_id); if (rc < 0) { switch (errno) { case NE_ERR_NO_CPUS_AVAIL_IN_POOL: {
printf("Error in add vcpu, no CPUs available in the NE CPU pool\n");
break;
}
case NE_ERR_VCPU_ALREADY_USED: {
printf("Error in add vcpu, the provided vCPU is already used\n");
break;
}
case NE_ERR_VCPU_NOT_IN_CPU_POOL: {
printf("Error in add vcpu, the provided vCPU is not in the NE CPU pool\n");
break;
}
case NE_ERR_VCPU_INVALID_CPU_CORE: {
printf("Error in add vcpu, the core id of the provided vCPU is invalid\n");
break;
}
case NE_ERR_NOT_IN_INIT_STATE: {
printf("Error in add vcpu, enclave not in init state\n");
break;
}
case NE_ERR_INVALID_VCPU: {
printf("Error in add vcpu, the provided vCPU is out of avail CPUs range\n");
break;
}
default:
printf("Error in add vcpu [%m]\n");
}
return rc;
}
return 0;
}
/** * ne_start_enclave() - Start the given enclave. * @enclave_fd : The file descriptor associated with the enclave. * @enclave_start_info : Enclave metadata used for starting e.g. vsock CID. * * Context: Process context. * Return: * * 0 on success. * * Negative return value on failure.
*/ staticint ne_start_enclave(int enclave_fd, struct ne_enclave_start_info *enclave_start_info)
{ int rc = -EINVAL;
rc = ioctl(enclave_fd, NE_START_ENCLAVE, enclave_start_info); if (rc < 0) { switch (errno) { case NE_ERR_NOT_IN_INIT_STATE: {
printf("Error in start enclave, enclave not in init state\n");
break;
}
case NE_ERR_NO_MEM_REGIONS_ADDED: {
printf("Error in start enclave, no memory regions have been added\n");
break;
}
case NE_ERR_NO_VCPUS_ADDED: {
printf("Error in start enclave, no vCPUs have been added\n");
break;
}
case NE_ERR_FULL_CORES_NOT_USED: {
printf("Error in start enclave, enclave has no full cores set\n");
break;
}
case NE_ERR_ENCLAVE_MEM_MIN_SIZE: {
printf("Error in start enclave, enclave memory is less than min size\n");
break;
}
case NE_ERR_INVALID_FLAG_VALUE: {
printf("Error in start enclave, provided invalid flag\n");
break;
}
case NE_ERR_INVALID_ENCLAVE_CID: {
printf("Error in start enclave, provided invalid enclave CID\n");
break;
}
default:
printf("Error in start enclave [%m]\n");
}
return rc;
}
return 0;
}
/** * ne_start_enclave_check_booted() - Start the enclave and wait for a heartbeat * from it, on a newly created vsock channel, * to check it has booted. * @enclave_fd : The file descriptor associated with the enclave. * * Context: Process context. * Return: * * 0 on success. * * Negative return value on failure.
*/ staticint ne_start_enclave_check_booted(int enclave_fd)
{ struct sockaddr_vm client_vsock_addr = {}; int client_vsock_fd = -1;
socklen_t client_vsock_len = sizeof(client_vsock_addr); struct ne_enclave_start_info enclave_start_info = {}; struct pollfd fds[1] = {}; int rc = -EINVAL; unsignedchar recv_buf = 0; struct sockaddr_vm server_vsock_addr = {
.svm_family = AF_VSOCK,
.svm_cid = NE_IMAGE_LOAD_HEARTBEAT_CID,
.svm_port = NE_IMAGE_LOAD_HEARTBEAT_PORT,
}; int server_vsock_fd = -1;
rc = poll(fds, 1, NE_POLL_WAIT_TIME_MS); if (rc < 0) {
printf("Error in poll [%m]\n");
goto out;
}
if (!rc) {
printf("Poll timeout, %d seconds elapsed\n", NE_POLL_WAIT_TIME);
rc = -ETIMEDOUT;
goto out;
}
if ((fds[0].revents & POLLIN) == 0) {
printf("Poll received value %d\n", fds[0].revents);
rc = -EINVAL;
goto out;
}
rc = accept(server_vsock_fd, (struct sockaddr *)&client_vsock_addr,
&client_vsock_len); if (rc < 0) {
printf("Error in accept [%m]\n");
goto out;
}
client_vsock_fd = rc;
/* * Read the heartbeat value that the init process in the enclave sends * after vsock connect.
*/
rc = read(client_vsock_fd, &recv_buf, sizeof(recv_buf)); if (rc < 0) {
printf("Error in read [%m]\n");
goto out;
}
if (rc != sizeof(recv_buf) || recv_buf != NE_IMAGE_LOAD_HEARTBEAT_VALUE) {
printf("Read %d instead of %d\n", recv_buf,
NE_IMAGE_LOAD_HEARTBEAT_VALUE);
goto out;
}
/* Write the heartbeat value back. */
rc = write(client_vsock_fd, &recv_buf, sizeof(recv_buf)); if (rc < 0) {
printf("Error in write [%m]\n");
goto out;
}
rc = 0;
out:
close(server_vsock_fd);
return rc;
}
int main(int argc, char *argv[])
{ int enclave_fd = -1; unsignedint i = 0; int ne_dev_fd = -1; struct ne_user_mem_region ne_user_mem_regions[NE_DEFAULT_NR_MEM_REGIONS] = {}; unsignedint ne_vcpus[NE_DEFAULT_NR_VCPUS] = {}; int rc = -EINVAL;
pthread_t thread_id = 0; unsignedlong slot_uid = 0;
if (argc != 2) {
printf("Usage: %s \n", argv[0]);
exit(EXIT_FAILURE);
}
if (strlen(argv[1]) >= PATH_MAX) {
printf("The size of the path to enclave image is higher than max path\n");
exit(EXIT_FAILURE);
}
ne_dev_fd = open(NE_DEV_NAME, O_RDWR | O_CLOEXEC); if (ne_dev_fd < 0) {
printf("Error in open NE device [%m]\n");
for (i = 0; i < NE_DEFAULT_NR_MEM_REGIONS; i++) {
rc = ne_set_user_mem_region(enclave_fd, ne_user_mem_regions[i]); if (rc < 0) {
printf("Error in set memory region, iter %d\n", i);
goto release_enclave_fd;
}
}
printf("Enclave memory regions were added\n");
for (i = 0; i < NE_DEFAULT_NR_VCPUS; i++) { /* * The vCPU is chosen from the enclave vCPU pool, if the value * of the vcpu_id is 0.
*/
ne_vcpus[i] = 0;
rc = ne_add_vcpu(enclave_fd, &ne_vcpus[i]); if (rc < 0) {
printf("Error in add vcpu, iter %d\n", i);
goto release_enclave_fd;
}
printf("Added vCPU %d to the enclave\n", ne_vcpus[i]);
}
printf("Enclave vCPUs were added\n");
rc = ne_start_enclave_check_booted(enclave_fd); if (rc < 0) {
printf("Error in the enclave start / image loading heartbeat logic [rc=%d]\n", rc);
goto release_enclave_fd;
}
printf("Entering sleep for %d seconds ...\n", NE_SLEEP_TIME);
Die Informationen auf dieser Webseite wurden
nach bestem Wissen sorgfältig zusammengestellt. Es wird jedoch weder Vollständigkeit, noch Richtigkeit,
noch Qualität der bereit gestellten Informationen zugesichert.
Bemerkung:
Die farbliche Syntaxdarstellung und die Messung sind noch experimentell.