Compare commits
27 Commits
new-dialog
...
5dff492663
Author | SHA1 | Date | |
---|---|---|---|
5dff492663
|
|||
3566131705
|
|||
6423e3b2ef
|
|||
5c92ece0db
|
|||
8700f4f5a2
|
|||
0df75ee195
|
|||
467087d76e
|
|||
448c862731
|
|||
b550c93884
|
|||
a7e5d7d92d
|
|||
56165c0b76
|
|||
b1ee452890
|
|||
8e1c325f98
|
|||
754a26884c
|
|||
2f82ab63ac
|
|||
90d94c7615
|
|||
a1ba96bf67
|
|||
e4dbc5becc
|
|||
33f55384bc
|
|||
c8f19fe30d
|
|||
4febeb7a82
|
|||
c7ec5819c6
|
|||
31f6cc6ab8
|
|||
d4a2cb3749
|
|||
bd4cedf996
|
|||
2a1e94f054
|
|||
fb18484aa8 |
2
Makefile
2
Makefile
@@ -36,7 +36,7 @@ CFLAGS += $(shell pkg-config --cflags $(PACKAGE_NAMES))
|
||||
LDFLAGS += $(shell pkg-config --libs $(PACKAGE_NAMES))
|
||||
|
||||
ifeq ($(DEBUG),1)
|
||||
CFLAGS += -O0 -pedantic -g -Wall -Wextra -Wcast-align \
|
||||
CFLAGS += -Og -pedantic -g -Wall -Wextra -Wcast-align \
|
||||
-Wcast-qual -Wdisabled-optimization -Wformat=2 \
|
||||
-Winit-self -Wlogical-op -Wmissing-declarations \
|
||||
-Wmissing-include-dirs -Wredundant-decls -Wshadow \
|
||||
|
26
README.md
26
README.md
@@ -15,20 +15,36 @@ Traditional access control mechanisms in operating systems allow the same level
|
||||
- Install dependencies
|
||||
- libfuse3
|
||||
- Debian: `sudo apt install fuse3 libfuse3-dev`
|
||||
- zenity
|
||||
- Debian: `sudo apt install zenity`
|
||||
- Build tools
|
||||
- Debian: `sudo apt install gcc make pkg-config`
|
||||
- Build using `make`:
|
||||
- In the project directory: `make`
|
||||
- Use `make DEBUG=1` for testing.
|
||||
- Add `DEBUG=1` to show more compiler warnings.
|
||||
- Add `TEST=1` to also test the program.
|
||||
- Add `DIALOGUE=0` to not compile the dialogue program.
|
||||
- Resulting binaries should appear in the `build` directory.
|
||||
|
||||
## Installation
|
||||
|
||||
Currently, there is no installer implemented.
|
||||
|
||||
## Usage
|
||||
|
||||
`icfs <FUSE arguments> [target directory]`
|
||||
```
|
||||
icfs <FUSE arguments> [target directory] [path to permanent permission database]
|
||||
```
|
||||
|
||||
The filesystem will be mounted over the target directory, and ask user permission every time a file in that directory is opened.
|
||||
The filesystem will be mounted over the target directory, and ask user permission every time a file in that directory is opened. We highly recommend adding `-o default_permissions` to increase performance and add an additional security layer.
|
||||
|
||||
### Development build
|
||||
|
||||
Execute this command in the root directory of this project:
|
||||
|
||||
```
|
||||
env PATH="$(realpath ./build):$PATH" build/icfs <FUSE arguments> [target directory] [path to permanent permission database]
|
||||
```
|
||||
|
||||
The `env PATH="$(realpath ./build):$PATH"` adds the access dialogue program to PATH, allowing ICFS to call it seamlessly.
|
||||
|
||||
## Docs
|
||||
|
||||
|
@@ -1,3 +1,11 @@
|
||||
/*
|
||||
ICFS: Interactively Controlled File System
|
||||
Copyright (C) 2024-2025 Fedir Kovalov
|
||||
|
||||
This program can be distributed under the terms of the GNU GPLv2.
|
||||
See the file LICENSE.
|
||||
*/
|
||||
|
||||
#ifndef ACCESS_T_H
|
||||
#define ACCESS_T_H
|
||||
|
||||
|
@@ -11,7 +11,9 @@
|
||||
See the file LICENSE.
|
||||
*/
|
||||
|
||||
#include "process_info.h"
|
||||
#include "real_filename.h"
|
||||
#include "set_mode_t.h"
|
||||
#include <assert.h>
|
||||
#include <stddef.h>
|
||||
#define FUSE_USE_VERSION 31
|
||||
@@ -41,8 +43,13 @@
|
||||
#include "fuse_operations.h"
|
||||
#include "proc_operations.h"
|
||||
#include "sourcefs.h"
|
||||
#include "temp_permissions_table.h"
|
||||
#include "ui-socket.h"
|
||||
|
||||
int auto_create_perm = GRANT_TEMP;
|
||||
|
||||
void set_auto_create_perm(int val) { auto_create_perm = val; }
|
||||
|
||||
static void *xmp_init(struct fuse_conn_info *conn, struct fuse_config *cfg) {
|
||||
(void)conn;
|
||||
cfg->use_ino = 1;
|
||||
@@ -53,7 +60,9 @@ static void *xmp_init(struct fuse_conn_info *conn, struct fuse_config *cfg) {
|
||||
in current function (recommended in high level API) or set fi->direct_io
|
||||
in xmp_create() or xmp_open(). */
|
||||
cfg->direct_io = 1;
|
||||
#if FUSE_VERSION > FUSE_MAKE_VERSION(3, 14)
|
||||
cfg->parallel_direct_writes = 1;
|
||||
#endif
|
||||
|
||||
/* Pick up changes from lower filesystem right away. This is
|
||||
also necessary for better hardlink support. When the kernel
|
||||
@@ -67,6 +76,7 @@ static void *xmp_init(struct fuse_conn_info *conn, struct fuse_config *cfg) {
|
||||
cfg->negative_timeout = 0;
|
||||
fprintf(stderr, "%d\n", getpid());
|
||||
assert(get_mountpoint() != NULL);
|
||||
init_garbage_collector();
|
||||
|
||||
return NULL;
|
||||
}
|
||||
@@ -82,7 +92,7 @@ static int xmp_getattr(const char *path, struct stat *stbuf,
|
||||
else
|
||||
res = source_stat(path, stbuf);
|
||||
if (res == -1) {
|
||||
perror("Stat failed");
|
||||
perror("[ICFS] Stat failed");
|
||||
return -errno;
|
||||
}
|
||||
|
||||
@@ -146,7 +156,7 @@ static int xmp_opendir(const char *path, struct fuse_file_info *fi) {
|
||||
|
||||
d->dp = source_opendir(path);
|
||||
if (d->dp == NULL) {
|
||||
perror("Opendir failed");
|
||||
perror("[ICFS] Opendir failed");
|
||||
res = -errno;
|
||||
free(d);
|
||||
return res;
|
||||
@@ -265,8 +275,7 @@ static int xmp_unlink(const char *path) {
|
||||
struct fuse_context *fc = fuse_get_context();
|
||||
|
||||
// ask the user for the permission for deleting the file
|
||||
pi.PID = fc->pid;
|
||||
pi.name = get_process_name_by_pid(pi.PID);
|
||||
pi = get_process_info(fc->pid);
|
||||
|
||||
// fprintf(stderr, "%s, %d\n", path, ask_access(path, pi));
|
||||
|
||||
@@ -313,8 +322,7 @@ static int xmp_rename(const char *from, const char *to, unsigned int flags) {
|
||||
struct process_info pi;
|
||||
struct fuse_context *fc = fuse_get_context();
|
||||
|
||||
pi.PID = fc->pid;
|
||||
pi.name = get_process_name_by_pid(pi.PID);
|
||||
pi = get_process_info(fc->pid);
|
||||
|
||||
// fprintf(stderr, "%s, %d\n", path, ask_access(path, pi));
|
||||
|
||||
@@ -344,8 +352,7 @@ static int xmp_link(const char *from, const char *to) {
|
||||
struct process_info pi;
|
||||
struct fuse_context *fc = fuse_get_context();
|
||||
|
||||
pi.PID = fc->pid;
|
||||
pi.name = get_process_name_by_pid(pi.PID);
|
||||
pi = get_process_info(fc->pid);
|
||||
|
||||
// fprintf(stderr, "%s, %d\n", path, ask_access(path, pi));
|
||||
if (!interactive_access(from, pi, 0)) {
|
||||
@@ -369,8 +376,7 @@ static int xmp_chmod(const char *path, mode_t mode, struct fuse_file_info *fi) {
|
||||
struct process_info pi;
|
||||
struct fuse_context *fc = fuse_get_context();
|
||||
|
||||
pi.PID = fc->pid;
|
||||
pi.name = get_process_name_by_pid(pi.PID);
|
||||
pi = get_process_info(fc->pid);
|
||||
|
||||
// fprintf(stderr, "%s, %d\n", path, ask_access(path, pi));
|
||||
if (!interactive_access(path, pi, 0)) {
|
||||
@@ -400,8 +406,7 @@ static int xmp_chown(const char *path, uid_t uid, gid_t gid,
|
||||
struct process_info pi;
|
||||
struct fuse_context *fc = fuse_get_context();
|
||||
|
||||
pi.PID = fc->pid;
|
||||
pi.name = get_process_name_by_pid(pi.PID);
|
||||
pi = get_process_info(fc->pid);
|
||||
|
||||
// fprintf(stderr, "%s, %d\n", path, ask_access(path, pi));
|
||||
if (!interactive_access(path, pi, 0)) {
|
||||
@@ -459,14 +464,15 @@ static int xmp_create(const char *path, mode_t mode,
|
||||
struct process_info pi;
|
||||
struct fuse_context *fc = fuse_get_context();
|
||||
|
||||
pi.PID = fc->pid;
|
||||
pi.name = get_process_name_by_pid(pi.PID);
|
||||
pi = get_process_info(fc->pid);
|
||||
|
||||
// fprintf(stderr, "%s, %d\n", path, ask_access(path, pi));
|
||||
|
||||
if (!interactive_access(path, pi, GRANT_PERM)) {
|
||||
free(pi.name);
|
||||
return -EACCES;
|
||||
if (auto_create_perm != 0) {
|
||||
if (!interactive_access(path, pi, auto_create_perm)) {
|
||||
free(pi.name);
|
||||
return -EACCES;
|
||||
}
|
||||
}
|
||||
|
||||
free(pi.name);
|
||||
@@ -484,8 +490,7 @@ static int xmp_open(const char *path, struct fuse_file_info *fi) {
|
||||
struct process_info pi;
|
||||
struct fuse_context *fc = fuse_get_context();
|
||||
|
||||
pi.PID = fc->pid;
|
||||
pi.name = get_process_name_by_pid(pi.PID);
|
||||
pi = get_process_info(fc->pid);
|
||||
|
||||
// fprintf(stderr, "%s, %d\n", path, ask_access(path, pi));
|
||||
if (!interactive_access(path, pi, 0)) {
|
||||
|
@@ -14,5 +14,6 @@
|
||||
#include <fuse3/fuse.h>
|
||||
|
||||
const struct fuse_operations *get_fuse_operations();
|
||||
void set_auto_create_perm(int val);
|
||||
|
||||
#endif
|
||||
|
@@ -143,6 +143,9 @@ int main(int argc, char **argv) {
|
||||
fprintf(stdout, "icfs_dialogue 1.0.0");
|
||||
}
|
||||
|
||||
// disable accessibility features to prevent attacks
|
||||
g_setenv("NO_AT_BRIDGE", "1", TRUE);
|
||||
|
||||
// Create a new application
|
||||
AdwApplication *app = adw_application_new("de.umbrasolis.icfs_dialogue",
|
||||
G_APPLICATION_HANDLES_COMMAND_LINE);
|
||||
|
37
src/main.c
37
src/main.c
@@ -10,6 +10,7 @@
|
||||
See the file LICENSE.
|
||||
*/
|
||||
|
||||
#include <string.h>
|
||||
#define FUSE_USE_VERSION 31
|
||||
|
||||
#define _GNU_SOURCE
|
||||
@@ -29,7 +30,28 @@ const char *mountpoint = NULL;
|
||||
int main(int argc, char *argv[]) {
|
||||
if (argc < 3) {
|
||||
fprintf(stderr, "Usage: icfs <FUSE arguments> [target directory] [path to "
|
||||
"the permanent permissions database\n");
|
||||
"the permanent permissions database] <ICFS "
|
||||
"arguments>\n\t--no-perm-on-create - do not give any "
|
||||
"access permissions on file creation"
|
||||
"(incompatible with --temp-on-create)\n\t--perm-on-create "
|
||||
"- automatically give permanent access permission to files "
|
||||
"a process creates "
|
||||
"(incompatible with --no-perm-on-create)\n");
|
||||
return EXIT_FAILURE;
|
||||
}
|
||||
|
||||
if ((0 == strcmp(argv[argc - 1], "--no-perm-on-create") &&
|
||||
0 == strcmp(argv[argc - 2], "--temp-on-create")) ||
|
||||
(0 == strcmp(argv[argc - 2], "--no-perm-on-create") &&
|
||||
0 == strcmp(argv[argc - 1], "--temp-on-create"))) {
|
||||
fprintf(stderr, "Usage: icfs <FUSE arguments> [target directory] [path to "
|
||||
"the permanent permissions database] <ICFS "
|
||||
"arguments>\n\t--no-perm-on-create - do not give any "
|
||||
"access permissions on file creation"
|
||||
"(incompatible with --temp-on-create)\n\t--perm-on-create "
|
||||
"- automatically give permanent access permission to files "
|
||||
"a process creates "
|
||||
"(incompatible with --no-perm-on-create)\n");
|
||||
return EXIT_FAILURE;
|
||||
}
|
||||
|
||||
@@ -37,11 +59,20 @@ int main(int argc, char *argv[]) {
|
||||
// permissions than it's caller reqested
|
||||
umask(0);
|
||||
|
||||
if (0 == strcmp(argv[argc - 1], "--no-perm-on-create")) {
|
||||
set_auto_create_perm(0);
|
||||
argc--;
|
||||
}
|
||||
if (0 == strcmp(argv[argc - 1], "--perm-on-create")) {
|
||||
set_auto_create_perm(GRANT_PERM);
|
||||
argc--;
|
||||
}
|
||||
|
||||
// ui socket should always be initialized before anything else, since it
|
||||
// handles the setuid bits!
|
||||
int ret = init_ui_socket(argv[argc - 1]);
|
||||
if (ret != 0) {
|
||||
fprintf(stderr, "Could not initalize ui-socket.\n");
|
||||
fprintf(stderr, "[ICFS] Could not initalize ui-socket.\n");
|
||||
exit(EXIT_FAILURE);
|
||||
}
|
||||
|
||||
@@ -49,7 +80,7 @@ int main(int argc, char *argv[]) {
|
||||
|
||||
ret = source_init(mountpoint);
|
||||
if (ret != 0) {
|
||||
perror("source_init");
|
||||
perror("[ICFS] source_init");
|
||||
exit(EXIT_FAILURE);
|
||||
}
|
||||
|
||||
|
@@ -29,19 +29,19 @@ const char *const table_name = "permissions";
|
||||
const int column_count = 3;
|
||||
const char *const schema[] = {"executable", "filename", "mode"};
|
||||
const char *const types[] = {"TEXT", "TEXT", "INTEGER"};
|
||||
uid_t ruid, euid, current_pid;
|
||||
uid_t ruid, euid, current_uid;
|
||||
pthread_mutex_t uid_switch = PTHREAD_MUTEX_INITIALIZER;
|
||||
|
||||
void set_db_fsuid() {
|
||||
pthread_mutex_lock(&uid_switch);
|
||||
if (current_pid == ruid)
|
||||
if (current_uid == ruid)
|
||||
return;
|
||||
|
||||
int status = -1;
|
||||
|
||||
status = setfsuid(ruid);
|
||||
if (status < 0) {
|
||||
fprintf(stderr, "Couldn't set uid to %d.\n", ruid);
|
||||
fprintf(stderr, "[ICFS] Couldn't set uid to %d.\n", ruid);
|
||||
exit(status);
|
||||
}
|
||||
pthread_mutex_unlock(&uid_switch);
|
||||
@@ -49,14 +49,14 @@ void set_db_fsuid() {
|
||||
|
||||
void set_real_fsuid() {
|
||||
pthread_mutex_lock(&uid_switch);
|
||||
if (current_pid == ruid)
|
||||
if (current_uid == ruid)
|
||||
return;
|
||||
|
||||
int status = -1;
|
||||
|
||||
status = setfsuid(ruid);
|
||||
if (status < 0) {
|
||||
fprintf(stderr, "Couldn't set uid to %d.\n", euid);
|
||||
fprintf(stderr, "[ICFS] Couldn't set uid to %d.\n", euid);
|
||||
exit(status);
|
||||
}
|
||||
pthread_mutex_unlock(&uid_switch);
|
||||
@@ -67,12 +67,13 @@ static int check_table_col_schema(void *notused, int argc, char **argv,
|
||||
(void)notused;
|
||||
(void)colname;
|
||||
if (argc < 3) {
|
||||
fprintf(stderr, "Unexpected amount of arguments given to the callback.\n");
|
||||
fprintf(stderr,
|
||||
"[ICFS] Unexpected amount of arguments given to the callback.\n");
|
||||
return 1;
|
||||
}
|
||||
int column_num = atoi(argv[0]);
|
||||
if (column_num >= column_count) {
|
||||
fprintf(stderr, "Table contains unexpected amount of columns.\n");
|
||||
fprintf(stderr, "[ICFS] Table contains unexpected amount of columns.\n");
|
||||
return 1;
|
||||
}
|
||||
|
||||
@@ -80,7 +81,8 @@ static int check_table_col_schema(void *notused, int argc, char **argv,
|
||||
strcmp(types[column_num], argv[2]) == 0) {
|
||||
return 0;
|
||||
}
|
||||
fprintf(stderr, "Column %d does not conform to the schema.\n", column_num);
|
||||
fprintf(stderr, "[ICFS] Column %d does not conform to the schema.\n",
|
||||
column_num);
|
||||
return 1;
|
||||
}
|
||||
|
||||
@@ -88,14 +90,15 @@ static int set_flag(void *flag, int argc, char **argv, char **colname) {
|
||||
(void)colname;
|
||||
|
||||
if (argc < 3) {
|
||||
fprintf(stderr,
|
||||
"Unexpected amount of arguments given to the callback: %d.\n",
|
||||
argc);
|
||||
fprintf(
|
||||
stderr,
|
||||
"[ICFS] Unexpected amount of arguments given to the callback: %d.\n",
|
||||
argc);
|
||||
return 1;
|
||||
}
|
||||
|
||||
if (atoi(argv[2])) {
|
||||
fprintf(stderr, "Third column was: %s\n", argv[2]);
|
||||
fprintf(stderr, "[ICFS] Third column was: %s\n", argv[2]);
|
||||
*(int *)flag = 1;
|
||||
} else {
|
||||
*(int *)flag = -1;
|
||||
@@ -104,7 +107,7 @@ static int set_flag(void *flag, int argc, char **argv, char **colname) {
|
||||
}
|
||||
|
||||
int create_database_schema() {
|
||||
fprintf(stderr, "Creating table 'permissions'.\n");
|
||||
fprintf(stderr, "[ICFS] Creating table 'permissions'.\n");
|
||||
const char *create_query =
|
||||
"CREATE TABLE permissions(executable TEXT NOT "
|
||||
"NULL, filename TEXT NOT NULL, mode INTEGER NOT NULL);";
|
||||
@@ -112,12 +115,12 @@ int create_database_schema() {
|
||||
int ret = sqlite3_exec(perm_database, create_query, NULL, NULL, &err);
|
||||
|
||||
if (ret != SQLITE_OK) {
|
||||
fprintf(stderr, "sqlite3 error: %s\n", err);
|
||||
fprintf(stderr, "[ICFS] sqlite3 error: %s\n", err);
|
||||
sqlite3_free(err);
|
||||
return 1;
|
||||
}
|
||||
|
||||
fprintf(stderr, "Database created successfully\n");
|
||||
fprintf(stderr, "[ICFS] Database created successfully\n");
|
||||
return 0;
|
||||
}
|
||||
|
||||
@@ -131,14 +134,14 @@ int ensure_database_schema() {
|
||||
int result = sqlite3_table_column_metadata(
|
||||
perm_database, NULL, table_name, NULL, NULL, NULL, NULL, NULL, NULL);
|
||||
if (result == SQLITE_ERROR) {
|
||||
fprintf(stderr, "Table '%s' does not exist.\n", table_name);
|
||||
fprintf(stderr, "[ICFS] Table '%s' does not exist.\n", table_name);
|
||||
if (create_database_schema()) {
|
||||
fprintf(stderr, "Table could not be created.\n");
|
||||
fprintf(stderr, "[ICFS] Table could not be created.\n");
|
||||
return 1;
|
||||
}
|
||||
return 0;
|
||||
} else if (result != SQLITE_OK) {
|
||||
fprintf(stderr, "Database metadata could not be retrieved.\n");
|
||||
fprintf(stderr, "[ICFS] Database metadata could not be retrieved.\n");
|
||||
return 1;
|
||||
}
|
||||
|
||||
@@ -148,12 +151,12 @@ int ensure_database_schema() {
|
||||
sqlite3_exec(perm_database, pragma, check_table_col_schema, NULL, &err);
|
||||
|
||||
if (ret != SQLITE_OK) {
|
||||
fprintf(stderr, "sqlite3 error: %s\n", err);
|
||||
fprintf(stderr, "[ICFS] sqlite3 error: %s\n", err);
|
||||
sqlite3_free(err);
|
||||
return 1;
|
||||
}
|
||||
|
||||
fprintf(stderr, "Schema is correct.\n");
|
||||
fprintf(stderr, "[ICFS] Schema is correct.\n");
|
||||
return 0;
|
||||
}
|
||||
|
||||
@@ -168,24 +171,25 @@ int init_perm_permissions_table(const char *db_filename) {
|
||||
umask(0077);
|
||||
ruid = getuid();
|
||||
euid = geteuid();
|
||||
fprintf(stderr, "Running with uid: %d, gid: %d\n", euid, getegid());
|
||||
fprintf(stderr, "[ICFS] Running with uid: %d, gid: %d\n", euid, getegid());
|
||||
|
||||
if (sqlite3_open_v2(db_filename, &perm_database,
|
||||
SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE |
|
||||
SQLITE_OPEN_FULLMUTEX,
|
||||
NULL)) {
|
||||
perror("Can't open permanent permissions database");
|
||||
perror("[ICFS] Can't open permanent permissions database");
|
||||
return -1;
|
||||
}
|
||||
umask(0);
|
||||
if (ensure_database_schema()) {
|
||||
fprintf(stderr, "Database schema is not correct.\n");
|
||||
fprintf(stderr, "[ICFS] Database schema is not correct.\n");
|
||||
return -1;
|
||||
}
|
||||
|
||||
int status = seteuid(ruid);
|
||||
if (status < 0) {
|
||||
fprintf(stderr, "Couldn't set euid to ruid during database setup.\n");
|
||||
fprintf(stderr,
|
||||
"[ICFS] Couldn't set euid to ruid during database setup.\n");
|
||||
exit(status);
|
||||
}
|
||||
|
||||
@@ -201,48 +205,42 @@ void destroy_perm_permissions_table(void) { sqlite3_close(perm_database); }
|
||||
* Checks if the process has a permanent access to the file.
|
||||
*
|
||||
* @param filename: The file that the process is trying to access
|
||||
* @pram pi: The process information
|
||||
* @param pi: The process information
|
||||
* @return: access status - ALLOW, DENY or NDEF in case if no information was
|
||||
* found
|
||||
*/
|
||||
access_t check_perm_access_noparent(const char *filename,
|
||||
struct process_info pi) {
|
||||
|
||||
char *query = NULL;
|
||||
int ret = asprintf(&query,
|
||||
"SELECT * FROM %s WHERE executable = \'%s\' "
|
||||
"AND ((\'%s\' LIKE CONCAT(filename, \'%%\') AND filename "
|
||||
"GLOB \'*/\') OR filename = \'%s\');",
|
||||
table_name, pi.name, filename, filename);
|
||||
fprintf(stderr, "query: %s\n", query);
|
||||
|
||||
if (ret < 0) {
|
||||
// If asprintf fails, the contents of query are undefined (see man
|
||||
// asprintf). That does not explicitly rule out that query will be a valid
|
||||
// pointer. But the risk of freeing a non-allocated pointer is too much to
|
||||
// justify preparing for this.
|
||||
fprintf(stderr, "Could not create query on access check");
|
||||
perror("");
|
||||
if (pi.name == NULL)
|
||||
return NDEF;
|
||||
}
|
||||
|
||||
char *sqlite_error = NULL;
|
||||
int flag = 0;
|
||||
ret = sqlite3_exec(perm_database, query, set_flag, &flag, &sqlite_error);
|
||||
free((void *)query);
|
||||
if (ret != SQLITE_OK) {
|
||||
fprintf(stderr, "SQLite returned an error: %s\n", sqlite_error);
|
||||
sqlite3_free(sqlite_error);
|
||||
return NDEF;
|
||||
}
|
||||
access_t ret = NDEF;
|
||||
sqlite3_stmt *stmt = NULL;
|
||||
const char *sql =
|
||||
"SELECT mode FROM permissions WHERE executable = ?1 "
|
||||
"AND (( ?2 LIKE (filename || \'%\') AND filename "
|
||||
"GLOB \'*/\') OR filename = ?2 ) ORDER BY LENGTH( filename ) DESC;";
|
||||
sqlite3_prepare_v2(perm_database, sql, -1, &stmt, NULL);
|
||||
sqlite3_bind_text(stmt, 1, pi.name, -1, SQLITE_STATIC);
|
||||
sqlite3_bind_text(stmt, 2, filename, -1, SQLITE_STATIC);
|
||||
|
||||
if (flag == 1) {
|
||||
return ALLOW;
|
||||
int step_ret = sqlite3_step(stmt);
|
||||
if (step_ret != SQLITE_ROW && step_ret != SQLITE_DONE) {
|
||||
fprintf(stderr, "[ICFS] SQLite error: %s\n", sqlite3_errstr(step_ret));
|
||||
sqlite3_finalize(stmt);
|
||||
return ret;
|
||||
}
|
||||
if (flag == -1) {
|
||||
return DENY;
|
||||
if (step_ret == SQLITE_ROW) {
|
||||
int mode_col = sqlite3_column_int(stmt, 0);
|
||||
if (mode_col) {
|
||||
ret = ALLOW;
|
||||
} else {
|
||||
ret = DENY;
|
||||
}
|
||||
}
|
||||
return NDEF;
|
||||
sqlite3_finalize(stmt);
|
||||
|
||||
return ret;
|
||||
}
|
||||
|
||||
/**
|
||||
@@ -250,7 +248,7 @@ access_t check_perm_access_noparent(const char *filename,
|
||||
* file.
|
||||
*
|
||||
* @param filename: The file that the process is trying to access
|
||||
* @pram pi: The process information
|
||||
* @param pi: The process information
|
||||
* @return: access status - ALLOW, DENY or NDEF in case if no information was
|
||||
* found. Does not return ALLOW_TEMP or DENY_TEMP.
|
||||
* @note: In case one of the parent processes is killed while this function
|
||||
@@ -258,7 +256,7 @@ access_t check_perm_access_noparent(const char *filename,
|
||||
* false negatives, though.
|
||||
*/
|
||||
access_t check_perm_access(const char *filename, struct process_info pi) {
|
||||
if (pi.PID == 0) {
|
||||
if (pi.PID == 0 || pi.name == NULL) {
|
||||
return NDEF;
|
||||
}
|
||||
|
||||
@@ -272,7 +270,7 @@ access_t check_perm_access(const char *filename, struct process_info pi) {
|
||||
}
|
||||
current_pi.name = NULL;
|
||||
while (current_pi.name == NULL) {
|
||||
current_pi.PID = get_parent_pid(current_pi.PID);
|
||||
current_pi.PID = get_main_thread_pid(get_parent_pid(current_pi.PID));
|
||||
if (current_pi.PID != 0) {
|
||||
current_pi.name = get_process_name_by_pid(current_pi.PID);
|
||||
} else {
|
||||
@@ -293,37 +291,27 @@ access_t check_perm_access(const char *filename, struct process_info pi) {
|
||||
*/
|
||||
int set_perm_access(const char *filename, struct process_info pi,
|
||||
set_mode_t mode) {
|
||||
char *query = NULL;
|
||||
int ret = -1;
|
||||
sqlite3_stmt *stmt = NULL;
|
||||
char *sql = NULL;
|
||||
|
||||
if (mode == SET_ALLOW) {
|
||||
ret = asprintf(&query, "INSERT INTO %s VALUES (\'%s\', \'%s\', TRUE);",
|
||||
table_name, pi.name, filename);
|
||||
sql = "INSERT INTO permissions VALUES (?1, ?2, TRUE);";
|
||||
} else if (mode == SET_DENY) {
|
||||
ret = asprintf(&query, "INSERT INTO %s VALUES (\'%s\', \'%s\', FALSE);",
|
||||
table_name, pi.name, filename);
|
||||
sql = "INSERT INTO permissions VALUES (?1, ?2, FALSE);";
|
||||
} else {
|
||||
return 1;
|
||||
}
|
||||
|
||||
if (ret < 0) {
|
||||
// If asprintf fails, the contents of query are undefined (see man
|
||||
// asprintf). That does not explicitly rule out that query will be a valid
|
||||
// pointer. But the risk of freeing a non-allocated pointer is too much to
|
||||
// justify preparing for this.
|
||||
fprintf(stderr, "Could not create query on rule insertion");
|
||||
perror("");
|
||||
return 1;
|
||||
}
|
||||
|
||||
char *sqlite_error = NULL;
|
||||
ret = sqlite3_exec(perm_database, query, NULL, NULL, &sqlite_error);
|
||||
free(query);
|
||||
if (ret != SQLITE_OK) {
|
||||
fprintf(stderr, "SQLite returned an error: %s\n", sqlite_error);
|
||||
sqlite3_free(sqlite_error);
|
||||
free(query);
|
||||
sqlite3_prepare_v2(perm_database, sql, -1, &stmt, NULL);
|
||||
sqlite3_bind_text(stmt, 1, pi.name, -1, SQLITE_STATIC);
|
||||
sqlite3_bind_text(stmt, 2, filename, -1, SQLITE_STATIC);
|
||||
int step_ret = sqlite3_step(stmt);
|
||||
if (step_ret != SQLITE_DONE) {
|
||||
fprintf(stderr, "[ICFS] SQLite error: %s\n", sqlite3_errstr(step_ret));
|
||||
sqlite3_finalize(stmt);
|
||||
return 1;
|
||||
}
|
||||
sqlite3_finalize(stmt);
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
@@ -30,7 +30,7 @@ void destroy_perm_permissions_table();
|
||||
* Checks if the process has a permanent access to the file.
|
||||
*
|
||||
* @param filename: The file that the process is trying to access
|
||||
* @pram pi: The process information
|
||||
* @param pi: The process information
|
||||
* @return: access status - ALLOW, DENY or NDEF in case if no information was
|
||||
* found
|
||||
*/
|
||||
@@ -43,7 +43,7 @@ access_t check_perm_access(const char *filename, struct process_info pi);
|
||||
* @param pi: The process information
|
||||
* @param mode: Kind of access rule to be set - SET_DENY to deny access, and
|
||||
* SET_ALLOW to allow access.
|
||||
* @return: 0 on success, -1 on failure
|
||||
* @return: 0 on success, 1 on failure
|
||||
*/
|
||||
int set_perm_access(const char *filename, struct process_info pi,
|
||||
set_mode_t mode);
|
||||
|
@@ -1,16 +1,94 @@
|
||||
/*
|
||||
ICFS: Interactively Controlled File System
|
||||
Copyright (C) 2024-2025 Fedir Kovalov
|
||||
|
||||
This program can be distributed under the terms of the GNU GPLv2.
|
||||
See the file LICENSE.
|
||||
*/
|
||||
|
||||
#include "proc_operations.h"
|
||||
#include <linux/limits.h>
|
||||
#include <stddef.h>
|
||||
#include <stdio.h>
|
||||
#include <stdlib.h>
|
||||
#include <unistd.h>
|
||||
|
||||
/**
|
||||
* @brief Returns the PID of the main thread (i.e., the process ID) of the
|
||||
* process that the given thread ID (tid) belongs to.
|
||||
*
|
||||
* @param tid The thread ID (TID) of any thread in the process.
|
||||
* @return pid_t The process ID (main thread's PID), or -1 on error.
|
||||
*/
|
||||
pid_t get_main_thread_pid(pid_t tid) {
|
||||
// Validate input
|
||||
if (tid <= 0) {
|
||||
// errno = EINVAL;
|
||||
return 0;
|
||||
}
|
||||
|
||||
char path[PATH_MAX];
|
||||
snprintf(path, sizeof(path), "/proc/%d/status", tid);
|
||||
|
||||
FILE *fp = fopen(path, "r");
|
||||
if (!fp) {
|
||||
return 0; // Could not open the file
|
||||
}
|
||||
|
||||
pid_t tgid = 0;
|
||||
char line[256];
|
||||
|
||||
while (fgets(line, sizeof(line), fp)) {
|
||||
if (sscanf(line, "Tgid: %d", &tgid) == 1) {
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
fclose(fp);
|
||||
if (tgid != tid) {
|
||||
fprintf(stderr,
|
||||
"[ICFS] The tid and and pid wasn't equal. tid:%d, pid:%d.\n", tid,
|
||||
tgid);
|
||||
}
|
||||
return tgid;
|
||||
}
|
||||
|
||||
char *get_process_name_by_pid(const int pid) {
|
||||
char path[1024];
|
||||
sprintf(path, "/proc/%d/exe", pid);
|
||||
|
||||
char *name = realpath(path, NULL);
|
||||
size_t size = 128;
|
||||
char *name = malloc(size);
|
||||
if (name == NULL) {
|
||||
fprintf(stderr, "Could not get process name by pid %d", pid);
|
||||
fprintf(stderr, "[ICFS] Could not get process name by pid %d", pid);
|
||||
perror("");
|
||||
return NULL;
|
||||
}
|
||||
|
||||
while (1) {
|
||||
ssize_t len = readlink(path, name, size);
|
||||
|
||||
if (len == -1) {
|
||||
fprintf(stderr, "[ICFS] Could not get process name by pid %d", pid);
|
||||
perror("");
|
||||
free(name);
|
||||
return NULL;
|
||||
}
|
||||
if ((size_t)len >= size) {
|
||||
size *= 2;
|
||||
char *new_name = realloc(name, size);
|
||||
if (!new_name) {
|
||||
free(name);
|
||||
return NULL;
|
||||
}
|
||||
name = new_name;
|
||||
} else {
|
||||
// readlink does not set the null character
|
||||
name[len] = 0;
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
return name;
|
||||
}
|
||||
|
||||
@@ -28,7 +106,7 @@ pid_t get_parent_pid(pid_t pid) {
|
||||
|
||||
FILE *file = fopen(path, "r");
|
||||
if (file == NULL) {
|
||||
perror("Failed to open /proc/<pid>/status");
|
||||
perror("[ICFS] Failed to open /proc/<pid>/status");
|
||||
return 0;
|
||||
}
|
||||
|
||||
|
@@ -1,3 +1,11 @@
|
||||
/*
|
||||
ICFS: Interactively Controlled File System
|
||||
Copyright (C) 2024-2025 Fedir Kovalov
|
||||
|
||||
This program can be distributed under the terms of the GNU GPLv2.
|
||||
See the file LICENSE.
|
||||
*/
|
||||
|
||||
#ifndef PROC_OPERATIONS
|
||||
#define PROC_OPERATIONS
|
||||
|
||||
@@ -14,4 +22,13 @@ char *get_process_name_by_pid(const int pid);
|
||||
*/
|
||||
pid_t get_parent_pid(pid_t pid);
|
||||
|
||||
/**
|
||||
* @brief Returns the PID of the main thread (i.e., the process ID) of the
|
||||
* process that the given thread ID (tid) belongs to.
|
||||
*
|
||||
* @param tid The thread ID (TID) of any thread in the process.
|
||||
* @return pid_t The process ID (main thread's PID), or -1 on error.
|
||||
*/
|
||||
pid_t get_main_thread_pid(pid_t tid);
|
||||
|
||||
#endif // !PROC_OPERATIONS
|
||||
|
@@ -9,10 +9,25 @@
|
||||
#ifndef PROCESS_INFO_H
|
||||
#define PROCESS_INFO_H
|
||||
|
||||
#include "proc_operations.h"
|
||||
#include <errno.h>
|
||||
#include <limits.h>
|
||||
#include <stdio.h>
|
||||
#include <sys/types.h>
|
||||
#include <unistd.h>
|
||||
struct process_info {
|
||||
pid_t PID;
|
||||
char *name;
|
||||
};
|
||||
|
||||
static inline struct process_info get_process_info(pid_t pid) {
|
||||
struct process_info pi;
|
||||
pi.PID = get_main_thread_pid(pid);
|
||||
pi.name = get_process_name_by_pid(pi.PID);
|
||||
if (pi.name == NULL) {
|
||||
pi.PID = 0;
|
||||
}
|
||||
return pi;
|
||||
}
|
||||
|
||||
#endif // PROCESS_INFO_H
|
||||
|
@@ -1,3 +1,11 @@
|
||||
/*
|
||||
ICFS: Interactively Controlled File System
|
||||
Copyright (C) 2024-2025 Fedir Kovalov
|
||||
|
||||
This program can be distributed under the terms of the GNU GPLv2.
|
||||
See the file LICENSE.
|
||||
*/
|
||||
|
||||
#ifndef REAL_FILENAME_H
|
||||
#define REAL_FILENAME_H
|
||||
|
||||
|
@@ -1,3 +1,10 @@
|
||||
/*
|
||||
ICFS: Interactively Controlled File System
|
||||
Copyright (C) 2024-2025 Fedir Kovalov
|
||||
|
||||
This program can be distributed under the terms of the GNU GPLv2.
|
||||
See the file LICENSE.
|
||||
*/
|
||||
|
||||
#ifndef SET_MODE_T_H
|
||||
#define SET_MODE_T_H
|
||||
|
@@ -32,7 +32,7 @@ const char *source_filename_translate(const char *filename) {
|
||||
int source_init(const char *root_path) {
|
||||
handle.mountpoint = malloc(strlen(root_path) + 1);
|
||||
if (handle.mountpoint == NULL) {
|
||||
perror("Malloc failed");
|
||||
perror("[ICFS] Malloc failed");
|
||||
return -1;
|
||||
}
|
||||
|
||||
@@ -41,7 +41,8 @@ int source_init(const char *root_path) {
|
||||
int root_fd = open(root_path, O_PATH);
|
||||
|
||||
if (root_fd == -1) {
|
||||
fprintf(stderr, "Could not initialize source file system at %s", root_path);
|
||||
fprintf(stderr, "[ICFS] Could not initialize source file system at %s",
|
||||
root_path);
|
||||
perror("");
|
||||
return -1;
|
||||
}
|
||||
@@ -65,7 +66,7 @@ const char *real_filename(const char *filename) {
|
||||
// Allocate memory (+1 for null terminator)
|
||||
char *result = malloc(total_len + 1);
|
||||
if (result == NULL) {
|
||||
fprintf(stderr, "Memory allocation failed");
|
||||
fprintf(stderr, "[ICFS] Memory allocation failed");
|
||||
perror("");
|
||||
return NULL;
|
||||
}
|
||||
@@ -111,7 +112,7 @@ DIR *source_opendir(const char *filename) {
|
||||
const char *relative_filename = source_filename_translate(filename);
|
||||
int fd = openat(handle.root_fd, relative_filename, 0);
|
||||
if (fd < 0) {
|
||||
perror("Openat failed");
|
||||
perror("[ICFS] Openat failed");
|
||||
return NULL;
|
||||
}
|
||||
DIR *dir_pointer = fdopendir(fd);
|
||||
@@ -148,7 +149,7 @@ int source_truncate(const char *filename, off_t length) {
|
||||
const char *relative_filename = source_filename_translate(filename);
|
||||
int fd = openat(handle.root_fd, relative_filename, 0);
|
||||
if (fd < 0) {
|
||||
perror("Openat failed");
|
||||
perror("[ICFS] Openat failed");
|
||||
return -1;
|
||||
}
|
||||
return ftruncate(fd, length);
|
||||
|
@@ -16,6 +16,8 @@
|
||||
#include <stdio.h>
|
||||
#include <string.h>
|
||||
#include <sys/types.h>
|
||||
#include <time.h>
|
||||
#include <unistd.h>
|
||||
|
||||
struct temp_process_permissions {
|
||||
// yes, this is a correct type for start time in jiffies (see
|
||||
@@ -26,7 +28,9 @@ struct temp_process_permissions {
|
||||
};
|
||||
|
||||
map(pid_t, struct temp_process_permissions) temp_permissions_table;
|
||||
pthread_mutex_t temp_permissions_table_lock;
|
||||
pthread_rwlock_t temp_permissions_table_lock = PTHREAD_RWLOCK_INITIALIZER;
|
||||
pthread_t gc_thread;
|
||||
int is_gc_active = 0;
|
||||
|
||||
/**
|
||||
* Function to get the process creation time (in jiffies) from the proc
|
||||
@@ -48,20 +52,21 @@ unsigned long long get_process_creation_time(pid_t pid) {
|
||||
// Open the status file
|
||||
fp = fopen(path, "r");
|
||||
if (fp == NULL) {
|
||||
perror("fopen");
|
||||
perror("[ICFS] fopen");
|
||||
return 0;
|
||||
}
|
||||
|
||||
// Read the creation time (the 22nd field in the stat file)
|
||||
for (int i = 1; i < 22; i++) {
|
||||
if (fscanf(fp, "%*s") == EOF) {
|
||||
fprintf(stderr, "Error reading process stat file on the number %d\n", i);
|
||||
fprintf(stderr,
|
||||
"[ICFS] Error reading process stat file on the number %d\n", i);
|
||||
fclose(fp);
|
||||
return 0;
|
||||
}
|
||||
}
|
||||
if (fscanf(fp, "%llu", &creation_time) != 1) {
|
||||
fprintf(stderr, "Error reading creation time\n");
|
||||
fprintf(stderr, "[ICFS] Error reading creation time\n");
|
||||
fclose(fp);
|
||||
return 0;
|
||||
}
|
||||
@@ -72,16 +77,70 @@ unsigned long long get_process_creation_time(pid_t pid) {
|
||||
return creation_time;
|
||||
}
|
||||
|
||||
int is_valid(pid_t pid, struct temp_process_permissions *entry) {
|
||||
unsigned long long creation_time = get_process_creation_time(pid);
|
||||
if (creation_time == 0) {
|
||||
return 0;
|
||||
}
|
||||
|
||||
if (creation_time != entry->creation_time) {
|
||||
return 0;
|
||||
}
|
||||
|
||||
return 1;
|
||||
}
|
||||
|
||||
void *garbage_collector(void *arg) {
|
||||
(void)arg;
|
||||
|
||||
while (is_gc_active) {
|
||||
sleep(1);
|
||||
pthread_rwlock_wrlock(&temp_permissions_table_lock);
|
||||
|
||||
vec(pid_t) blacklist;
|
||||
init(&blacklist);
|
||||
|
||||
for_each(&temp_permissions_table, pid, entry) {
|
||||
if (!is_valid(*pid, entry)) {
|
||||
push(&blacklist, *pid);
|
||||
for_each(&entry->allowed_files, allowed_file) { free(*allowed_file); }
|
||||
cleanup(&entry->allowed_files);
|
||||
for_each(&entry->denied_files, denied_file) { free(*denied_file); }
|
||||
cleanup(&entry->denied_files);
|
||||
}
|
||||
}
|
||||
|
||||
for_each(&blacklist, pid) { erase(&temp_permissions_table, *pid); }
|
||||
|
||||
cleanup(&blacklist);
|
||||
|
||||
pthread_rwlock_unlock(&temp_permissions_table_lock);
|
||||
}
|
||||
|
||||
return NULL;
|
||||
}
|
||||
|
||||
/**
|
||||
* Initializes the temporary permissions table.
|
||||
*
|
||||
* @return: 0 on success, -1 on failure (e.g. ENOMEM)
|
||||
*/
|
||||
int init_temp_permissions_table(void) {
|
||||
pthread_mutex_init(&temp_permissions_table_lock, PTHREAD_MUTEX_DEFAULT);
|
||||
init(&temp_permissions_table);
|
||||
return 0;
|
||||
}
|
||||
/**
|
||||
* Starts the temporary permissions table garbage_collector.
|
||||
*
|
||||
* @return: 0 on success, -1 on failure (e.g. ENOMEM)
|
||||
*/
|
||||
int init_garbage_collector(void) {
|
||||
is_gc_active = 1;
|
||||
if (pthread_create(&gc_thread, NULL, garbage_collector, NULL) != 0) {
|
||||
return -1;
|
||||
}
|
||||
return 0;
|
||||
}
|
||||
|
||||
/**
|
||||
* Destroys the temporary permissions table.
|
||||
@@ -91,6 +150,11 @@ int init_temp_permissions_table(void) {
|
||||
* screwed.
|
||||
*/
|
||||
void destroy_temp_permissions_table(void) {
|
||||
if (is_gc_active) {
|
||||
is_gc_active = 0;
|
||||
pthread_join(gc_thread, NULL);
|
||||
}
|
||||
|
||||
// free the memory allocated for the table
|
||||
for_each(&temp_permissions_table, entry) {
|
||||
for_each(&entry->allowed_files, allowed_file) { free(*allowed_file); }
|
||||
@@ -102,27 +166,26 @@ void destroy_temp_permissions_table(void) {
|
||||
}
|
||||
|
||||
cleanup(&temp_permissions_table);
|
||||
pthread_mutex_destroy(&temp_permissions_table_lock);
|
||||
}
|
||||
|
||||
/**
|
||||
* Checks if the process has a temporary access to the file.
|
||||
*
|
||||
* @param filename: The file that the process is trying to access
|
||||
* @pram pid: PID of the process
|
||||
* @param pid: PID of the process
|
||||
* @return: access status - ALLOW, DENY or NDEF in case if no information was
|
||||
* found is avaliable
|
||||
*/
|
||||
access_t check_temp_access_noparent(const char *filename, pid_t pid) {
|
||||
// TODO: more efficient locking
|
||||
pthread_mutex_lock(&temp_permissions_table_lock);
|
||||
pthread_rwlock_rdlock(&temp_permissions_table_lock);
|
||||
struct temp_process_permissions *permission_entry =
|
||||
get(&temp_permissions_table, pid);
|
||||
if (permission_entry != NULL) {
|
||||
unsigned long long process_creation_time = get_process_creation_time(pid);
|
||||
if (process_creation_time == 0) {
|
||||
perror("Could not retrieve process creation time");
|
||||
pthread_mutex_unlock(&temp_permissions_table_lock);
|
||||
perror("[ICFS] Could not retrieve process creation time");
|
||||
pthread_rwlock_unlock(&temp_permissions_table_lock);
|
||||
return NDEF;
|
||||
}
|
||||
|
||||
@@ -130,29 +193,35 @@ access_t check_temp_access_noparent(const char *filename, pid_t pid) {
|
||||
// the process is the same as the one that was granted temporary access
|
||||
// to the file
|
||||
size_t filename_len = strlen(filename);
|
||||
access_t ret = NDEF;
|
||||
size_t maxlen = 0;
|
||||
for_each(&permission_entry->denied_files, denied_file) {
|
||||
size_t denied_file_len = strlen(*denied_file);
|
||||
if (strncmp(*denied_file, filename, denied_file_len) == 0 &&
|
||||
((denied_file_len < filename_len &&
|
||||
(*denied_file)[denied_file_len - 1] == '/') ||
|
||||
(denied_file_len == filename_len))) {
|
||||
pthread_mutex_unlock(&temp_permissions_table_lock);
|
||||
return DENY;
|
||||
if ((strncmp(*denied_file, filename, denied_file_len) == 0 &&
|
||||
((denied_file_len < filename_len &&
|
||||
(*denied_file)[denied_file_len - 1] == '/') ||
|
||||
(denied_file_len == filename_len))) &&
|
||||
denied_file_len > maxlen) {
|
||||
maxlen = denied_file_len;
|
||||
ret = DENY;
|
||||
}
|
||||
}
|
||||
for_each(&permission_entry->allowed_files, allowed_file) {
|
||||
size_t allowed_file_len = strlen(*allowed_file);
|
||||
if (strncmp(*allowed_file, filename, allowed_file_len) == 0 &&
|
||||
((allowed_file_len < filename_len &&
|
||||
(*allowed_file)[allowed_file_len - 1] == '/') ||
|
||||
(allowed_file_len == filename_len))) {
|
||||
pthread_mutex_unlock(&temp_permissions_table_lock);
|
||||
return ALLOW;
|
||||
if ((strncmp(*allowed_file, filename, allowed_file_len) == 0 &&
|
||||
((allowed_file_len < filename_len &&
|
||||
(*allowed_file)[allowed_file_len - 1] == '/') ||
|
||||
(allowed_file_len == filename_len))) &&
|
||||
allowed_file > maxlen) {
|
||||
maxlen = allowed_file_len;
|
||||
ret = ALLOW;
|
||||
}
|
||||
}
|
||||
pthread_rwlock_unlock(&temp_permissions_table_lock);
|
||||
return ret;
|
||||
}
|
||||
}
|
||||
pthread_mutex_unlock(&temp_permissions_table_lock);
|
||||
pthread_rwlock_unlock(&temp_permissions_table_lock);
|
||||
return NDEF;
|
||||
}
|
||||
|
||||
@@ -161,7 +230,7 @@ access_t check_temp_access_noparent(const char *filename, pid_t pid) {
|
||||
* file.
|
||||
*
|
||||
* @param filename: The file that the process is trying to access
|
||||
* @pram pi: The process information
|
||||
* @param pi: The process information
|
||||
* @return: access status - ALLOW, DENY or NDEF in case if no information was
|
||||
* found. Does not return ALLOW_TEMP.
|
||||
* @note: In case one of the parent processes is killed while this function
|
||||
@@ -175,7 +244,7 @@ access_t check_temp_access(const char *filename, struct process_info pi) {
|
||||
if (access != NDEF) {
|
||||
return access;
|
||||
}
|
||||
current_pid = get_parent_pid(current_pid);
|
||||
current_pid = get_main_thread_pid(get_parent_pid(current_pid));
|
||||
}
|
||||
|
||||
return NDEF;
|
||||
@@ -192,7 +261,9 @@ access_t check_temp_access(const char *filename, struct process_info pi) {
|
||||
*/
|
||||
int set_temp_access(const char *filename, struct process_info pi,
|
||||
set_mode_t mode) {
|
||||
pthread_mutex_lock(&temp_permissions_table_lock);
|
||||
if (pi.PID == 0)
|
||||
return NDEF;
|
||||
pthread_rwlock_wrlock(&temp_permissions_table_lock);
|
||||
struct temp_process_permissions *permission_entry =
|
||||
get(&temp_permissions_table, pi.PID);
|
||||
|
||||
@@ -201,8 +272,8 @@ int set_temp_access(const char *filename, struct process_info pi,
|
||||
unsigned long long process_creation_time =
|
||||
get_process_creation_time(pi.PID);
|
||||
if (process_creation_time == 0) {
|
||||
perror("Could not retrieve process creation time");
|
||||
pthread_mutex_unlock(&temp_permissions_table_lock);
|
||||
perror("[ICFS] Could not retrieve process creation time");
|
||||
pthread_rwlock_unlock(&temp_permissions_table_lock);
|
||||
return -1;
|
||||
}
|
||||
|
||||
@@ -216,7 +287,7 @@ int set_temp_access(const char *filename, struct process_info pi,
|
||||
push(&permission_entry->denied_files, strdup(filename));
|
||||
}
|
||||
|
||||
pthread_mutex_unlock(&temp_permissions_table_lock);
|
||||
pthread_rwlock_unlock(&temp_permissions_table_lock);
|
||||
return 0;
|
||||
}
|
||||
// we have an entry for the process, but the process is different
|
||||
@@ -241,6 +312,6 @@ int set_temp_access(const char *filename, struct process_info pi,
|
||||
|
||||
insert(&temp_permissions_table, pi.PID, new_permission_entry);
|
||||
|
||||
pthread_mutex_unlock(&temp_permissions_table_lock);
|
||||
pthread_rwlock_unlock(&temp_permissions_table_lock);
|
||||
return 0;
|
||||
}
|
||||
|
@@ -1,3 +1,10 @@
|
||||
/*
|
||||
ICFS: Interactively Controlled File System
|
||||
Copyright (C) 2024-2025 Fedir Kovalov
|
||||
|
||||
This program can be distributed under the terms of the GNU GPLv2.
|
||||
See the file LICENSE.
|
||||
*/
|
||||
|
||||
#ifndef TEMP_PERMISSIONS_TABLE_H
|
||||
#define TEMP_PERMISSIONS_TABLE_H
|
||||
@@ -13,6 +20,13 @@
|
||||
*/
|
||||
int init_temp_permissions_table(void);
|
||||
|
||||
/**
|
||||
* Starts the temporary permissions table garbage_collector.
|
||||
*
|
||||
* @return: 0 on success, -1 on failure (e.g. ENOMEM)
|
||||
*/
|
||||
int init_garbage_collector(void);
|
||||
|
||||
/**
|
||||
* Destroys the temporary permissions table.
|
||||
*
|
||||
@@ -27,7 +41,7 @@ void destroy_temp_permissions_table(void);
|
||||
* file.
|
||||
*
|
||||
* @param filename: The file that the process is trying to access
|
||||
* @pram pi: The process information
|
||||
* @param pi: The process information
|
||||
* @return: access status - ALLOW, DENY or NDEF in case if no information was
|
||||
* found. Does not return ALLOW_TEMP.
|
||||
* @note: In case one of the parent processes is killed while this function
|
||||
|
122
src/ui-socket.c
122
src/ui-socket.c
@@ -30,6 +30,8 @@
|
||||
#define DIALOGUE_NO 1
|
||||
#define DIALOGUE_PERM 2
|
||||
|
||||
pthread_mutex_t access_check_mutex = PTHREAD_MUTEX_INITIALIZER;
|
||||
|
||||
struct dialogue_response {
|
||||
access_t decision;
|
||||
char *filename;
|
||||
@@ -39,19 +41,21 @@ int init_ui_socket(const char *perm_permissions_db_filename) {
|
||||
FILE *fp = NULL;
|
||||
|
||||
if (init_temp_permissions_table()) {
|
||||
fprintf(stderr, "Could not initialize temporary permissions table.\n");
|
||||
fprintf(stderr,
|
||||
"[ICFS] Could not initialize temporary permissions table.\n");
|
||||
return 1;
|
||||
}
|
||||
|
||||
if (init_perm_permissions_table(perm_permissions_db_filename)) {
|
||||
fprintf(stderr, "Could not initialize permanent permissions table.\n");
|
||||
fprintf(stderr,
|
||||
"[ICFS] Could not initialize permanent permissions table.\n");
|
||||
return 1;
|
||||
}
|
||||
|
||||
// Test if dialogue is installed (get version)
|
||||
fp = popen("icfs_dialogue --version", "r");
|
||||
if (fp == NULL) {
|
||||
perror("Pipe returned an error");
|
||||
perror("[ICFS] Pipe returned an error");
|
||||
return 1;
|
||||
}
|
||||
|
||||
@@ -89,7 +93,7 @@ struct dialogue_response ask_access(const char *filename,
|
||||
// asprintf). That does not explicitly rule out that command will be a valid
|
||||
// pointer. But the risk of freeing a non-allocated pointer is too much to
|
||||
// justify preparing for this.
|
||||
fprintf(stderr, "Could not create query on rule insertion");
|
||||
fprintf(stderr, "[ICFS] Could not create query on rule insertion");
|
||||
perror("");
|
||||
response.decision = DENY;
|
||||
response.filename = malloc(2);
|
||||
@@ -103,7 +107,7 @@ struct dialogue_response ask_access(const char *filename,
|
||||
free(command);
|
||||
|
||||
if (fp == NULL) {
|
||||
perror("Pipe returned a error");
|
||||
perror("[ICFS] Pipe returned a error");
|
||||
response.decision = DENY;
|
||||
response.filename = malloc(2);
|
||||
response.filename[0] = '/';
|
||||
@@ -122,8 +126,9 @@ struct dialogue_response ask_access(const char *filename,
|
||||
}
|
||||
|
||||
int dialogue_exit_code = WEXITSTATUS(pclose(fp));
|
||||
fprintf(stderr, "dialogue wrote out %s\n", first(&dialogue_output));
|
||||
fprintf(stderr, "dialogue returned %d\n", dialogue_exit_code);
|
||||
|
||||
fprintf(stderr, "[ICFS] dialogue wrote out %s\n", first(&dialogue_output));
|
||||
fprintf(stderr, "[ICFS] dialogue returned %d\n", dialogue_exit_code);
|
||||
|
||||
if (size(&dialogue_output) == 0) {
|
||||
push(&dialogue_output, '/');
|
||||
@@ -137,6 +142,7 @@ struct dialogue_response ask_access(const char *filename,
|
||||
|
||||
// assert(0 == strcmp(response.filename, first(&dialogue_output)));
|
||||
cleanup(&dialogue_output);
|
||||
time_t now = time(0);
|
||||
|
||||
if (dialogue_exit_code == (DIALOGUE_YES | DIALOGUE_PERM)) {
|
||||
response.decision = ALLOW;
|
||||
@@ -158,47 +164,56 @@ struct dialogue_response ask_access(const char *filename,
|
||||
* 3. user descision
|
||||
*
|
||||
* @param filename: The file that the process is trying to access
|
||||
* @pram pi: The process information
|
||||
* @param pi: The process information
|
||||
* @param opts: options (GRANT_TEMP, GRANT_PERM)
|
||||
* @return: 0 if access is denied, 1 if access is allowed
|
||||
*/
|
||||
int interactive_access(const char *filename, struct process_info proc_info,
|
||||
int opts) {
|
||||
char *real_path = real_filename(filename);
|
||||
pthread_mutex_lock(&access_check_mutex);
|
||||
|
||||
access_t access = check_temp_access(real_path, proc_info);
|
||||
if (access == ALLOW) {
|
||||
fprintf(stderr,
|
||||
"Permission allowed to %s based on a rule present in the temp "
|
||||
"permission table.\n",
|
||||
proc_info.name);
|
||||
fprintf(
|
||||
stderr,
|
||||
"[ICFS] Permission allowed to %s based on a rule present in the temp "
|
||||
"permission table.\n",
|
||||
proc_info.name);
|
||||
free(real_path);
|
||||
pthread_mutex_unlock(&access_check_mutex);
|
||||
return 1;
|
||||
}
|
||||
if (access == DENY) {
|
||||
fprintf(stderr,
|
||||
"Permission denied to %s based on a rule present in the temp "
|
||||
"permission table.\n",
|
||||
proc_info.name);
|
||||
fprintf(
|
||||
stderr,
|
||||
"[ICFS] Permission denied to %s based on a rule present in the temp "
|
||||
"permission table.\n",
|
||||
proc_info.name);
|
||||
free(real_path);
|
||||
pthread_mutex_unlock(&access_check_mutex);
|
||||
return 0;
|
||||
}
|
||||
|
||||
access = check_perm_access(real_path, proc_info);
|
||||
if (access == ALLOW) {
|
||||
fprintf(stderr,
|
||||
"Permission allowed to %s based on a rule present in the perm "
|
||||
"permission table.\n",
|
||||
proc_info.name);
|
||||
fprintf(
|
||||
stderr,
|
||||
"[ICFS] Permission allowed to %s based on a rule present in the perm "
|
||||
"permission table.\n",
|
||||
proc_info.name);
|
||||
free(real_path);
|
||||
pthread_mutex_unlock(&access_check_mutex);
|
||||
return 1;
|
||||
}
|
||||
if (access == DENY) {
|
||||
fprintf(stderr,
|
||||
"Permission denied to %s based on a rule present in the perm "
|
||||
"permission table.\n",
|
||||
proc_info.name);
|
||||
fprintf(
|
||||
stderr,
|
||||
"[ICFS] Permission denied to %s based on a rule present in the perm "
|
||||
"permission table.\n",
|
||||
proc_info.name);
|
||||
free(real_path);
|
||||
pthread_mutex_unlock(&access_check_mutex);
|
||||
return 0;
|
||||
}
|
||||
|
||||
@@ -206,15 +221,19 @@ int interactive_access(const char *filename, struct process_info proc_info,
|
||||
// permissions are granted
|
||||
|
||||
if (opts & GRANT_PERM) {
|
||||
fprintf(stderr, "Permission granted permanently to %s.\n", proc_info.name);
|
||||
fprintf(stderr, "[ICFS] Permission granted permanently to %s.\n",
|
||||
proc_info.name);
|
||||
set_perm_access(real_path, proc_info, SET_ALLOW);
|
||||
free(real_path);
|
||||
pthread_mutex_unlock(&access_check_mutex);
|
||||
return 1;
|
||||
}
|
||||
if (opts & GRANT_TEMP) {
|
||||
fprintf(stderr, "Permission granted temporarily to %s.\n", proc_info.name);
|
||||
fprintf(stderr, "[ICFS] Permission granted temporarily to %s.\n",
|
||||
proc_info.name);
|
||||
set_temp_access(real_path, proc_info, SET_ALLOW);
|
||||
free(real_path);
|
||||
pthread_mutex_unlock(&access_check_mutex);
|
||||
return 1;
|
||||
}
|
||||
|
||||
@@ -227,7 +246,7 @@ int interactive_access(const char *filename, struct process_info proc_info,
|
||||
|
||||
while (source_access(response.filename, F_OK)) {
|
||||
// if it is invalid, just ask again.
|
||||
fprintf(stderr, "Filename returned by zenty wasn't correct: %s\n",
|
||||
fprintf(stderr, "[ICFS] Filename returned by zenty wasn't correct: %s\n",
|
||||
response.filename);
|
||||
free(response.filename);
|
||||
response = ask_access(filename, proc_info);
|
||||
@@ -238,43 +257,40 @@ int interactive_access(const char *filename, struct process_info proc_info,
|
||||
real_path = real_filename(response.filename);
|
||||
free(response.filename);
|
||||
|
||||
int ret = 0;
|
||||
|
||||
if (response.decision == ALLOW) {
|
||||
fprintf(stderr,
|
||||
"Permission granted permanently to %s based on zenty response.\n",
|
||||
"[ICFS] Permission granted permanently to %s based on zenty "
|
||||
"response.\n",
|
||||
proc_info.name);
|
||||
set_perm_access(real_path, proc_info, SET_ALLOW);
|
||||
free(real_path);
|
||||
return 1;
|
||||
}
|
||||
|
||||
if (response.decision == ALLOW_TEMP) {
|
||||
ret = 1;
|
||||
} else if (response.decision == ALLOW_TEMP) {
|
||||
fprintf(stderr,
|
||||
"Permission granted temporarily to %s based on zenty response.\n",
|
||||
"[ICFS] Permission granted temporarily to %s based on zenty "
|
||||
"response.\n",
|
||||
proc_info.name);
|
||||
set_temp_access(real_path, proc_info, SET_ALLOW);
|
||||
free(real_path);
|
||||
return 1;
|
||||
}
|
||||
|
||||
if (response.decision == DENY_TEMP) {
|
||||
fprintf(stderr,
|
||||
"Permission denied temporarily to %s based on zenty response.\n",
|
||||
proc_info.name);
|
||||
ret = 1;
|
||||
} else if (response.decision == DENY_TEMP) {
|
||||
fprintf(
|
||||
stderr,
|
||||
"[ICFS] Permission denied temporarily to %s based on zenty response.\n",
|
||||
proc_info.name);
|
||||
set_temp_access(real_path, proc_info, SET_DENY);
|
||||
free(real_path);
|
||||
return 0;
|
||||
}
|
||||
|
||||
if (response.decision == DENY) {
|
||||
fprintf(stderr,
|
||||
"Permission denied permanently to %s based on zenty response.\n",
|
||||
proc_info.name);
|
||||
ret = 0;
|
||||
} else if (response.decision == DENY) {
|
||||
fprintf(
|
||||
stderr,
|
||||
"[ICFS] Permission denied permanently to %s based on zenty response.\n",
|
||||
proc_info.name);
|
||||
set_perm_access(real_path, proc_info, SET_DENY);
|
||||
free(real_path);
|
||||
return 0;
|
||||
ret = 0;
|
||||
}
|
||||
pthread_mutex_unlock(&access_check_mutex);
|
||||
|
||||
free(real_path);
|
||||
// deny on unknown options.
|
||||
return 0;
|
||||
return ret;
|
||||
}
|
||||
|
@@ -35,7 +35,7 @@ void destroy_ui_socket(void);
|
||||
* 3. user descision
|
||||
*
|
||||
* @param filename: The file that the process is trying to access
|
||||
* @pram pi: The process information
|
||||
* @param pi: The process information
|
||||
* @param opts: options (GRANT_TEMP, GRANT_PERM)
|
||||
* @return: 0 if access is denied, 1 if access is allowed
|
||||
*/
|
||||
|
6
test/stress.bash
Executable file
6
test/stress.bash
Executable file
@@ -0,0 +1,6 @@
|
||||
#!/bin/bash
|
||||
|
||||
count=$1
|
||||
for i in $(seq $count); do
|
||||
$2 ./protected/haystack/
|
||||
done
|
@@ -10,7 +10,7 @@ chmod 777 ./protected/perm777 ./protected/perm000
|
||||
echo "Free code, free world." >./protected/motto
|
||||
|
||||
mkdir protected/haystack
|
||||
for i in {1..10}; do
|
||||
for i in {1..100}; do
|
||||
touch "./protected/haystack/hay$i"
|
||||
done
|
||||
touch ./protected/haystack/needle
|
||||
@@ -22,7 +22,7 @@ make -C ./opener || (
|
||||
echo "Could not make the opener program."
|
||||
exit 1
|
||||
)
|
||||
for i in {1..10}; do
|
||||
for i in {1..12}; do
|
||||
cp ./opener/opener "./openers/opener$i"
|
||||
ln --symbolic "$(realpath "./openers/opener$i")" "./openers/symlinked_opener$i"
|
||||
done
|
||||
@@ -43,16 +43,24 @@ if [[ $1 == "--setuid" ]]; then
|
||||
echo "Valgrind will not be used due to setuid compatibility issues."
|
||||
../build/icfs -o default_permissions ./protected ./.pt.db &
|
||||
sleep 1
|
||||
elif [[ $1 == "--performance" ]]; then
|
||||
echo "Database protection will not be tested due to the lack of setuid capabilites."
|
||||
echo "To test it, run this script with '--setuid'."
|
||||
echo "valgrind won't be used to make performance measurements more accurate."
|
||||
../build/icfs -o default_permissions ./protected ./.pt.db &
|
||||
sleep 5
|
||||
else
|
||||
echo "Database protection will not be tested due to the lack of setuid capabilites."
|
||||
echo "To test it, run this script with '--setuid'."
|
||||
#valgrind --leak-check=full -s ../build/icfs -o default_permissions -o debug ./protected ./.pt.db 2>&1 | grep "==\|zenity\|Permission\|column\|callback" &
|
||||
valgrind --leak-check=full -s ../build/icfs -o default_permissions ./protected ./.pt.db &
|
||||
#valgrind --leak-check=full -s ../build/icfs -o default_permissions -o debug ./protected ./.pt.db 2>&1 | grep "==\|zenity\|Permission\|column\|callback\|SQLite" &
|
||||
valgrind --leak-check=full --show-leak-kinds=all -s ../build/icfs -o default_permissions ./protected ./.pt.db &
|
||||
sleep 5
|
||||
fi
|
||||
|
||||
#valgrind -s ../build/icfs -o default_permissions ./protected &
|
||||
|
||||
echo "[ICFS-TEST]: You may see memory errors from valgrind at this stage. This is normal - memory isn't lost, the libfuse just forked the process."
|
||||
|
||||
# WARN: please don't use `>` or `>>` operators. They force **this script** to open the file, **not the program you are trying to run**. This is probably not what you mean when you want to test a specific program's access.
|
||||
# WARN: avoid using touch, since it generates errors because setting times is not implemented in icfs **yet**.
|
||||
|
||||
@@ -205,9 +213,36 @@ else
|
||||
echo "[ICFS-TEST]: permanent permissions database access was not tested due to the lack of seuid bit setting capabilites. To test this, run the script with '--setuid' flag"
|
||||
fi
|
||||
|
||||
RUNS_NUM=500
|
||||
|
||||
if [[ $1 == '--performance' ]]; then
|
||||
|
||||
#warmup
|
||||
icfs_dialogue --set-fake-response yes
|
||||
parallel -j8 ::: "./stress.bash $RUNS_NUM openers/opener10"
|
||||
|
||||
icfs_dialogue --set-fake-response yes
|
||||
echo "[ICFS-TEST]: temp permissions"
|
||||
time parallel -j8 ::: "./stress.bash $RUNS_NUM openers/opener7"
|
||||
|
||||
icfs_dialogue --set-fake-response yes_perm
|
||||
echo "[ICFS-TEST]: perm permissions"
|
||||
time parallel -j8 ::: "./stress.bash $RUNS_NUM openers/opener8"
|
||||
|
||||
fi
|
||||
|
||||
# unmount
|
||||
|
||||
sleep 0.5
|
||||
#lsof +f -- $(realpath ./protected)
|
||||
umount "$(realpath ./protected)"
|
||||
sleep 0.5
|
||||
sleep 3
|
||||
|
||||
if [[ $1 == '--performance' ]]; then
|
||||
|
||||
#warmup
|
||||
parallel -j8 ::: "./stress.bash $RUNS_NUM openers/opener9"
|
||||
|
||||
echo "[ICFS-TEST]: bare filesystem"
|
||||
time parallel -j8 ::: "./stress.bash $RUNS_NUM openers/opener9"
|
||||
fi
|
||||
|
Reference in New Issue
Block a user