summaryrefslogtreecommitdiff
path: root/src/user
diff options
context:
space:
mode:
authorRichard Qin <richard.qin.x@gmail.com>2026-01-04 18:06:31 +0800
committerRichard Qin <richard.qin.x@gmail.com>2026-01-04 18:06:31 +0800
commit3886749b1c8d79d4701bf6b8e66249c4e1491648 (patch)
tree142e6d9ada3d511663c6c0540196d270c69c0227 /src/user
parenta64d25c07b31d57f8706073e11cd774d0880d6dd (diff)
downloadlume-3886749b1c8d79d4701bf6b8e66249c4e1491648.tar.gz
lume-3886749b1c8d79d4701bf6b8e66249c4e1491648.tar.xz
dev(shell): implement basic shell tools
fixed(file-system): fixed read and write bugs
Diffstat (limited to 'src/user')
-rw-r--r--src/user/cat.cc48
-rw-r--r--src/user/cp.cc48
-rw-r--r--src/user/grep.cc68
-rw-r--r--src/user/kill.cc23
-rw-r--r--src/user/ln.cc18
-rw-r--r--src/user/mv.cc26
-rw-r--r--src/user/rm.cc24
-rw-r--r--src/user/sh.cc26
-rw-r--r--src/user/touch.cc27
-rw-r--r--src/user/wc.cc56
10 files changed, 354 insertions, 10 deletions
diff --git a/src/user/cat.cc b/src/user/cat.cc
new file mode 100644
index 0000000..67feb1c
--- /dev/null
+++ b/src/user/cat.cc
@@ -0,0 +1,48 @@
+#include "ulib/stdio.h"
+#include "ulib/stdlib.h"
+#include "ulib/string.h"
+#include "user/user.h"
+#include "common/fcntl.h"
+
+char buf[512];
+
+void cat(int fd)
+{
+ int n;
+ while ((n = read(fd, buf, sizeof(buf))) > 0)
+ {
+ if (write(1, buf, n) != n)
+ {
+ printf("cat: write error\n");
+ exit(1);
+ }
+ }
+ if (n < 0)
+ {
+ printf("cat: read error\n");
+ exit(1);
+ }
+}
+
+int main(int argc, char *argv[])
+{
+ int fd, i;
+
+ if (argc <= 1)
+ {
+ cat(0);
+ exit(0);
+ }
+
+ for (i = 1; i < argc; i++)
+ {
+ if ((fd = open(argv[i], O_RDONLY)) < 0)
+ {
+ printf("cat: cannot open %s\n", argv[i]);
+ exit(1);
+ }
+ cat(fd);
+ close(fd);
+ }
+ exit(0);
+} \ No newline at end of file
diff --git a/src/user/cp.cc b/src/user/cp.cc
new file mode 100644
index 0000000..9f13bef
--- /dev/null
+++ b/src/user/cp.cc
@@ -0,0 +1,48 @@
+#include "ulib/stdio.h"
+#include "ulib/stdlib.h"
+#include "user/user.h"
+#include "common/fcntl.h"
+
+char buf[512];
+
+int main(int argc, char *argv[])
+{
+ int fd_src, fd_dst, n;
+
+ if (argc != 3)
+ {
+ printf("Usage: cp src dst\n");
+ exit(1);
+ }
+
+ if ((fd_src = open(argv[1], O_RDONLY)) < 0)
+ {
+ printf("cp: cannot open source %s\n", argv[1]);
+ exit(1);
+ }
+
+ if ((fd_dst = open(argv[2], O_WRONLY | O_CREATE | O_TRUNC)) < 0)
+ {
+ printf("cp: cannot create destination %s\n", argv[2]);
+ close(fd_src);
+ exit(1);
+ }
+
+ while ((n = read(fd_src, buf, sizeof(buf))) > 0)
+ {
+ if (write(fd_dst, buf, n) != n)
+ {
+ printf("cp: write error\n");
+ exit(1);
+ }
+ }
+
+ if (n < 0)
+ {
+ printf("cp: read error\n");
+ }
+
+ close(fd_src);
+ close(fd_dst);
+ exit(0);
+} \ No newline at end of file
diff --git a/src/user/grep.cc b/src/user/grep.cc
new file mode 100644
index 0000000..5ed61b4
--- /dev/null
+++ b/src/user/grep.cc
@@ -0,0 +1,68 @@
+#include "ulib/stdio.h"
+#include "ulib/stdlib.h"
+#include "ulib/string.h"
+#include "user/user.h"
+#include "common/fcntl.h"
+
+char buf[1024];
+
+void grep(char *pattern, int fd)
+{
+ int n, m;
+ char *p, *q;
+
+ m = 0;
+ while ((n = read(fd, buf + m, sizeof(buf) - m - 1)) > 0)
+ {
+ m += n;
+ buf[m] = '\0';
+ p = buf;
+ while ((q = strchr(p, '\n')) != 0)
+ {
+ *q = 0;
+ if (strstr(p, pattern) != 0)
+ {
+ printf("%s\n", p);
+ }
+ p = q + 1;
+ }
+ if (p == buf)
+ m = 0;
+ if (m > 0)
+ {
+ m -= p - buf;
+ memmove(buf, p, m);
+ }
+ }
+}
+
+int main(int argc, char *argv[])
+{
+ int fd, i;
+ char *pattern;
+
+ if (argc < 2)
+ {
+ printf("Usage: grep pattern [file...]\n");
+ exit(1);
+ }
+ pattern = argv[1];
+
+ if (argc == 2)
+ {
+ grep(pattern, 0); // stdin
+ exit(0);
+ }
+
+ for (i = 2; i < argc; i++)
+ {
+ if ((fd = open(argv[i], O_RDONLY)) < 0)
+ {
+ printf("grep: cannot open %s\n", argv[i]);
+ exit(1);
+ }
+ grep(pattern, fd);
+ close(fd);
+ }
+ exit(0);
+} \ No newline at end of file
diff --git a/src/user/kill.cc b/src/user/kill.cc
new file mode 100644
index 0000000..18b7f02
--- /dev/null
+++ b/src/user/kill.cc
@@ -0,0 +1,23 @@
+#include "ulib/stdio.h"
+#include "ulib/stdlib.h"
+#include "user/user.h"
+
+int main(int argc, char *argv[])
+{
+ int i;
+
+ if (argc < 2)
+ {
+ printf("Usage: kill pid...\n");
+ exit(1);
+ }
+ for (i = 1; i < argc; i++)
+ {
+ int pid = atoi(argv[i]);
+ if (kill(pid) < 0)
+ {
+ printf("kill: failed to kill %d\n", pid);
+ }
+ }
+ exit(0);
+} \ No newline at end of file
diff --git a/src/user/ln.cc b/src/user/ln.cc
new file mode 100644
index 0000000..2370fdc
--- /dev/null
+++ b/src/user/ln.cc
@@ -0,0 +1,18 @@
+#include "ulib/stdio.h"
+#include "ulib/stdlib.h"
+#include "user/user.h"
+
+int main(int argc, char *argv[])
+{
+ if (argc != 3)
+ {
+ printf("Usage: ln old new\n");
+ exit(1);
+ }
+ if (link(argv[1], argv[2]) < 0)
+ {
+ printf("link %s %s failed\n", argv[1], argv[2]);
+ exit(1);
+ }
+ exit(0);
+} \ No newline at end of file
diff --git a/src/user/mv.cc b/src/user/mv.cc
new file mode 100644
index 0000000..2d30f01
--- /dev/null
+++ b/src/user/mv.cc
@@ -0,0 +1,26 @@
+#include "ulib/stdio.h"
+#include "ulib/stdlib.h"
+#include "user/user.h"
+
+int main(int argc, char *argv[])
+{
+ if (argc != 3)
+ {
+ printf("Usage: mv old new\n");
+ exit(1);
+ }
+
+ if (link(argv[1], argv[2]) < 0)
+ {
+ printf("mv: failed to link %s to %s\n", argv[1], argv[2]);
+ exit(1);
+ }
+
+ if (unlink(argv[1]) < 0)
+ {
+ printf("mv: failed to unlink %s\n", argv[1]);
+ exit(1);
+ }
+
+ exit(0);
+} \ No newline at end of file
diff --git a/src/user/rm.cc b/src/user/rm.cc
new file mode 100644
index 0000000..82b04c5
--- /dev/null
+++ b/src/user/rm.cc
@@ -0,0 +1,24 @@
+#include "ulib/stdio.h"
+#include "ulib/stdlib.h"
+#include "user/user.h"
+
+int main(int argc, char *argv[])
+{
+ int i;
+
+ if (argc < 2)
+ {
+ printf("Usage: rm files...\n");
+ exit(1);
+ }
+
+ for (i = 1; i < argc; i++)
+ {
+ if (unlink(argv[i]) < 0)
+ {
+ printf("rm: %s failed to delete\n", argv[i]);
+ exit(1);
+ }
+ }
+ exit(0);
+} \ No newline at end of file
diff --git a/src/user/sh.cc b/src/user/sh.cc
index b4122f7..760f29e 100644
--- a/src/user/sh.cc
+++ b/src/user/sh.cc
@@ -67,11 +67,26 @@ struct RedirCommand : public Command
void run() override
{
close(fd);
- if (open(file, mode) < 0)
+
+ int newfd = open(file, mode);
+
+ if (newfd < 0)
{
printf("open %s failed\n", file);
exit(1);
}
+
+ if (newfd != fd)
+ {
+
+ if (dup(newfd) != fd)
+ {
+ printf("Redirection failed: could not move fd %d to %d\n", newfd, fd);
+ exit(1);
+ }
+ close(newfd);
+ }
+
sub_cmd->run();
}
};
@@ -348,15 +363,6 @@ int main()
{
static char buf[100];
- // int fd;
- // while ((fd = open("console", O_RDWR)) >= 0)
- // {
- // if (fd >= 3)
- // {
- // close(fd);
- // break;
- // }
- // }
printf(ANSI_GREEN"\n[Lume Shell] Welcome! \n"ANSI_RESET);
printf(ANSI_YELLOW "[Lume Shell] Start your journey of exploration!"ANSI_RESET);
diff --git a/src/user/touch.cc b/src/user/touch.cc
new file mode 100644
index 0000000..b978f52
--- /dev/null
+++ b/src/user/touch.cc
@@ -0,0 +1,27 @@
+#include "ulib/stdio.h"
+#include "ulib/stdlib.h"
+#include "user/user.h"
+#include "common/fcntl.h"
+
+int main(int argc, char *argv[])
+{
+ int i, fd;
+
+ if (argc < 2)
+ {
+ printf("Usage: touch files...\n");
+ exit(1);
+ }
+
+ for (i = 1; i < argc; i++)
+ {
+ fd = open(argv[i], O_CREATE | O_RDWR);
+ if (fd < 0)
+ {
+ printf("touch: cannot touch %s\n", argv[i]);
+ exit(1);
+ }
+ close(fd);
+ }
+ exit(0);
+} \ No newline at end of file
diff --git a/src/user/wc.cc b/src/user/wc.cc
new file mode 100644
index 0000000..654aac2
--- /dev/null
+++ b/src/user/wc.cc
@@ -0,0 +1,56 @@
+#include "ulib/stdio.h"
+#include "ulib/stdlib.h"
+#include "ulib/string.h"
+#include "user/user.h"
+#include "common/fcntl.h"
+
+char buf[512];
+
+void wc(int fd, char *name)
+{
+ int i, n;
+ int l, w, c, inword;
+
+ l = w = c = 0;
+ inword = 0;
+ while ((n = read(fd, buf, sizeof(buf))) > 0)
+ {
+ for (i = 0; i < n; i++)
+ {
+ c++;
+ if (buf[i] == '\n')
+ l++;
+ if (strchr(" \r\t\n\v", buf[i]))
+ inword = 0;
+ else if (!inword)
+ {
+ w++;
+ inword = 1;
+ }
+ }
+ }
+ printf("%d %d %d %s\n", l, w, c, name);
+}
+
+int main(int argc, char *argv[])
+{
+ int fd, i;
+
+ if (argc <= 1)
+ {
+ wc(0, "");
+ exit(0);
+ }
+
+ for (i = 1; i < argc; i++)
+ {
+ if ((fd = open(argv[i], O_RDONLY)) < 0)
+ {
+ printf("wc: cannot open %s\n", argv[i]);
+ exit(1);
+ }
+ wc(fd, argv[i]);
+ close(fd);
+ }
+ exit(0);
+} \ No newline at end of file