Lines Matching full:m
44 std::vector<int64_t> getSessions(int taskId, const SessionTaskMap &m) { in getSessions() argument
46 m.forEachSessionInTask( in getSessions()
53 std::vector<int> getTasks(int64_t sessionId, const SessionTaskMap &m) { in getTasks() argument
55 m.forEachSessionValTasks([&](int64_t sessId, const auto & /*sve*/, const auto &linkedTasks) { in getTasks()
66 SessionTaskMap m; in TEST() local
67 EXPECT_TRUE(m.add(1, makeSession(1000), {10, 20, 30})); in TEST()
68 EXPECT_TRUE(m.add(2, makeSession(2000), {40, 50})); in TEST()
69 EXPECT_TRUE(m.add(3, makeSession(2000), {60})); in TEST()
70 EXPECT_FALSE(m.add(3, makeSession(2000), {70})); in TEST()
74 SessionTaskMap m; in TEST() local
75 m.add(1, makeSession(1000), {10, 20, 30}); in TEST()
76 m.add(2, makeSession(2000), {40, 50, 60}); in TEST()
77 m.add(3, makeSession(3000), {50}); in TEST()
80 EXPECT_EQ(std::vector<int64_t>({1}), getSessions(10, m)); in TEST()
81 EXPECT_EQ(std::vector<int64_t>({1}), getSessions(20, m)); in TEST()
82 EXPECT_EQ(std::vector<int64_t>({1}), getSessions(30, m)); in TEST()
83 EXPECT_EQ(std::vector<int64_t>({2}), getSessions(40, m)); in TEST()
84 EXPECT_EQ(std::vector<int64_t>({2, 3}), getSessions(50, m)); in TEST()
85 EXPECT_EQ(std::vector<int64_t>({2}), getSessions(60, m)); in TEST()
89 SessionTaskMap m; in TEST() local
90 m.add(1, makeSession(1000), {10, 20, 30}); in TEST()
91 m.add(2, makeSession(2000), {40, 50, 60}); in TEST()
92 m.add(3, makeSession(3000), {50}); in TEST()
95 EXPECT_EQ(std::vector<int>({10, 20, 30}), getTasks(1, m)); in TEST()
96 EXPECT_EQ(std::vector<int>({40, 50, 60}), getTasks(2, m)); in TEST()
97 EXPECT_EQ(std::vector<int>({50}), getTasks(3, m)); in TEST()
101 SessionTaskMap m; in TEST() local
102 EXPECT_FALSE(m.remove(1)); in TEST()
106 SessionTaskMap m; in TEST() local
107 m.add(1, makeSession(1000), {10, 20, 30}); in TEST()
108 m.add(2, makeSession(2000), {40, 50, 60}); in TEST()
109 m.add(3, makeSession(3000), {50}); in TEST()
112 EXPECT_TRUE(m.remove(2)); in TEST()
115 EXPECT_EQ(std::vector<int64_t>({1}), getSessions(10, m)); in TEST()
116 EXPECT_EQ(std::vector<int64_t>({1}), getSessions(20, m)); in TEST()
117 EXPECT_EQ(std::vector<int64_t>({1}), getSessions(30, m)); in TEST()
118 EXPECT_EQ(std::vector<int64_t>({}), getSessions(40, m)); in TEST()
119 EXPECT_EQ(std::vector<int64_t>({3}), getSessions(50, m)); in TEST()
123 SessionTaskMap m; in TEST() local
124 EXPECT_FALSE(m.remove(1)); in TEST()
126 m.add(1, makeSession(1000), {10, 20, 30}); in TEST()
127 m.add(2, makeSession(2000), {40, 50, 60}); in TEST()
128 m.add(3, makeSession(3000), {50}); in TEST()
131 EXPECT_TRUE(m.remove(2)); in TEST()
132 EXPECT_FALSE(m.remove(2)); in TEST()
135 EXPECT_EQ(std::vector<int>({10, 20, 30}), getTasks(1, m)); in TEST()
136 EXPECT_EQ(std::vector<int>({}), getTasks(2, m)); in TEST()
137 EXPECT_EQ(std::vector<int>({50}), getTasks(3, m)); in TEST()
141 SessionTaskMap m; in TEST() local
142 EXPECT_EQ(nullptr, m.findSession(1)); in TEST()
146 SessionTaskMap m; in TEST() local
147 EXPECT_TRUE(m.add(1, makeSession(1000), {})); in TEST()
148 EXPECT_NE(nullptr, m.findSession(1)); in TEST()
152 SessionTaskMap m; in TEST() local
153 EXPECT_EQ(nullptr, m.findSession(1)); in TEST()
154 EXPECT_TRUE(m.add(1, makeSession(1000), {})); in TEST()
155 EXPECT_NE(nullptr, m.findSession(1)); in TEST()
156 EXPECT_TRUE(m.remove(1)); in TEST()
157 EXPECT_EQ(nullptr, m.findSession(1)); in TEST()
161 SessionTaskMap m; in TEST() local
162 EXPECT_EQ(0, m.sizeTasks()); in TEST()
163 EXPECT_TRUE(m.add(1, makeSession(1000), {10, 20, 30})); in TEST()
164 EXPECT_TRUE(m.add(2, makeSession(2000), {40, 50, 60})); in TEST()
165 EXPECT_EQ(6, m.sizeTasks()); in TEST()
169 SessionTaskMap m; in TEST() local
170 EXPECT_EQ(0, m.sizeSessions()); in TEST()
171 EXPECT_TRUE(m.add(1, makeSession(1000), {10, 20, 30})); in TEST()
172 EXPECT_TRUE(m.add(2, makeSession(2000), {40, 50, 60})); in TEST()
173 EXPECT_EQ(2, m.sizeSessions()); in TEST()
177 SessionTaskMap m; in TEST() local
180 EXPECT_TRUE(m.add(1, makeSession(1000), {10, 20, 30})); in TEST()
181 EXPECT_TRUE(m.add(2, makeSession(2000), {20})); in TEST()
186 m.replace(1, {10, 40}, &addedThreads, &removedThreads); in TEST()
195 SessionTaskMap m; in TEST() local
202 m.add(sessionId, sve, {10, 20, 30}); in TEST()
203 EXPECT_TRUE(m.isAnyAppSessionActive(tNow)); in TEST()
204 EXPECT_TRUE(m.remove(sessionId)); in TEST()
205 EXPECT_FALSE(m.isAnyAppSessionActive(tNow)); in TEST()
209 SessionTaskMap m; in TEST() local
212 EXPECT_FALSE(m.isAnyAppSessionActive(tNow)); in TEST()
222 EXPECT_TRUE(m.add(sessionId, sv, {10, 20, 30})); in TEST()
223 EXPECT_TRUE(m.isAnyAppSessionActive(tNow)); in TEST()
224 EXPECT_FALSE(m.isAnyAppSessionActive(tNow + 500ms)); in TEST()
227 int getVoteMin(const SessionTaskMap &m, int64_t taskId, std::chrono::steady_clock::time_point t) { in getVoteMin() argument
230 m.getTaskVoteRange(taskId, t, range, fakeEfficiencyParam, fakeEfficiencyParam); in getVoteMin()
235 SessionTaskMap m; in TEST() local
238 EXPECT_TRUE(m.add(1, makeSession(1000), {10})); in TEST()
246 m.addVote(1, 1, 111, voteMax, t0 + 20ns, 40ns); in TEST()
247 m.addVote(1, 2, 122, voteMax, t0 + 60ns, 25ns); in TEST()
248 m.addVote(1, 3, 133, voteMax, t0 + 60ns, 30ns); in TEST()
251 EXPECT_EQ(0, getVoteMin(m, 10, t0 + 0ns)); in TEST()
253 EXPECT_EQ(111, getVoteMin(m, 10, t0 + 20ns)); in TEST()
255 EXPECT_EQ(111, getVoteMin(m, 10, t0 + 35ns)); in TEST()
257 EXPECT_EQ(133, getVoteMin(m, 10, t0 + 60ns)); in TEST()
259 EXPECT_EQ(133, getVoteMin(m, 10, t0 + 61ns)); in TEST()
261 EXPECT_EQ(133, getVoteMin(m, 10, t0 + 86ns)); in TEST()
263 EXPECT_EQ(0, getVoteMin(m, 10, t0 + 91ns)); in TEST()
267 SessionTaskMap m; in TEST() local
269 EXPECT_TRUE(m.add(2, makeSession(2000), {20})); in TEST()
277 m.addVote(2, 1, 211, voteMax, t0 + 30ns, 25ns); in TEST()
278 m.addVote(2, 2, 222, voteMax, t0 + 100ns, 35ns); in TEST()
279 m.addVote(2, 3, 233, voteMax, t0 + 140ns, 40ns); in TEST()
282 EXPECT_EQ(0, getVoteMin(m, 20, t0 + 0ns)); in TEST()
284 EXPECT_EQ(211, getVoteMin(m, 20, t0 + 30ns)); in TEST()
286 EXPECT_EQ(222, getVoteMin(m, 20, t0 + 100ns)); in TEST()
288 EXPECT_EQ(233, getVoteMin(m, 20, t0 + 140ns)); in TEST()
290 EXPECT_EQ(0, getVoteMin(m, 20, t0 + 181ns)); in TEST()
295 SessionTaskMap m; in TEST() local
304 EXPECT_TRUE(m.add(1001, sv, {10, 20, 30})); in TEST()
314 EXPECT_TRUE(m.add(2001, sv, {10, 20, 30})); in TEST()
319 m.getTaskVoteRange(10, tNow + 10ns, uclampRange, fakeEfficiencyParam, fakeEfficiencyParam); in TEST()
322 auto sessItr = m.findSession(2001); in TEST()
328 m.getTaskVoteRange(10, tNow + 10ns, uclampRange, fakeEfficiencyParam, fakeEfficiencyParam); in TEST()
334 SessionTaskMap m; in TEST() local
344 EXPECT_TRUE(m.add(id, sv, {10, 20, 30})); in TEST()
349 m.addGpuVote(session_id1, gpu_vote_id, Cycles(222), now, 400ms); in TEST()
350 EXPECT_EQ(m.getSessionsGpuCapacity(now + 1ms), Cycles(222)); in TEST()
351 EXPECT_EQ(m.getSessionsGpuCapacity(now + 401ms), Cycles(0)); in TEST()
353 m.addGpuVote(session_id1, gpu_vote_id, Cycles(111), now, 100ms); in TEST()
354 EXPECT_EQ(m.getSessionsGpuCapacity(now + 1ms), Cycles(111)); in TEST()
355 EXPECT_EQ(m.getSessionsGpuCapacity(now + 101ms), Cycles(0)); in TEST()
357 m.addGpuVote(session_id2, gpu_vote_id, Cycles(555), now, 50ms); in TEST()
358 EXPECT_EQ(m.getSessionsGpuCapacity(now + 1ms), Cycles(555)); in TEST()
359 EXPECT_EQ(m.getSessionsGpuCapacity(now + 51ms), Cycles(111)); in TEST()
360 EXPECT_EQ(m.getSessionsGpuCapacity(now + 101ms), Cycles(0)); in TEST()
365 SessionTaskMap m; in TEST() local
377 EXPECT_TRUE(m.add(id, sv, {10, 20, 30})); in TEST()
382 m.addGpuVote(session_id1, capacity_vote_id, Cycles(222), now, 400ms); in TEST()
383 m.addGpuVote(session_id1, load_vote_id, Cycles(111), now, 100ms); in TEST()
384 EXPECT_EQ(m.getSessionsGpuCapacity(now + 1ms), Cycles(333)); in TEST()
385 EXPECT_EQ(m.getSessionsGpuCapacity(now + 101ms), Cycles(222)); in TEST()
386 EXPECT_EQ(m.getSessionsGpuCapacity(now + 401ms), Cycles(0)); in TEST()
388 m.addGpuVote(session_id2, capacity_vote_id, Cycles(321), now, 150ms); in TEST()
389 m.addGpuVote(session_id2, load_vote_id, Cycles(123), now, 50ms); in TEST()
390 EXPECT_EQ(m.getSessionsGpuCapacity(now + 1ms), Cycles(444)); in TEST()
391 EXPECT_EQ(m.getSessionsGpuCapacity(now + 51ms), Cycles(333)); in TEST()
392 EXPECT_EQ(m.getSessionsGpuCapacity(now + 151ms), Cycles(222)); in TEST()
396 SessionTaskMap m; in TEST() local
398 m.add(2, entry, {20}); in TEST()
400 m.add(3, entry, {30}); in TEST()
409 m.addVote(2, 1, baseVote.uclampMin, baseVote.uclampMax, t0, 400ns); in TEST()
410 m.addVote(3, 1, baseVote.uclampMin, baseVote.uclampMax, t0, 400ns); in TEST()
413 m.getTaskVoteRange(30, t0 + 10ns, range, maxEfficientBase, maxEfficientOffset); in TEST()
418 m.getTaskVoteRange(30, t0 + 800ns, range, maxEfficientBase, maxEfficientOffset); in TEST()
423 m.getTaskVoteRange(20, t0 + 10ns, range, maxEfficientBase, maxEfficientOffset); in TEST()
428 m.getTaskVoteRange(20, t0 + 800ns, range, maxEfficientBase, maxEfficientOffset); in TEST()