Implement argc/argv support for spawned tasks.

Celebrate the new functionality with a simple /bin/cat implementation. :^)
This commit is contained in:
Andreas Kling 2018-10-26 11:16:56 +02:00
parent 53abfa7ea1
commit df87dda63c
Notes: sideshowbarker 2024-07-19 18:38:34 +09:00
13 changed files with 105 additions and 17 deletions

View File

@ -65,7 +65,7 @@ DWORD handle(DWORD function, DWORD arg1, DWORD arg2, DWORD arg3)
case Syscall::PosixGettimeofday: case Syscall::PosixGettimeofday:
return current->sys$gettimeofday((timeval*)arg1); return current->sys$gettimeofday((timeval*)arg1);
case Syscall::Spawn: case Syscall::Spawn:
return current->sys$spawn((const char*)arg1); return current->sys$spawn((const char*)arg1, (const char**)arg2);
case Syscall::GetDirEntries: case Syscall::GetDirEntries:
return current->sys$get_dir_entries((int)arg1, (void*)arg2, (size_t)arg3); return current->sys$get_dir_entries((int)arg1, (void*)arg2, (size_t)arg3);
case Syscall::PosixLstat: case Syscall::PosixLstat:
@ -108,6 +108,8 @@ DWORD handle(DWORD function, DWORD arg1, DWORD arg2, DWORD arg3)
current->sys$exit((int)arg1); current->sys$exit((int)arg1);
ASSERT_NOT_REACHED(); ASSERT_NOT_REACHED();
return 0; return 0;
case Syscall::GetArguments:
return current->sys$get_arguments((int*)arg1, (char***)arg2);
default: default:
kprintf("int0x80: Unknown function %x requested {%x, %x, %x}\n", function, arg1, arg2, arg3); kprintf("int0x80: Unknown function %x requested {%x, %x, %x}\n", function, arg1, arg2, arg3);
break; break;

View File

@ -31,6 +31,7 @@ enum Function {
PosixGetcwd = 0x1999, PosixGetcwd = 0x1999,
PosixGettimeofday = 0x2000, PosixGettimeofday = 0x2000,
PosixGethostname = 0x2001, PosixGethostname = 0x2001,
GetArguments = 0x2002,
}; };
void initialize(); void initialize();

View File

@ -185,18 +185,19 @@ int Task::sys$gethostname(char* buffer, size_t size)
if (size < (hn.length() + 1)) if (size < (hn.length() + 1))
return -ENAMETOOLONG; return -ENAMETOOLONG;
memcpy(buffer, hn.characters(), size); memcpy(buffer, hn.characters(), size);
return 0;
} }
int Task::sys$spawn(const char* path) int Task::sys$spawn(const char* path, const char** args)
{ {
int error = 0; int error = 0;
auto* child = Task::createUserTask(path, m_uid, m_gid, m_pid, error); auto* child = Task::createUserTask(path, m_uid, m_gid, m_pid, error, args);
if (child) if (child)
return child->pid(); return child->pid();
return error; return error;
} }
Task* Task::createUserTask(const String& path, uid_t uid, gid_t gid, pid_t parentPID, int& error) Task* Task::createUserTask(const String& path, uid_t uid, gid_t gid, pid_t parentPID, int& error, const char** args)
{ {
auto parts = path.split('/'); auto parts = path.split('/');
if (parts.isEmpty()) { if (parts.isEmpty()) {
@ -216,9 +217,20 @@ Task* Task::createUserTask(const String& path, uid_t uid, gid_t gid, pid_t paren
return nullptr; return nullptr;
} }
Vector<String> taskArguments;
if (args) {
for (size_t i = 0; args[i]; ++i) {
taskArguments.append(args[i]);
}
} else {
taskArguments.append(parts.last());
}
InterruptDisabler disabler; // FIXME: Get rid of this, jesus christ. This "critical" section is HUGE. InterruptDisabler disabler; // FIXME: Get rid of this, jesus christ. This "critical" section is HUGE.
Task* t = new Task(parts.takeLast(), uid, gid, parentPID, Ring3); Task* t = new Task(parts.takeLast(), uid, gid, parentPID, Ring3);
t->m_arguments = move(taskArguments);
ExecSpace space; ExecSpace space;
space.hookableAlloc = [&] (const String& name, size_t size) { space.hookableAlloc = [&] (const String& name, size_t size) {
if (!size) if (!size)
@ -257,6 +269,25 @@ Task* Task::createUserTask(const String& path, uid_t uid, gid_t gid, pid_t paren
return t; return t;
} }
int Task::sys$get_arguments(int* argc, char*** argv)
{
auto* region = allocateRegion(4096, "argv");
if (!region)
return -ENOMEM;
MemoryManager::the().mapRegion(*this, *region);
char* argpage = (char*)region->linearAddress.get();
*argc = m_arguments.size();
*argv = (char**)argpage;
char* bufptr = argpage + (sizeof(char*) * m_arguments.size());
for (size_t i = 0; i < m_arguments.size(); ++i) {
(*argv)[i] = bufptr;
memcpy(bufptr, m_arguments[i].characters(), m_arguments[i].length());
bufptr += m_arguments[i].length();
*(bufptr++) = '\0';
}
return 0;
}
Task* Task::createKernelTask(void (*e)(), String&& name) Task* Task::createKernelTask(void (*e)(), String&& name)
{ {
Task* task = new Task(move(name), (uid_t)0, (gid_t)0, (pid_t)0, Ring0); Task* task = new Task(move(name), (uid_t)0, (gid_t)0, (pid_t)0, Ring0);

View File

@ -16,7 +16,7 @@ class Task : public InlineLinkedListNode<Task> {
friend class InlineLinkedListNode<Task>; friend class InlineLinkedListNode<Task>;
public: public:
static Task* createKernelTask(void (*entry)(), String&& name); static Task* createKernelTask(void (*entry)(), String&& name);
static Task* createUserTask(const String& path, uid_t, gid_t, pid_t parentPID, int& error); static Task* createUserTask(const String& path, uid_t, gid_t, pid_t parentPID, int& error, const char** args = nullptr);
~Task(); ~Task();
static Vector<Task*> allTasks(); static Vector<Task*> allTasks();
@ -92,7 +92,7 @@ public:
int sys$kill(pid_t pid, int sig); int sys$kill(pid_t pid, int sig);
int sys$geterror() { return m_error; } int sys$geterror() { return m_error; }
void sys$exit(int status); void sys$exit(int status);
int sys$spawn(const char* path); int sys$spawn(const char* path, const char** args);
pid_t sys$waitpid(pid_t); pid_t sys$waitpid(pid_t);
void* sys$mmap(void*, size_t size); void* sys$mmap(void*, size_t size);
int sys$munmap(void*, size_t size); int sys$munmap(void*, size_t size);
@ -101,6 +101,7 @@ public:
int sys$sleep(unsigned seconds); int sys$sleep(unsigned seconds);
int sys$gettimeofday(timeval*); int sys$gettimeofday(timeval*);
int sys$gethostname(char* name, size_t length); int sys$gethostname(char* name, size_t length);
int sys$get_arguments(int* argc, char*** argv);
static void initialize(); static void initialize();
@ -170,6 +171,8 @@ private:
LinearAddress m_nextRegion; LinearAddress m_nextRegion;
pid_t m_parentPID { 0 }; pid_t m_parentPID { 0 };
Vector<String> m_arguments;
}; };
extern void task_init(); extern void task_init();

Binary file not shown.

View File

@ -10,5 +10,6 @@ cp ../Userland/date mnt/bin/date
cp ../Userland/true mnt/bin/true cp ../Userland/true mnt/bin/true
cp ../Userland/false mnt/bin/false cp ../Userland/false mnt/bin/false
cp ../Userland/hostname mnt/bin/hostname cp ../Userland/hostname mnt/bin/hostname
cp ../Userland/cat mnt/bin/cat
umount mnt umount mnt
sync sync

View File

@ -8,9 +8,12 @@ extern "C" int _start()
{ {
errno = 0; errno = 0;
// FIXME: Pass appropriate argc/argv. int argc;
int status = main(0, nullptr); char** argv;
int rc = Syscall::invoke(Syscall::GetArguments, (dword)&argc, (dword)&argv);
int status = 254;
if (rc == 0)
status = main(argc, argv);
Syscall::invoke(Syscall::PosixExit, status); Syscall::invoke(Syscall::PosixExit, status);
// Birger's birthday <3 // Birger's birthday <3

View File

@ -4,9 +4,9 @@
extern "C" { extern "C" {
int spawn(const char* path) int spawn(const char* path, const char** args)
{ {
int rc = Syscall::invoke(Syscall::Spawn, (dword)path); int rc = Syscall::invoke(Syscall::Spawn, (dword)path, (dword)args);
__RETURN_WITH_ERRNO(rc, rc, -1); __RETURN_WITH_ERRNO(rc, rc, -1);
} }

View File

@ -2,7 +2,7 @@
extern "C" { extern "C" {
int spawn(const char* path); int spawn(const char* path, const char** args);
} }

3
Userland/.gitignore vendored
View File

@ -1,3 +1,4 @@
*.o
id id
sh sh
ps ps
@ -8,4 +9,4 @@ date
false false
true true
hostname hostname
*.o cat

View File

@ -8,7 +8,8 @@ OBJS = \
date.o \ date.o \
true.o \ true.o \
false.o \ false.o \
hostname.o hostname.o \
cat.o
APPS = \ APPS = \
id \ id \
@ -20,7 +21,8 @@ APPS = \
date \ date \
true \ true \
false \ false \
hostname hostname \
cat
ARCH_FLAGS = ARCH_FLAGS =
STANDARD_FLAGS = -std=c++17 -nostdinc++ -nostdlib STANDARD_FLAGS = -std=c++17 -nostdinc++ -nostdlib
@ -70,6 +72,9 @@ false: false.o
hostname: hostname.o hostname: hostname.o
$(LD) -o $@ $(LDFLAGS) $< ../LibC/LibC.a $(LD) -o $@ $(LDFLAGS) $< ../LibC/LibC.a
cat: cat.o
$(LD) -o $@ $(LDFLAGS) $< ../LibC/LibC.a
.cpp.o: .cpp.o:
@echo "CXX $<"; $(CXX) $(CXXFLAGS) -o $@ -c $< @echo "CXX $<"; $(CXX) $(CXXFLAGS) -o $@ -c $<

30
Userland/cat.cpp Normal file
View File

@ -0,0 +1,30 @@
#include <LibC/stdio.h>
#include <LibC/unistd.h>
#include <LibC/errno.h>
#include <LibC/string.h>
int main(int argc, char** argv)
{
if (argc != 2) {
printf("usage: cat <file>\n");
return 1;
}
int fd = open(argv[1]);
if (fd == -1) {
printf("failed to open %s: %s\n", argv[1], strerror(errno));
return 1;
}
for (;;) {
char buf[128];
ssize_t nread = read(fd, buf, sizeof(buf));
if (nread == 0)
break;
if (nread < 0) {
printf("read() error: %s\n", strerror(errno));
return 2;
}
for (ssize_t i = 0; i < nread; ++i)
putchar(buf[i]);
}
return 0;
}

View File

@ -16,10 +16,21 @@ static int runcmd(char* cmd)
{ {
if (cmd[0] == 0) if (cmd[0] == 0)
return 0; return 0;
//printf("command: '%s'\n", cmd);
char buf[128]; char buf[128];
sprintf(buf, "/bin/%s", cmd); sprintf(buf, "/bin/%s", cmd);
int ret = spawn(buf);
const char* argv[32];
size_t argi = 1;
argv[0] = &buf[0];
size_t buflen = strlen(buf);
for (size_t i = 0; i < buflen; ++i) {
if (buf[i] == ' ') {
buf[i] = '\0';
argv[argi++] = &buf[i + 1];
}
}
argv[argi + 1] = nullptr;
int ret = spawn(argv[0], argv);
if (ret == -1) { if (ret == -1) {
printf("spawn failed: %s (%s)\n", cmd, strerror(errno)); printf("spawn failed: %s (%s)\n", cmd, strerror(errno));
return 1; return 1;