RepoMirrors
/
mars
mirror of https://github.com/schoebel/mars
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

infra: invalidate user caches

This commit is contained in:
Thomas Schoebel-Theuer 2020-10-21 22:29:34 +02:00
parent 166fefb676
commit c26fb3bef2
3 changed files with 24 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
kernel/mars_server.c
View File

@ -607,6 +607,7 @@ int handler_thread(void *data)
status = -EPERM;
break;
}
invalidate_user_cache();
status =
ordered_symlink(cmd.cmd_str1,
@ -629,6 +630,7 @@ int handler_thread(void *data)
status = mars_stat(cmd.cmd_str2, &probe, true);
if (status < 0) {
invalidate_user_cache();
activate_peer(cmd.cmd_str1, NULL, NULL, true);
}
status = 0;

20
kernel/sy_old/mars_main.c
View File

@ -223,6 +223,15 @@ void _crashme(int mode, bool do_sync)
#endif
void invalidate_user_cache(void)
{
const char *path;
path = path_make("/mars/cache-%s/invalid", my_id());
ordered_symlink("1", path, NULL);
brick_string_free(path);
}
#define GLOBAL_PATH_LIST \
"/mars" \
"|/mars/ips/" \
@ -2629,6 +2638,14 @@ int run_bone(struct mars_peerinfo *peer, struct mars_dent *remote_dent)
#endif
}
} else if (S_ISLNK(remote_dent->new_stat.mode) && remote_dent->new_link) {
/* is something in /mars/ips/ (or a guest membership) updated ? */
if ((!stat_ok ||
lamport_time_compare(&remote_dent->new_stat.mtime,
&local_stat.mtime) > 0) &&
(!strncmp(remote_dent->d_name, "device-", 7) ||
!strncmp(remote_path, MARS_IP_STR, strlen(MARS_IP_STR))))
invalidate_user_cache();
/* Important: not not create .deleted values
* unless the object already exists.
*/
@ -2638,7 +2655,8 @@ int run_bone(struct mars_peerinfo *peer, struct mars_dent *remote_dent)
status = ordered_symlink(remote_dent->new_link,
remote_path,
&remote_dent->new_stat.mtime);
MARS_DBG("create symlink '%s' -> '%s' status = %d\n", remote_path, remote_dent->new_link, status);
MARS_DBG("create symlink '%s' -> '%s' status = %d\n",
remote_path, remote_dent->new_link, status);
run_trigger = true;
if (!status &&
(!strncmp(remote_dent->d_name, "primary", 7) ||

3
kernel/sy_old/strategy.h
View File

@ -72,6 +72,9 @@ extern int mars_keep_msg;
extern int mars_fast_fullsync;
#define MARS_IP_STR "/mars/ips/ip-"
extern void invalidate_user_cache(void);
extern char *my_id(void);
extern const char *my_uuid;