retro_cpu/debug_interface.cc at master · achaulk/retro_cpu · GitHub

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
#include "debug_interface.h"

DebugInterface::DebugInterface(EmulatedCpu *cpu, EventQueue *events, SystemBus *bus, bool cross_thread)
	: bus(bus), events(events), cpu(cpu)
{
	if(!cross_thread)
		pause = 1;
	breakpoints_pause = cross_thread;
}

DebugInterface::~DebugInterface() {}

void DebugInterface::PausedFunc()
{
	std::unique_lock<std::mutex> l(pause_lock);
	pause_response = true;
	pause_wait_var.notify_all();
	while(pause) {
		pause_var.wait(l);
	}
	pause_response = false;
	pause_wait_var.notify_all();
}

void DebugInterface::SingleStepFunc()
{
	{
		std::unique_lock<std::mutex> l(pause_lock);
		step_pending = false;
		pause++;
	}
	PausedFunc();
}

void DebugInterface::Pause(bool schedule_event)
{
	std::unique_lock<std::mutex> l(pause_lock);
	if(pause++)
		return;
	if(schedule_event)
		events->Schedule(0, std::bind(&DebugInterface::PausedFunc, this));
	while(!pause_response) {
		pause_wait_var.wait(l);
	}
}

void DebugInterface::Resume()
{
	std::unique_lock<std::mutex> l(pause_lock);
	if(--pause)
		return;
	pause_var.notify_all();
	while(pause_response && !pause) {
		pause_wait_var.wait(l);
	}
}

void DebugInterface::SingleStep(uint32_t n_clocks)
{
	// The CPU is paused here
	if(!step_pending) {
		step_pending = true;
		events->ScheduleNoLock(cpu->GetCpuState()->cycle + n_clocks,
			std::bind(&DebugInterface::SingleStepFunc, this));
	}
	Resume();

	// Wait for the run thread to pause
	std::unique_lock<std::mutex> l(pause_lock);
	while(!pause_response) {
		pause_wait_var.wait(l);
	}
}

void DebugInterface::SetBreakpoint(cpuaddr_t addr, std::function<void(EmulatedCpu*)> fn, bool pause_on_hit)
{
	std::function<void(EmulatedCpu*)> bp_fn =
		[this, pause_on_hit, moved_fn{std::move(fn)}](EmulatedCpu *cpu) {
			bool was_stepping;
			{
				std::unique_lock<std::mutex> l(pause_lock);
				was_stepping = step_pending;
				if(breakpoints_pause && !was_stepping)
					++pause;
			}
			if(moved_fn)
				moved_fn(cpu);
			// Note: if the client called Resume() prematurely, this will result in a no-op because
			// Resume will set pause to 0, see pause_response == false and return, and PausedFunc
			// will see pause == 0 and return
			if(pause_on_hit && breakpoints_pause && !was_stepping) {
				PausedFunc();
			} else {
				std::unique_lock<std::mutex> l(pause_lock);
				--pause;
			}
		};
	if(pause)
		cpu->AddBreakpoint(addr, std::move(bp_fn));
	else
		events->Schedule(0, std::bind(&EmulatedCpu::AddBreakpoint, cpu, addr, std::move(bp_fn)));
}

void DebugInterface::ClearBreakpoint(cpuaddr_t addr)
{
	if(pause)
		cpu->RemoveBreakpoint(addr);
	else
		events->Schedule(0, std::bind(&EmulatedCpu::RemoveBreakpoint, cpu, (cpuaddr_t)addr));
}