Compare commits
3 Commits
a2d2a84850
...
f130d1991c
| Author | SHA1 | Date |
|---|---|---|
 Rekai Nyangadzayi Musuka
|
f130d1991c | |
|
Rekai Nyangadzayi Musuka
|
24a8905c29 | |
|
Rekai Nyangadzayi Musuka
|
e70fe73899 |
216
src/apu.zig
216
src/apu.zig
|
|
@ -53,7 +53,7 @@ pub const Apu = struct {
|
|||
.bias = .{ .raw = 0x0200 },
|
||||
|
||||
.sampling_cycle = 0b00,
|
||||
.stream = SDL.SDL_NewAudioStream(SDL.AUDIO_F32, 2, 1 << 15, SDL.AUDIO_F32, 2, host_sample_rate) orelse unreachable,
|
||||
.stream = SDL.SDL_NewAudioStream(SDL.AUDIO_U16, 2, 1 << 15, SDL.AUDIO_U16, 2, host_sample_rate) orelse unreachable,
|
||||
.sched = sched,
|
||||
|
||||
.capacitor = 0,
|
||||
|
|
@ -133,64 +133,60 @@ pub const Apu = struct {
|
|||
}
|
||||
|
||||
pub fn sampleAudio(self: *Self, late: u64) void {
|
||||
// zig fmt: off
|
||||
const any_ch_enabled = self.ch1.enabled
|
||||
or self.ch2.enabled
|
||||
or self.ch3.enabled
|
||||
or self.ch4.enabled;
|
||||
// zig fmt: on
|
||||
var left: i16 = 0;
|
||||
var right: i16 = 0;
|
||||
|
||||
// SOUNDCNT_L Channel Enable flags
|
||||
const ch_left: u4 = self.psg_cnt.ch_left.read();
|
||||
const ch_right: u4 = self.psg_cnt.ch_right.read();
|
||||
|
||||
// FIXME: Obscure behaviour?
|
||||
// Apply NR50 Volume Modifications
|
||||
const left_master_vol = (@intToFloat(f32, self.psg_cnt.left_vol.read()) + 1.0) / 7.0;
|
||||
const right_master_vol = (@intToFloat(f32, self.psg_cnt.right_vol.read()) + 1.0) / 7.0;
|
||||
|
||||
// Apply SOUNDCNT_H Volume Modifications
|
||||
const gba_vol: f32 = switch (self.dma_cnt.ch_vol.read()) {
|
||||
0b00 => 0.25,
|
||||
0b01 => 0.5,
|
||||
0b10 => 0.75,
|
||||
0b11 => 0.0,
|
||||
// Determine SOUNDCNT_H volume modifications
|
||||
const gba_vol: u4 = switch (self.dma_cnt.ch_vol.read()) {
|
||||
0b00 => 2,
|
||||
0b01 => 1,
|
||||
else => 0,
|
||||
};
|
||||
|
||||
// Sample Channel 1
|
||||
const ch1_sample = self.highPass(self.ch1.amplitude(), any_ch_enabled);
|
||||
const ch1_left = if (ch_left & 1 == 1) ch1_sample else 0;
|
||||
const ch1_right = if (ch_right & 1 == 1) ch1_sample else 0;
|
||||
// Add all PSG channels together
|
||||
left += if (ch_left & 1 == 1) self.ch1.amplitude() else 0;
|
||||
left += if (ch_left >> 1 & 1 == 1) self.ch2.amplitude() else 0;
|
||||
left += if (ch_left >> 2 & 1 == 1) self.ch3.amplitude() else 0;
|
||||
left += if (ch_left >> 3 == 1) self.ch4.amplitude() else 0;
|
||||
|
||||
// Sample Channel 2
|
||||
const ch2_sample = self.highPass(self.ch2.amplitude(), any_ch_enabled);
|
||||
const ch2_left = if (ch_left >> 1 & 1 == 1) ch2_sample else 0;
|
||||
const ch2_right = if (ch_right >> 1 & 1 == 1) ch2_sample else 0;
|
||||
right += if (ch_right & 1 == 1) self.ch1.amplitude() else 0;
|
||||
right += if (ch_right >> 1 & 1 == 1) self.ch2.amplitude() else 0;
|
||||
right += if (ch_right >> 2 & 1 == 1) self.ch3.amplitude() else 0;
|
||||
right += if (ch_right >> 3 == 1) self.ch4.amplitude() else 0;
|
||||
|
||||
// Sample Channel 3
|
||||
const ch3_sample = self.highPass(self.ch3.amplitude(), any_ch_enabled);
|
||||
const ch3_left = if (ch_left >> 2 & 1 == 1) ch3_sample else 0;
|
||||
const ch3_right = if (ch_right >> 2 & 1 == 1) ch3_sample else 0;
|
||||
// Multiply by master channel volume
|
||||
left *= 1 + @as(i16, self.psg_cnt.left_vol.read());
|
||||
right *= 1 + @as(i16, self.psg_cnt.right_vol.read());
|
||||
|
||||
// Sample Channel 4
|
||||
const ch4_sample = self.highPass(self.ch4.amplitude(), any_ch_enabled);
|
||||
const ch4_left = if (ch_left >> 3 == 1) ch4_sample else 0;
|
||||
const ch4_right = if (ch_right >> 3 == 1) ch4_sample else 0;
|
||||
// Apply GBA volume modifications to PSG Channels
|
||||
left >>= gba_vol;
|
||||
right >>= gba_vol;
|
||||
|
||||
const psg_left = (ch1_left + ch2_left + ch3_left + ch4_left) * left_master_vol * gba_vol;
|
||||
const psg_right = (ch1_right + ch2_right + ch3_right + ch4_right) * right_master_vol * gba_vol;
|
||||
const chA_sample = self.chA.amplitude() << if (self.dma_cnt.chA_vol.read()) @as(u4, 2) else 1;
|
||||
const chB_sample = self.chB.amplitude() << if (self.dma_cnt.chB_vol.read()) @as(u4, 2) else 1;
|
||||
|
||||
// Sample Dma Channels
|
||||
const chA_sample = if (self.dma_cnt.chA_vol.read()) self.chA.amplitude() * 4 else self.chA.amplitude() * 2;
|
||||
const chA_left = if (self.dma_cnt.chA_left.read()) chA_sample else 0;
|
||||
const chA_right = if (self.dma_cnt.chA_right.read()) chA_sample else 0;
|
||||
left += if (self.dma_cnt.chA_left.read()) chA_sample else 0;
|
||||
left += if (self.dma_cnt.chB_left.read()) chB_sample else 0;
|
||||
|
||||
const chB_sample = if (self.dma_cnt.chB_vol.read()) self.chB.amplitude() * 4 else self.chB.amplitude() * 2;
|
||||
const chB_left = if (self.dma_cnt.chB_left.read()) chB_sample else 0;
|
||||
const chB_right = if (self.dma_cnt.chB_right.read()) chB_sample else 0;
|
||||
right += if (self.dma_cnt.chA_right.read()) chA_sample else 0;
|
||||
right += if (self.dma_cnt.chB_right.read()) chB_sample else 0;
|
||||
|
||||
// Mix all Channels
|
||||
const left = (chA_left + chB_left + psg_left) / 6.0;
|
||||
const right = (chA_right + chB_right + psg_right) / 6.0;
|
||||
// Add SOUNDBIAS
|
||||
// FIXME: Is SOUNDBIAS 9-bit or 10-bit?
|
||||
const bias = @as(i16, self.bias.level.read()) << 1;
|
||||
left += bias;
|
||||
right += bias;
|
||||
|
||||
const tmp_left = std.math.clamp(@intCast(u16, left), std.math.minInt(u11), std.math.maxInt(u11));
|
||||
const tmp_right = std.math.clamp(@intCast(u16, left), std.math.minInt(u11), std.math.maxInt(u11));
|
||||
|
||||
// Extend to 16-bit signed audio samples
|
||||
const final_left = (tmp_left << 5) | (tmp_left >> 6);
|
||||
const final_right = (tmp_right << 5) | (tmp_right >> 6);
|
||||
|
||||
if (self.sampling_cycle != self.bias.sampling_cycle.read()) {
|
||||
log.info("Sampling Cycle changed from {} to {}", .{ self.sampling_cycle, self.bias.sampling_cycle.read() });
|
||||
|
|
@ -201,15 +197,90 @@ pub const Apu = struct {
|
|||
defer SDL.SDL_FreeAudioStream(old);
|
||||
|
||||
self.sampling_cycle = self.bias.sampling_cycle.read();
|
||||
self.stream = SDL.SDL_NewAudioStream(SDL.AUDIO_F32, 2, @intCast(c_int, self.sampleRate()), SDL.AUDIO_F32, 2, host_sample_rate) orelse unreachable;
|
||||
self.stream = SDL.SDL_NewAudioStream(SDL.AUDIO_U16, 2, @intCast(c_int, self.sampleRate()), SDL.AUDIO_U16, 2, host_sample_rate) orelse unreachable;
|
||||
}
|
||||
|
||||
while (SDL.SDL_AudioStreamAvailable(self.stream) > (@sizeOf(f32) * 2 * 0x800)) {}
|
||||
|
||||
_ = SDL.SDL_AudioStreamPut(self.stream, &[2]f32{ left, right }, 2 * @sizeOf(f32));
|
||||
_ = SDL.SDL_AudioStreamPut(self.stream, &[2]u16{ final_left, final_right }, 2 * @sizeOf(u16));
|
||||
self.sched.push(.SampleAudio, self.sampleTicks() -| late);
|
||||
}
|
||||
|
||||
// pub fn sampleAudio(self: *Self, late: u64) void {
|
||||
// // zig fmt: off
|
||||
// const any_ch_enabled = self.ch1.enabled
|
||||
// or self.ch2.enabled
|
||||
// or self.ch3.enabled
|
||||
// or self.ch4.enabled;
|
||||
// // zig fmt: on
|
||||
|
||||
// const ch_left: u4 = self.psg_cnt.ch_left.read();
|
||||
// const ch_right: u4 = self.psg_cnt.ch_right.read();
|
||||
|
||||
// // FIXME: Obscure behaviour?
|
||||
// // Apply NR50 Volume Modifications
|
||||
// const left_master_vol = (@intToFloat(f32, self.psg_cnt.left_vol.read()) + 1.0) / 7.0;
|
||||
// const right_master_vol = (@intToFloat(f32, self.psg_cnt.right_vol.read()) + 1.0) / 7.0;
|
||||
|
||||
// // Apply SOUNDCNT_H Volume Modifications
|
||||
// const gba_vol: f32 = switch (self.dma_cnt.ch_vol.read()) {
|
||||
// 0b00 => 0.25,
|
||||
// 0b01 => 0.5,
|
||||
// else => 1.0,
|
||||
// };
|
||||
|
||||
// // Sample Channel 1
|
||||
// const ch1_sample = self.highPass(self.ch1.amplitude(), any_ch_enabled);
|
||||
// const ch1_left = if (ch_left & 1 == 1) ch1_sample else 0;
|
||||
// const ch1_right = if (ch_right & 1 == 1) ch1_sample else 0;
|
||||
|
||||
// // Sample Channel 2
|
||||
// const ch2_sample = self.highPass(self.ch2.amplitude(), any_ch_enabled);
|
||||
// const ch2_left = if (ch_left >> 1 & 1 == 1) ch2_sample else 0;
|
||||
// const ch2_right = if (ch_right >> 1 & 1 == 1) ch2_sample else 0;
|
||||
|
||||
// // Sample Channel 3
|
||||
// const ch3_sample = self.highPass(self.ch3.amplitude(), any_ch_enabled);
|
||||
// const ch3_left = if (ch_left >> 2 & 1 == 1) ch3_sample else 0;
|
||||
// const ch3_right = if (ch_right >> 2 & 1 == 1) ch3_sample else 0;
|
||||
|
||||
// // Sample Channel 4
|
||||
// const ch4_sample = self.highPass(self.ch4.amplitude(), any_ch_enabled);
|
||||
// const ch4_left = if (ch_left >> 3 == 1) ch4_sample else 0;
|
||||
// const ch4_right = if (ch_right >> 3 == 1) ch4_sample else 0;
|
||||
|
||||
// const psg_left = (ch1_left + ch2_left + ch3_left + ch4_left) * left_master_vol * gba_vol;
|
||||
// const psg_right = (ch1_right + ch2_right + ch3_right + ch4_right) * right_master_vol * gba_vol;
|
||||
|
||||
// // Sample Dma Channels
|
||||
// const chA_sample = if (self.dma_cnt.chA_vol.read()) self.chA.amplitude() * 4 else self.chA.amplitude() * 2;
|
||||
// const chA_left = if (self.dma_cnt.chA_left.read()) chA_sample else 0;
|
||||
// const chA_right = if (self.dma_cnt.chA_right.read()) chA_sample else 0;
|
||||
|
||||
// const chB_sample = if (self.dma_cnt.chB_vol.read()) self.chB.amplitude() * 4 else self.chB.amplitude() * 2;
|
||||
// const chB_left = if (self.dma_cnt.chB_left.read()) chB_sample else 0;
|
||||
// const chB_right = if (self.dma_cnt.chB_right.read()) chB_sample else 0;
|
||||
|
||||
// // Mix all Channels
|
||||
// const left = (chA_left + chB_left + psg_left) / 6.0;
|
||||
// const right = (chA_right + chB_right + psg_right) / 6.0;
|
||||
|
||||
// if (self.sampling_cycle != self.bias.sampling_cycle.read()) {
|
||||
// log.info("Sampling Cycle changed from {} to {}", .{ self.sampling_cycle, self.bias.sampling_cycle.read() });
|
||||
|
||||
// // Sample Rate Changed, Create a new Resampler since i can't figure out how to change
|
||||
// // the parameters of the old one
|
||||
// const old = self.stream;
|
||||
// defer SDL.SDL_FreeAudioStream(old);
|
||||
|
||||
// self.sampling_cycle = self.bias.sampling_cycle.read();
|
||||
// self.stream = SDL.SDL_NewAudioStream(SDL.AUDIO_F32, 2, @intCast(c_int, self.sampleRate()), SDL.AUDIO_F32, 2, host_sample_rate) orelse unreachable;
|
||||
// }
|
||||
|
||||
// while (SDL.SDL_AudioStreamAvailable(self.stream) > (@sizeOf(f32) * 2 * 0x800)) {}
|
||||
|
||||
// _ = SDL.SDL_AudioStreamPut(self.stream, &[2]f32{ left, right }, 2 * @sizeOf(f32));
|
||||
// self.sched.push(.SampleAudio, self.sampleTicks() -| late);
|
||||
// }
|
||||
|
||||
fn sampleTicks(self: *const Self) u64 {
|
||||
return (1 << 24) / self.sampleRate();
|
||||
}
|
||||
|
|
@ -296,7 +367,7 @@ const ToneSweep = struct {
|
|||
square: SquareWave,
|
||||
enabled: bool,
|
||||
|
||||
sample: u8,
|
||||
sample: i8,
|
||||
|
||||
const SweepDevice = struct {
|
||||
const This = @This();
|
||||
|
|
@ -389,11 +460,11 @@ const ToneSweep = struct {
|
|||
|
||||
self.sample = 0;
|
||||
if (!self.isDacEnabled()) return;
|
||||
self.sample = if (self.enabled) self.square.sample(self.duty) * self.env_dev.vol else 0;
|
||||
self.sample = if (self.enabled) self.square.sample(self.duty) * @as(i8, self.env_dev.vol) else 0;
|
||||
}
|
||||
|
||||
fn amplitude(self: *const Self) f32 {
|
||||
return (@intToFloat(f32, self.sample) / 7.5) - 1.0;
|
||||
fn amplitude(self: *const Self) i16 {
|
||||
return @as(i16, self.sample);
|
||||
}
|
||||
|
||||
/// NR11, NR12
|
||||
|
|
@ -484,7 +555,7 @@ const Tone = struct {
|
|||
square: SquareWave,
|
||||
|
||||
enabled: bool,
|
||||
sample: u8,
|
||||
sample: i8,
|
||||
|
||||
fn init(sched: *Scheduler) Self {
|
||||
return .{
|
||||
|
|
@ -523,11 +594,11 @@ const Tone = struct {
|
|||
|
||||
self.sample = 0;
|
||||
if (!self.isDacEnabled()) return;
|
||||
self.sample = if (self.enabled) self.square.sample(self.duty) * self.env_dev.vol else 0;
|
||||
self.sample = if (self.enabled) self.square.sample(self.duty) * @as(i8, self.env_dev.vol) else 0;
|
||||
}
|
||||
|
||||
fn amplitude(self: *const Self) f32 {
|
||||
return (@intToFloat(f32, self.sample) / 7.5) - 1.0;
|
||||
fn amplitude(self: *const Self) i16 {
|
||||
return @as(i16, self.sample);
|
||||
}
|
||||
|
||||
/// NR21, NR22
|
||||
|
|
@ -609,7 +680,7 @@ const Wave = struct {
|
|||
wave_dev: WaveDevice,
|
||||
|
||||
enabled: bool,
|
||||
sample: u8,
|
||||
sample: i8,
|
||||
|
||||
fn init(sched: *Scheduler) Self {
|
||||
return .{
|
||||
|
|
@ -696,11 +767,12 @@ const Wave = struct {
|
|||
|
||||
self.sample = 0;
|
||||
if (!self.select.enabled.read()) return;
|
||||
self.sample = if (self.enabled) self.wave_dev.sample(self.select) >> self.wave_dev.shift(self.vol) else 0;
|
||||
// Convert unsigned 4-bit wave sample to signed 8-bit sample
|
||||
self.sample = (2 * @as(i8, self.wave_dev.sample(self.select)) - 15) >> self.wave_dev.shift(self.vol);
|
||||
}
|
||||
|
||||
fn amplitude(self: *const Self) f32 {
|
||||
return (@intToFloat(f32, self.sample) / 7.5) - 1.0;
|
||||
fn amplitude(self: *const Self) i16 {
|
||||
return @as(i16, self.sample);
|
||||
}
|
||||
};
|
||||
|
||||
|
|
@ -727,7 +799,7 @@ const Noise = struct {
|
|||
lfsr: Lfsr,
|
||||
|
||||
enabled: bool,
|
||||
sample: u8,
|
||||
sample: i8,
|
||||
|
||||
fn init(sched: *Scheduler) Self {
|
||||
return .{
|
||||
|
|
@ -821,11 +893,11 @@ const Noise = struct {
|
|||
|
||||
self.sample = 0;
|
||||
if (!self.isDacEnabled()) return;
|
||||
self.sample = if (self.enabled) self.lfsr.sample() * self.env_dev.vol else 0;
|
||||
self.sample = if (self.enabled) self.lfsr.sample() * @as(i8, self.env_dev.vol) else 0;
|
||||
}
|
||||
|
||||
fn amplitude(self: *const Self) f32 {
|
||||
return (@intToFloat(f32, self.sample) / 7.5) - 1.0;
|
||||
fn amplitude(self: *const Self) i16 {
|
||||
return @as(i16, self.sample);
|
||||
}
|
||||
|
||||
fn isDacEnabled(self: *const Self) bool {
|
||||
|
|
@ -861,8 +933,8 @@ pub fn DmaSound(comptime kind: DmaSoundKind) type {
|
|||
if (self.fifo.readItem()) |sample| self.sample = @bitCast(i8, sample);
|
||||
}
|
||||
|
||||
pub fn amplitude(self: *const Self) f32 {
|
||||
return @intToFloat(f32, self.sample) / 127.5 - (1 / 255);
|
||||
pub fn amplitude(self: *const Self) i16 {
|
||||
return @as(i16, self.sample);
|
||||
}
|
||||
};
|
||||
}
|
||||
|
|
@ -1100,7 +1172,7 @@ const SquareWave = struct {
|
|||
self.sched.push(.{ .ApuChannel = if (kind == .Ch1) 0 else 1 }, @as(u64, self.timer) * tickInterval);
|
||||
}
|
||||
|
||||
fn sample(self: *const Self, cnt: io.Duty) u1 {
|
||||
fn sample(self: *const Self, cnt: io.Duty) i8 {
|
||||
const pattern = cnt.pattern.read();
|
||||
|
||||
const i = self.pos ^ 7; // index of 0 should get highest bit
|
||||
|
|
@ -1111,7 +1183,7 @@ const SquareWave = struct {
|
|||
0b11 => @as(u8, 0b11111100) >> i, // 75%
|
||||
};
|
||||
|
||||
return @truncate(u1, result);
|
||||
return if (result & 1 == 1) 1 else -1;
|
||||
}
|
||||
};
|
||||
|
||||
|
|
@ -1133,8 +1205,8 @@ const Lfsr = struct {
|
|||
};
|
||||
}
|
||||
|
||||
fn sample(self: *const Self) u1 {
|
||||
return @truncate(u1, ~self.shift);
|
||||
fn sample(self: *const Self) i8 {
|
||||
return if ((~self.shift & 1) == 1) 1 else -1;
|
||||
}
|
||||
|
||||
fn updateLength(_: *Self, fs: *const FrameSequencer, ch4: *Noise, new: io.NoiseControl) void {
|
||||
|
|
|
|||
87
src/emu.zig
87
src/emu.zig
|
|
@ -1,14 +1,17 @@
|
|||
const std = @import("std");
|
||||
const SDL = @import("sdl2");
|
||||
|
||||
const Bus = @import("Bus.zig");
|
||||
const Scheduler = @import("scheduler.zig").Scheduler;
|
||||
const Arm7tdmi = @import("cpu.zig").Arm7tdmi;
|
||||
const EmulatorFps = @import("util.zig").EmulatorFps;
|
||||
const FpsTracker = @import("util.zig").FpsTracker;
|
||||
|
||||
const Timer = std.time.Timer;
|
||||
const Thread = std.Thread;
|
||||
const Atomic = std.atomic.Atomic;
|
||||
|
||||
const audio_sync = true;
|
||||
|
||||
// 228 Lines which consist of 308 dots (which are 4 cycles long)
|
||||
const cycles_per_frame: u64 = 228 * (308 * 4); //280896
|
||||
const clock_rate: u64 = 1 << 24; // 16.78MHz
|
||||
|
|
@ -32,7 +35,9 @@ const RunKind = enum {
|
|||
LimitedBusy,
|
||||
};
|
||||
|
||||
pub fn run(kind: RunKind, quit: *Atomic(bool), fps: *EmulatorFps, sched: *Scheduler, cpu: *Arm7tdmi) void {
|
||||
pub fn run(kind: RunKind, quit: *Atomic(bool), fps: *FpsTracker, sched: *Scheduler, cpu: *Arm7tdmi) void {
|
||||
if (audio_sync) log.info("Audio sync enabled", .{});
|
||||
|
||||
switch (kind) {
|
||||
.Unlimited => runUnsynchronized(quit, sched, cpu, null),
|
||||
.Limited => runSynchronized(quit, sched, cpu, null),
|
||||
|
|
@ -56,50 +61,78 @@ pub fn runFrame(sched: *Scheduler, cpu: *Arm7tdmi) void {
|
|||
}
|
||||
}
|
||||
|
||||
pub fn runUnsynchronized(quit: *Atomic(bool), sched: *Scheduler, cpu: *Arm7tdmi, fps: ?*EmulatorFps) void {
|
||||
fn syncToAudio(cpu: *const Arm7tdmi) void {
|
||||
const stream = cpu.bus.apu.stream;
|
||||
const min_sample_count = 0x800;
|
||||
|
||||
// Busy Loop while we wait for the Audio system to catch up
|
||||
while (SDL.SDL_AudioStreamAvailable(stream) > (@sizeOf(u16) * 2) * min_sample_count) {}
|
||||
}
|
||||
|
||||
pub fn runUnsynchronized(quit: *Atomic(bool), sched: *Scheduler, cpu: *Arm7tdmi, fps: ?*FpsTracker) void {
|
||||
log.info("Emulation thread w/out video sync", .{});
|
||||
|
||||
if (fps) |tracker| {
|
||||
log.info("Start unsynchronized emu thread w/ fps tracking", .{});
|
||||
log.info("FPS Tracking Enabled", .{});
|
||||
|
||||
while (!quit.load(.SeqCst)) {
|
||||
runFrame(sched, cpu);
|
||||
if (audio_sync) syncToAudio(cpu);
|
||||
|
||||
tracker.completeFrame();
|
||||
}
|
||||
} else {
|
||||
log.info("Start unsynchronized emu thread", .{});
|
||||
while (!quit.load(.SeqCst)) runFrame(sched, cpu);
|
||||
while (!quit.load(.SeqCst)) {
|
||||
runFrame(sched, cpu);
|
||||
if (audio_sync) syncToAudio(cpu);
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
pub fn runSynchronized(quit: *Atomic(bool), sched: *Scheduler, cpu: *Arm7tdmi, fps: ?*EmulatorFps) void {
|
||||
pub fn runSynchronized(quit: *Atomic(bool), sched: *Scheduler, cpu: *Arm7tdmi, fps: ?*FpsTracker) void {
|
||||
log.info("Emulation thread w/ video sync", .{});
|
||||
var timer = Timer.start() catch unreachable;
|
||||
var wake_time: u64 = frame_period;
|
||||
|
||||
if (fps) |tracker| {
|
||||
log.info("Start synchronized emu thread w/ fps tracking", .{});
|
||||
log.info("FPS Tracking Enabled", .{});
|
||||
|
||||
while (!quit.load(.SeqCst)) {
|
||||
runSyncCore(sched, cpu, &timer, &wake_time);
|
||||
runFrame(sched, cpu);
|
||||
const new_wake_time = syncToVideo(&timer, wake_time);
|
||||
|
||||
// Spin to make up the difference of OS scheduler innacuracies
|
||||
// If we happen to also be syncing to audio, we choose to spin on
|
||||
// the amount of time needed for audio to catch up rather than
|
||||
// our expected wake-up time
|
||||
if (audio_sync) syncToAudio(cpu) else spinLoop(&timer, wake_time);
|
||||
wake_time = new_wake_time;
|
||||
|
||||
tracker.completeFrame();
|
||||
}
|
||||
} else {
|
||||
log.info("Start synchronized emu thread", .{});
|
||||
while (!quit.load(.SeqCst)) runSyncCore(sched, cpu, &timer, &wake_time);
|
||||
while (!quit.load(.SeqCst)) {
|
||||
runFrame(sched, cpu);
|
||||
const new_wake_time = syncToVideo(&timer, wake_time);
|
||||
// see above comment
|
||||
if (audio_sync) syncToAudio(cpu) else spinLoop(&timer, wake_time);
|
||||
|
||||
wake_time = new_wake_time;
|
||||
}
|
||||
}
|
||||
}
|
||||
|
||||
inline fn runSyncCore(sched: *Scheduler, cpu: *Arm7tdmi, timer: *Timer, wake_time: *u64) void {
|
||||
runFrame(sched, cpu);
|
||||
inline fn syncToVideo(timer: *Timer, wake_time: u64) u64 {
|
||||
// Use the OS scheduler to put the emulation thread to sleep
|
||||
const maybe_recalc_wake_time = sleep(timer, wake_time);
|
||||
|
||||
// Put the Thread to Sleep + Backup Spin Loop
|
||||
// This saves on resource usage when frame limiting
|
||||
sleep(timer, wake_time);
|
||||
|
||||
// Update to the new wake time
|
||||
wake_time.* += frame_period;
|
||||
// If sleep() determined we need to adjust our wake up time, do so
|
||||
// otherwise predict our next wake up time according to the frame period
|
||||
return if (maybe_recalc_wake_time) |recalc| recalc else wake_time + frame_period;
|
||||
}
|
||||
|
||||
pub fn runBusyLoop(quit: *Atomic(bool), sched: *Scheduler, cpu: *Arm7tdmi) void {
|
||||
log.info("Start synchronized emu thread using busy loop", .{});
|
||||
log.info("Emulation thread with video sync using busy loop", .{});
|
||||
var timer = Timer.start() catch unreachable;
|
||||
var wake_time: u64 = frame_period;
|
||||
|
||||
|
|
@ -112,21 +145,17 @@ pub fn runBusyLoop(quit: *Atomic(bool), sched: *Scheduler, cpu: *Arm7tdmi) void
|
|||
}
|
||||
}
|
||||
|
||||
fn sleep(timer: *Timer, wake_time: *u64) void {
|
||||
fn sleep(timer: *Timer, wake_time: u64) ?u64 {
|
||||
// const step = std.time.ns_per_ms * 10; // 10ms
|
||||
const timestamp = timer.read();
|
||||
|
||||
// ns_late is non zero if we are late.
|
||||
const ns_late = timestamp -| wake_time.*;
|
||||
const ns_late = timestamp -| wake_time;
|
||||
|
||||
// If we're more than a frame late, skip the rest of this loop
|
||||
// Recalculate what our new wake time should be so that we can
|
||||
// get "back on track"
|
||||
if (ns_late > frame_period) {
|
||||
wake_time.* = timestamp + frame_period;
|
||||
return;
|
||||
}
|
||||
|
||||
if (ns_late > frame_period) return timestamp + frame_period;
|
||||
const sleep_for = frame_period - ns_late;
|
||||
|
||||
// // Employ several sleep calls in periods of 10ms
|
||||
|
|
@ -139,9 +168,7 @@ fn sleep(timer: *Timer, wake_time: *u64) void {
|
|||
|
||||
std.time.sleep(sleep_for);
|
||||
|
||||
// Spin to make up the difference if there is a need
|
||||
// Make sure that we're using the old wake time and not the onne we recalculated
|
||||
spinLoop(timer, wake_time.*);
|
||||
return null;
|
||||
}
|
||||
|
||||
fn spinLoop(timer: *Timer, wake_time: u64) void {
|
||||
|
|
|
|||
131
src/main.zig
131
src/main.zig
|
|
@ -9,7 +9,7 @@ const Bus = @import("Bus.zig");
|
|||
const Apu = @import("apu.zig").Apu;
|
||||
const Arm7tdmi = @import("cpu.zig").Arm7tdmi;
|
||||
const Scheduler = @import("scheduler.zig").Scheduler;
|
||||
const EmulatorFps = @import("util.zig").EmulatorFps;
|
||||
const FpsTracker = @import("util.zig").FpsTracker;
|
||||
|
||||
const Timer = std.time.Timer;
|
||||
const Thread = std.Thread;
|
||||
|
|
@ -31,65 +31,61 @@ pub const log_level = if (builtin.mode != .Debug) .info else std.log.default_lev
|
|||
|
||||
const asString = @import("util.zig").asString;
|
||||
|
||||
// CLI Arguments + Help Text
|
||||
const params = clap.parseParamsComptime(
|
||||
\\-h, --help Display this help and exit.
|
||||
\\-b, --bios <str> Optional path to a GBA BIOS ROM.
|
||||
\\<str> Path to the GBA GamePak ROM
|
||||
\\
|
||||
);
|
||||
|
||||
pub fn main() anyerror!void {
|
||||
// Allocator for Emulator + CLI
|
||||
var gpa = std.heap.GeneralPurposeAllocator(.{}){};
|
||||
const alloc = gpa.allocator();
|
||||
defer std.debug.assert(!gpa.deinit());
|
||||
const alloc = gpa.allocator();
|
||||
|
||||
// CLI Arguments
|
||||
const params = comptime clap.parseParamsComptime(
|
||||
\\-h, --help Display this help and exit.
|
||||
\\-b, --bios <str> Optional path to a GBA BIOS ROM.
|
||||
\\<str> Path to the GBA GamePak ROM
|
||||
\\
|
||||
);
|
||||
|
||||
// Setup CLI using zig-clap
|
||||
var res = try clap.parse(clap.Help, ¶ms, clap.parsers.default, .{});
|
||||
defer res.deinit();
|
||||
|
||||
const stderr = std.io.getStdErr();
|
||||
defer stderr.close();
|
||||
|
||||
// Display Help, if requested
|
||||
// Grab ROM and BIOS paths if provided
|
||||
if (res.args.help) return clap.help(stderr.writer(), clap.Help, ¶ms, .{});
|
||||
const rom_path = try getRomPath(res, stderr);
|
||||
const bios_path: ?[]const u8 = if (res.args.bios) |p| p else null;
|
||||
|
||||
const rom_path = switch (res.positionals.len) {
|
||||
1 => res.positionals[0],
|
||||
0 => {
|
||||
try stderr.writeAll("ZBA requires a positional path to a GamePak ROM.\n");
|
||||
return CliError.InsufficientOptions;
|
||||
},
|
||||
else => {
|
||||
try stderr.writeAll("ZBA received too many arguments.\n");
|
||||
return CliError.UnneededOptions;
|
||||
},
|
||||
};
|
||||
|
||||
// Determine Save Directory
|
||||
const save_dir = try setupSavePath(alloc);
|
||||
const save_dir = try getSavePath(alloc);
|
||||
defer if (save_dir) |path| alloc.free(path);
|
||||
log.info("Found save directory: {s}", .{save_dir});
|
||||
|
||||
// Initialize SDL
|
||||
_ = initSdl2();
|
||||
defer SDL.SDL_Quit();
|
||||
|
||||
// Initialize Emulator
|
||||
// Initialize Scheduler and ARM7TDMI Emulator
|
||||
// Provide GBA Bus (initialized with ARM7TDMI) with a valid ptr to ARM7TDMI
|
||||
var scheduler = Scheduler.init(alloc);
|
||||
defer scheduler.deinit();
|
||||
|
||||
const paths = .{ .bios = bios_path, .rom = rom_path, .save = save_dir };
|
||||
var cpu = try Arm7tdmi.init(alloc, &scheduler, paths);
|
||||
defer cpu.deinit();
|
||||
|
||||
cpu.bus.attach(&cpu);
|
||||
// cpu.fastBoot();
|
||||
// cpu.fastBoot(); // Uncomment to skip BIOS
|
||||
|
||||
// Initialize SDL Audio
|
||||
const audio_dev = initAudio(&cpu.bus.apu);
|
||||
defer SDL.SDL_CloseAudioDevice(audio_dev);
|
||||
// Copy ROM title while Emulator still belongs to this thread
|
||||
const title = cpu.bus.pak.title;
|
||||
|
||||
// Initialize SDL2
|
||||
initSdl2();
|
||||
defer SDL.SDL_Quit();
|
||||
|
||||
const dev = initAudio(&cpu.bus.apu);
|
||||
defer SDL.SDL_CloseAudioDevice(dev);
|
||||
|
||||
// TODO: Refactor or delete this Logging code
|
||||
// I probably still need logging in some form though (e.g. Golden Sun IIRC)
|
||||
const log_file: ?File = if (enable_logging) blk: {
|
||||
const file = try std.fs.cwd().createFile(if (is_binary) "zba.bin" else "zba.log", .{});
|
||||
cpu.useLogger(&file, is_binary);
|
||||
|
|
@ -97,16 +93,17 @@ pub fn main() anyerror!void {
|
|||
} else null;
|
||||
defer if (log_file) |file| file.close();
|
||||
|
||||
// Init Atomics
|
||||
var quit = Atomic(bool).init(false);
|
||||
var emu_rate = EmulatorFps.init();
|
||||
var emu_rate = FpsTracker.init();
|
||||
|
||||
// Create Emulator Thread
|
||||
// Run Emulator in it's separate thread
|
||||
// From this point on, interacting with Arm7tdmi or Scheduler
|
||||
// be justified, as it will require to be thread-afe
|
||||
const emu_thread = try Thread.spawn(.{}, emu.run, .{ .LimitedFPS, &quit, &emu_rate, &scheduler, &cpu });
|
||||
defer emu_thread.join();
|
||||
|
||||
var title_buf: [0x20]u8 = std.mem.zeroes([0x20]u8);
|
||||
const window_title = try std.fmt.bufPrint(&title_buf, "ZBA | {s}", .{asString(cpu.bus.pak.title)});
|
||||
const window_title = try std.fmt.bufPrint(&title_buf, "ZBA | {s}", .{asString(title)});
|
||||
|
||||
const window = createWindow(window_title, gba_width, gba_height);
|
||||
defer SDL.SDL_DestroyWindow(window);
|
||||
|
|
@ -158,7 +155,7 @@ pub fn main() anyerror!void {
|
|||
SDL.SDLK_s => io.keyinput.shoulder_r.set(),
|
||||
SDL.SDLK_RETURN => io.keyinput.start.set(),
|
||||
SDL.SDLK_RSHIFT => io.keyinput.select.set(),
|
||||
SDL.SDLK_i => std.debug.print("{} samples\n", .{@intCast(u32, SDL.SDL_AudioStreamAvailable(cpu.bus.apu.stream)) / (2 * @sizeOf(f32))}),
|
||||
SDL.SDLK_i => std.debug.print("{} samples\n", .{@intCast(u32, SDL.SDL_AudioStreamAvailable(cpu.bus.apu.stream)) / (2 * @sizeOf(u16))}),
|
||||
else => {},
|
||||
}
|
||||
},
|
||||
|
|
@ -189,31 +186,9 @@ fn sdlPanic() noreturn {
|
|||
@panic(std.mem.sliceTo(str, 0));
|
||||
}
|
||||
|
||||
// FIXME: Superfluous allocations?
|
||||
fn setupSavePath(alloc: std.mem.Allocator) !?[]const u8 {
|
||||
const save_subpath = try std.fs.path.join(alloc, &[_][]const u8{ "zba", "save" });
|
||||
defer alloc.free(save_subpath);
|
||||
|
||||
const maybe_data_path = try known_folders.getPath(alloc, .data);
|
||||
defer if (maybe_data_path) |path| alloc.free(path);
|
||||
|
||||
const save_path = if (maybe_data_path) |base| try std.fs.path.join(alloc, &[_][]const u8{ base, save_subpath }) else null;
|
||||
|
||||
if (save_path) |_| {
|
||||
// If we've determined what our save path should be, ensure the prereq directories
|
||||
// are present so that we can successfully write to the path when necessary
|
||||
const maybe_data_dir = try known_folders.open(alloc, .data, .{});
|
||||
if (maybe_data_dir) |data_dir| try data_dir.makePath(save_subpath);
|
||||
}
|
||||
|
||||
return save_path;
|
||||
}
|
||||
|
||||
fn initSdl2() c_int {
|
||||
fn initSdl2() void {
|
||||
const status = SDL.SDL_Init(SDL.SDL_INIT_VIDEO | SDL.SDL_INIT_EVENTS | SDL.SDL_INIT_AUDIO | SDL.SDL_INIT_GAMECONTROLLER);
|
||||
if (status < 0) sdlPanic();
|
||||
|
||||
return status;
|
||||
}
|
||||
|
||||
fn createWindow(title: []u8, width: c_int, height: c_int) *SDL.SDL_Window {
|
||||
|
|
@ -245,7 +220,7 @@ fn initAudio(apu: *Apu) SDL.SDL_AudioDeviceID {
|
|||
var have: SDL.SDL_AudioSpec = undefined;
|
||||
var want: SDL.SDL_AudioSpec = .{
|
||||
.freq = sample_rate,
|
||||
.format = SDL.AUDIO_F32,
|
||||
.format = SDL.AUDIO_U16,
|
||||
.channels = 2,
|
||||
.samples = 0x100,
|
||||
.callback = audioCallback,
|
||||
|
|
@ -268,3 +243,35 @@ export fn audioCallback(userdata: ?*anyopaque, stream: [*c]u8, len: c_int) void
|
|||
const apu = @ptrCast(*Apu, @alignCast(8, userdata));
|
||||
_ = SDL.SDL_AudioStreamGet(apu.stream, stream, len);
|
||||
}
|
||||
|
||||
fn getSavePath(alloc: std.mem.Allocator) !?[]const u8 {
|
||||
const save_subpath = "zba" ++ [_]u8{std.fs.path.sep} ++ "save";
|
||||
|
||||
const maybe_data_path = try known_folders.getPath(alloc, .data);
|
||||
defer if (maybe_data_path) |path| alloc.free(path);
|
||||
|
||||
const save_path = if (maybe_data_path) |base| try std.fs.path.join(alloc, &[_][]const u8{ base, "zba", "save" }) else null;
|
||||
|
||||
if (save_path) |_| {
|
||||
// If we've determined what our save path should be, ensure the prereq directories
|
||||
// are present so that we can successfully write to the path when necessary
|
||||
const maybe_data_dir = try known_folders.open(alloc, .data, .{});
|
||||
if (maybe_data_dir) |data_dir| try data_dir.makePath(save_subpath);
|
||||
}
|
||||
|
||||
return save_path;
|
||||
}
|
||||
|
||||
fn getRomPath(res: clap.Result(clap.Help, ¶ms, clap.parsers.default), stderr: std.fs.File) ![]const u8 {
|
||||
return switch (res.positionals.len) {
|
||||
1 => res.positionals[0],
|
||||
0 => {
|
||||
try stderr.writeAll("ZBA requires a positional path to a GamePak ROM.\n");
|
||||
return CliError.InsufficientOptions;
|
||||
},
|
||||
else => {
|
||||
try stderr.writeAll("ZBA received too many arguments.\n");
|
||||
return CliError.UnneededOptions;
|
||||
},
|
||||
};
|
||||
}
|
||||
|
|
|
|||
|
|
@ -17,7 +17,7 @@ pub inline fn rotr(comptime T: type, x: T, r: anytype) T {
|
|||
return x >> ar | x << (1 +% ~ar);
|
||||
}
|
||||
|
||||
pub const EmulatorFps = struct {
|
||||
pub const FpsTracker = struct {
|
||||
const Self = @This();
|
||||
|
||||
fps: u32,
|
||||
|
|
|
|||
Loading…
Reference in New Issue