jeka/utun2
1
0 Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Drive relay generation wakeup through actual queue consumption

Browse Source
This commit is contained in:
evgeny committed 2026-10-22 19:46:30 +02:00
1 parent 8f97cf8070
commit 1aec478787
1 file changed
+4 -2
Download Patch File Download Diff File Expand all files Collapse all files
tests/test_media_blocks.c
+4 -2
View File
@@ -397,7 +397,8 @@ static void test_relay_generation(void) {
char old_path[FILE_IO_PATH_MAX]; snprintf(old_path, sizeof(old_path), "%s", old_source->storage.temporary);
struct packet request = request_packet(dl, 0x300); receive(f.client, &request);
struct ETCP_ROUTER_CONN* slow = etcp_router_conn_get(f.client, GROUP, 0x300, ETCP_RT_ID_MEDIA_DELIVERY);
queue_set_threshold(slow->send_q, -1, 0);
queue_set_threshold(slow->send_q, 0, 0);
struct ll_entry* pending = queue_entry_new(0); REQUIRE(pending && !queue_data_put(slow->send_q, pending));
struct packet old_chunk = chunk_packet(f.client, 0, 1), old_done = done_packet(f.client);
receive(f.client, &old_chunk); receive(f.client, &old_done); poll_ready();
REQUIRE(!download(f.client) && old_source->refs == 1 && old_source->verified && !access(old_path, F_OK));
@@ -406,7 +407,8 @@ static void test_relay_generation(void) {
REQUIRE(new_source != old_source && !old_source->indexed && new_source->indexed && new_source->refs == 1);
unchanged(f.client, &old_chunk); unchanged(f.client, &old_done);
if (cancel_new) REQUIRE(!media_download_cancel(f.client, dl->media_id, NULL, 0));
capture_blocks = 1; queue_set_threshold(slow->send_q, 0, 0); poll_ready();
capture_blocks = 1;
pending = queue_data_get(slow->send_q); REQUIRE(pending); queue_entry_free(pending); poll_ready();
REQUIRE(access(old_path, F_OK) && !f.client->md.streams && packet_count == 2);
REQUIRE(packets[0].data[0] == MEDIA_SUBCMD_BLOCK_CHUNK && packets[1].data[0] == MEDIA_SUBCMD_BLOCK_DONE);
REQUIRE(!memcmp(((struct media_pkt_block_chunk*)packets[0].data)->transfer_id,