|
|
|
|
@ -1516,7 +1516,6 @@ int main(int argc, char **argv) {
|
|
|
|
|
return 0; |
|
|
|
|
} |
|
|
|
|
test_profile_atomicity(); |
|
|
|
|
test_delayed_media_reader(); |
|
|
|
|
stream_set_event_callback(nodes[0], on_stream, NULL); stream_set_event_callback(nodes[1], on_stream, NULL); |
|
|
|
|
struct STREAM_HANDLE *publisher = NULL, *publisher2 = NULL, *other_group = NULL, *mobile = NULL, *desktop = NULL; |
|
|
|
|
CHECK(stream_publish_open(nodes[0], GROUP1, NULL, &publisher) == STREAM_OK); |
|
|
|
|
@ -1637,6 +1636,8 @@ int main(int argc, char **argv) {
|
|
|
|
|
CHECK(stream_member_load(nodes[0], GROUP1, nodes[0]->node_id, &state, NULL) == STREAM_OK && !state.published && !state.count); |
|
|
|
|
CHECK(data_events[0] == 1); /* Pending 100ms batch не выполнилась после stop. */ |
|
|
|
|
DEBUG_INFO(DEBUG_CATEGORY_STREAM, "[PASS] CHAT stop keeps UTUN/core; source timer cancelled; stale signed options cleared on restart"); |
|
|
|
|
for (unsigned i = 0; i < 4; i++) stream_set_event_callback(nodes[i], NULL, NULL); |
|
|
|
|
test_delayed_media_reader(); |
|
|
|
|
for (unsigned i = 0; i < 3; i++) topo_group_peer_close(connections[i]); |
|
|
|
|
for (unsigned i = 0; i < 4; i++) utun_instance_destroy(nodes[i]); |
|
|
|
|
uasync_destroy(ua, 1); test_clock_finish(); |
|
|
|
|
|