Skip to content

fix: fix ip cache #194

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
stepanrodimanov wants to merge 1 commit into
base: traffic_filtering
Choose a base branch
from
Open

fix: fix ip cache #194

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 3 additions & 3 deletions worker/src/dpdk_filter/ip_cache.c
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ static int ip_str_to_key(const char *ip_str, struct ip_key *key) {
static int load_ip_categories(const char *ip_str,
struct node_cache_ip *node_ip) {
const char *sql_cat =
"SELECT certain_category FROM categories_table WHERE ip_str = ?;";
"SELECT certain_category FROM ip_categories_table WHERE ip_str = ?;";
sqlite3_stmt *stmt_cat = NULL;
int rc_cat = sqlite3_prepare_v2(ip_cache_table, sql_cat, -1, &stmt_cat, NULL);
if (rc_cat != SQLITE_OK) {
Expand Down Expand Up @@ -243,7 +243,7 @@ static int insert_ip_main_record(const char *ip_str,
}

static int delete_ip_categories(const char *ip_str) {
const char *sql = "DELETE FROM categories_table WHERE ip_str = ?";
const char *sql = "DELETE FROM ip_categories_table WHERE ip_str = ?";
sqlite3_stmt *stmt = NULL;
int ret = sqlite3_prepare_v2(ip_cache_table, sql, -1, &stmt, NULL);
if (ret != SQLITE_OK) {
Expand All @@ -260,7 +260,7 @@ static int delete_ip_categories(const char *ip_str) {

static int insert_ip_categories(const char *ip_str,
struct node_cache_ip *node) {
const char *sql = "INSERT INTO categories_table (ip_str, "
const char *sql = "INSERT INTO ip_categories_table (ip_str, "
"certain_category) VALUES (?, ?)";
sqlite3_stmt *stmt = NULL;
int ret = sqlite3_prepare_v2(ip_cache_table, sql, -1, &stmt, NULL);
Expand Down
Loading