Compare commits

...

8 Commits

13 changed files with 242 additions and 48 deletions

View File

@@ -9,10 +9,11 @@ find_program(GDB gdb)
set(patched_kernel ${CMAKE_CURRENT_BINARY_DIR}/kernel/${kernel_name}.elf32)
set(generic_flags -m 1G)
set(no_debug_flags)
if (${CMAKE_HOST_SYSTEM_NAME} STREQUAL "Linux")
message(STATUS "QEMU: Enabling KVM acceleration")
set(generic_flags ${generic_flags} -enable-kvm)
set(no_debug_flags ${no_debug_flags} -enable-kvm)
else ()
message(STATUS "QEMU: Host system is not Linux. KVM acceleration unavailable")
endif ()
@@ -33,7 +34,7 @@ add_custom_target(run-kernel
${QEMU}
-kernel ${patched_kernel}
-initrd ${sys_dir}/${bsp_name}
${generic_flags}
${generic_flags} ${no_debug_flags}
-serial stdio
--append kernel.early-console=ttyS0
USES_TERMINAL
@@ -42,12 +43,12 @@ add_custom_target(run-kernel
add_custom_target(run-kernel-monitor
COMMAND
${QEMU}
-kernel $<TARGET_FILE:${kernel_name}>
-kernel ${patched_kernel}
-initrd ${sys_dir}/${bsp_name}
${generic_flags}
${generic_flags} ${no_debug_flags}
-monitor stdio
USES_TERMINAL
DEPENDS ${kernel_name} bsp)
DEPENDS ${patched_kernel} bsp)
if (image_cdrom)
message(STATUS "QEMU: Enable CD-ROM boot")
@@ -55,7 +56,7 @@ if (image_cdrom)
COMMAND
${QEMU}
-cdrom ${image_cdrom}
${generic_flags}
${generic_flags} ${no_debug_flags}
-serial stdio
USES_TERMINAL
DEPENDS ${image_cdrom})
@@ -99,9 +100,9 @@ elseif (GDB)
-initrd ${sys_dir}/${bsp_name}
${generic_flags}
-s -S &
${GDB}
-o "file ${CMAKE_BINARY_DIR}/kernel/${kernel_name}.debug"
-o "remote localhost:1234"
${GDB} -tui
-ex "file ${CMAKE_BINARY_DIR}/kernel/${kernel_name}.debug"
-ex "target remote localhost:1234"
USES_TERMINAL
DEPENDS ${patched_kernel} bsp)
@@ -114,10 +115,9 @@ elseif (GDB)
${generic_flags}
-s -S &
${GDB} -tui
-s "${CMAKE_BINARY_DIR}/kernel/${kernel_name}.debug"
-ex "file ${CMAKE_BINARY_DIR}/kernel/${kernel_name}.debug"
-ex "target remote localhost:1234"
USES_TERMINAL
DEPENDS ${image_cdrom})
endif ()
endif ()

View File

@@ -8,6 +8,7 @@ if [ ! -n "$target_arch" ]; then
exit -1
fi
build_type=Debug
source_dir=$(realpath $(dirname "$0"))
native_build_dir=$source_dir/build-native
target_build_dir=$source_dir/build
@@ -28,6 +29,7 @@ cmake \
-DCMAKE_LIBRARY_OUTPUT_DIRECTORY="$native_build_dir/lib" \
-DCMAKE_ARCHIVE_OUTPUT_DIRECTORY="$native_build_dir/lib" \
-DCMAKE_EXPORT_COMPILE_COMMANDS=ON \
-DCMAKE_BUILD_TYPE=$build_type \
$source_dir/kernel/tools
popd
@@ -39,6 +41,7 @@ cmake \
-DCMAKE_INSTALL_PREFIX=$sysroot_dir \
-DCMAKE_EXPORT_COMPILE_COMMANDS=ON \
-DTARGET_ARCH=$target_arch \
-DCMAKE_BUILD_TYPE=$build_type \
$source_dir \
-DCMAKE_MODULE_PATH=$source_dir/arch/$target_arch \
-DCMAKE_SYSTEM_NAME=Rosetta \

2
kernel

Submodule kernel updated: 5f0654430d...1c7c90ef39

View File

@@ -18,4 +18,4 @@ sysroot_add_library(
HEADER_DIR /usr/include
LIB_DIR /usr/lib)
target_link_libraries(libmsg-fs libmsg libmango)
target_link_libraries(libmsg-fs libmsg libmango ulibc)

View File

@@ -1,3 +1,111 @@
void msg_fs_tmp(void)
#include <rosetta/msg/fs.h>
#include <string.h>
kern_status_t rosetta_msg_fs_open_send(
kern_handle_t port,
const char *path,
int flags,
int *out_err)
{
size_t path_len = strlen(path);
struct rosetta_msg_fs_open msg = {0};
rosetta_msg_init(&msg.msg_base, ROSETTA_MSG_FS, ROSETTA_MSG_FS_OPEN);
uint16_t offset = sizeof msg;
msg.msg_request.o_path = offset;
msg.msg_request.o_path_len = path_len;
msg.msg_request.o_flags = flags;
struct iovec send_vec[] = {
IOVEC(&msg, sizeof msg),
IOVEC(path, path_len),
};
struct iovec reply_vec[] = {
IOVEC(&msg, sizeof msg),
};
struct msg req = {
.msg_data = send_vec,
.msg_data_count = sizeof send_vec / sizeof send_vec[0],
};
struct msg resp = {
.msg_data = reply_vec,
.msg_data_count = sizeof reply_vec / sizeof reply_vec[0],
};
kern_status_t status = msg_send(port, 0, &req, &resp);
if (status != KERN_OK) {
return status;
}
*out_err = msg.msg_response.o_err;
return KERN_OK;
}
kern_status_t rosetta_msg_fs_open_recv(
kern_handle_t channel,
msgid_t id,
struct rosetta_msg_string *out_path,
int *out_flags)
{
struct rosetta_msg_fs_open msg;
struct iovec vec = IOVEC(&msg, sizeof msg);
size_t r = 0;
kern_status_t status = msg_read(channel, id, 0, &vec, 1, &r);
if (status != KERN_OK) {
return status;
}
if (r != sizeof msg) {
/* TODO better error code for malformed messages */
return KERN_INVALID_ARGUMENT;
}
out_path->s_len = msg.msg_request.o_path_len;
if (out_path->s_max > 0) {
vec.io_base = (virt_addr_t)out_path->s_buf;
vec.io_len = out_path->s_max - 1;
if (vec.io_len > out_path->s_len) {
vec.io_len = out_path->s_len;
}
status = msg_read(
channel,
id,
msg.msg_request.o_path,
&vec,
1,
&r);
if (status != KERN_OK) {
return status;
}
if (r != out_path->s_len) {
return KERN_INVALID_ARGUMENT;
}
out_path->s_buf[out_path->s_len] = 0;
}
*out_flags = msg.msg_request.o_flags;
return KERN_OK;
}
kern_status_t rosetta_msg_fs_open_reply(
kern_handle_t channel,
msgid_t id,
int err)
{
struct rosetta_msg_fs_open msg = {0};
msg.msg_response.o_err = err;
struct iovec vec = IOVEC(&msg, sizeof msg);
struct msg kmsg = {.msg_data = &vec, .msg_data_count = 1};
return msg_reply(channel, 0, id, &kmsg);
}

View File

@@ -7,21 +7,36 @@
#define ROSETTA_MSG_FS 0x01409DD2U
/* rosetta.msg.fs.open message ID */
#define ROSETTA_MSG_FS_OPEN 0x7D837778U
#define ROSETTA_MSG_FS_OPEN 0x7778U
struct rosetta_msg_fs_open {
struct rosetta_msg msg_base;
union {
struct {
uint16_t o_path;
uint16_t o_path_len;
uint16_t o_flags;
} msg_request;
struct {
int o_err;
uint16_t o_fd_index;
} msg_response;
};
};
extern kern_status_t rosetta_msg_fs_open_send(
kern_handle_t port,
const char *path,
int flags,
int *out_err);
extern kern_status_t rosetta_msg_fs_open_recv(
kern_handle_t channel,
msgid_t id,
struct rosetta_msg_string *out_path,
int *out_flags);
extern kern_status_t rosetta_msg_fs_open_reply(
kern_handle_t channel,
msgid_t id,
int err);
#endif

View File

@@ -18,4 +18,4 @@ sysroot_add_library(
HEADER_DIR /usr/include
LIB_DIR /usr/lib)
target_link_libraries(libmsg libmango)
target_link_libraries(libmsg libmango ulibc)

View File

@@ -3,6 +3,7 @@
#define ROSETTA_MSG_MAGIC 0x9AB07D10U
#include <mango/msg.h>
#include <stdint.h>
struct rosetta_msg {
@@ -12,4 +13,19 @@ struct rosetta_msg {
uint16_t msg_reserved;
};
struct rosetta_msg_string {
char *s_buf;
size_t s_len;
size_t s_max;
};
extern void rosetta_msg_init(
struct rosetta_msg *msg,
uint32_t protocol_id,
uint16_t msg_id);
extern kern_status_t rosetta_msg_recv(
kern_handle_t channel,
msgid_t *out_id,
struct rosetta_msg *out_msg);
#endif

View File

@@ -1,3 +1,33 @@
void msg_tmp(void)
#include <rosetta/msg.h>
#include <string.h>
void rosetta_msg_init(
struct rosetta_msg *msg,
uint32_t protocol_id,
uint16_t msg_id)
{
memset(msg, 0x0, sizeof *msg);
msg->msg_magic = ROSETTA_MSG_MAGIC;
msg->msg_protocol = protocol_id;
msg->msg_id = msg_id;
}
kern_status_t rosetta_msg_recv(
kern_handle_t channel,
msgid_t *out_id,
struct rosetta_msg *out_msg)
{
struct iovec iov = IOVEC(out_msg, sizeof *out_msg);
struct msg kmsg = MSG(&iov, 1, NULL, 0);
kern_status_t status = msg_recv(channel, 0, out_id, &kmsg);
if (status != KERN_OK) {
return status;
}
if (out_msg->msg_magic != ROSETTA_MSG_MAGIC) {
return KERN_INVALID_ARGUMENT;
}
return KERN_OK;
}

View File

@@ -5,7 +5,7 @@ set_property(SOURCE ${arch_sources} PROPERTY LANGUAGE C)
add_executable(bootstrap ${c_sources} ${arch_sources})
target_link_libraries(bootstrap libmango ulibc liblaunch)
target_link_libraries(bootstrap libmango ulibc liblaunch libmsg-fs)
target_compile_options(bootstrap PRIVATE
-fPIC -pie -fno-stack-protector -nostdlib -ffreestanding)

View File

@@ -5,9 +5,10 @@
#include <mango/msg.h>
#include <mango/task.h>
#include <mango/types.h>
#include <rosetta/msg.h>
#include <rosetta/msg/fs.h>
#include <stdint.h>
#include <stdio.h>
#include <string.h>
#define INIT_PATH "/usr/bin/test"
@@ -98,27 +99,47 @@ int main(
kern_logf("launch result: %d", status);
#if 1
char msg_buf[512];
struct iovec vec = {
.io_base = (virt_addr_t)msg_buf,
.io_len = sizeof msg_buf,
};
struct msg msg = {.msg_data = &vec, .msg_data_count = 1};
while (1) {
msgid_t id = 0;
kern_status_t kstatus = msg_recv(channel, 0, &id, &msg);
if (kstatus != KERN_OK) {
kern_logf("msg_recv failed %d", kstatus);
break;
msgid_t id;
struct rosetta_msg msg;
kern_status_t status = rosetta_msg_recv(channel, &id, &msg);
if (status != KERN_OK) {
kern_logf("message recv error %d", status);
continue;
}
kern_logf("received message %zx: %s", id, msg_buf);
if (msg.msg_protocol != ROSETTA_MSG_FS) {
kern_logf(
"unknown message protocol %u",
msg.msg_protocol);
continue;
}
size_t len = snprintf(msg_buf, sizeof msg_buf, "Goodbye!");
vec.io_len = len + 1;
if (msg.msg_id != ROSETTA_MSG_FS_OPEN) {
kern_logf("unknown message function %u", msg.msg_id);
continue;
}
msg_reply(channel, 0, id, &msg);
char path[4096];
int flags;
struct rosetta_msg_string path_str = {
.s_buf = path,
.s_max = sizeof path,
};
status = rosetta_msg_fs_open_recv(
channel,
id,
&path_str,
&flags);
if (status != KERN_OK) {
kern_logf("rosetta.fs.open recv error %d", status);
continue;
}
kern_logf("open(%s, %d)", path, flags);
rosetta_msg_fs_open_reply(channel, id, 0);
}
#endif

View File

@@ -9,7 +9,7 @@ set_target_properties(ld PROPERTIES
OUTPUT_NAME "ld64"
SUFFIX ".so")
target_link_libraries(ld ulibc libmango)
target_link_libraries(ld ulibc libmango libmsg-fs)
target_compile_options(ld PRIVATE
-fPIC -fno-stack-protector -nostdlib -ffreestanding)

View File

@@ -1,6 +1,7 @@
#include <mango/log.h>
#include <mango/msg.h>
#include <mango/types.h>
#include <rosetta/msg/fs.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
@@ -35,21 +36,21 @@ int main(
#if 1
port_connect(port, 0, 0);
const char msg_buf[] = "Hello!";
struct iovec vec = IOVEC(msg_buf, 7);
struct msg msg = MSG(&vec, 1, NULL, 0);
const char *path = "/usr/lib/libc.so";
int flags = 4;
int err = 0;
char recv_buf[64];
struct iovec recv_vec = IOVEC(recv_buf, sizeof recv_buf);
struct msg recv_msg = MSG(&recv_vec, 1, NULL, 0);
kern_logf("calling open(%s, %d)", path, flags);
status = rosetta_msg_fs_open_send(port, path, flags, &err);
kern_logf("sending message...");
status = msg_send(port, 0, &msg, &recv_msg);
kern_logf("msg_send: %d", status);
if (status == KERN_OK) {
kern_logf("reply: %s", recv_buf);
if (status != KERN_OK) {
kern_logf("open call failed (status %d)", status);
} else if (err != 0) {
kern_logf("open call returned error %d", err);
} else {
kern_logf("open call succeeded");
}
#endif
return 0;
}