1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
|
#include "config.h"
#include "test_main_thread.h"
#include <signal.h>
#include "data/thread_disk.h"
#include "test/helpers/mock_function.h"
#include "torrent/exceptions.h"
#include "torrent/net/resolver.h"
#include "torrent/utils/log.h"
#include "torrent/utils/scheduler.h"
#include "tracker/thread_tracker.h"
std::unique_ptr<TestMainThread>
TestMainThread::create() {
// Needs to be called before Thread is created.
mock_redirect_defaults();
return std::unique_ptr<TestMainThread>(new TestMainThread());
}
std::unique_ptr<TestMainThread>
TestMainThread::create_with_mock() {
return std::unique_ptr<TestMainThread>(new TestMainThread());
}
void
TestMainThread::init_thread() {
m_resolver = std::make_unique<torrent::net::Resolver>();
m_state = STATE_INITIALIZED;
//m_instrumentation_index = INSTRUMENTATION_POLLING_DO_POLL_MAIN - INSTRUMENTATION_POLLING_DO_POLL;
init_thread_local();
}
void
TestMainThread::cleanup_thread() {
}
void
TestMainThread::call_events() {
process_callbacks();
}
std::chrono::microseconds
TestMainThread::next_timeout() {
return 10min;
}
void
TestFixtureWithMainThread::setUp() {
test_fixture::setUp();
m_main_thread = TestMainThread::create();
m_main_thread->init_thread();
}
void
TestFixtureWithMainThread::tearDown() {
m_main_thread.reset();
test_fixture::tearDown();
}
void
TestFixtureWithMainAndDiskThread::setUp() {
test_fixture::setUp();
m_main_thread = TestMainThread::create();
m_main_thread->init_thread();
// m_hash_check_queue.slot_chunk_done() binds to main_thread().
torrent::ThreadDisk::create_thread();
torrent::thread_disk()->init_thread();
torrent::thread_disk()->start_thread();
signal(SIGUSR1, [](auto){});
}
void
TestFixtureWithMainAndDiskThread::tearDown() {
torrent::thread_disk()->stop_thread_wait();
delete torrent::thread_disk();
m_main_thread.reset();
test_fixture::tearDown();
}
void
TestFixtureWithMainAndTrackerThread::setUp() {
test_fixture::setUp();
m_main_thread = TestMainThread::create();
m_main_thread->init_thread();
log_add_group_output(torrent::LOG_TRACKER_EVENTS, "test_output");
log_add_group_output(torrent::LOG_TRACKER_REQUESTS, "test_output");
torrent::ThreadTracker::create_thread(m_main_thread.get());
torrent::thread_tracker()->init_thread();
torrent::thread_tracker()->start_thread();
}
void
TestFixtureWithMainAndTrackerThread::tearDown() {
torrent::thread_tracker()->stop_thread_wait();
delete torrent::thread_tracker();
m_main_thread.reset();
test_fixture::tearDown();
}
void
TestFixtureWithMockAndMainThread::setUp() {
test_fixture::setUp();
m_main_thread = TestMainThread::create_with_mock();
m_main_thread->init_thread();
}
void
TestFixtureWithMockAndMainThread::tearDown() {
m_main_thread.reset();
test_fixture::tearDown();
}
|
