Compare commits
5 Commits
beec6f4a4c
...
profiling
Author | SHA1 | Date | |
---|---|---|---|
6fd6907121
|
|||
1bc25af6f1
|
|||
![]() |
13fd0db8a8
|
||
![]() |
55fb5c54c6
|
||
![]() |
402a5d109f
|
2
.gitignore
vendored
2
.gitignore
vendored
@@ -4,3 +4,5 @@ build/*
|
||||
test/protected/*
|
||||
test/.pt.db
|
||||
compile_commands.json
|
||||
test/perf*
|
||||
test/callgraph*
|
||||
|
4
Makefile
4
Makefile
@@ -21,14 +21,14 @@ endif
|
||||
|
||||
# set up cflags and libs
|
||||
|
||||
CFLAGS := -D_FILE_OFFSET_BITS=64
|
||||
CFLAGS := -D_FILE_OFFSET_BITS=64 -g
|
||||
LDFLAGS :=
|
||||
|
||||
CFLAGS += $(shell pkg-config --cflags $(PACKAGE_NAMES))
|
||||
LDFLAGS += $(shell pkg-config --libs $(PACKAGE_NAMES))
|
||||
|
||||
ifeq ($(DEBUG),1)
|
||||
CFLAGS += -O0 -pedantic -g -Wall -Wextra -Wcast-align \
|
||||
CFLAGS += -O0 -pedantic -Wall -Wextra -Wcast-align \
|
||||
-Wcast-qual -Wdisabled-optimization -Wformat=2 \
|
||||
-Winit-self -Wlogical-op -Wmissing-declarations \
|
||||
-Wmissing-include-dirs -Wredundant-decls -Wshadow \
|
||||
|
@@ -11,6 +11,7 @@
|
||||
See the file LICENSE.
|
||||
*/
|
||||
|
||||
#include <stddef.h>
|
||||
#define FUSE_USE_VERSION 31
|
||||
|
||||
#define _GNU_SOURCE
|
||||
@@ -40,22 +41,57 @@
|
||||
#include "ui-socket.h"
|
||||
|
||||
const char *get_process_name_by_pid(const int pid) {
|
||||
char *name = (char *)calloc(1024, sizeof(char));
|
||||
if (name) {
|
||||
sprintf(name, "/proc/%d/cmdline", pid);
|
||||
FILE *file = fopen(name, "r");
|
||||
char path[1024];
|
||||
sprintf(path, "/proc/%d/exe", pid);
|
||||
|
||||
char *name = realpath(path, NULL);
|
||||
if (name == NULL) {
|
||||
fprintf(stderr, "Could not get process name by pid %d", pid);
|
||||
perror("");
|
||||
}
|
||||
|
||||
/*
|
||||
size_t namelen = 32;
|
||||
ssize_t readret = 0;
|
||||
char *name = NULL;
|
||||
while (namelen >= (size_t)readret && readret > 0) {
|
||||
namelen *= 2;
|
||||
name = calloc(namelen, sizeof(char));
|
||||
if (name == NULL) {
|
||||
free(path);
|
||||
fprintf(stderr, "Could not get get process name by pid %d", pid);
|
||||
perror("");
|
||||
return NULL;
|
||||
}
|
||||
readret = readlink(path, name, namelen);
|
||||
if (readret < 0) {
|
||||
free(name);
|
||||
free(path);
|
||||
fprintf(stderr, "Couldn't get process name by pid %d", pid);
|
||||
perror("");
|
||||
return NULL;
|
||||
}
|
||||
if (namelen >= (size_t)readret) {
|
||||
free(name);
|
||||
}
|
||||
}
|
||||
*/
|
||||
|
||||
return name;
|
||||
|
||||
/*
|
||||
FILE *file = fopen(path, "r");
|
||||
if (file) {
|
||||
size_t size = 0;
|
||||
size = fread(name, sizeof(char), 1024, file);
|
||||
size = fread(path, sizeof(char), 1024, file);
|
||||
if (size > 0) {
|
||||
if ('\n' == name[size - 1]) {
|
||||
name[size - 1] = '\0';
|
||||
if ('\n' == path[size - 1]) {
|
||||
path[size - 1] = '\0';
|
||||
}
|
||||
}
|
||||
fclose(file);
|
||||
}
|
||||
}
|
||||
return name;
|
||||
*/
|
||||
}
|
||||
|
||||
// TODO: move this somewhere else
|
||||
@@ -83,6 +119,7 @@ static void *xmp_init(struct fuse_conn_info *conn, struct fuse_config *cfg) {
|
||||
cfg->entry_timeout = 0;
|
||||
cfg->attr_timeout = 0;
|
||||
cfg->negative_timeout = 0;
|
||||
fprintf(stderr, "%d\n", getpid());
|
||||
|
||||
return NULL;
|
||||
}
|
||||
|
@@ -27,6 +27,7 @@ const int column_count = 2;
|
||||
const char *const schema[] = {"executable", "filename"};
|
||||
const char *const types[] = {"TEXT", "TEXT"};
|
||||
uid_t ruid, euid, current_pid;
|
||||
sqlite3_stmt *perm_check_statement = NULL;
|
||||
pthread_mutex_t uid_switch = PTHREAD_MUTEX_INITIALIZER;
|
||||
|
||||
void set_db_fsuid() {
|
||||
@@ -141,6 +142,45 @@ int ensure_database_schema() {
|
||||
return 0;
|
||||
}
|
||||
|
||||
int prepare_sql_queries() {
|
||||
const char *query_template =
|
||||
"SELECT * FROM %s WHERE executable = ? AND filename = ?;";
|
||||
char *query_string = NULL;
|
||||
int query_len = snprintf(NULL, 0, query_template, table_name) + 1;
|
||||
|
||||
if (query_len < 0) {
|
||||
fprintf(stderr, "Failed to prepare statement");
|
||||
perror("");
|
||||
return 1;
|
||||
}
|
||||
|
||||
query_string = malloc(query_len);
|
||||
if (query_string == NULL) {
|
||||
fprintf(stderr, "Failed to allocate memory for the query");
|
||||
perror("");
|
||||
return 1;
|
||||
}
|
||||
|
||||
int ret = snprintf(query_string, query_len, query_template, table_name);
|
||||
if (ret < 0) {
|
||||
fprintf(stderr, "Failed to prepare statement");
|
||||
perror("");
|
||||
free(query_string);
|
||||
return 1;
|
||||
}
|
||||
|
||||
if (sqlite3_prepare_v2(perm_database, query_string, -1, &perm_check_statement,
|
||||
NULL) != SQLITE_OK) {
|
||||
fprintf(stderr, "Failed to prepare statement: %s\n",
|
||||
sqlite3_errmsg(perm_database));
|
||||
free(query_string);
|
||||
return 1;
|
||||
}
|
||||
free(query_string);
|
||||
return 0;
|
||||
}
|
||||
|
||||
void free_sql_queries(void) { sqlite3_finalize(perm_check_statement); }
|
||||
/**
|
||||
* Initializes the permanent permissions table.
|
||||
*
|
||||
@@ -169,17 +209,24 @@ int init_perm_permissions_table(const char *db_filename) {
|
||||
|
||||
int status = seteuid(ruid);
|
||||
if (status < 0) {
|
||||
fprintf(stderr, "Couldn't set euid to ruid during database setup.\n");
|
||||
fprintf(stderr, "Couldn't set euid to ruid.\n");
|
||||
exit(status);
|
||||
}
|
||||
|
||||
if (prepare_sql_queries()) {
|
||||
fprintf(stderr, "Couldn't prepare sql queries.\n");
|
||||
exit(status);
|
||||
}
|
||||
return 0;
|
||||
}
|
||||
|
||||
/**
|
||||
* Destroys the permanent permissions table.
|
||||
*/
|
||||
void destroy_perm_permissions_table() { sqlite3_close(perm_database); }
|
||||
void destroy_perm_permissions_table(void) {
|
||||
free_sql_queries();
|
||||
sqlite3_close(perm_database);
|
||||
}
|
||||
|
||||
/**
|
||||
* Checks if the process has a permanent access to the file.
|
||||
|
@@ -13,7 +13,6 @@
|
||||
#include "perm_permissions_table.h"
|
||||
#include "temp_permissions_table.h"
|
||||
#include "ui-socket.h"
|
||||
#include <errno.h>
|
||||
#include <pthread.h>
|
||||
#include <stdio.h>
|
||||
#include <stdlib.h>
|
||||
@@ -22,9 +21,10 @@
|
||||
#include <sys/un.h>
|
||||
#include <unistd.h>
|
||||
|
||||
#define ZENITY_TEMP_ALLOW_MESSAGE "Allow this time\n"
|
||||
|
||||
int init_ui_socket(const char *perm_permissions_db_filename) {
|
||||
char line[256];
|
||||
FILE *fp;
|
||||
FILE *fp = NULL;
|
||||
|
||||
if (init_temp_permissions_table()) {
|
||||
fprintf(stderr, "Could not initialize temporary permissions table.\n");
|
||||
@@ -43,13 +43,11 @@ int init_ui_socket(const char *perm_permissions_db_filename) {
|
||||
return 1;
|
||||
}
|
||||
|
||||
while (fgets(line, sizeof(line), fp))
|
||||
printf("%s", line);
|
||||
pclose(fp);
|
||||
return 0;
|
||||
}
|
||||
|
||||
void destroy_ui_socket() {
|
||||
void destroy_ui_socket(void) {
|
||||
destroy_temp_permissions_table();
|
||||
destroy_perm_permissions_table();
|
||||
}
|
||||
@@ -63,16 +61,16 @@ void destroy_ui_socket() {
|
||||
* @return: 0 if access is denied, 1 if access is allowed, 2 if access is
|
||||
* allowed for the runtime of the process
|
||||
*/
|
||||
int ask_access(const char *filename, struct process_info pi) {
|
||||
FILE *fp;
|
||||
int ask_access(const char *filename, struct process_info proc_info) {
|
||||
FILE *fp = NULL;
|
||||
size_t command_len =
|
||||
139 + sizeof(pid_t) * 8 + strlen(pi.name) + strlen(filename);
|
||||
139 + sizeof(pid_t) * 8 + strlen(proc_info.name) + strlen(filename);
|
||||
char *command = (char *)malloc(command_len);
|
||||
snprintf(command, command_len,
|
||||
"zenity --question --extra-button \"Allow this time\" --title "
|
||||
"\"Allow Access?\" --text \"Allow process "
|
||||
"<tt>%s</tt> with PID <tt>%d</tt> to access <tt>%s</tt>\"",
|
||||
pi.name, pi.PID, filename);
|
||||
proc_info.name, proc_info.PID, filename);
|
||||
|
||||
// Zenity Question Message Popup
|
||||
fp = popen(command, "r");
|
||||
@@ -86,10 +84,10 @@ int ask_access(const char *filename, struct process_info pi) {
|
||||
// if the user clicks the "Allow this time" button, `zenity` will only
|
||||
// write it to `stdout`, but the exit code will still be `1`. So, we need
|
||||
// to manually check the output.
|
||||
char buffer[1024];
|
||||
char buffer[sizeof(ZENITY_TEMP_ALLOW_MESSAGE) + 1];
|
||||
while (fgets(buffer, sizeof(buffer), fp)) {
|
||||
printf("%s", buffer);
|
||||
if (strcmp(buffer, "Allow this time\n") == 0) {
|
||||
if (strcmp(buffer, ZENITY_TEMP_ALLOW_MESSAGE) == 0) {
|
||||
pclose(fp);
|
||||
return 2;
|
||||
}
|
||||
@@ -116,9 +114,11 @@ int ask_access(const char *filename, struct process_info pi) {
|
||||
* @param opts: options (GRANT_TEMP, GRANT_PERM)
|
||||
* @return: 0 if access is denied, 1 if access is allowed
|
||||
*/
|
||||
int interactive_access(const char *filename, struct process_info pi, int opts) {
|
||||
int interactive_access(const char *filename, struct process_info proc_info,
|
||||
int opts) {
|
||||
|
||||
if (check_temp_access(filename, pi) || check_perm_access(filename, pi)) {
|
||||
if (check_temp_access(filename, proc_info) ||
|
||||
check_perm_access(filename, proc_info)) {
|
||||
// access was already granted before
|
||||
return 1;
|
||||
}
|
||||
@@ -127,22 +127,24 @@ int interactive_access(const char *filename, struct process_info pi, int opts) {
|
||||
// permissions are granted
|
||||
|
||||
if (opts & GRANT_PERM) {
|
||||
give_perm_access(filename, pi);
|
||||
give_perm_access(filename, proc_info);
|
||||
return 1;
|
||||
}
|
||||
if (opts & GRANT_TEMP) {
|
||||
give_temp_access(filename, pi);
|
||||
give_temp_access(filename, proc_info);
|
||||
return 1;
|
||||
}
|
||||
|
||||
int user_response = ask_access(filename, pi);
|
||||
int user_response = ask_access(filename, proc_info);
|
||||
if (user_response == 1) {
|
||||
// user said "yes"
|
||||
give_perm_access(filename, pi);
|
||||
give_perm_access(filename, proc_info);
|
||||
return 1;
|
||||
} else if (user_response == 2) {
|
||||
}
|
||||
|
||||
if (user_response == 2) {
|
||||
// user said "yes, but only this time"
|
||||
give_temp_access(filename, pi);
|
||||
give_temp_access(filename, proc_info);
|
||||
return 1;
|
||||
}
|
||||
|
||||
|
@@ -12,10 +12,17 @@ else
|
||||
if [[ $FAKE_ZENITY_RESPONSE == "yes_tmp" ]]; then
|
||||
printf "Allow this time\n"
|
||||
exit 1
|
||||
elif [[ $FAKE_ZENITY_RESPONSE == "yes_tmp_alt" ]]; then
|
||||
printf "Allow this time\n"
|
||||
echo "yes_alt" >~/.fake_zenity_response
|
||||
exit 1
|
||||
elif [[ $FAKE_ZENITY_RESPONSE == "no" ]]; then
|
||||
exit 1
|
||||
elif [[ $FAKE_ZENITY_RESPONSE == "yes" ]]; then
|
||||
exit 0
|
||||
elif [[ $FAKE_ZENITY_RESPONSE == "yes_alt" ]]; then
|
||||
echo "yes_tmp_alt" >~/.fake_zenity_response
|
||||
exit 0
|
||||
fi
|
||||
fi
|
||||
fi
|
||||
|
@@ -25,10 +25,18 @@ if [[ $1 == "--setuid" ]]; then
|
||||
echo "Valgrind will not be used due to setuid compatibility issues."
|
||||
../build/icfs -o default_permissions ./protected ./.pt.db &
|
||||
sleep 1
|
||||
elif [[ $1 == "--perf" ]]; then
|
||||
echo "Profiling with perf..."
|
||||
../build/icfs -o default_permissions ./protected ./.pt.db &
|
||||
echo "Profiling will require root privilieges."
|
||||
sleep 3
|
||||
echo "Attaching to $(pgrep icfs)"
|
||||
sudo perf record -g -e cycles:u --call-graph dwarf -p $(pgrep icfs) &
|
||||
sleep 10
|
||||
else
|
||||
echo "Database protection will not be tested due to the lack of setuid capabilites."
|
||||
echo "To test it, run this script with '--setuid'."
|
||||
valgrind -s ../build/icfs -o default_permissions ./protected ./.pt.db &
|
||||
valgrind --leak-check=full -s ../build/icfs -o default_permissions ./protected ./.pt.db &
|
||||
sleep 5
|
||||
fi
|
||||
|
||||
@@ -126,9 +134,29 @@ else
|
||||
echo "[ICFS-TEST]: OK"
|
||||
fi
|
||||
|
||||
if [[ $1 == "--perf" ]]; then
|
||||
zenity --set-fake-response yes_tmp
|
||||
rm -rf ./protected/*
|
||||
zenity --set-fake-response yes_alt
|
||||
bonnie++ -p 4
|
||||
bonnie++ -d ./protected -c 4 -r 256 -y s >/dev/null &
|
||||
bonnie++ -d ./protected -c 4 -r 256 -y s >/dev/null &
|
||||
bonnie++ -d ./protected -c 4 -r 256 -y s >/dev/null &
|
||||
bonnie++ -d ./protected -c 4 -r 256 -y s >/dev/null
|
||||
bonnie++ -p -1
|
||||
fi
|
||||
|
||||
# unmount
|
||||
|
||||
sleep 0.5
|
||||
#lsof +f -- $(realpath ./protected)
|
||||
umount $(realpath ./protected)
|
||||
sleep 0.5
|
||||
|
||||
if [[ $1 == "--perf" ]]; then
|
||||
mv ./callgraph.png ./callgraph_old.png
|
||||
real_user=$USER
|
||||
sudo chown "$real_user" ./perf.data
|
||||
perf script --dsos=icfs | gprof2dot -f perf | dot -Tpng -o callgraph.png
|
||||
echo "Profile graph was written to \"callgraph.png\""
|
||||
fi
|
||||
|
Reference in New Issue
Block a user