fs: add lock() file method

Implements file based locking on a given file handle.

Signed-off-by: Felix Fietkau <nbd@nbd.name>

1 files changed, 56 insertions, 0 deletions

diff --git a/lib/fs.c b/lib/fs.c
index f237102..d0d97ac 100644
--- a/lib/fs.c
+++ b/lib/fs.c
@@ -53,6 +53,7 @@
 #include <unistd.h>
 #include <sys/stat.h>
 #include <sys/types.h>
+#include <sys/file.h>
 #include <grp.h>
 #include <pwd.h>
 #include <glob.h>
@@ -776,6 +777,60 @@ uc_fs_truncate(uc_vm_t *vm, size_t nargs)
 }
 
 /**
+ * Locks or unlocks a file.
+ *
+ * The mode argument specifies lock/unlock operation flags.
+ *
+ * | Flag    | Description                  |
+ * |---------|------------------------------|
+ * | "s"     | shared lock                  |
+ * | "x"     | exclusive lock               |
+ * | "n"     | don't block when locking     |
+ * | "u"     | unlock                       |
+ *
+ * Returns `true` if the file was successfully locked/unlocked.
+ *
+ * Returns `null` if an error occurred.
+ *
+ * @function module:fs.file#lock
+ *
+ * @param {string} [op]
+ * The lock operation flags
+ *
+ * @returns {?boolean}
+ */
+static uc_value_t *
+uc_fs_lock(uc_vm_t *vm, size_t nargs)
+{
+	FILE *fp = uc_fn_thisval("fs.file");
+	uc_value_t *mode = uc_fn_arg(0);
+	int i, op = 0;
+	char *m;
+
+	if (!fp)
+		err_return(EBADF);
+
+	if (ucv_type(mode) != UC_STRING)
+		err_return(EINVAL);
+
+	m = ucv_string_get(mode);
+	for (i = 0; m[i]; i++) {
+		switch (m[i]) {
+		case 's': op |= LOCK_SH; break;
+		case 'x': op |= LOCK_EX; break;
+		case 'n': op |= LOCK_NB; break;
+		case 'u': op |= LOCK_UN; break;
+		default: err_return(EINVAL);
+		}
+	}
+
+	if (flock(fileno(fp), op) < 0)
+		err_return(errno);
+
+	return ucv_boolean_new(true);
+}
+
+/**
  * Obtain current read position.
  *
  * Obtains the current, absolute read position of the open file.
@@ -2609,6 +2664,7 @@ static const uc_function_list_t file_fns[] = {
 	{ "error",		uc_fs_error },
 	{ "isatty",		uc_fs_isatty },
 	{ "truncate",	uc_fs_truncate },
+	{ "lock",		uc_fs_lock },
 };
 
 static const uc_function_list_t dir_fns[] = {