Skip to content

Commit

Permalink
fs: add lock() file method
Browse files Browse the repository at this point in the history
Implements file based locking on a given file handle.

Signed-off-by: Felix Fietkau <[email protected]>
  • Loading branch information
nbd168 committed Jun 17, 2024
1 parent e0bab40 commit 5d305cf
Show file tree
Hide file tree
Showing 2 changed files with 57 additions and 0 deletions.
56 changes: 56 additions & 0 deletions lib/fs.c
Original file line number Diff line number Diff line change
Expand Up @@ -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>
Expand Down Expand Up @@ -775,6 +776,60 @@ uc_fs_truncate(uc_vm_t *vm, size_t nargs)
return ucv_boolean_new(true);
}

/**
* 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.
*
Expand Down Expand Up @@ -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[] = {
Expand Down
1 change: 1 addition & 0 deletions tests/custom/03_stdlib/40_proto
Original file line number Diff line number Diff line change
Expand Up @@ -38,6 +38,7 @@ When invoked with two arguments, returns the given value.
Hello, World!
[
{
"lock": "function lock(...) { [native code] }",
"truncate": "function truncate(...) { [native code] }",
"isatty": "function isatty(...) { [native code] }",
"error": "function error(...) { [native code] }",
Expand Down

0 comments on commit 5d305cf

Please sign in to comment.