|
|
|
|
@ -118,6 +118,8 @@ int main(void) {
|
|
|
|
|
debug_set_category_level(DEBUG_CATEGORY_DM, DEBUG_LEVEL_DEBUG); |
|
|
|
|
debug_set_category_level(DEBUG_CATEGORY_CHAT_SYNC, DEBUG_LEVEL_DEBUG); |
|
|
|
|
debug_set_category_level(DEBUG_CATEGORY_MEMBER_SYNC, DEBUG_LEVEL_INFO); |
|
|
|
|
debug_set_category_level(DEBUG_CATEGORY_BGP, DEBUG_LEVEL_DEBUG); |
|
|
|
|
debug_set_category_level(DEBUG_CATEGORY_CONNECTION, DEBUG_LEVEL_DEBUG); |
|
|
|
|
} |
|
|
|
|
utun_instance_set_tun_init_enabled(0); |
|
|
|
|
struct UASYNC* ua = uasync_create(); |
|
|
|
|
@ -175,9 +177,13 @@ int main(void) {
|
|
|
|
|
"delivered link is registered with ten minute lifetime"); |
|
|
|
|
CHECK(!join_link(ua, link), "B joins target group using received PM link"); |
|
|
|
|
char target_id[64]; snprintf(target_id, sizeof(target_id), "%llu", (unsigned long long)target); |
|
|
|
|
chat_core_connect_channel(nodes[1], target_id); |
|
|
|
|
deadline = get_time_tb() + 100000; |
|
|
|
|
while (!topo_node_sqlite_member_in_channel(nodes[1]->topo_sqlite_db, target_id, nodes[1]->node_id) && |
|
|
|
|
get_time_tb() < deadline) uasync_poll(ua, 100); |
|
|
|
|
DEBUG_INFO(DEBUG_CATEGORY_DM, "invite test: membership after JOIN ch=%s A_has_B=%d B_has_B=%d", target_id, |
|
|
|
|
topo_node_sqlite_member_in_channel(nodes[0]->topo_sqlite_db, target_id, nodes[1]->node_id), |
|
|
|
|
topo_node_sqlite_member_in_channel(nodes[1]->topo_sqlite_db, target_id, nodes[1]->node_id)); |
|
|
|
|
CHECK(topo_node_sqlite_member_in_channel(nodes[0]->topo_sqlite_db, target_id, nodes[1]->node_id) && |
|
|
|
|
topo_node_sqlite_member_in_channel(nodes[1]->topo_sqlite_db, target_id, nodes[1]->node_id), "membership committed on both nodes"); |
|
|
|
|
request(6, target, "", 0); |
|
|
|
|
|