RepoMirrors/mars
1
0
Fork 0
mirror of https://github.com/schoebel/mars synced 2024-12-28 09:32:25 +00:00
Code Issues Packages Projects Releases Wiki Activity

main: allow push to non-activated peer

Browse Source
This commit is contained in:
Thomas Schoebel-Theuer 2020-10-14 18:06:58 +02:00
parent 38ce235e86
commit 8fc98684bc
1 changed files with 22 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
kernel/sy_old/mars_main.c
View File

@ -2146,6 +2146,9 @@ void show_peers(void)
up_read(&peer_lock);
}
static
void peer_destruct(void *_peer);
/* Please use this only for _initialization_ of new memberships etc,
* but never for ordinary operations.
* Normally, the PULL PRINCIPLE is the prefered one.
@ -2155,12 +2158,29 @@ bool push_link(const char *peer_name,
const char *src,
const char *dst)
{
struct mars_dent *peer_dent;
struct mars_peerinfo *peer;
struct push_info *push;
peer = find_peer(peer_name);
if (!peer)
if (unlikely(!peer_name ||
!peer_name[0] ||
!strcmp(peer_name, my_id()))) {
MARS_WRN("invalid peer_name '%s'\n", peer_name);
return false;
}
peer_dent = find_peer_dent(peer_name);
if (unlikely(!peer_dent)) {
MARS_WRN("peer '%s' does not exist in /mars/ips/\n",
peer_name);
return false;
}
peer = peer_dent->d_private;
if (!peer) {
peer = new_peer(peer_name);
peer_dent->d_private = peer;
peer_dent->d_private_destruct = peer_destruct;
}
push = brick_zmem_alloc(sizeof(struct push_info));
INIT_LIST_HEAD(&push->push_head);
push->src = brick_strdup(src);