Compare commits

...

48 Commits

Author SHA1 Message Date
79e9f2fb9a
Fixed permission on access problem. 2025-06-24 13:18:27 +02:00
91621605b1
Fixed buffer overflow 2025-06-23 20:56:03 +02:00
ea2e41693c
Fixed code errors 2025-06-23 20:47:54 +02:00
4909a35a6a
Add utime operations 2025-06-12 08:08:34 +02:00
eec782057c
Fixed Makefile typo 2025-06-11 21:06:49 +02:00
29ce8f6cff
Fixed Makefile typo 2025-06-11 21:05:02 +02:00
cbe2bf81eb
Fixed wrong permissions on the dialogue executable 2025-06-11 21:03:36 +02:00
0a6faab7d7
Fixed wrong Debian adwaita package name 2025-06-11 20:44:56 +02:00
01e72e4aac
Fixed README typo 2025-06-11 20:27:19 +02:00
5700238509
Fixed dialog arguments error. 2025-06-11 20:16:34 +02:00
b3e71d13aa
Fixed dialogue arguments error. 2025-06-11 20:00:16 +02:00
012fa05e8f
Updated README 2025-06-11 19:59:28 +02:00
2ebc450132
Fixed Makefile errors 2025-06-11 18:11:14 +02:00
2f4f1a0a56
Updated readme 2025-05-23 20:52:27 +02:00
22cb958b4f
Code readability improvements 2025-05-23 20:35:40 +02:00
9b0eb10965
Add description to set_auto_perm 2025-05-23 19:14:18 +02:00
77775e4097
Updated readme 2025-05-22 19:01:24 +02:00
49f4612c6e
Changed exit codes of dialogue to change the semantics of closing dialogue window with (x) button. 2025-05-22 19:01:16 +02:00
7dac50e4d9
Created CONTENTS.md and updated Makefile 2025-05-22 11:44:05 +02:00
8ca44dfab3
Added install rule to Makefile 2025-05-22 11:02:47 +02:00
1b53a9638e
Added dialogue file existence checks 2025-05-22 11:02:31 +02:00
5dff492663
Changed semantics of --no-perm-on-create flag 2025-05-22 09:02:11 +02:00
3566131705
Added memory errors warning 2025-05-22 09:01:50 +02:00
6423e3b2ef
Fixed yet another SQL injection bug. 2025-05-21 19:04:52 +02:00
5c92ece0db
Removed file logging 2025-05-21 18:56:35 +02:00
8700f4f5a2
Changed perm/temp permission logic 2025-05-21 18:54:35 +02:00
0df75ee195
Fixed old sqlite3 version compatibility bug. 2025-05-21 18:31:05 +02:00
467087d76e
Added performance tests and creation permission flags 2025-05-21 16:21:33 +02:00
448c862731
Changed -O0 to -Og in the debug build 2025-05-20 11:25:38 +02:00
b550c93884
Fixed arbitrary permission order 2025-05-20 11:07:28 +02:00
a7e5d7d92d
Fixed undefined order of permissions 2025-05-20 10:50:58 +02:00
56165c0b76
Fixed a mistake in README 2025-05-20 10:12:18 +02:00
b1ee452890
Updated readme 2025-05-20 10:11:32 +02:00
8e1c325f98
Added mutex to permissions checks to avoid inconsistent permission checking 2025-05-20 09:59:18 +02:00
754a26884c
Changed realpath to readlink
/proc/pid/exe already seems to be a link to the absolute path to the
executable. This fixes bugs related to containerised applications.
2025-05-20 09:57:59 +02:00
2f82ab63ac
Fixed undefined permission check errors 2025-05-20 09:24:07 +02:00
90d94c7615
Fixed SQL injection
Fixed an emabarassignly obvious SQL injection bug by throwing
`sqlite3_exec` away.
2025-05-19 21:18:19 +02:00
a1ba96bf67
Updated the test 2025-05-19 21:15:42 +02:00
e4dbc5becc
Fixed wrong pid bug
The issue was that the thread ID wasn't factored in. A presumption was,
that FUSE already returned the PID, not TID. The issue was fixed by
implementing a function that translates the TID to PID.
2025-05-14 20:37:32 +02:00
33f55384bc
Added more leak checks 2025-05-13 18:01:03 +02:00
c8f19fe30d
Fixed invalid pi bug 2025-05-13 17:59:32 +02:00
4febeb7a82
Added a logfile 2025-05-13 17:59:00 +02:00
c7ec5819c6
Fixed typos 2025-05-08 10:16:02 +02:00
31f6cc6ab8
Added missing license headers 2025-05-07 16:06:19 +02:00
d4a2cb3749
Fixed garbage collector being inactive 2025-05-07 15:55:47 +02:00
bd4cedf996
Added garbage collection to the temporary permission table. 2025-05-07 15:43:34 +02:00
2a1e94f054
Updated readme 2025-05-06 18:22:15 +02:00
fb18484aa8 Merge pull request 'new-dialogue' (#8) from new-dialogue into main
Reviewed-on: #8
2025-05-06 18:10:43 +02:00
28 changed files with 1272 additions and 639 deletions

25
CONTENTS.md Normal file
View File

@ -0,0 +1,25 @@
The source code is available in `src` directory:
* `main.c` - main function.
* `cc.h` - Convenient Containers library.
* `fuse_operations.c`, `fuse_operations.h` - Implementation of FUSE operations.
* `perm_permissions_table.c`, `perm_permissions_table.h` - implementation of permanent permissions table.
* `proc_operations.c`, `proc_operations.c` - different utility functions that interface with procfs.
* `temp_permissions_table.c` `temp_permissions_table.h` - implementation of temporary permission table.
* `sourcefs.c`, `sourcefs.h`, `real_filename.h` - operations used to access the underlying filesystem.
* `ui-socket.c` `ui-socket.h` - permission logic and interaction with access dialogues.
* `gui/` directory - source code of the access dialogue.
* Other files are dedicated to special data type definitions.
`LICENSE` is the text of GPLv2 source code license.
`Makefile` is code for the `make` build system.
Tests are located in the `test` directory:
* `test.bash` - script that tests ICFS correctness (see `README` for usage instructions)
* `stress.bash` - helper script that loads ICFS with `open` operations.
* `opener/` directory - source code for a scpecial program that tests whether file can be opened.
* `mock/` directory - bash script that mocks behaviour of access dialogue.
After building the program, make is going to create `build` directory where icfs and access dialogue executables will be located.

View File

@ -14,6 +14,8 @@ ifndef ($(BUILD_DIR))
BUILD_DIR := ./build BUILD_DIR := ./build
endif endif
CC := gcc CC := gcc
CXX := g++ CXX := g++
@ -36,7 +38,7 @@ CFLAGS += $(shell pkg-config --cflags $(PACKAGE_NAMES))
LDFLAGS += $(shell pkg-config --libs $(PACKAGE_NAMES)) LDFLAGS += $(shell pkg-config --libs $(PACKAGE_NAMES))
ifeq ($(DEBUG),1) 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 \ -Wcast-qual -Wdisabled-optimization -Wformat=2 \
-Winit-self -Wlogical-op -Wmissing-declarations \ -Winit-self -Wlogical-op -Wmissing-declarations \
-Wmissing-include-dirs -Wredundant-decls -Wshadow \ -Wmissing-include-dirs -Wredundant-decls -Wshadow \
@ -65,10 +67,13 @@ endif
default: $(TARGETS) default: $(TARGETS)
.PHONY: clean icfs_test clean-icfs clean-icfs_dialogue .PHONY: clean icfs_test clean-icfs clean-icfs_dialogue install uninstall
$(BUILD_DIR):
if [[ ! -d "$(BUILD_DIR)" ]]; then mkdir $(BUILD_DIR); fi
$(BUILD_DIR)/icfs_dialogue: $(BUILD_DIR)/icfs_dialogue:
make -C $(SOURCES_DIR)/gui TEST=$(TEST) DEBUG=$(shell realpath $(DEBUG)) SOURCES_DIR=$(shell realpath $(SOURCES_DIR)/gui) BUILD_DIR=$(shell realpath $(BUILD_DIR)) TESTS_DIR=$(shell realpath $(TESTS_DIR)) make -C $(SOURCES_DIR)/gui TEST=$(TEST) DEBUG=$(DEBUG) SOURCES_DIR=$(shell realpath $(SOURCES_DIR)/gui) BUILD_DIR=$(shell realpath $(BUILD_DIR)) TESTS_DIR=$(shell realpath $(TESTS_DIR))
$(BUILD_DIR)/icfs: $(BUILD_DIR)/main.o $(BUILD_DIR)/fuse_operations.o $(BUILD_DIR)/sourcefs.o $(BUILD_DIR)/ui-socket.o $(BUILD_DIR)/temp_permissions_table.o $(BUILD_DIR)/perm_permissions_table.o $(BUILD_DIR)/proc_operations.o $(BUILD_DIR)/icfs: $(BUILD_DIR)/main.o $(BUILD_DIR)/fuse_operations.o $(BUILD_DIR)/sourcefs.o $(BUILD_DIR)/ui-socket.o $(BUILD_DIR)/temp_permissions_table.o $(BUILD_DIR)/perm_permissions_table.o $(BUILD_DIR)/proc_operations.o
$(CC) $(CFLAGS) $^ $(LDFLAGS) -o $(BUILD_DIR)/icfs $(CC) $(CFLAGS) $^ $(LDFLAGS) -o $(BUILD_DIR)/icfs
@ -76,28 +81,28 @@ $(BUILD_DIR)/icfs: $(BUILD_DIR)/main.o $(BUILD_DIR)/fuse_operations.o $(BUILD_DI
icfs_test: $(BUILD_DIR)/icfs icfs_test: $(BUILD_DIR)/icfs
cd ./test && ./test.bash cd ./test && ./test.bash
$(BUILD_DIR)/test_access_control.o: $(TESTS_DIR)/test_access_control.c $(BUILD_DIR)/test_access_control.o: $(TESTS_DIR)/test_access_control.c $(BUILD_DIR)
$(CC) $(CFLAGS) -c $< $(LDFLAGS) -o $@ $(CC) $(CFLAGS) -c $< $(LDFLAGS) -o $@
$(BUILD_DIR)/main.o: $(SOURCES_DIR)/main.c $(BUILD_DIR)/main.o: $(SOURCES_DIR)/main.c $(BUILD_DIR)
$(CC) $(CFLAGS) -c $< $(LDFLAGS) -o $(BUILD_DIR)/main.o $(CC) $(CFLAGS) -c $< $(LDFLAGS) -o $(BUILD_DIR)/main.o
$(BUILD_DIR)/fuse_operations.o: $(SOURCES_DIR)/fuse_operations.c $(SOURCES_DIR)/fuse_operations.h $(BUILD_DIR)/fuse_operations.o: $(SOURCES_DIR)/fuse_operations.c $(SOURCES_DIR)/fuse_operations.h $(BUILD_DIR)
$(CC) $(CFLAGS) -c $< $(LDFLAGS) -o $@ $(CC) $(CFLAGS) -c $< $(LDFLAGS) -o $@
$(BUILD_DIR)/sourcefs.o: $(SOURCES_DIR)/sourcefs.c $(SOURCES_DIR)/sourcefs.h $(SOURCES_DIR)/real_filename.h $(BUILD_DIR)/sourcefs.o: $(SOURCES_DIR)/sourcefs.c $(SOURCES_DIR)/sourcefs.h $(SOURCES_DIR)/real_filename.h $(BUILD_DIR)
$(CC) $(CFLAGS) -c $< $(LDFLAGS) -o $@ $(CC) $(CFLAGS) -c $< $(LDFLAGS) -o $@
$(BUILD_DIR)/ui-socket.o: $(SOURCES_DIR)/ui-socket.c $(SOURCES_DIR)/ui-socket.h $(BUILD_DIR)/ui-socket.o: $(SOURCES_DIR)/ui-socket.c $(SOURCES_DIR)/ui-socket.h $(BUILD_DIR)
$(CC) $(CFLAGS) -c $< $(LDFLAGS) -o $@ $(CC) $(CFLAGS) -c $< $(LDFLAGS) -o $@
$(BUILD_DIR)/temp_permissions_table.o: $(SOURCES_DIR)/temp_permissions_table.c $(SOURCES_DIR)/temp_permissions_table.h $(BUILD_DIR)/temp_permissions_table.o: $(SOURCES_DIR)/temp_permissions_table.c $(SOURCES_DIR)/temp_permissions_table.h $(BUILD_DIR)
$(CC) $(CFLAGS) -c $< $(LDFLAGS) -o $@ $(CC) $(CFLAGS) -c $< $(LDFLAGS) -o $@
$(BUILD_DIR)/perm_permissions_table.o: $(SOURCES_DIR)/perm_permissions_table.c $(SOURCES_DIR)/perm_permissions_table.h $(BUILD_DIR)/perm_permissions_table.o: $(SOURCES_DIR)/perm_permissions_table.c $(SOURCES_DIR)/perm_permissions_table.h $(BUILD_DIR)
$(CC) $(CFLAGS) -c $< $(LDFLAGS) -o $@ $(CC) $(CFLAGS) -c $< $(LDFLAGS) -o $@
$(BUILD_DIR)/proc_operations.o: $(SOURCES_DIR)/proc_operations.c $(SOURCES_DIR)/proc_operations.h $(BUILD_DIR)/proc_operations.o: $(SOURCES_DIR)/proc_operations.c $(SOURCES_DIR)/proc_operations.h $(BUILD_DIR)
$(CC) $(CFLAGS) -c $< $(LDFLAGS) -o $@ $(CC) $(CFLAGS) -c $< $(LDFLAGS) -o $@
CLEAN_TARGETS=clean-icfs CLEAN_TARGETS=clean-icfs
@ -113,3 +118,19 @@ clean-icfs:
clean-icfs_dialogue: clean-icfs_dialogue:
make -C $(SOURCES_DIR)/gui clean SOURCES_DIR=$(shell realpath $(SOURCES_DIR)/gui) BUILD_DIR=$(shell realpath $(BUILD_DIR)) TESTS_DIR=$(shell realpath $(TESTS_DIR)) make -C $(SOURCES_DIR)/gui clean SOURCES_DIR=$(shell realpath $(SOURCES_DIR)/gui) BUILD_DIR=$(shell realpath $(BUILD_DIR)) TESTS_DIR=$(shell realpath $(TESTS_DIR))
install: $(BUILD_DIR)/icfs $(BUILD_DIR)/icfs_dialogue
@echo "Install script needs superuser permission to:"
@printf "\t1. Move executables to /usr/bin.\n"
@printf "\t2. Create \"icfs\" user.\n"
@printf "\t3. Set the setuid bit of icfs executable.\n"
sudo cp $(BUILD_DIR)/icfs /usr/bin/icfs && sudo cp $(BUILD_DIR)/icfs_dialogue /usr/bin/icfs_dialogue
id -u icfs &>/dev/null || sudo useradd --system --user-group icfs
sudo chown icfs: /usr/bin/icfs && sudo chmod 4755 /usr/bin/icfs && sudo chmod 755 /usr/bin/icfs_dialogue
@read -p "Create /etc/icfs directory for permission databases [y/N]: " permd; if [[ $$permd == "y" ]]; then echo "sudo mkdir /etc/icfs && sudo chown :icfs /etc/icfs && sudo chmod g+rw,o= /etc/icfs;"; sudo mkdir /etc/icfs && sudo chown icfs:icfs /etc/icfs && sudo chmod g+rw,o= /etc/icfs; fi
uninstall:
@echo "Install script needs superuser permission to remove executables in /usr/bin"
sudo rm -f /usr/bin/icfs /usr/bin/icfs_dialogue
@read -p "Remove /etc/icfs directory [y/N]: " permd; if [[ $$permd == "y" ]]; then echo "sudo rm -rf /etc/icfs"; sudo rm -rf /etc/icfs; fi

View File

@ -1,5 +1,9 @@
# ICFS -- Interactively Controlled File System # ICFS -- Interactively Controlled File System
> [!IMPORTANT]
> If you need the version that correponds to the thesis attachment, go [here](https://git.umbrasolis.de/fedir/ICFS/src/commit/2f4f1a0a569704b770f50b3e7cf39c09b9b8381a). This version contains corrections of errors that the opponent brought to my attention.
## Motivation ## Motivation
Traditional access control mechanisms in operating systems allow the same level of access to all processes running on behalf of the same user. This typically enables malicious processes to read and/or modify all data accessible to the user running a vulnerable application. It can be dealt using various mandatory access control mechanisms, but these are often complicated to configure and are rarely used in common user oriented scenarios. This thesis focuses on design and implementation of a file system layer which delegates the decision to allow or deny access to a file system object by a specific process to the user. Traditional access control mechanisms in operating systems allow the same level of access to all processes running on behalf of the same user. This typically enables malicious processes to read and/or modify all data accessible to the user running a vulnerable application. It can be dealt using various mandatory access control mechanisms, but these are often complicated to configure and are rarely used in common user oriented scenarios. This thesis focuses on design and implementation of a file system layer which delegates the decision to allow or deny access to a file system object by a specific process to the user.
@ -15,20 +19,67 @@ Traditional access control mechanisms in operating systems allow the same level
- Install dependencies - Install dependencies
- libfuse3 - libfuse3
- Debian: `sudo apt install fuse3 libfuse3-dev` - Debian: `sudo apt install fuse3 libfuse3-dev`
- zenity - SQLite3
- Debian: `sudo apt install zenity` - Debian: `sudo apt install libsqlite3-dev`
- GTK4, libadwaita
- Debian: `sudo apt install libgtk-4-dev libadwaita-1-dev`
- Build tools - Build tools
- Debian: `sudo apt install gcc make pkg-config` - Debian: `sudo apt install gcc make pkg-config`
- Build using `make`: - Build using `make`:
- In the project directory: `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. - Resulting binaries should appear in the `build` directory.
## Installation
- `make install`
- Uninstall with `make uninstall`
## Usage ## Usage
`icfs <FUSE arguments> [target directory]` ```
Usage: icfs <FUSE arguments> [target directory] [path to the permanent permissions database] <ICFS arguments>
--no-grant-on-create - do not give any access permissions on file creation(incompatible with --perm-on-create)
--perm-on-create - automatically give permanent access permission to files a process creates (incompatible with --no-grant-on-create)
```
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. If you have installed icfs along with `/etc/icfs` folder, you can create your permanent permission databases in this folder (you might want to do this, if your home folder does not have the "execute" permission for other users).
### 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.
#### Running tests
ICFS includes a testing script in the `test` directory.
You can run it **from `test` directory** by running:
```
./test.bash
```
All testing artifacts will be available in the appropriate folders after run. To test setuid capabilities too (**from `test` directory!!!**):
```
./test.bash --setuid
```
You can also test performance by adding `--performance` (**from `test` directory!!!**):
```
./test.bash --performance
```
***Important:*** **flags cannot be combined together (e.g. you can't add `--performance` and `--setuid`)**
## Docs ## Docs
@ -38,6 +89,6 @@ The filesystem will be mounted over the target directory, and ask user permissio
## Credit ## Credit
_Student:_ Fedir Kovalov *Student:* Fedir Kovalov
_Supervisor:_ RNDr. Jaroslav Janáček, PhD. *Supervisor:* RNDr. Jaroslav Janáček, PhD.

View File

@ -1,66 +0,0 @@
# File subsystem with process-specific file access control for Linux.
## The problem
When you run a program on Linux, it can access the same files as the user account that started it, which is usually overly permissive.
For example, one may write a trojan, that would download all of your photos, documents, personal info, data of other programs, etc. and you wouldn't even have a way of knowing it happened.
At the same time, you *sometimes* would like *some* programs to have access to *some* of your files, for example if you are applying for the university, you would like your text editor to have access to application form, but you only need it when you are applying for a university, and you only need the editor to access this specific file.
So you have to somehow control *when* and *which* programs can access *what* file.
## Existing file access control solutions
### Linux security modules
Kernel modules such as SELinux and AppArmor can certainly enforce rules on *which* programs can access *what* files, which certainly helps. Unfortunately:
* They are overcomplicated (especially SELinux).
* They have to be compiled into the kernel.
* They give permissions forever: you have to reset them manually.
### Flatpaks, Snaps and similar namespace-based solutions
When the programs themselves are isolated from the rest of the OS, it definitely helps to prevent unwanted access to the filesystem. However:
* To even be able to override the default filesystem access permissions the user needs to use another app (flatseal for example) or to master the CLI tools.
* They give permissions forever: you have to revoke them manually.
* The program has to be packaged and distributed is a specific way, which is a developer's decision.
* **LOTS of apps need access to some files. Because the default permissions are regulated by the developer himself, it is usually easier to give entire filesystem access permissions, rather than select a specific folder that it needs.**
## My idea to solve the problem
Make a program using FUSE that would control processes' access to selected files by freezing the process and letting the user to choose whether to allow the access or not.
From the point of view of the process files would appear completely normal, so no involvement of the developer is required.
When a process calls `open()` on a file that our system controls, that process would be frozen. User then uses the system's interface to either allow (and then the file is opened normally), or deny access (and then the `open()` returns `EACCES`).
Under the hood, the system's daemon would open some other file stored in a hidden directory with restricted "classic" POSIX permissions (I talk more about how those files are protected in the problems section). From now on, these files would be called "source files".
The program would keep track processes' permissions, and allow repeated access to the same file, to avoid bothering the user excessively.
Also, because the program is running fully within userspace, it will make it far easier to develop, interface with, install and distribute.
## Problems
See `bc-thesis-problems.md` .
## (Proposed) time plan
* before 31.10 - A sort of "security risk assessment" and therefore a review of requirements, since this kind of is a security project.
* before 30.11 - Architecture and design.
* before 28.01 - Implementation.
* before 31.02 - Testing.
* before 30.03 - The thesis itself.
Rest of the time is reserved for unexpected problems.
Since the "buisness analysis" and requirements are already more than half-ready, I am not including them.
## Formal specification
Name:
`File subsystem with temporary, process-specific file access control policies for Linux.`
Goal:
`Develop and implement a virtual file subsystem that would manage and enforce temporary, process and file specific rules and policies regulated by the user's choice, therefore ensuring greater security by restricting arbitrary file access by processes.`
[^1]: I haven't found any better information on that topic. The solutions mentioned seem overcomplicated.
[^2]: Which is obtained through 22-nd field in /proc/\[pid\]/stat (see `man proc_pid_stat(5)`).
[^3]: To the best of my knowledge.

View File

@ -1,78 +0,0 @@
# Problems
## Keeping track of running processes
Since [we can't simply be notified about random process's termination](https://stackoverflow.com/questions/15275366/how-to-get-notified-on-termination-of-some-another-process-in-linux)[^1], the question arises: how to keep track of the processes in the permission table?
If we don't delete a permission table entry exactly before the process finishes, another process, [intentionally](https://stackoverflow.com/questions/18122592/how-to-set-process-id-in-linux-for-a-specific-program) or not, gets the same PID, it would gain unauthorized access to files.
The solution I offer involves writing down process's start time:
* Permission table will consist of entries $(pid, starttime, permission)$, where $pid$ is the process's PID, $starttime$ is the process's start time and $permission$ is the type of access the process is allowed (e.g. to which files).
* When the process opens a file, search through the table.
+ If an entry with the correct PID was found:
- If $starttime_{table} < starttime_{actual}$[^2], delete all the entries with that PID and file a permission request to the user -- the process that requested access is not the same because it has started after the original process who had this permission(and because their PIDs match, the original process had to end before this could start).
- Otherwise:
* If the permission matches the request, open the file.
* Otherwise file a new permission request.
+ Otherwise file a new permission request.
This approach should make "permission hijacking" practically impossible, as it would take a considerable amount of time just to approve the permission. Even if our permissions could be approved instantly it would still take a few scheduler cycles to execute the original program, so the new ones must have a later start time.
This approach still has an issue: the table would be hoarded with old permissions, and therefore waste memory. This might be mitigated by regular cleanups (e.g. every time you create a new permission, check if the oldest one's process is still running)
Another issue might be speed, because all of the table lookups take linear time. But considering that file opening isn't exactly a time-critical operation and that the table could be sorted by PID, it does not seem to be that big of an issue.
## FUSE issues
As mentioned in the initial idea, the source files have to be protected from external access in some way.
Here I can see three solutions:
1. Encrypting source files.
2. Running our virtual filesystem daemon as a special user, and making all our source files only accessible to this special user, therefore processes would have no permissions to access the source files.
3. Use some LSM's MAC policy to deny access to source files to any process except our daemon.
The first solution would definitely be preferable from the standpoint of compatibility, as it requires no special configuration, and because it mitigates the issue the best, as the attacker has to get encryption keys from the memory. Moreover, it could allow us to deny access for processes running as `root`[^3]. However, implementing encryption seems to be way out of scope of this project.
The second solution seems to work well in theory. There are some specific details to be clarified about it's implementation, but generally it seems to work out.
Although the third solution looks like exactly what we are looking for, but it requires a kernel module that enforces MAC policies. Even though those modules are common on most distros, they are pretty different from each other, and I think their usage should be limited to being an additional layer on top of the second solution.
## User interface
From the description of the software, it remains unclear what type of user interaction design is appropriate. Do we make a CLI? GUI?
I propose to deal with it like the [Transmission](https://github.com/transmission/transmission) did[^3] -- create the backend with an integrated CLI first, and then make GUI wrapper in GTK after (if there would be time, of course `:)` ).
## Programs with CLI
Programs that are run via shell can have an execution time of a fraction of a second, which means you would have to re-allow the access for them every time you run them.
My solution is to give an option to set permissions for specific *sessions*, so that every command run from a specific terminal window would have the same permissions.
Then the permission table would be populated with the session process's data (e.g. the shell), or maybe this would necessitate a separate table just for the sessions.
That might also imply a creation of two CLI tools:
* `sprequest [PERM]` -- request a certain permission for the session
* `spdrop` -- drop all permissions given to the session
## Too many files...
It would be annoying to go and allow access for each program every time one of them opens a new file.
For example, if the file subsystem looks like this:
```
Documents/
| Work/
| | horalky_secret_recipe.pdf
| | colleagues.csv
| Notes/
| | set_theory.md
| | Peano_axioms.md
| | ...
| | Cantor_theorem.md
```
If I want to view my notes, I would want allow my markdown editor the access to all the files in the `Documents/Notes` folder to make links work, but when I want to find a name of my colleague, I would like to only give the permission to the `Documents/Work/colleagues.csv` file.
The solution is obvious: to give an option for the user to give permissions for the entire folder, not just a specific file.
## Other
* Threads (not that big of a problem, but a complication nevertheless).
* All of the permissions get reset after the process is ended, which is annoying. Perhaps it would be possible to implement permanent permissions through identifying programs by their executables' hashes/paths, but updates almost certainly make that impossible (unless we are modifying a package manager, which is clearly out of scope of this project).
Another issue, severity of which I can't assess properly, is whether this idea fits the Informatics degree, as it does not seem to be as much of an experimental or "theoretical" idea. In my opinion it sill holds enough water to entertain the possibility though.
[^1]: I haven't found any better information on that topic. The solutions mentioned seem overcomplicated.
[^2]: Which is obtained through 22-nd field in /proc/\[pid\]/stat (see `man proc_pid_stat(5)`).
[^3]: To the best of my knowledge.

View File

@ -1,33 +0,0 @@
# Formal specification
## Name
```
Filesystem with Interactive Access Control for Linux
```
```
Súborový systém s interaktívnym riadením prístupu pre Linux
```
## Note
```
Traditional access control mechanisms in operating systems allow the same level of access to all processes running on behalf of the same user. This typically enables malicious processes to read and/or modify all data accessible to the user running a vulnerable application. It can be dealt using various mandatory access control mechanisms, but these are often complicated to configure and are rarely used in common user oriented scenarios. This thesis focuses on design and implementation of a filesystem layer which delegates the decision to allow or deny access to a filesystem object by a specific process to the user.
```
```
Tradičné mechanizmy riadenia prístupu v operačných systémoch povoľujú rovnakú úroveň prístupu všetkým procesom bežiacim v mene toho istého používateľa. Toto typicky umožňuje škodlivým procesom čítať a/alebo modifikovať všetky údaje prístupné používateľovi, ktorý spustil zraniteľnú aplikáciu. Dá sa to riešiť použitím rôznych mechanizmov povinného riadenia prístupu, no tieto sú často náročné na konfiguráciu a zriedkavo sa používajú v bežných scenároch orientovaných na používateľa. Táto práca sa zameriava na návrh a implementáciu vrstvy súborového systému, ktorá rozhodnutie povoliť alebo zakázať prístup k objektu súborového systému konkrétnym procesom deleguje na používateľa.
```
## Goal
```
- analyse the problem and design a solution
- implement the solution using the FUSE framework
- test the solution and demonstrate its benefits
```
```
- analyzovať problém a navrhnúť riešenie
- implementovať riešenie využitím FUSE
- otestovať riešenie a demonštrovať jeho prínos
```

View File

@ -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 #ifndef ACCESS_T_H
#define ACCESS_T_H #define ACCESS_T_H

View File

@ -11,7 +11,9 @@
See the file LICENSE. See the file LICENSE.
*/ */
#include "process_info.h"
#include "real_filename.h" #include "real_filename.h"
#include "set_mode_t.h"
#include <assert.h> #include <assert.h>
#include <stddef.h> #include <stddef.h>
#define FUSE_USE_VERSION 31 #define FUSE_USE_VERSION 31
@ -41,8 +43,21 @@
#include "fuse_operations.h" #include "fuse_operations.h"
#include "proc_operations.h" #include "proc_operations.h"
#include "sourcefs.h" #include "sourcefs.h"
#include "temp_permissions_table.h"
#include "ui-socket.h" #include "ui-socket.h"
int auto_create_perm = GRANT_TEMP;
#define HAVE_UTIMENSAT
/*
* Sets the default permission granted by file creation.
*
* @param val: the default permission to grant. Should be one of GRANT_TEMP,
* GRANT_TEM and 0. When set to 0, grants no permissions.
*/
void set_auto_create_perm(int val) { auto_create_perm = val; }
static void *xmp_init(struct fuse_conn_info *conn, struct fuse_config *cfg) { static void *xmp_init(struct fuse_conn_info *conn, struct fuse_config *cfg) {
(void)conn; (void)conn;
cfg->use_ino = 1; cfg->use_ino = 1;
@ -53,7 +68,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 current function (recommended in high level API) or set fi->direct_io
in xmp_create() or xmp_open(). */ in xmp_create() or xmp_open(). */
cfg->direct_io = 1; cfg->direct_io = 1;
#if FUSE_VERSION > FUSE_MAKE_VERSION(3, 14)
cfg->parallel_direct_writes = 1; cfg->parallel_direct_writes = 1;
#endif
/* Pick up changes from lower filesystem right away. This is /* Pick up changes from lower filesystem right away. This is
also necessary for better hardlink support. When the kernel also necessary for better hardlink support. When the kernel
@ -67,6 +84,7 @@ static void *xmp_init(struct fuse_conn_info *conn, struct fuse_config *cfg) {
cfg->negative_timeout = 0; cfg->negative_timeout = 0;
fprintf(stderr, "%d\n", getpid()); fprintf(stderr, "%d\n", getpid());
assert(get_mountpoint() != NULL); assert(get_mountpoint() != NULL);
init_garbage_collector();
return NULL; return NULL;
} }
@ -82,7 +100,7 @@ static int xmp_getattr(const char *path, struct stat *stbuf,
else else
res = source_stat(path, stbuf); res = source_stat(path, stbuf);
if (res == -1) { if (res == -1) {
perror("Stat failed"); perror("[ICFS] Stat failed");
return -errno; return -errno;
} }
@ -94,7 +112,11 @@ static int xmp_access(const char *path, int mask) {
// if mask is F_OK, then we don't need to check the permissions // if mask is F_OK, then we don't need to check the permissions
// (is that possible?) // (is that possible?)
//
// EDIT: now lie to the program by not telling it whether it can actually
// access the file.
/*
if (mask != F_OK) { if (mask != F_OK) {
struct process_info proc_info; struct process_info proc_info;
struct fuse_context *context = fuse_get_context(); struct fuse_context *context = fuse_get_context();
@ -111,6 +133,7 @@ static int xmp_access(const char *path, int mask) {
free((void *)proc_info.name); free((void *)proc_info.name);
} }
*/
res = source_access(path, mask); res = source_access(path, mask);
@ -146,7 +169,7 @@ static int xmp_opendir(const char *path, struct fuse_file_info *fi) {
d->dp = source_opendir(path); d->dp = source_opendir(path);
if (d->dp == NULL) { if (d->dp == NULL) {
perror("Opendir failed"); perror("[ICFS] Opendir failed");
res = -errno; res = -errno;
free(d); free(d);
return res; return res;
@ -265,8 +288,7 @@ static int xmp_unlink(const char *path) {
struct fuse_context *fc = fuse_get_context(); struct fuse_context *fc = fuse_get_context();
// ask the user for the permission for deleting the file // ask the user for the permission for deleting the file
pi.PID = fc->pid; pi = get_process_info(fc->pid);
pi.name = get_process_name_by_pid(pi.PID);
// fprintf(stderr, "%s, %d\n", path, ask_access(path, pi)); // fprintf(stderr, "%s, %d\n", path, ask_access(path, pi));
@ -313,8 +335,7 @@ static int xmp_rename(const char *from, const char *to, unsigned int flags) {
struct process_info pi; struct process_info pi;
struct fuse_context *fc = fuse_get_context(); struct fuse_context *fc = fuse_get_context();
pi.PID = fc->pid; pi = get_process_info(fc->pid);
pi.name = get_process_name_by_pid(pi.PID);
// fprintf(stderr, "%s, %d\n", path, ask_access(path, pi)); // fprintf(stderr, "%s, %d\n", path, ask_access(path, pi));
@ -344,8 +365,7 @@ static int xmp_link(const char *from, const char *to) {
struct process_info pi; struct process_info pi;
struct fuse_context *fc = fuse_get_context(); struct fuse_context *fc = fuse_get_context();
pi.PID = fc->pid; pi = get_process_info(fc->pid);
pi.name = get_process_name_by_pid(pi.PID);
// fprintf(stderr, "%s, %d\n", path, ask_access(path, pi)); // fprintf(stderr, "%s, %d\n", path, ask_access(path, pi));
if (!interactive_access(from, pi, 0)) { if (!interactive_access(from, pi, 0)) {
@ -369,8 +389,7 @@ static int xmp_chmod(const char *path, mode_t mode, struct fuse_file_info *fi) {
struct process_info pi; struct process_info pi;
struct fuse_context *fc = fuse_get_context(); struct fuse_context *fc = fuse_get_context();
pi.PID = fc->pid; pi = get_process_info(fc->pid);
pi.name = get_process_name_by_pid(pi.PID);
// fprintf(stderr, "%s, %d\n", path, ask_access(path, pi)); // fprintf(stderr, "%s, %d\n", path, ask_access(path, pi));
if (!interactive_access(path, pi, 0)) { if (!interactive_access(path, pi, 0)) {
@ -391,8 +410,8 @@ static int xmp_chmod(const char *path, mode_t mode, struct fuse_file_info *fi) {
} }
/** /**
* This filesystem is not designed for multiuser operation (e.g. with * This filesystem is not designed for multiuser operation (with
* allow_other) so there is little point in having chown implemnted * allow_other option) so there is little point in having chown implemnted
*/ */
static int xmp_chown(const char *path, uid_t uid, gid_t gid, static int xmp_chown(const char *path, uid_t uid, gid_t gid,
struct fuse_file_info *fi) { struct fuse_file_info *fi) {
@ -400,8 +419,7 @@ static int xmp_chown(const char *path, uid_t uid, gid_t gid,
struct process_info pi; struct process_info pi;
struct fuse_context *fc = fuse_get_context(); struct fuse_context *fc = fuse_get_context();
pi.PID = fc->pid; pi = get_process_info(fc->pid);
pi.name = get_process_name_by_pid(pi.PID);
// fprintf(stderr, "%s, %d\n", path, ask_access(path, pi)); // fprintf(stderr, "%s, %d\n", path, ask_access(path, pi));
if (!interactive_access(path, pi, 0)) { if (!interactive_access(path, pi, 0)) {
@ -440,12 +458,21 @@ static int xmp_truncate(const char *path, off_t size,
static int xmp_utimens(const char *path, const struct timespec ts[2], static int xmp_utimens(const char *path, const struct timespec ts[2],
struct fuse_file_info *fi) { struct fuse_file_info *fi) {
int res; int res;
struct process_info pi;
struct fuse_context *fc = fuse_get_context();
pi = get_process_info(fc->pid);
if (!interactive_access(path, pi, 0)) {
free(pi.name);
return -EACCES;
}
/* don't use utime/utimes since they follow symlinks */ /* don't use utime/utimes since they follow symlinks */
if (fi) if (fi)
res = futimens(fi->fh, ts); res = futimens(fi->fh, ts);
else else
res = utimensat(0, path, ts, AT_SYMLINK_NOFOLLOW); res = source_utimens(path, ts, AT_SYMLINK_NOFOLLOW);
if (res == -1) if (res == -1)
return -errno; return -errno;
@ -459,14 +486,13 @@ static int xmp_create(const char *path, mode_t mode,
struct process_info pi; struct process_info pi;
struct fuse_context *fc = fuse_get_context(); struct fuse_context *fc = fuse_get_context();
pi.PID = fc->pid; pi = get_process_info(fc->pid);
pi.name = get_process_name_by_pid(pi.PID);
// fprintf(stderr, "%s, %d\n", path, ask_access(path, pi)); if (auto_create_perm != 0) {
if (!interactive_access(path, pi, auto_create_perm)) {
if (!interactive_access(path, pi, GRANT_PERM)) { free(pi.name);
free(pi.name); return -EACCES;
return -EACCES; }
} }
free(pi.name); free(pi.name);
@ -484,8 +510,7 @@ static int xmp_open(const char *path, struct fuse_file_info *fi) {
struct process_info pi; struct process_info pi;
struct fuse_context *fc = fuse_get_context(); struct fuse_context *fc = fuse_get_context();
pi.PID = fc->pid; pi = get_process_info(fc->pid);
pi.name = get_process_name_by_pid(pi.PID);
// fprintf(stderr, "%s, %d\n", path, ask_access(path, pi)); // fprintf(stderr, "%s, %d\n", path, ask_access(path, pi));
if (!interactive_access(path, pi, 0)) { if (!interactive_access(path, pi, 0)) {
@ -747,7 +772,7 @@ static const struct fuse_operations xmp_oper = {
.chown = xmp_chown, .chown = xmp_chown,
.truncate = xmp_truncate, .truncate = xmp_truncate,
#ifdef HAVE_UTIMENSAT #ifdef HAVE_UTIMENSAT
// .utimens = xmp_utimens, .utimens = xmp_utimens,
#endif #endif
.create = xmp_create, .create = xmp_create,
.open = xmp_open, .open = xmp_open,

View File

@ -15,4 +15,12 @@
const struct fuse_operations *get_fuse_operations(); const struct fuse_operations *get_fuse_operations();
/*
* Sets the default permission granted by file creation.
*
* @param val: the default permission to grant. Should be one of GRANT_TEMP,
* GRANT_TEM and 0. When set to 0, grants no permissions.
*/
void set_auto_create_perm(int val);
#endif #endif

View File

@ -7,9 +7,10 @@
#include <stdio.h> #include <stdio.h>
#include <stdlib.h> #include <stdlib.h>
#define YES 0 #define YES 1
#define NO 1 #define NO 0
#define PERM 2 #define PERM 2
#define TEMP 0
int exit_code = 0; int exit_code = 0;
gboolean is_permanent = false; gboolean is_permanent = false;
@ -20,7 +21,7 @@ static void positive_response(GtkWindow *window) {
fprintf(stdout, "%s", gtk_entry_buffer_get_text(entry_buffer)); fprintf(stdout, "%s", gtk_entry_buffer_get_text(entry_buffer));
exit_code = (gtk_check_button_get_active(GTK_CHECK_BUTTON(checkbox))) exit_code = (gtk_check_button_get_active(GTK_CHECK_BUTTON(checkbox)))
? YES | PERM ? YES | PERM
: YES; : YES | TEMP;
gtk_window_close(window); gtk_window_close(window);
} }
@ -28,7 +29,7 @@ static void negative_response(GtkWindow *window) {
fprintf(stdout, "%s", gtk_entry_buffer_get_text(entry_buffer)); fprintf(stdout, "%s", gtk_entry_buffer_get_text(entry_buffer));
exit_code = (gtk_check_button_get_active(GTK_CHECK_BUTTON(checkbox))) exit_code = (gtk_check_button_get_active(GTK_CHECK_BUTTON(checkbox)))
? NO | PERM ? NO | PERM
: NO; : NO | TEMP;
gtk_window_close(window); gtk_window_close(window);
} }
@ -118,7 +119,7 @@ static int on_command_line(GApplication *app, GApplicationCommandLine *cmdline,
argv = g_application_command_line_get_arguments(cmdline, &argc); argv = g_application_command_line_get_arguments(cmdline, &argc);
// Handle your arguments here // Handle your arguments here
if (argc >= 4) { if (argc >= 5) {
fprintf(stderr, "%s\n", argv[1]); fprintf(stderr, "%s\n", argv[1]);
g_object_set_data_full(G_OBJECT(app), "accessing_pid", g_strdup(argv[1]), g_object_set_data_full(G_OBJECT(app), "accessing_pid", g_strdup(argv[1]),
g_free); g_free);
@ -141,8 +142,18 @@ int main(int argc, char **argv) {
if (argc == 2 && strcmp(argv[1], "--version") == 0) { if (argc == 2 && strcmp(argv[1], "--version") == 0) {
fprintf(stdout, "icfs_dialogue 1.0.0"); fprintf(stdout, "icfs_dialogue 1.0.0");
return 0;
} }
if (argc != 5) {
fprintf(stdout, "Usage: icfs_dialogue [accessing pid] [accessing name] "
"[root folder] [access dir]");
return 255;
}
// disable accessibility features to prevent attacks
g_setenv("NO_AT_BRIDGE", "1", TRUE);
// Create a new application // Create a new application
AdwApplication *app = adw_application_new("de.umbrasolis.icfs_dialogue", AdwApplication *app = adw_application_new("de.umbrasolis.icfs_dialogue",
G_APPLICATION_HANDLES_COMMAND_LINE); G_APPLICATION_HANDLES_COMMAND_LINE);

View File

@ -10,6 +10,7 @@
See the file LICENSE. See the file LICENSE.
*/ */
#include <string.h>
#define FUSE_USE_VERSION 31 #define FUSE_USE_VERSION 31
#define _GNU_SOURCE #define _GNU_SOURCE
@ -29,7 +30,28 @@ const char *mountpoint = NULL;
int main(int argc, char *argv[]) { int main(int argc, char *argv[]) {
if (argc < 3) { if (argc < 3) {
fprintf(stderr, "Usage: icfs <FUSE arguments> [target directory] [path to " fprintf(stderr, "Usage: icfs <FUSE arguments> [target directory] [path to "
"the permanent permissions database\n"); "the permanent permissions database] <ICFS "
"arguments>\n\t--no-grant-on-create - do not give any "
"access permissions on file creation"
"(incompatible with --perm-on-create)\n\t--perm-on-create "
"- automatically give permanent access permission to files "
"a process creates "
"(incompatible with --no-grant-on-create)\n");
return EXIT_FAILURE;
}
if ((0 == strcmp(argv[argc - 1], "--no-grant-on-create") &&
0 == strcmp(argv[argc - 2], "--temp-on-create")) ||
(0 == strcmp(argv[argc - 2], "--no-grant-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-grant-on-create - do not give any "
"access permissions on file creation"
"(incompatible with --perm-on-create)\n\t--perm-on-create "
"- automatically give permanent access permission to files "
"a process creates "
"(incompatible with --no-grant-on-create)\n");
return EXIT_FAILURE; return EXIT_FAILURE;
} }
@ -37,11 +59,20 @@ int main(int argc, char *argv[]) {
// permissions than it's caller reqested // permissions than it's caller reqested
umask(0); umask(0);
if (0 == strcmp(argv[argc - 1], "--no-grant-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 // ui socket should always be initialized before anything else, since it
// handles the setuid bits! // handles the setuid bits!
int ret = init_ui_socket(argv[argc - 1]); int ret = init_ui_socket(argv[argc - 1]);
if (ret != 0) { if (ret != 0) {
fprintf(stderr, "Could not initalize ui-socket.\n"); fprintf(stderr, "[ICFS] Could not initalize ui-socket.\n");
exit(EXIT_FAILURE); exit(EXIT_FAILURE);
} }
@ -49,7 +80,7 @@ int main(int argc, char *argv[]) {
ret = source_init(mountpoint); ret = source_init(mountpoint);
if (ret != 0) { if (ret != 0) {
perror("source_init"); perror("[ICFS] source_init");
exit(EXIT_FAILURE); exit(EXIT_FAILURE);
} }

View File

@ -23,56 +23,39 @@
#include <sys/types.h> #include <sys/types.h>
#include <unistd.h> #include <unistd.h>
// Global pointer to the SQLite database storing permanent permissions
sqlite3 *perm_database = NULL; sqlite3 *perm_database = NULL;
const char *const table_name = "permissions"; const char *const table_name = "permissions";
// one row corresponds to a permission to access one file for one executable // Each row represents a permission to access a specific file for an executable
const int column_count = 3; const int column_count = 3;
// Column names in the permissions table
const char *const schema[] = {"executable", "filename", "mode"}; const char *const schema[] = {"executable", "filename", "mode"};
// Expected SQL data types for each column
const char *const types[] = {"TEXT", "TEXT", "INTEGER"}; 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)
return;
int status = -1;
status = setfsuid(ruid);
if (status < 0) {
fprintf(stderr, "Couldn't set uid to %d.\n", ruid);
exit(status);
}
pthread_mutex_unlock(&uid_switch);
}
void set_real_fsuid() {
pthread_mutex_lock(&uid_switch);
if (current_pid == ruid)
return;
int status = -1;
status = setfsuid(ruid);
if (status < 0) {
fprintf(stderr, "Couldn't set uid to %d.\n", euid);
exit(status);
}
pthread_mutex_unlock(&uid_switch);
}
/**
* Callback to validate the database schema matches expectations.
* Verifies column order, names, and types during schema checks.
*
* @param unused: Ignored context pointer
* @param argc: Number of columns returned (should be 3)
* @param argv: Column data: index 0=name, 1=type, 2=notnull flag
* @param colname: Column names (unused)
* @return 0 on success, 1 if schema mismatch
*/
static int check_table_col_schema(void *notused, int argc, char **argv, static int check_table_col_schema(void *notused, int argc, char **argv,
char **colname) { char **colname) {
(void)notused; (void)notused;
(void)colname; (void)colname;
if (argc < 3) { 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; return 1;
} }
int column_num = atoi(argv[0]); int column_num = atoi(argv[0]);
if (column_num >= column_count) { 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; return 1;
} }
@ -80,31 +63,19 @@ static int check_table_col_schema(void *notused, int argc, char **argv,
strcmp(types[column_num], argv[2]) == 0) { strcmp(types[column_num], argv[2]) == 0) {
return 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; return 1;
} }
static int set_flag(void *flag, int argc, char **argv, char **colname) { /**
(void)colname; * Creates the permissions table schema in the database.
* Called when the table doesn't exist yet.
if (argc < 3) { *
fprintf(stderr, * @return 0 on success, 1 on failure
"Unexpected amount of arguments given to the callback: %d.\n", */
argc); int create_database_schema(void) {
return 1; fprintf(stderr, "[ICFS] Creating table 'permissions'.\n");
}
if (atoi(argv[2])) {
fprintf(stderr, "Third column was: %s\n", argv[2]);
*(int *)flag = 1;
} else {
*(int *)flag = -1;
}
return 0;
}
int create_database_schema() {
fprintf(stderr, "Creating table 'permissions'.\n");
const char *create_query = const char *create_query =
"CREATE TABLE permissions(executable TEXT NOT " "CREATE TABLE permissions(executable TEXT NOT "
"NULL, filename TEXT NOT NULL, mode INTEGER NOT NULL);"; "NULL, filename TEXT NOT NULL, mode INTEGER NOT NULL);";
@ -112,80 +83,89 @@ int create_database_schema() {
int ret = sqlite3_exec(perm_database, create_query, NULL, NULL, &err); int ret = sqlite3_exec(perm_database, create_query, NULL, NULL, &err);
if (ret != SQLITE_OK) { if (ret != SQLITE_OK) {
fprintf(stderr, "sqlite3 error: %s\n", err); fprintf(stderr, "[ICFS] sqlite3 error: %s\n", err);
sqlite3_free(err); sqlite3_free(err);
return 1; return 1;
} }
fprintf(stderr, "Database created successfully\n"); fprintf(stderr, "[ICFS] Database created successfully\n");
return 0; return 0;
} }
/** /**
* Ensures that the database schema is correct. * Ensures the database schema matches expected structure.
* Validates table existence and column definitions.
* *
* @return: 0 if the schema is correct, 1 if the schema could not be corrected. * @return 0 if schema is valid, 1 if validation failed or repair failed
*/ */
int ensure_database_schema() { int ensure_database_schema(void) {
// Check for the table. // Check for the table.
int result = sqlite3_table_column_metadata( int result = sqlite3_table_column_metadata(
perm_database, NULL, table_name, NULL, NULL, NULL, NULL, NULL, NULL); perm_database, NULL, table_name, NULL, NULL, NULL, NULL, NULL, NULL);
if (result == SQLITE_ERROR) { 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()) { if (create_database_schema()) {
fprintf(stderr, "Table could not be created.\n"); fprintf(stderr, "[ICFS] Table could not be created.\n");
return 1; return 1;
} }
return 0; return 0;
} else if (result != SQLITE_OK) { } 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; return 1;
} }
// Verify column definitions
const char *pragma = "PRAGMA table_info(permissions);"; const char *pragma = "PRAGMA table_info(permissions);";
char *err = NULL; char *err = NULL;
int ret = int ret =
sqlite3_exec(perm_database, pragma, check_table_col_schema, NULL, &err); sqlite3_exec(perm_database, pragma, check_table_col_schema, NULL, &err);
if (ret != SQLITE_OK) { if (ret != SQLITE_OK) {
fprintf(stderr, "sqlite3 error: %s\n", err); fprintf(stderr, "[ICFS] sqlite3 error: %s\n", err);
sqlite3_free(err); sqlite3_free(err);
return 1; return 1;
} }
fprintf(stderr, "Schema is correct.\n"); fprintf(stderr, "[ICFS] Schema is correct.\n");
return 0; return 0;
} }
/** /**
* Initializes the permanent permissions table. * Initializes the permanent permissions database.
* Creates/opens the database file and sets up schema.
* *
* @param db_filename: The filename of the permissions sqlite3 database * @param db_filename Path to the SQLite database file
* @return: 0 on success, -1 on failure * @return 0 on success, -1 on failure
*/ */
int init_perm_permissions_table(const char *db_filename) { int init_perm_permissions_table(const char *db_filename) {
// we don't want the group and others to access the db // Prevent group/others access during file creation
umask(0077); umask(0077);
ruid = getuid(); ruid = getuid();
euid = geteuid(); 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());
// Open database with read/write access and full mutex protection
if (sqlite3_open_v2(db_filename, &perm_database, if (sqlite3_open_v2(db_filename, &perm_database,
SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE | SQLITE_OPEN_READWRITE | SQLITE_OPEN_CREATE |
SQLITE_OPEN_FULLMUTEX, SQLITE_OPEN_FULLMUTEX,
NULL)) { NULL)) {
perror("Can't open permanent permissions database"); perror("[ICFS] Can't open permanent permissions database");
return -1; return -1;
} }
umask(0); umask(0); // Restore default umask
// Verify and initialize schema
if (ensure_database_schema()) { if (ensure_database_schema()) {
fprintf(stderr, "Database schema is not correct.\n"); fprintf(stderr, "[ICFS] Database schema is not correct.\n");
return -1; return -1;
} }
// Switch to real UID, since we started with the icfs user to open the
// database
int status = seteuid(ruid); int status = seteuid(ruid);
if (status < 0) { 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); exit(status);
} }
@ -193,86 +173,85 @@ int init_perm_permissions_table(const char *db_filename) {
} }
/** /**
* Destroys the permanent permissions table. * Closes the database connection and releases resources.
* Should be called when the module is shutting down.
*/ */
void destroy_perm_permissions_table(void) { sqlite3_close(perm_database); } void destroy_perm_permissions_table(void) { sqlite3_close(perm_database); }
/** /**
* Checks if the process has a permanent access to the file. * Checks if a specific process has permanent access to a file.
* Does not check parent processes.
* *
* @param filename: The file that the process is trying to access * @param filename Path to the file being accessed
* @pram pi: The process information * @param pi Process information structure
* @return: access status - ALLOW, DENY or NDEF in case if no information was * @return ALLOW (explicit allow), DENY (explicit deny), or NDEF (no info)
* found
*/ */
access_t check_perm_access_noparent(const char *filename, access_t check_perm_access_noparent(const char *filename,
struct process_info pi) { struct process_info pi) {
if (pi.name == NULL)
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("");
return NDEF; return NDEF;
access_t ret = NDEF;
sqlite3_stmt *stmt = NULL;
// Query checks:
// 1. Exact match for filename
// 2. Directory prefix match (filename starts with stored path + '/')
// Ordered by longest path for most specific match first
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);
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;
} }
char *sqlite_error = NULL; if (step_ret == SQLITE_ROW) {
int flag = 0; int mode_col = sqlite3_column_int(stmt, 0);
ret = sqlite3_exec(perm_database, query, set_flag, &flag, &sqlite_error); ret = mode_col ? ALLOW : DENY;
free((void *)query);
if (ret != SQLITE_OK) {
fprintf(stderr, "SQLite returned an error: %s\n", sqlite_error);
sqlite3_free(sqlite_error);
return NDEF;
} }
if (flag == 1) { sqlite3_finalize(stmt);
return ALLOW; return ret;
}
if (flag == -1) {
return DENY;
}
return NDEF;
} }
/** /**
* Checks if the process or any of it's parents have permanent access to the * Checks if a process or any of its ancestors have permanent access.
* file. * Handles hierarchical permission inheritance.
* *
* @param filename: The file that the process is trying to access * @param filename Path to the file being accessed
* @pram pi: The process information * @param pi Process information structure
* @return: access status - ALLOW, DENY or NDEF in case if no information was * @return ALLOW/DENY/NDEF with NDEF meaning no explicit rule found
* found. Does not return ALLOW_TEMP or DENY_TEMP. * @note May return false negatives if parent processes terminate during check
* @note: In case one of the parent processes is killed while this function
* execution the result is not guranteed to be correct. It should only lead to
* false negatives, though.
*/ */
access_t check_perm_access(const char *filename, struct process_info pi) { 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; return NDEF;
} }
struct process_info current_pi = pi; struct process_info current_pi = pi;
current_pi.name = strdup(current_pi.name); current_pi.name = strdup(current_pi.name);
while (current_pi.PID != 0) { while (current_pi.PID != 0) {
access_t access = check_perm_access_noparent(filename, current_pi); access_t access = check_perm_access_noparent(filename, current_pi);
free(current_pi.name); free(current_pi.name);
if (access != NDEF) { if (access != NDEF) {
return access; return access;
} }
current_pi.name = NULL; current_pi.name = NULL;
// Traverse to parent process
while (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) { if (current_pi.PID != 0) {
current_pi.name = get_process_name_by_pid(current_pi.PID); current_pi.name = get_process_name_by_pid(current_pi.PID);
} else { } else {
@ -285,45 +264,38 @@ access_t check_perm_access(const char *filename, struct process_info pi) {
} }
/** /**
* Gives permanent access to the process to the file. * Sets a permanent access rule for a process-file combination.
* *
* @param filename: The file that the process is trying to access * @param filename Path to the file needing access
* @param pi: The process information * @param pi Process information
* @return: 0 on success, 1 on failure * @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
*/ */
int set_perm_access(const char *filename, struct process_info pi, int set_perm_access(const char *filename, struct process_info pi,
set_mode_t mode) { set_mode_t mode) {
char *query = NULL; sqlite3_stmt *stmt = NULL;
int ret = -1; char *sql = NULL;
if (mode == SET_ALLOW) { if (mode == SET_ALLOW) {
ret = asprintf(&query, "INSERT INTO %s VALUES (\'%s\', \'%s\', TRUE);", sql = "INSERT INTO permissions VALUES (?1, ?2, TRUE);";
table_name, pi.name, filename);
} else if (mode == SET_DENY) { } else if (mode == SET_DENY) {
ret = asprintf(&query, "INSERT INTO %s VALUES (\'%s\', \'%s\', FALSE);", sql = "INSERT INTO permissions VALUES (?1, ?2, FALSE);";
table_name, pi.name, filename);
} else { } else {
return 1; // Invalid mode
}
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; return 1;
} }
if (ret < 0) { sqlite3_finalize(stmt);
// 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);
return 1;
}
return 0; return 0;
} }

View File

@ -14,36 +14,38 @@
#include "set_mode_t.h" #include "set_mode_t.h"
/** /**
* Initializes the permanent permissions table. * Initializes the permanent permissions database.
* Creates/opens the database file and sets up schema.
* *
* @param db_filename: The filename of the permissions sqlite3 database * @param db_filename Path to the SQLite database file
* @return: 0 on success, -1 on failure (e.g. ENOMEM) * @return 0 on success, -1 on failure
*/ */
int init_perm_permissions_table(const char *db_filename); int init_perm_permissions_table(const char *db_filename);
/** /**
* Destroys the permanent permissions table. * Closes the database connection and releases resources.
* Should be called when the module is shutting down.
*/ */
void destroy_perm_permissions_table(); void destroy_perm_permissions_table();
/** /**
* Checks if the process has a permanent access to the file. * Checks if a process or any of its ancestors have permanent access.
* Handles hierarchical permission inheritance.
* *
* @param filename: The file that the process is trying to access * @param filename Path to the file being accessed
* @pram pi: The process information * @param pi Process information structure
* @return: access status - ALLOW, DENY or NDEF in case if no information was * @return ALLOW/DENY/NDEF with NDEF meaning no explicit rule found
* found * @note May return false negatives if parent processes terminate during check
*/ */
access_t check_perm_access(const char *filename, struct process_info pi); access_t check_perm_access(const char *filename, struct process_info pi);
/** /**
* Gives permanent access to the process to the file. * Sets a permanent access rule for a process-file combination.
* *
* @param filename: The file that the process is trying to access * @param filename Path to the file needing access
* @param pi: The process information * @param pi Process information
* @param mode: Kind of access rule to be set - SET_DENY to deny access, and * @param mode SET_ALLOW (whitelist) or SET_DENY (blacklist)
* 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, int set_perm_access(const char *filename, struct process_info pi,
set_mode_t mode); set_mode_t mode);

View File

@ -1,39 +1,147 @@
/*
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 "proc_operations.h"
#include <linux/limits.h>
#include <stddef.h>
#include <stdio.h> #include <stdio.h>
#include <stdlib.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.
*
* In Linux, threads within the same process share the same thread group ID
* (TGID), which is equal to the PID of the main thread. This function retrieves
* the TGID by parsing `/proc/<tid>/status`, effectively returning the main
* thread's PID.
*
* @param tid The thread ID (TID) of any thread in the process.
* @return pid_t The process ID (main thread's PID), or 0 on error (invalid tid
* or file read failure).
*/
pid_t get_main_thread_pid(pid_t tid) {
// Validate input
if (tid <= 0) {
// Invalid TID: TIDs are always positive in Linux
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);
// Debugging check: If the provided tid is not the main thread's tid,
// this logs a message but does not affect the return value.
// This is useful for detecting cases where non-main threads are being
// inspected.
if (tgid != tid) {
fprintf(stderr,
"[ICFS] The tid and and pid wasn't equal. tid:%d, pid:%d.\n", tid,
tgid);
}
return tgid;
}
/**
* @brief Retrieves the full path of the executable for a given process ID.
*
* This function reads the `/proc/<pid>/exe` symbolic link, which points to the
* executable file of the process. The returned string is dynamically allocated
* and must be freed by the caller.
*
* @param pid The process ID to query.
* @return char* Dynamically allocated string containing the executable path, or
* NULL on failure.
*/
char *get_process_name_by_pid(const int pid) { char *get_process_name_by_pid(const int pid) {
char path[1024]; char path[1024];
sprintf(path, "/proc/%d/exe", pid); sprintf(path, "/proc/%d/exe", pid);
char *name = realpath(path, NULL); size_t size = 128;
char *name = malloc(size);
if (name == NULL) { 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(""); 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 the buffer was too small, double its size and try again
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 null-terminate, so we must do it manually
name[len] = '\0';
break;
}
}
return name; return name;
} }
/** /**
* Finds the parent process ID of a given process. * @brief Finds the parent process ID of a given process.
* *
* @param pid: The process ID of the process to find the parent of * This function parses the `/proc/<pid>/status` file to extract the `PPid`
* @return: The parent process ID, or 0 if the parent process ID could not be * field, which represents the parent process ID. This is useful for tracing
* found * process lineage.
*
* @param pid The process ID of the process to find the parent of.
* @return pid_t The parent process ID, or 0 if the parent could not be
* determined.
*/ */
pid_t get_parent_pid(pid_t pid) { pid_t get_parent_pid(pid_t pid) {
pid_t ppid = 0; pid_t ppid = 0;
char path[256]; char path[256];
snprintf(path, sizeof(path), "/proc/%u/status", pid); snprintf(path, sizeof(path), "/proc/%d/status",
pid); // Use %d for signed pid_t
FILE *file = fopen(path, "r"); FILE *file = fopen(path, "r");
if (file == NULL) { if (file == NULL) {
perror("Failed to open /proc/<pid>/status"); perror("[ICFS] Failed to open /proc/<pid>/status");
return 0; return 0;
} }
char line[256]; char line[256];
while (fgets(line, sizeof(line), file)) { while (fgets(line, sizeof(line), file)) {
// The "PPid:" field in `/proc/<pid>/status` is followed by a tab character
if (sscanf(line, "PPid:\t%d", &ppid) == 1) { if (sscanf(line, "PPid:\t%d", &ppid) == 1) {
fclose(file); fclose(file);
return ppid; return ppid;

View File

@ -1,17 +1,55 @@
/*
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 #ifndef PROC_OPERATIONS
#define PROC_OPERATIONS #define PROC_OPERATIONS
#include <time.h> #include <time.h>
/**
* @brief Retrieves the full path of the executable for a given process ID.
*
* This function reads the `/proc/<pid>/exe` symbolic link, which points to the
* executable file of the process. The returned string is dynamically allocated
* and must be freed by the caller.
*
* @param pid The process ID to query.
* @return char* Dynamically allocated string containing the executable path, or
* NULL on failure.
*/
char *get_process_name_by_pid(const int pid); char *get_process_name_by_pid(const int pid);
/** /**
* Finds the parent process ID of a given process. * @brief Finds the parent process ID of a given process.
* *
* @param pid: The process ID of the process to find the parent of * This function parses the `/proc/<pid>/status` file to extract the `PPid`
* @return: The parent process ID, or 0 if the parent process ID could not be * field, which represents the parent process ID. This is useful for tracing
* found * process lineage.
*
* @param pid The process ID of the process to find the parent of.
* @return pid_t The parent process ID, or 0 if the parent could not be
* determined.
*/ */
pid_t get_parent_pid(pid_t 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.
*
* In Linux, threads within the same process share the same thread group ID
* (TGID), which is equal to the PID of the main thread. This function retrieves
* the TGID by parsing `/proc/<tid>/status`, effectively returning the main
* thread's PID.
*
* @param tid The thread ID (TID) of any thread in the process.
* @return pid_t The process ID (main thread's PID), or 0 on error (invalid tid
* or file read failure).
*/
pid_t get_main_thread_pid(pid_t tid);
#endif // !PROC_OPERATIONS #endif // !PROC_OPERATIONS

View File

@ -9,10 +9,25 @@
#ifndef PROCESS_INFO_H #ifndef PROCESS_INFO_H
#define 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 <sys/types.h>
#include <unistd.h>
struct process_info { struct process_info {
pid_t PID; pid_t PID;
char *name; 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 #endif // PROCESS_INFO_H

View File

@ -1,7 +1,26 @@
/*
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 #ifndef REAL_FILENAME_H
#define REAL_FILENAME_H #define REAL_FILENAME_H
/**
* @brief Build a real path to the file.
*
* @param filename Relative path within the filesystem
* @return Newly allocated absolute path (caller must free)
*/
const char *real_filename(const char *filename); const char *real_filename(const char *filename);
/**
* @brief Get the current mount point path
* @return Absolute path to the filesystem root
*/
const char *get_mountpoint(void); const char *get_mountpoint(void);
#endif // !REAL_FILENAME_H #endif // !REAL_FILENAME_H

View File

@ -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 #ifndef SET_MODE_T_H
#define SET_MODE_T_H #define SET_MODE_T_H

View File

@ -16,108 +16,188 @@
#include <string.h> #include <string.h>
#include <unistd.h> #include <unistd.h>
/**
* @brief Global handle for the source filesystem implementation
*
* Stores the root directory information to enable relative path operations.
*/
static struct source_files_handle { static struct source_files_handle {
const char *mountpoint; char *mountpoint; // Absolute path to the mounted filesystem root
int root_fd; int root_fd; // File descriptor for the root directory (O_PATH)
} handle; } handle;
/**
* @brief Translate FUSE paths to real paths in the underlying filesystem
*
* FUSE passes paths starting with '/' (e.g., "/dir/file"), but we need to
* operate relative to our root_fd. This function converts:
* - "/" -> "." (current directory)
* - "/dir/file" -> "dir/file"
*
* @param filename Path from FUSE (always starts with '/')
* @return Relative path suitable for use with root_fd
*/
const char *source_filename_translate(const char *filename) { const char *source_filename_translate(const char *filename) {
if (strcmp("/", filename) == 0) { if (strcmp("/", filename) == 0) {
return "."; return ".";
} else {
return filename + 1;
} }
return filename + 1; // Skip leading slash
} }
/**
* @brief Initialize the source filesystem with a root directory
*
* Sets up the mount point and opens a protected file descriptor to the
* root directory for safe relative operations.
*
* @param root_path Absolute path to the physical root directory
* @return 0 on success, -1 on failure
*/
int source_init(const char *root_path) { int source_init(const char *root_path) {
// Allocate memory for mount point path
handle.mountpoint = malloc(strlen(root_path) + 1); handle.mountpoint = malloc(strlen(root_path) + 1);
if (handle.mountpoint == NULL) { if (handle.mountpoint == NULL) {
perror("Malloc failed"); perror("[ICFS] Malloc failed");
return -1; return -1;
} }
strcpy(handle.mountpoint, root_path); strcpy(handle.mountpoint, root_path);
// Open root directory with O_PATH to prevent accidental reads/writes
// while maintaining a valid descriptor for relative operations
int root_fd = open(root_path, O_PATH); int root_fd = open(root_path, O_PATH);
if (root_fd == -1) { 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(""); perror("");
return -1; return -1;
} }
handle.root_fd = root_fd; handle.root_fd = root_fd;
return 0; return 0;
} }
void source_destroy(void) { free(handle.mountpoint); } /**
* @brief Clean up resources used by the source filesystem
*/
void source_destroy(void) {
free(handle.mountpoint); // Free allocated mount point path
}
/**
* @brief Get the current mount point path
* @return Absolute path to the filesystem root
*/
const char *get_mountpoint(void) { return handle.mountpoint; } const char *get_mountpoint(void) { return handle.mountpoint; }
/**
* @brief Build a real path to the file.
*
* @param filename Relative path within the filesystem
* @return Newly allocated absolute path (caller must free)
*/
const char *real_filename(const char *filename) { const char *real_filename(const char *filename) {
const char *mountpoint = get_mountpoint(); const char *mountpoint = get_mountpoint();
// Calculate required length
size_t len1 = strlen(mountpoint); size_t len1 = strlen(mountpoint);
size_t len2 = strlen(filename); size_t len2 = strlen(filename);
size_t total_len = len1 + len2;
// Allocate memory (+1 for null terminator) // Allocate space for combined path + null terminator
char *result = malloc(total_len + 1); char *result = malloc(len1 + len2 + 1);
if (result == NULL) { if (result == NULL) {
fprintf(stderr, "Memory allocation failed"); fprintf(stderr, "[ICFS] Memory allocation failed");
perror(""); perror("");
return NULL; return NULL;
} }
// Copy strings
strcpy(result, mountpoint); strcpy(result, mountpoint);
strcat(result, filename); strcat(result, filename);
return result; return result;
} }
/**
* @brief Create a directory in the filesystem
*
* Uses mkdirat() to safely create directories relative to root_fd,
* preventing race conditions from concurrent path modifications.
*/
int source_mkdir(const char *filename, mode_t mode) { int source_mkdir(const char *filename, mode_t mode) {
const char *relative_filename = source_filename_translate(filename); const char *relative_filename = source_filename_translate(filename);
return mkdirat(handle.root_fd, relative_filename, mode); return mkdirat(handle.root_fd, relative_filename, mode);
} }
/**
* @brief Remove a file from the filesystem
*
* Uses unlinkat() to safely remove files relative to the root directory.
*/
int source_unlink(const char *filename) { int source_unlink(const char *filename) {
const char *relative_filename = source_filename_translate(filename); const char *relative_filename = source_filename_translate(filename);
return unlinkat(handle.root_fd, relative_filename, 0); return unlinkat(handle.root_fd, relative_filename, 0);
} }
/**
* @brief Get file status information
*
* Uses fstatat() to retrieve metadata relative to root_fd. Follows symlinks
* by default (flags=0).
*/
int source_stat(const char *restrict filename, struct stat *restrict statbuf) { int source_stat(const char *restrict filename, struct stat *restrict statbuf) {
const char *relative_filename = source_filename_translate(filename); const char *relative_filename = source_filename_translate(filename);
return fstatat(handle.root_fd, relative_filename, statbuf, 0); return fstatat(handle.root_fd, relative_filename, statbuf, 0);
} }
/**
* @brief Remove an empty directory
*
* Uses unlinkat() with AT_REMOVEDIR flag to safely remove directories.
*/
int source_rmdir(const char *filename) { int source_rmdir(const char *filename) {
const char *relative_filename = source_filename_translate(filename); const char *relative_filename = source_filename_translate(filename);
return unlinkat(handle.root_fd, relative_filename, AT_REMOVEDIR); return unlinkat(handle.root_fd, relative_filename, AT_REMOVEDIR);
} }
/**
* @brief Create a symbolic link
*
* Creates symlinks relative to the root_fd directory for safety.
*/
int source_symlink(const char *target, const char *linkpath) { int source_symlink(const char *target, const char *linkpath) {
const char *relative_linkpath = source_filename_translate(linkpath); const char *relative_linkpath = source_filename_translate(linkpath);
return symlinkat(target, handle.root_fd, relative_linkpath); return symlinkat(target, handle.root_fd, relative_linkpath);
} }
/**
* @brief Check file access permissions
*
* Uses faccessat() to check access rights relative to root_fd.
*/
int source_access(const char *filename, int mode) { int source_access(const char *filename, int mode) {
const char *relative_filename = source_filename_translate(filename); const char *relative_filename = source_filename_translate(filename);
return faccessat(handle.root_fd, relative_filename, mode, 0); return faccessat(handle.root_fd, relative_filename, mode, 0);
} }
/**
* @brief Open a directory for reading
*
* Combines openat() and fdopendir() to safely access directories relative
* to the root_fd.
*/
DIR *source_opendir(const char *filename) { DIR *source_opendir(const char *filename) {
const char *relative_filename = source_filename_translate(filename); const char *relative_filename = source_filename_translate(filename);
int fd = openat(handle.root_fd, relative_filename, 0); int fd = openat(handle.root_fd, relative_filename, 0);
if (fd < 0) { if (fd < 0) {
perror("Openat failed"); perror("[ICFS] Openat failed");
return NULL; return NULL;
} }
DIR *dir_pointer = fdopendir(fd); DIR *dir_pointer = fdopendir(fd);
return dir_pointer; return dir_pointer;
} }
/**
* @brief Rename a file or directory
*
* Uses renameat() to safely rename within the same root_fd namespace.
*/
int source_rename(const char *oldpath, const char *newpath) { int source_rename(const char *oldpath, const char *newpath) {
const char *relative_oldpath = source_filename_translate(oldpath); const char *relative_oldpath = source_filename_translate(oldpath);
const char *relative_newpath = source_filename_translate(newpath); const char *relative_newpath = source_filename_translate(newpath);
@ -125,41 +205,80 @@ int source_rename(const char *oldpath, const char *newpath) {
relative_newpath); relative_newpath);
} }
/**
* @brief Create a hard link
*
* Uses linkat() with flags=0 (default behavior). May need AT_SYMLINK_NOFOLLOW
* if symlink handling should be modified.
*/
int source_link(const char *oldpath, const char *newpath) { int source_link(const char *oldpath, const char *newpath) {
const char *relative_oldpath = source_filename_translate(oldpath); const char *relative_oldpath = source_filename_translate(oldpath);
const char *relative_newpath = source_filename_translate(newpath); const char *relative_newpath = source_filename_translate(newpath);
return linkat(handle.root_fd, relative_oldpath, handle.root_fd, return linkat(handle.root_fd, relative_oldpath, handle.root_fd,
relative_newpath, 0); relative_newpath, 0);
// NOTE: perhaps the flags here need to be reevaluated.
} }
/**
* @brief Change file access mode
*
* Uses fchmodat() with flags=0 (follow symlinks). Consider using
* AT_SYMLINK_NOFOLLOW if symlink metadata should be modified directly.
*/
int source_chmod(const char *filename, mode_t mode) { int source_chmod(const char *filename, mode_t mode) {
const char *relative_filename = source_filename_translate(filename); const char *relative_filename = source_filename_translate(filename);
return fchmodat(handle.root_fd, relative_filename, mode, 0); return fchmodat(handle.root_fd, relative_filename, mode, 0);
// NOTE: perhaps the flags here need to be reevaluated.
} }
/**
* @brief Change file owner and group
*
* Uses fchownat() with AT_SYMLINK_NOFOLLOW to modify symlink metadata
* rather than its target.
*/
int source_chown(const char *filename, uid_t owner, gid_t group) { int source_chown(const char *filename, uid_t owner, gid_t group) {
const char *relative_filename = source_filename_translate(filename); const char *relative_filename = source_filename_translate(filename);
return fchownat(handle.root_fd, filename, owner, group, AT_SYMLINK_NOFOLLOW); return fchownat(handle.root_fd, filename, owner, group, AT_SYMLINK_NOFOLLOW);
} }
/**
* @brief Truncate a file to a specified length
*
* Opens the file with read-only access then truncates it. This may fail
* if the file wasn't opened with write permissions. Consider changing
* openat() flags to O_WRONLY for reliability.
*/
int source_truncate(const char *filename, off_t length) { int source_truncate(const char *filename, off_t length) {
const char *relative_filename = source_filename_translate(filename); const char *relative_filename = source_filename_translate(filename);
int fd = openat(handle.root_fd, relative_filename, 0); int fd = openat(handle.root_fd, relative_filename, 0);
if (fd < 0) { if (fd < 0) {
perror("Openat failed"); perror("[ICFS] Openat failed");
return -1; return -1;
} }
return ftruncate(fd, length); return ftruncate(fd, length);
} }
/**
* @brief Open a file with specified flags
*
* Uses openat() to safely access files relative to root_fd.
*/
int source_open(const char *filename, int flags) { int source_open(const char *filename, int flags) {
const char *relative_filename = source_filename_translate(filename); const char *relative_filename = source_filename_translate(filename);
return openat(handle.root_fd, relative_filename, flags); return openat(handle.root_fd, relative_filename, flags);
} }
/**
* @brief Create and open a new file
*
* Uses openat() with O_CREAT to create files relative to root_fd.
*/
int source_create(const char *filename, int flags, mode_t mode) { int source_create(const char *filename, int flags, mode_t mode) {
const char *relative_filename = source_filename_translate(filename); const char *relative_filename = source_filename_translate(filename);
return openat(handle.root_fd, relative_filename, flags, mode); return openat(handle.root_fd, relative_filename, flags | O_CREAT, mode);
}
int source_utimens(const char *filename, const struct timespec ts[2],
int flags) {
const char *relative_filename = source_filename_translate(filename);
return utimensat(handle.root_fd, relative_filename, ts, AT_SYMLINK_NOFOLLOW);
} }

View File

@ -13,48 +13,132 @@
#include <sys/stat.h> #include <sys/stat.h>
/** /**
* Initializes the source file handling. * @brief Initialize the source filesystem with a root directory
* *
* @param root_path The root of the source files folder. * Sets up the mount point and opens a protected file descriptor to the
* @return 0 on success, -1 on failure. * root directory for safe relative operations.
*
* @param root_path Absolute path to the physical root directory
* @return 0 on success, -1 on failure
*/ */
int source_init(const char *root_path); int source_init(const char *root_path);
/**
* @brief Clean up resources used by the source filesystem
*/
void source_destroy(void); void source_destroy(void);
/* All of the functions below are designed to behave exactly as their non-source /**
* counterparts. */ * @brief Get file status information
*
* Uses fstatat() to retrieve metadata relative to root_fd. Follows symlinks
* by default (flags=0).
*/
int source_stat(const char *restrict filename, struct stat *restrict statbuf); int source_stat(const char *restrict filename, struct stat *restrict statbuf);
struct dirent *source_readdir(DIR *dirp); /**
* @brief Open a directory for reading
*
* Combines openat() and fdopendir() to safely access directories relative
* to the root_fd.
*/
DIR *source_opendir(const char *filename); DIR *source_opendir(const char *filename);
/**
* @brief Remove a file from the filesystem
*
* Uses unlinkat() with AT_REMOVEDIR flag to safely remove files relative
* to the root directory.
*/
int source_unlink(const char *filename); int source_unlink(const char *filename);
/**
* @brief Create a directory in the filesystem
*
* Uses mkdirat() to safely create directories relative to root_fd,
* preventing race conditions from concurrent path modifications.
*/
int source_mkdir(const char *filename, mode_t mode); int source_mkdir(const char *filename, mode_t mode);
/**
* @brief Remove an empty directory
*
* Uses unlinkat() with AT_REMOVEDIR flag to safely remove directories.
*/
int source_rmdir(const char *filename); int source_rmdir(const char *filename);
/**
* @brief Create a symbolic link
*
* Creates symlinks relative to the root_fd directory for safety.
*/
int source_symlink(const char *target, const char *linkpath); int source_symlink(const char *target, const char *linkpath);
/**
* @brief Rename a file or directory
*
* Uses renameat() to safely rename within the same root_fd namespace.
*/
int source_rename(const char *oldpath, const char *newpath); int source_rename(const char *oldpath, const char *newpath);
/**
* @brief Create a hard link
*
* Uses linkat() with flags=0 (default behavior). May need AT_SYMLINK_NOFOLLOW
* if symlink handling should be modified.
*/
int source_link(const char *oldpath, const char *newpath); int source_link(const char *oldpath, const char *newpath);
/**
* @brief Change file access mode
*
* Uses fchmodat() with flags=0 (follow symlinks). Consider using
* AT_SYMLINK_NOFOLLOW if symlink metadata should be modified directly.
*/
int source_chmod(const char *filename, mode_t mode); int source_chmod(const char *filename, mode_t mode);
/**
* @brief Change file owner and group
*
* Uses fchownat() with AT_SYMLINK_NOFOLLOW to modify symlink metadata
* rather than its target.
*/
int source_chown(const char *filename, uid_t owner, gid_t group); int source_chown(const char *filename, uid_t owner, gid_t group);
/**
* @brief Truncate a file to a specified length
*
* Opens the file with read-only access then truncates it. This may fail
* if the file wasn't opened with write permissions. Consider changing
* openat() flags to O_WRONLY for reliability.
*/
int source_truncate(const char *filename, off_t length); int source_truncate(const char *filename, off_t length);
/**
* @brief Check file access permissions
*
* Uses faccessat() to check access rights relative to root_fd.
*/
int source_access(const char *filename, int mode); int source_access(const char *filename, int mode);
/* `open` and `create` are designed to correspond to fuse operations, not the /* `open` and `create` are designed to correspond to fuse operations, not the
* libc's `open(2)`. Both of them actually call `openat`. */ * libc's `open(2)`. Both of them actually call `openat`. */
/**
* @brief Open a file with specified flags
*
* Uses openat() to safely access files relative to root_fd.
*/
int source_open(const char *filename, int flags); int source_open(const char *filename, int flags);
/**
* @brief Create and open a new file
*
* Uses openat() with O_CREAT to create files relative to root_fd.
*/
int source_create(const char *filename, int flags, mode_t mode); int source_create(const char *filename, int flags, mode_t mode);
int source_utimens(const char *filename, const struct timespec ts[2],
int flags);
#endif // !SOURCEFS_H #endif // !SOURCEFS_H

View File

@ -16,25 +16,64 @@
#include <stdio.h> #include <stdio.h>
#include <string.h> #include <string.h>
#include <sys/types.h> #include <sys/types.h>
#include <time.h>
#include <unistd.h>
struct temp_process_permissions { #define GC_INTERVAL 1 // Garbage collection time interval.
// yes, this is a correct type for start time in jiffies (see
// proc_pid_stat(5))
unsigned long long creation_time;
vec(char *) allowed_files;
vec(char *) denied_files;
};
map(pid_t, struct temp_process_permissions) temp_permissions_table;
pthread_mutex_t temp_permissions_table_lock;
/** /**
* Function to get the process creation time (in jiffies) from the proc * @struct temp_process_permissions
* @brief Stores temporary file access permissions for a process
*
* This structure tracks temporary file access permissions for a specific
* process. The permissions are tied to the process's lifetime using its
* creation time.
*/
struct temp_process_permissions {
unsigned long long creation_time; /**< Process creation time */
vec(char *) allowed_files; /**< List of allowed file paths (prefixes) */
vec(char *) denied_files; /**< List of denied file paths (prefixes) */
};
/**
* @brief Global table mapping PIDs to temporary permissions
*
* This map stores the temporary file access permissions for processes.
* Entries are keyed by process ID (pid_t) and contain temp_process_permissions
* structures with the access rules.
*/
map(pid_t, struct temp_process_permissions) temp_permissions_table;
/**
* @brief Read-write lock for thread-safe access to temp_permissions_table
*
* A read-write lock to ensure thread-safe operations on the
* temp_permissions_table. Allows concurrent reads but exclusive writes.
*/
pthread_rwlock_t temp_permissions_table_lock = PTHREAD_RWLOCK_INITIALIZER;
/**
* @brief Thread handle for the garbage collector
*
* This thread handles cleanup of stale entries in the temp_permissions_table.
*/
pthread_t gc_thread;
/**
* @brief Flag indicating whether garbage collector is active
*
* When non-zero, indicates that the garbage collector thread should continue
* running.
*/
int is_gc_active = 0;
/**
* Function to get the process creation time from the proc
* filesystem * filesystem
* *
* @param pid: The process ID of the process to get the creation time of * @param pid The process ID of the process to get the creation time of
* @return: The process creation time in jiffies, or 0 on error * @return The process creation time, or 0 on error
* @note: although nothing in the documentation says that the creation time is * @note although nothing in the documentation says that the creation time is
* never really equal to 0, it exceptionally unlikely. * never really equal to 0, it exceptionally unlikely.
*/ */
unsigned long long get_process_creation_time(pid_t pid) { unsigned long long get_process_creation_time(pid_t pid) {
@ -48,20 +87,21 @@ unsigned long long get_process_creation_time(pid_t pid) {
// Open the status file // Open the status file
fp = fopen(path, "r"); fp = fopen(path, "r");
if (fp == NULL) { if (fp == NULL) {
perror("fopen"); perror("[ICFS] fopen");
return 0; return 0;
} }
// Read the creation time (the 22nd field in the stat file) // Read the creation time (the 22nd field in the stat file)
for (int i = 1; i < 22; i++) { for (int i = 1; i < 22; i++) {
if (fscanf(fp, "%*s") == EOF) { 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); fclose(fp);
return 0; return 0;
} }
} }
if (fscanf(fp, "%llu", &creation_time) != 1) { if (fscanf(fp, "%llu", &creation_time) != 1) {
fprintf(stderr, "Error reading creation time\n"); fprintf(stderr, "[ICFS] Error reading creation time\n");
fclose(fp); fclose(fp);
return 0; return 0;
} }
@ -72,26 +112,108 @@ unsigned long long get_process_creation_time(pid_t pid) {
return creation_time; return creation_time;
} }
/**
* @brief Validates if a process entry is still valid
*
* Checks if the given process entry matches the current process state
* by comparing creation times.
*
* @param pid Process ID to validate
* @param entry Pointer to the permission entry to validate
* @return 1 if valid, 0 if invalid or error
*/
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 the creation time doesn't match, this is a different process instance
if (creation_time != entry->creation_time) {
return 0;
}
return 1;
}
/**
* @brief Garbage collector thread for cleaning up stale entries
*
* Periodically scans the permissions table and removes entries for processes
* that no longer exist. Runs every second while is_gc_active is true.
*
* @param arg Unused thread argument parameter
* @return Always NULL
*/
void *garbage_collector(void *arg) {
(void)arg;
while (is_gc_active) {
sleep(GC_INTERVAL); // Check once per second for stale entries
pthread_rwlock_wrlock(&temp_permissions_table_lock);
vec(pid_t) blacklist;
init(&blacklist);
// Identify stale entries
for_each(&temp_permissions_table, pid, entry) {
if (!is_valid(*pid, entry)) {
push(&blacklist, *pid);
// Free memory for this entry's file lists
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);
}
}
// Remove all stale entries from the table
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. * Initializes the temporary permissions table.
* *
* @return: 0 on success, -1 on failure (e.g. ENOMEM) * @return 0 on success, -1 on failure
*/ */
int init_temp_permissions_table(void) { int init_temp_permissions_table(void) {
pthread_mutex_init(&temp_permissions_table_lock, PTHREAD_MUTEX_DEFAULT);
init(&temp_permissions_table); init(&temp_permissions_table);
return 0; return 0;
} }
/**
* Starts the temporary permissions table garbage_collector.
*
* @return 0 on success, -1 on failure
*/
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. * Destroys the temporary permissions table.
* *
* @note: the table is guranteed to be destroyed if it is already initialized. * @note the table is guranteed to be destroyed if it is already initialized.
* It does not indicate any errors whatsoever. If something goes wrong - you are * It does not indicate any errors whatsoever. If something goes wrong - you are
* screwed. * screwed.
*/ */
void destroy_temp_permissions_table(void) { void destroy_temp_permissions_table(void) {
// free the memory allocated for the table 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(&temp_permissions_table, entry) {
for_each(&entry->allowed_files, allowed_file) { free(*allowed_file); } for_each(&entry->allowed_files, allowed_file) { free(*allowed_file); }
cleanup(&entry->allowed_files); cleanup(&entry->allowed_files);
@ -102,57 +224,70 @@ void destroy_temp_permissions_table(void) {
} }
cleanup(&temp_permissions_table); cleanup(&temp_permissions_table);
pthread_mutex_destroy(&temp_permissions_table_lock);
} }
/** /**
* Checks if the process has a temporary access to the file. * @brief Checks if a specific process has temporary access to a file
* *
* @param filename: The file that the process is trying to access * Checks only the specified process (not its parents) for temporary access
* @pram pid: PID of the process * permissions to the given file. Uses a longest-match algorithm for path
* @return: access status - ALLOW, DENY or NDEF in case if no information was * prefixes.
* found is avaliable *
* @param filename Path to the file being accessed
* @param pid Process ID of the process to check
* @return Access status ALLOW, DENY, or NDEF (no information)
*/ */
access_t check_temp_access_noparent(const char *filename, pid_t pid) { access_t check_temp_access_noparent(const char *filename, pid_t pid) {
// TODO: more efficient locking pthread_rwlock_rdlock(&temp_permissions_table_lock);
pthread_mutex_lock(&temp_permissions_table_lock);
struct temp_process_permissions *permission_entry = struct temp_process_permissions *permission_entry =
get(&temp_permissions_table, pid); get(&temp_permissions_table, pid);
if (permission_entry != NULL) { if (permission_entry != NULL) {
unsigned long long process_creation_time = get_process_creation_time(pid); unsigned long long process_creation_time = get_process_creation_time(pid);
if (process_creation_time == 0) { if (process_creation_time == 0) {
perror("Could not retrieve process creation time"); perror("[ICFS] Could not retrieve process creation time");
pthread_mutex_unlock(&temp_permissions_table_lock); pthread_rwlock_unlock(&temp_permissions_table_lock);
return NDEF; return NDEF;
} }
if (process_creation_time == permission_entry->creation_time) { if (process_creation_time == permission_entry->creation_time) {
// the process is the same as the one that was granted temporary access // The process is the same as the one that was granted temporary access
// to the file
size_t filename_len = strlen(filename); size_t filename_len = strlen(filename);
access_t ret = NDEF;
size_t maxlen = 0;
// Check denied files first (deny takes precedence over allow)
for_each(&permission_entry->denied_files, denied_file) { for_each(&permission_entry->denied_files, denied_file) {
size_t denied_file_len = strlen(*denied_file); size_t denied_file_len = strlen(*denied_file);
if (strncmp(*denied_file, filename, denied_file_len) == 0 && // Check if this denied path prefix matches the requested file
((denied_file_len < filename_len && if ((strncmp(*denied_file, filename, denied_file_len) == 0 &&
(*denied_file)[denied_file_len - 1] == '/') || ((denied_file_len < filename_len &&
(denied_file_len == filename_len))) { (*denied_file)[denied_file_len - 1] == '/') ||
pthread_mutex_unlock(&temp_permissions_table_lock); (denied_file_len == filename_len))) &&
return DENY; denied_file_len > maxlen) {
maxlen = denied_file_len;
ret = DENY;
} }
} }
// Check allowed files
for_each(&permission_entry->allowed_files, allowed_file) { for_each(&permission_entry->allowed_files, allowed_file) {
size_t allowed_file_len = strlen(*allowed_file); size_t allowed_file_len = strlen(*allowed_file);
if (strncmp(*allowed_file, filename, allowed_file_len) == 0 && // Check if this allowed path prefix matches the requested file
((allowed_file_len < filename_len && if ((strncmp(*allowed_file, filename, allowed_file_len) == 0 &&
(*allowed_file)[allowed_file_len - 1] == '/') || ((allowed_file_len < filename_len &&
(allowed_file_len == filename_len))) { (*allowed_file)[allowed_file_len - 1] == '/') ||
pthread_mutex_unlock(&temp_permissions_table_lock); (allowed_file_len == filename_len))) &&
return ALLOW; allowed_file_len > 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; return NDEF;
} }
@ -160,12 +295,12 @@ access_t check_temp_access_noparent(const char *filename, pid_t pid) {
* Checks if the process or any of it's parents have temporary access to the * Checks if the process or any of it's parents have temporary access to the
* file. * file.
* *
* @param filename: The file that the process is trying to access * @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 * @return access status - ALLOW, DENY or NDEF in case if no information was
* found. Does not return ALLOW_TEMP. * found. Does not return ALLOW_TEMP.
* @note: In case one of the parent processes is killed while this function * @note In case one of the parent processes is killed while this function
* execution the result is not guranteed to be correct. It should only lead to * execution the result is not guranteed to be correct. It should only
* false negatives, though. * false negatives, though.
*/ */
access_t check_temp_access(const char *filename, struct process_info pi) { access_t check_temp_access(const char *filename, struct process_info pi) {
@ -175,7 +310,7 @@ access_t check_temp_access(const char *filename, struct process_info pi) {
if (access != NDEF) { if (access != NDEF) {
return access; return access;
} }
current_pid = get_parent_pid(current_pid); current_pid = get_main_thread_pid(get_parent_pid(current_pid));
} }
return NDEF; return NDEF;
@ -184,15 +319,17 @@ access_t check_temp_access(const char *filename, struct process_info pi) {
/** /**
* Sets temporary access mode of the process to the file. * Sets temporary access mode of the process to the file.
* *
* @param filename: The file that the process is trying to access * @param filename The file that the process is trying to access
* @param pi: The process information * @param pi The process information
* @param mode: Kind of access rule to be set - SET_DENY to deny access, and * @param mode Kind of access rule to be set - SET_DENY to deny access, and
* SET_ALLOW to allow access. * SET_ALLOW to allow access.
* @return: 0 on success, -1 on failure. * @return 0 on success, -1 on failure.
*/ */
int set_temp_access(const char *filename, struct process_info pi, int set_temp_access(const char *filename, struct process_info pi,
set_mode_t mode) { 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 = struct temp_process_permissions *permission_entry =
get(&temp_permissions_table, pi.PID); get(&temp_permissions_table, pi.PID);
@ -201,14 +338,13 @@ int set_temp_access(const char *filename, struct process_info pi,
unsigned long long process_creation_time = unsigned long long process_creation_time =
get_process_creation_time(pi.PID); get_process_creation_time(pi.PID);
if (process_creation_time == 0) { if (process_creation_time == 0) {
perror("Could not retrieve process creation time"); perror("[ICFS] Could not retrieve process creation time");
pthread_mutex_unlock(&temp_permissions_table_lock); pthread_rwlock_unlock(&temp_permissions_table_lock);
return -1; return -1;
} }
if (process_creation_time == permission_entry->creation_time) { if (process_creation_time == permission_entry->creation_time) {
// the process is the same as the one that was granted temporary access // The process is the same as the one that was granted temporary access
// to the file
if (mode == SET_ALLOW) { if (mode == SET_ALLOW) {
push(&permission_entry->allowed_files, strdup(filename)); push(&permission_entry->allowed_files, strdup(filename));
} }
@ -216,22 +352,22 @@ int set_temp_access(const char *filename, struct process_info pi,
push(&permission_entry->denied_files, strdup(filename)); push(&permission_entry->denied_files, strdup(filename));
} }
pthread_mutex_unlock(&temp_permissions_table_lock); pthread_rwlock_unlock(&temp_permissions_table_lock);
return 0; return 0;
} }
// we have an entry for the process, but the process is different // We have an entry for the process, but the process is different
// delete the entry and create a new one // Delete the entry and create a new one
erase(&temp_permissions_table, pi.PID); erase(&temp_permissions_table, pi.PID);
permission_entry = NULL; permission_entry = NULL;
} }
// no entry is present // No entry is present - construct a new one
// construct the entry
struct temp_process_permissions new_permission_entry; struct temp_process_permissions new_permission_entry;
new_permission_entry.creation_time = get_process_creation_time(pi.PID); new_permission_entry.creation_time = get_process_creation_time(pi.PID);
init(&new_permission_entry.allowed_files); init(&new_permission_entry.allowed_files);
init(&new_permission_entry.denied_files); init(&new_permission_entry.denied_files);
if (mode == SET_ALLOW) { if (mode == SET_ALLOW) {
push(&new_permission_entry.allowed_files, strdup(filename)); push(&new_permission_entry.allowed_files, strdup(filename));
} }
@ -241,6 +377,6 @@ int set_temp_access(const char *filename, struct process_info pi,
insert(&temp_permissions_table, pi.PID, new_permission_entry); 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; return 0;
} }

View File

@ -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 #ifndef TEMP_PERMISSIONS_TABLE_H
#define TEMP_PERMISSIONS_TABLE_H #define TEMP_PERMISSIONS_TABLE_H
@ -9,14 +16,21 @@
/** /**
* Initializes the temporary permissions table. * Initializes the temporary permissions table.
* *
* @return: 0 on success, -1 on failure (e.g. ENOMEM) * @return: 0 on success, -1 on failure
*/ */
int init_temp_permissions_table(void); int init_temp_permissions_table(void);
/**
* Starts the temporary permissions table garbage_collector.
*
* @return 0 on success, -1 on failure
*/
int init_garbage_collector(void);
/** /**
* Destroys the temporary permissions table. * Destroys the temporary permissions table.
* *
* @note: the table is guranteed to be destroyed if it is already initialized. * @note the table is guranteed to be destroyed if it is already initialized.
* It does not indicate any errors whatsoever. If something goes wrong - you are * It does not indicate any errors whatsoever. If something goes wrong - you are
* screwed. * screwed.
*/ */
@ -26,12 +40,12 @@ void destroy_temp_permissions_table(void);
* Checks if the process or any of it's parents have temporary access to the * Checks if the process or any of it's parents have temporary access to the
* file. * file.
* *
* @param filename: The file that the process is trying to access * @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 * @return access status - ALLOW, DENY or NDEF in case if no information was
* found. Does not return ALLOW_TEMP. * found. Does not return ALLOW_TEMP.
* @note: In case one of the parent processes is killed while this function * @note In case one of the parent processes is killed while this function
* execution the result is not guranteed to be correct. It should only lead to * execution the result is not guranteed to be correct. It should only
* false negatives, though. * false negatives, though.
*/ */
access_t check_temp_access(const char *filename, struct process_info pi); access_t check_temp_access(const char *filename, struct process_info pi);
@ -39,11 +53,11 @@ access_t check_temp_access(const char *filename, struct process_info pi);
/** /**
* Sets temporary access mode of the process to the file. * Sets temporary access mode of the process to the file.
* *
* @param filename: The file that the process is trying to access * @param filename The file that the process is trying to access
* @param pi: The process information * @param pi The process information
* @param mode: Kind of access rule to be set - SET_DENY to deny access, and * @param mode Kind of access rule to be set - SET_DENY to deny access, and
* SET_ALLOW to allow access. * SET_ALLOW to allow access.
* @return: 0 on success, -1 on failure. * @return 0 on success, -1 on failure.
*/ */
int set_temp_access(const char *filename, struct process_info pi, int set_temp_access(const char *filename, struct process_info pi,
set_mode_t mode); set_mode_t mode);

View File

@ -7,10 +7,11 @@
*/ */
#include "access_t.h" #include "access_t.h"
#include <signal.h>
#include <stddef.h> #include <stddef.h>
#include <sys/types.h> #include <sys/types.h>
#include <time.h> #include <time.h>
#define _GNU_SOURCE #define _GNU_SOURCE // Required for certain POSIX extensions
#include "cc.h" #include "cc.h"
#include "perm_permissions_table.h" #include "perm_permissions_table.h"
#include "real_filename.h" #include "real_filename.h"
@ -25,33 +26,50 @@
#include <sys/socket.h> #include <sys/socket.h>
#include <sys/un.h> #include <sys/un.h>
#include <unistd.h> #include <unistd.h>
#include <wait.h>
#define DIALOGUE_YES 0 // Exit status codes for icfs_dialogue process interaction
#define DIALOGUE_NO 1 #define DIALOGUE_YES 1
#define DIALOGUE_NO 0
#define DIALOGUE_PERM 2 #define DIALOGUE_PERM 2
#define DIALOGUE_TEMP 0 // Bitmask position, not value
// Mutex to protect concurrent access to permission tables
pthread_mutex_t access_check_mutex = PTHREAD_MUTEX_INITIALIZER;
// Structure to hold user permission decision response
struct dialogue_response { struct dialogue_response {
access_t decision; access_t decision;
char *filename; char *filename;
}; };
/**
* Initialize UI socket and required permission tables
*
* @param perm_permissions_db_filename Path to persistent permissions DB
* @return 0 on success, 1 on failure
*/
int init_ui_socket(const char *perm_permissions_db_filename) { int init_ui_socket(const char *perm_permissions_db_filename) {
FILE *fp = NULL; FILE *fp = NULL;
// Initialize in-memory temporary permissions table
if (init_temp_permissions_table()) { 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; return 1;
} }
// Initialize permanent permissions database
if (init_perm_permissions_table(perm_permissions_db_filename)) { 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; return 1;
} }
// Test if dialogue is installed (get version) // Verify dialogue utility is available
fp = popen("icfs_dialogue --version", "r"); fp = popen("icfs_dialogue --version", "r");
if (fp == NULL) { if (fp == NULL) {
perror("Pipe returned an error"); perror("[ICFS] Pipe returned an error");
return 1; return 1;
} }
@ -59,52 +77,85 @@ int init_ui_socket(const char *perm_permissions_db_filename) {
return 0; return 0;
} }
/**
* Clean up UI socket resources
*/
void destroy_ui_socket(void) { void destroy_ui_socket(void) {
destroy_temp_permissions_table(); destroy_temp_permissions_table();
destroy_perm_permissions_table(); destroy_perm_permissions_table();
} }
/** /**
* Asks the user if the process should be allowed to access the file using the * Query user for file access permission through GUI dialogue
* GUI
* *
* @param filename: The file that the process is trying to access * Constructs and executes the icfs_dialogue command to get user consent.
* @param pi: The process information * Handles memory allocation errors gracefully and parses the response.
* @return: access status - ALLOW, DENY or ALLOW_TEMP *
* allowed for the runtime of the process * @param filename File being accessed
* @param proc_info Process requesting access
* @return Struct containing access decision and resolved filename
*/ */
struct dialogue_response ask_access(const char *filename, struct dialogue_response ask_access(const char *filename,
struct process_info proc_info) { struct process_info proc_info) {
FILE *fp = NULL; FILE *fp = NULL;
char *command = NULL;
int ret = asprintf(&command, "icfs_dialogue \"%d\" \"%s\" \"%s\" \"%s\"",
proc_info.PID, proc_info.name, get_mountpoint(), filename);
struct dialogue_response response; struct dialogue_response response;
response.decision = DENY; response.decision = DENY;
response.filename = NULL; response.filename = NULL;
if (ret < 0) { // instead of popeen --------------
// If asprintf fails, the contents of command are undefined (see man
// asprintf). That does not explicitly rule out that command will be a valid char pid_str[sizeof(pid_t) *
// pointer. But the risk of freeing a non-allocated pointer is too much to 8]; // amount of bits should be enough for a decimal
// justify preparing for this. snprintf(pid_str, sizeof(pid_str), "%d", proc_info.PID);
fprintf(stderr, "Could not create query on rule insertion");
perror(""); int pipefd[2];
response.decision = DENY; if (pipe(pipefd) == -1) {
perror("[ICFS] pipe returned a error");
response.filename = malloc(2); response.filename = malloc(2);
response.filename[0] = '/'; response.filename[0] = '/';
response.filename[1] = 0; response.filename[1] = 0;
return response; return response;
} }
// dialogue Question Message Popup pid_t pid = fork();
fp = popen(command, "r"); if (pid == -1) {
free(command); perror("[ICFS] fork returned a error");
response.filename = malloc(2);
response.filename[0] = '/';
response.filename[1] = 0;
return response;
}
if (pid == 0) {
// Child process
close(pipefd[0]); // Close read end
dup2(pipefd[1], STDOUT_FILENO); // Redirect stdout
close(pipefd[1]); // Close original write end
// Prepare command and arguments
char *args[] = {"icfs_dialogue", // Command name (looked up in PATH)
pid_str,
(char *)proc_info.name,
(char *)get_mountpoint(),
(char *)filename,
NULL};
// Execute the command using execvp (uses PATH)
execvp("icfs_dialogue", args);
// If execvp fails
perror("execvp failed");
exit(EXIT_FAILURE);
}
// instead of popen ---------------
close(pipefd[1]); // Close write end
fp = fdopen(pipefd[0], "r");
if (fp == NULL) { if (fp == NULL) {
perror("Pipe returned a error"); perror("[ICFS] fdopen returned a error");
response.decision = DENY;
response.filename = malloc(2); response.filename = malloc(2);
response.filename[0] = '/'; response.filename[0] = '/';
response.filename[1] = 0; response.filename[1] = 0;
@ -114,33 +165,58 @@ struct dialogue_response ask_access(const char *filename,
str(char) dialogue_output; str(char) dialogue_output;
init(&dialogue_output); init(&dialogue_output);
char line[1024]; // Buffer to read individual lines char line[1024];
// Read the command output line by line // Read entire command output
while (fgets(line, sizeof(line), fp)) { while (fgets(line, sizeof(line), fp)) {
push_fmt(&dialogue_output, line); if (push_fmt(&dialogue_output, line) == NULL) {
cleanup(&dialogue_output);
perror("[ICFS] not enough memory for dialogue output.");
// kill the dialogue if it's still there
kill(pid, SIGQUIT);
fclose(fp);
response.filename = malloc(2);
response.filename[0] = '/';
response.filename[1] = 0;
return response;
}
} }
int dialogue_exit_code = WEXITSTATUS(pclose(fp)); fclose(fp);
fprintf(stderr, "dialogue wrote out %s\n", first(&dialogue_output));
fprintf(stderr, "dialogue returned %d\n", dialogue_exit_code);
// Wait for the child to finish
int status;
if (waitpid(pid, &status, 0) == -1) {
cleanup(&dialogue_output);
perror("[ICFS] waitpid error");
// kill the dialogue if it is still there
kill(pid, SIGQUIT);
response.filename = malloc(2);
response.filename[0] = '/';
response.filename[1] = 0;
return response;
}
int dialogue_exit_code = WEXITSTATUS(status);
fprintf(stderr, "[ICFS] dialogue wrote out %s\n", first(&dialogue_output));
fprintf(stderr, "[ICFS] dialogue returned %d\n", dialogue_exit_code);
// Handle empty output case
if (size(&dialogue_output) == 0) { if (size(&dialogue_output) == 0) {
perror("[ICFS] empty dialogue output.");
push(&dialogue_output, '/'); push(&dialogue_output, '/');
} }
assert(strlen(first(&dialogue_output)) == size(&dialogue_output)); // Allocate and copy final filename
response.filename = malloc(size(&dialogue_output) + 1); response.filename = malloc(size(&dialogue_output) + 1);
strcpy(response.filename, first(&dialogue_output)); strcpy(response.filename, first(&dialogue_output));
// response.filename[size(&dialogue_output)] = 0;
// assert(0 == strcmp(response.filename, first(&dialogue_output)));
cleanup(&dialogue_output); cleanup(&dialogue_output);
// Parse exit code combination
if (dialogue_exit_code == (DIALOGUE_YES | DIALOGUE_PERM)) { if (dialogue_exit_code == (DIALOGUE_YES | DIALOGUE_PERM)) {
response.decision = ALLOW; response.decision = ALLOW;
} else if (dialogue_exit_code == DIALOGUE_YES) { } else if (dialogue_exit_code == DIALOGUE_YES | DIALOGUE_TEMP) {
response.decision = ALLOW_TEMP; response.decision = ALLOW_TEMP;
} else if (dialogue_exit_code == (DIALOGUE_NO | DIALOGUE_PERM)) { } else if (dialogue_exit_code == (DIALOGUE_NO | DIALOGUE_PERM)) {
response.decision = DENY; response.decision = DENY;
@ -152,129 +228,128 @@ struct dialogue_response ask_access(const char *filename,
} }
/** /**
* Check access according to: * Determine file access based on permission tables and user input
* 1. temp permission table
* 2. permanent permission table
* 3. user descision
* *
* @param filename: The file that the process is trying to access * Checks permissions in order:
* @pram pi: The process information * 1. Temporary permission table
* @param opts: options (GRANT_TEMP, GRANT_PERM) * 2. Permanent permission table
* @return: 0 if access is denied, 1 if access is allowed * 3. User decision via GUI
*
* @param filename File being accessed
* @param pi Process information
* @param opts Flags to force permission (GRANT_TEMP/GRANT_PERM)
* @return 1 if access allowed, 0 if denied
*/ */
int interactive_access(const char *filename, struct process_info proc_info, int interactive_access(const char *filename, struct process_info proc_info,
int opts) { int opts) {
char *real_path = real_filename(filename); char *real_path = real_filename(filename);
pthread_mutex_lock(&access_check_mutex);
// First check temporary permissions
access_t access = check_temp_access(real_path, proc_info); access_t access = check_temp_access(real_path, proc_info);
if (access == ALLOW) { if (access == ALLOW) {
fprintf(stderr, fprintf(stderr, "[ICFS] Permission allowed to %s based on temp table.\n",
"Permission allowed to %s based on a rule present in the temp "
"permission table.\n",
proc_info.name); proc_info.name);
free(real_path); free(real_path);
pthread_mutex_unlock(&access_check_mutex);
return 1; return 1;
} }
if (access == DENY) { if (access == DENY) {
fprintf(stderr, fprintf(stderr, "[ICFS] Permission denied to %s based on temp table.\n",
"Permission denied to %s based on a rule present in the temp "
"permission table.\n",
proc_info.name); proc_info.name);
free(real_path); free(real_path);
pthread_mutex_unlock(&access_check_mutex);
return 0; return 0;
} }
// Then check permanent permissions
access = check_perm_access(real_path, proc_info); access = check_perm_access(real_path, proc_info);
if (access == ALLOW) { if (access == ALLOW) {
fprintf(stderr, fprintf(stderr, "[ICFS] Permission allowed to %s based on perm table.\n",
"Permission allowed to %s based on a rule present in the perm "
"permission table.\n",
proc_info.name); proc_info.name);
free(real_path); free(real_path);
pthread_mutex_unlock(&access_check_mutex);
return 1; return 1;
} }
if (access == DENY) { if (access == DENY) {
fprintf(stderr, fprintf(stderr, "[ICFS] Permission denied to %s based on perm table.\n",
"Permission denied to %s based on a rule present in the perm "
"permission table.\n",
proc_info.name); proc_info.name);
free(real_path); free(real_path);
pthread_mutex_unlock(&access_check_mutex);
return 0; return 0;
} }
// if noth GRANT_TEMP and GRANT_PERM are selected, then only permanent // Handle forced permission grants
// permissions are granted
if (opts & GRANT_PERM) { 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); set_perm_access(real_path, proc_info, SET_ALLOW);
free(real_path); free(real_path);
pthread_mutex_unlock(&access_check_mutex);
return 1; return 1;
} }
if (opts & GRANT_TEMP) { 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); set_temp_access(real_path, proc_info, SET_ALLOW);
free(real_path); free(real_path);
pthread_mutex_unlock(&access_check_mutex);
return 1; return 1;
} }
// Get user decision
struct dialogue_response response = ask_access(filename, proc_info); struct dialogue_response response = ask_access(filename, proc_info);
// fprintf(stderr, "%s", response.filename);
// assert(0 != strlen(response.filename));
// the user might specify a different file in the dialogue, so we need to // Validate returned filename meets requirements:
// check if it is valid // 1. Must exist
// 2. Must be prefix of original filename with trailing slash
while (source_access(response.filename, F_OK)) { // or exact match
// if it is invalid, just ask again. while (
fprintf(stderr, "Filename returned by zenty wasn't correct: %s\n", source_access(response.filename, F_OK) ||
!(strncmp(response.filename, filename, strlen(response.filename)) == 0 &&
((strlen(response.filename) < strlen(filename) &&
response.filename[strlen(response.filename) - 1] == '/') ||
(strlen(response.filename) == strlen(filename))))) {
fprintf(stderr, "[ICFS] Invalid filename returned by dialogue: %s\n",
response.filename); response.filename);
free(response.filename); free(response.filename);
response = ask_access(filename, proc_info); response = ask_access(filename, proc_info);
} }
free(real_path); free(real_path);
real_path = real_filename(response.filename); real_path = real_filename(response.filename);
free(response.filename); free(response.filename);
int ret = 0;
// Apply user decision to appropriate permission table
if (response.decision == ALLOW) { if (response.decision == ALLOW) {
fprintf(stderr, fprintf(stderr,
"Permission granted permanently to %s based on zenty response.\n", "[ICFS] Permission granted permanently to %s based on response.\n",
proc_info.name); proc_info.name);
set_perm_access(real_path, proc_info, SET_ALLOW); set_perm_access(real_path, proc_info, SET_ALLOW);
free(real_path); ret = 1;
return 1; } else if (response.decision == ALLOW_TEMP) {
}
if (response.decision == ALLOW_TEMP) {
fprintf(stderr, fprintf(stderr,
"Permission granted temporarily to %s based on zenty response.\n", "[ICFS] Permission granted temporarily to %s based on response.\n",
proc_info.name); proc_info.name);
set_temp_access(real_path, proc_info, SET_ALLOW); set_temp_access(real_path, proc_info, SET_ALLOW);
free(real_path); ret = 1;
return 1; } else if (response.decision == DENY_TEMP) {
}
if (response.decision == DENY_TEMP) {
fprintf(stderr, fprintf(stderr,
"Permission denied temporarily to %s based on zenty response.\n", "[ICFS] Permission denied temporarily to %s based on response.\n",
proc_info.name); proc_info.name);
set_temp_access(real_path, proc_info, SET_DENY); set_temp_access(real_path, proc_info, SET_DENY);
free(real_path); ret = 0;
return 0; } else if (response.decision == DENY) {
}
if (response.decision == DENY) {
fprintf(stderr, fprintf(stderr,
"Permission denied permanently to %s based on zenty response.\n", "[ICFS] Permission denied permanently to %s based on response.\n",
proc_info.name); proc_info.name);
set_perm_access(real_path, proc_info, SET_DENY); set_perm_access(real_path, proc_info, SET_DENY);
free(real_path); ret = 0;
return 0;
} }
pthread_mutex_unlock(&access_check_mutex);
free(real_path); free(real_path);
// deny on unknown options. return ret;
return 0;
} }

View File

@ -6,10 +6,6 @@
See the file LICENSE. See the file LICENSE.
*/ */
/*
* Interface for controlling communication with the UI.
*/
#ifndef UI_SOCKET_H #ifndef UI_SOCKET_H
#define UI_SOCKET_H #define UI_SOCKET_H
@ -17,27 +13,30 @@
#include <sys/types.h> #include <sys/types.h>
/** /**
* Initialize the GUI communication. * Initialize UI socket and required permission tables
* *
* @return: 0 on success, -1 on faliure. * @param perm_permissions_db_filename Path to persistent permissions DB
* @return 0 on success, 1 on failure
*/ */
int init_ui_socket(const char *perm_permissions_db_filename); int init_ui_socket(const char *perm_permissions_db_filename);
/** /**
* Close the GUI communication. * Clean up UI socket resources
*/ */
void destroy_ui_socket(void); void destroy_ui_socket(void);
/** /**
* Check access according to: * Determine file access based on permission tables and user input
* 1. temporary permission table
* 2. permanent permission table
* 3. user descision
* *
* @param filename: The file that the process is trying to access * Checks permissions in order:
* @pram pi: The process information * 1. Temporary permission table
* @param opts: options (GRANT_TEMP, GRANT_PERM) * 2. Permanent permission table
* @return: 0 if access is denied, 1 if access is allowed * 3. User decision via GUI
*
* @param filename File being accessed
* @param pi Process information
* @param opts Flags to force permission (GRANT_TEMP/GRANT_PERM)
* @return 1 if access allowed, 0 if denied
*/ */
int interactive_access(const char *filename, struct process_info pi, int opts); int interactive_access(const char *filename, struct process_info pi, int opts);

View File

@ -2,9 +2,10 @@
# fake-icfs_dialogue: script that mocks the behavior of icfs_dialogue based on the ./.fake-icfs_dialogue-response file # fake-icfs_dialogue: script that mocks the behavior of icfs_dialogue based on the ./.fake-icfs_dialogue-response file
ICFS_DIALOGUE_YES=0 ICFS_DIALOGUE_YES=1
ICFS_DIALOGUE_NO=1 ICFS_DIALOGUE_NO=0
ICFS_DIALOGUE_PERM=2 ICFS_DIALOGUE_PERM=2
ICFS_DIALOGUE_TEMP=0
if [[ $1 == "--set-fake-response" ]]; then if [[ $1 == "--set-fake-response" ]]; then
#someone knows we are fake :) #someone knows we are fake :)
@ -27,9 +28,9 @@ else
fi fi
if [[ $FAKE_ICFS_DIALOGUE_RESPONSE == "yes" ]]; then if [[ $FAKE_ICFS_DIALOGUE_RESPONSE == "yes" ]]; then
exit "$ICFS_DIALOGUE_YES" exit "$((ICFS_DIALOGUE_YES | ICFS_DIALOGUE_TEMP))"
elif [[ $FAKE_ICFS_DIALOGUE_RESPONSE == "no" ]]; then elif [[ $FAKE_ICFS_DIALOGUE_RESPONSE == "no" ]]; then
exit "$ICFS_DIALOGUE_NO" exit "$((ICFS_DIALOGUE_NO | ICFS_DIALOGUE_TEMP))"
elif [[ $FAKE_ICFS_DIALOGUE_RESPONSE == "yes_perm" ]]; then elif [[ $FAKE_ICFS_DIALOGUE_RESPONSE == "yes_perm" ]]; then
exit "$((ICFS_DIALOGUE_YES | ICFS_DIALOGUE_PERM))" exit "$((ICFS_DIALOGUE_YES | ICFS_DIALOGUE_PERM))"
elif [[ $FAKE_ICFS_DIALOGUE_RESPONSE == "no_perm" ]]; then elif [[ $FAKE_ICFS_DIALOGUE_RESPONSE == "no_perm" ]]; then

View File

@ -54,24 +54,32 @@ int main(int argc, char *argv[]) {
} }
// Construct the full path // Construct the full path
char fullpath[PATH_MAX]; char *fullpath = NULL;
snprintf(fullpath, PATH_MAX, "%s/%s", path, entry->d_name); if (asprintf(&fullpath, "%s/%s", path, entry->d_name) == -1 ||
fullpath == NULL) {
perror("asprintf");
success = 0;
break;
}
// Stat the entry to check if it's a regular file // Stat the entry to check if it's a regular file
struct stat entry_stat; struct stat entry_stat;
if (lstat(fullpath, &entry_stat) == -1) { if (lstat(fullpath, &entry_stat) == -1) {
perror("lstat"); perror("lstat");
success = 0; success = 0;
free(fullpath);
break; break;
} }
// Only process regular files // Only process regular files
if (!S_ISREG(entry_stat.st_mode)) { if (!S_ISREG(entry_stat.st_mode)) {
free(fullpath);
continue; continue;
} }
// Try to open and immediately close the file // Try to open and immediately close the file
int fd = open(fullpath, O_RDONLY); int fd = open(fullpath, O_RDONLY);
free(fullpath);
if (fd == -1) { if (fd == -1) {
perror("open"); perror("open");
success = 0; success = 0;

6
test/stress.bash Executable file
View File

@ -0,0 +1,6 @@
#!/bin/bash
count=$1
for i in $(seq $count); do
$2 ./protected/haystack/
done

View File

@ -10,7 +10,7 @@ chmod 777 ./protected/perm777 ./protected/perm000
echo "Free code, free world." >./protected/motto echo "Free code, free world." >./protected/motto
mkdir protected/haystack mkdir protected/haystack
for i in {1..10}; do for i in {1..100}; do
touch "./protected/haystack/hay$i" touch "./protected/haystack/hay$i"
done done
touch ./protected/haystack/needle touch ./protected/haystack/needle
@ -22,7 +22,7 @@ make -C ./opener || (
echo "Could not make the opener program." echo "Could not make the opener program."
exit 1 exit 1
) )
for i in {1..10}; do for i in {1..12}; do
cp ./opener/opener "./openers/opener$i" cp ./opener/opener "./openers/opener$i"
ln --symbolic "$(realpath "./openers/opener$i")" "./openers/symlinked_opener$i" ln --symbolic "$(realpath "./openers/opener$i")" "./openers/symlinked_opener$i"
done done
@ -43,16 +43,23 @@ if [[ $1 == "--setuid" ]]; then
echo "Valgrind will not be used due to setuid compatibility issues." echo "Valgrind will not be used due to setuid compatibility issues."
../build/icfs -o default_permissions ./protected ./.pt.db & ../build/icfs -o default_permissions ./protected ./.pt.db &
sleep 1 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 else
echo "Database protection will not be tested due to the lack of setuid capabilites." echo "Database protection will not be tested due to the lack of setuid capabilites."
echo "To test it, run this script with '--setuid'." 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 ./protected ./.pt.db &
sleep 5 sleep 5
fi fi
#valgrind -s ../build/icfs -o default_permissions ./protected & #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: 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**. # WARN: avoid using touch, since it generates errors because setting times is not implemented in icfs **yet**.
@ -205,9 +212,29 @@ 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" 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 fi
# performance testing code
RUNS_NUM=500
if [[ $1 == '--performance' ]]; then
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 # unmount
sleep 0.5 sleep 0.5
#lsof +f -- $(realpath ./protected) #lsof +f -- $(realpath ./protected)
umount "$(realpath ./protected)" umount "$(realpath ./protected)"
sleep 0.5 sleep 3
# test the same thing, but without ICFS mounted
if [[ $1 == '--performance' ]]; then
echo "[ICFS-TEST]: bare filesystem"
time parallel -j8 ::: "./stress.bash $RUNS_NUM openers/opener9"
fi