mirror of
				https://github.com/TomHarte/CLK.git
				synced 2025-10-31 05:16:08 +00:00 
			
		
		
		
	
		
			
				
	
	
		
			1257 lines
		
	
	
		
			45 KiB
		
	
	
	
		
			C++
		
	
	
	
	
	
			
		
		
	
	
			1257 lines
		
	
	
		
			45 KiB
		
	
	
	
		
			C++
		
	
	
	
	
	
| //
 | |
| //  main.cpp
 | |
| //  Clock Signal
 | |
| //
 | |
| //  Created by Thomas Harte on 04/11/2017.
 | |
| //  Copyright 2017 Thomas Harte. All rights reserved.
 | |
| //
 | |
| 
 | |
| #include <algorithm>
 | |
| #include <array>
 | |
| #include <atomic>
 | |
| #include <cstdio>
 | |
| #include <cstdlib>
 | |
| #include <cstring>
 | |
| #include <iomanip>
 | |
| #include <iostream>
 | |
| #include <map>
 | |
| #include <memory>
 | |
| #include <sys/stat.h>
 | |
| #include <unistd.h>
 | |
| 
 | |
| #include <SDL2/SDL.h>
 | |
| 
 | |
| #include "../../Analyser/Static/StaticAnalyser.hpp"
 | |
| #include "../../Machines/Utility/MachineForTarget.hpp"
 | |
| 
 | |
| #include "../../ClockReceiver/TimeTypes.hpp"
 | |
| #include "../../ClockReceiver/ScanSynchroniser.hpp"
 | |
| 
 | |
| #include "../../Machines/MachineTypes.hpp"
 | |
| 
 | |
| #include "../../Activity/Observer.hpp"
 | |
| #include "../../Outputs/OpenGL/Primitives/Rectangle.hpp"
 | |
| #include "../../Outputs/OpenGL/ScanTarget.hpp"
 | |
| #include "../../Outputs/OpenGL/Screenshot.hpp"
 | |
| 
 | |
| #include "../../Reflection/Enum.hpp"
 | |
| #include "../../Reflection/Struct.hpp"
 | |
| 
 | |
| namespace {
 | |
| 
 | |
| struct MachineRunner {
 | |
| 	MachineRunner() {
 | |
| 		frame_lock_.clear();
 | |
| 	}
 | |
| 
 | |
| 	~MachineRunner() {
 | |
| 		stop();
 | |
| 	}
 | |
| 
 | |
| 	void start() {
 | |
| 		last_time_ = Time::nanos_now();
 | |
| 		timer_ = SDL_AddTimer(timer_period, &sdl_callback, reinterpret_cast<void *>(this));
 | |
| 	}
 | |
| 
 | |
| 	void stop() {
 | |
| 		if(timer_) {
 | |
| 			// SDL doesn't define whether SDL_RemoveTimer will block until any pending calls
 | |
| 			// have been completed, or will return instantly. So: do an ordered shutdown,
 | |
| 			// then remove the timer.
 | |
| 			state_ = State::Stopping;
 | |
| 			while(state_ == State::Stopping) {
 | |
| 				frame_lock_.clear();
 | |
| 			}
 | |
| 
 | |
| 			SDL_RemoveTimer(timer_);
 | |
| 			timer_ = 0;
 | |
| 		}
 | |
| 	}
 | |
| 
 | |
| 	void signal_vsync() {
 | |
| 		const auto now = Time::nanos_now();
 | |
| 		const auto previous_vsync_time = vsync_time_.load();
 | |
| 		vsync_time_.store(now);
 | |
| 
 | |
| 		// Update estimate of current frame time.
 | |
| 		frame_time_average_ -= frame_times_[frame_time_pointer_];
 | |
| 		frame_times_[frame_time_pointer_] = now - previous_vsync_time;
 | |
| 		frame_time_average_ += frame_times_[frame_time_pointer_];
 | |
| 		frame_time_pointer_ = (frame_time_pointer_ + 1) & (frame_times_.size() - 1);
 | |
| 
 | |
| 		_frame_period.store((1e9 * 32.0) / double(frame_time_average_));
 | |
| 	}
 | |
| 
 | |
| 	void signal_did_draw() {
 | |
| 		frame_lock_.clear();
 | |
| 	}
 | |
| 
 | |
| 	void set_speed_multiplier(double multiplier) {
 | |
| 		scan_synchroniser_.set_base_speed_multiplier(multiplier);
 | |
| 	}
 | |
| 
 | |
| 	std::mutex *machine_mutex;
 | |
| 	Machine::DynamicMachine *machine;
 | |
| 
 | |
| 	private:
 | |
| 		SDL_TimerID timer_ = 0;
 | |
| 		Time::Nanos last_time_ = 0;
 | |
| 		std::atomic<Time::Nanos> vsync_time_;
 | |
| 		std::atomic_flag frame_lock_;
 | |
| 
 | |
| 		enum class State {
 | |
| 			Running,
 | |
| 			Stopping,
 | |
| 			Stopped
 | |
| 		};
 | |
| 		std::atomic<State> state_{State::Running};
 | |
| 
 | |
| 		Time::ScanSynchroniser scan_synchroniser_;
 | |
| 
 | |
| 		// A slightly clumsy means of trying to derive frame rate from calls to
 | |
| 		// signal_vsync(); SDL_DisplayMode provides only an integral quantity
 | |
| 		// whereas, empirically, it's fairly common for monitors to run at the
 | |
| 		// NTSC-esque frame rates of 59.94Hz.
 | |
| 		std::array<Time::Nanos, 32> frame_times_;
 | |
| 		Time::Nanos frame_time_average_ = 0;
 | |
| 		size_t frame_time_pointer_ = 0;
 | |
| 		std::atomic<double> _frame_period;
 | |
| 
 | |
| 		static constexpr Uint32 timer_period = 4;
 | |
| 		static Uint32 sdl_callback(Uint32, void *param) {
 | |
| 			reinterpret_cast<MachineRunner *>(param)->update();
 | |
| 			return timer_period;
 | |
| 		}
 | |
| 
 | |
| 		void update() {
 | |
| 			// If a shutdown is in progress, signal stoppage and do nothing.
 | |
| 			if(state_ != State::Running) {
 | |
| 				state_ = State::Stopped;
 | |
| 				return;
 | |
| 			}
 | |
| 
 | |
| 			// Get time now and determine how long it has been since the last time this
 | |
| 			// function was called. If it's more than half a second then forego any activity
 | |
| 			// now, as there's obviously been some sort of substantial time glitch.
 | |
| 			const auto time_now = Time::nanos_now();
 | |
| 			if(time_now - last_time_ > Time::Nanos(500'000'000)) {
 | |
| 				last_time_ = time_now - Time::Nanos(500'000'000);
 | |
| 			}
 | |
| 
 | |
| 			const auto vsync_time = vsync_time_.load();
 | |
| 
 | |
| 			std::unique_lock lock_guard(*machine_mutex);
 | |
| 			const auto scan_producer = machine->scan_producer();
 | |
| 			const auto timed_machine = machine->timed_machine();
 | |
| 
 | |
| 			bool split_and_sync = false;
 | |
| 			if(last_time_ < vsync_time && time_now >= vsync_time) {
 | |
| 				split_and_sync = scan_synchroniser_.can_synchronise(scan_producer->get_scan_status(), _frame_period);
 | |
| 			}
 | |
| 
 | |
| 			if(split_and_sync) {
 | |
| 				timed_machine->run_for(double(vsync_time - last_time_) / 1e9);
 | |
| 				timed_machine->set_speed_multiplier(
 | |
| 					scan_synchroniser_.next_speed_multiplier(scan_producer->get_scan_status())
 | |
| 				);
 | |
| 
 | |
| 				// This is a bit of an SDL ugliness; wait here until the next frame is drawn.
 | |
| 				// That is, unless and until I can think of a good way of running background
 | |
| 				// updates via a share group — possibly an extra intermediate buffer is needed?
 | |
| 				lock_guard.unlock();
 | |
| 				while(frame_lock_.test_and_set());
 | |
| 				lock_guard.lock();
 | |
| 
 | |
| 				timed_machine->run_for(double(time_now - vsync_time) / 1e9);
 | |
| 			} else {
 | |
| 				timed_machine->set_speed_multiplier(scan_synchroniser_.get_base_speed_multiplier());
 | |
| 				timed_machine->run_for(double(time_now - last_time_) / 1e9);
 | |
| 			}
 | |
| 			last_time_ = time_now;
 | |
| 		}
 | |
| };
 | |
| 
 | |
| struct SpeakerDelegate: public Outputs::Speaker::Speaker::Delegate {
 | |
| 	// This is empirically the best that I can seem to do with SDL's timer precision.
 | |
| 	static constexpr size_t buffered_samples = 1024;
 | |
| 	bool is_stereo = false;
 | |
| 
 | |
| 	void speaker_did_complete_samples(Outputs::Speaker::Speaker *, const std::vector<int16_t> &buffer) final {
 | |
| 		std::lock_guard lock_guard(audio_buffer_mutex_);
 | |
| 		const size_t buffer_size = buffered_samples * (is_stereo ? 2 : 1);
 | |
| 		if(audio_buffer_.size() > buffer_size) {
 | |
| 			audio_buffer_.erase(audio_buffer_.begin(), audio_buffer_.end() - buffer_size);
 | |
| 		}
 | |
| 		audio_buffer_.insert(audio_buffer_.end(), buffer.begin(), buffer.end());
 | |
| 	}
 | |
| 
 | |
| 	void audio_callback(Uint8 *stream, int len) {
 | |
| 		std::lock_guard lock_guard(audio_buffer_mutex_);
 | |
| 
 | |
| 		// SDL buffer length is in bytes, so there's no need to adjust for stereo/mono in here.
 | |
| 		const std::size_t sample_length = size_t(len) / sizeof(int16_t);
 | |
| 		const std::size_t copy_length = std::min(sample_length, audio_buffer_.size());
 | |
| 		int16_t *const target = static_cast<int16_t *>(static_cast<void *>(stream));
 | |
| 
 | |
| 		std::memcpy(stream, audio_buffer_.data(), copy_length * sizeof(int16_t));
 | |
| 		if(copy_length < sample_length) {
 | |
| 			std::memset(&target[copy_length], 0, (sample_length - copy_length) * sizeof(int16_t));
 | |
| 		}
 | |
| 		audio_buffer_.erase(audio_buffer_.begin(), audio_buffer_.begin() + copy_length);
 | |
| 	}
 | |
| 
 | |
| 	static void SDL_audio_callback(void *userdata, Uint8 *stream, int len) {
 | |
| 		reinterpret_cast<SpeakerDelegate *>(userdata)->audio_callback(stream, len);
 | |
| 	}
 | |
| 
 | |
| 	SDL_AudioDeviceID audio_device;
 | |
| 
 | |
| 	std::mutex audio_buffer_mutex_;
 | |
| 	std::vector<int16_t> audio_buffer_;
 | |
| };
 | |
| 
 | |
| class ActivityObserver: public Activity::Observer {
 | |
| 	public:
 | |
| 		ActivityObserver(Activity::Source *source, float aspect_ratio) {
 | |
| 			// Get the suorce to supply all LEDs and drives.
 | |
| 			source->set_activity_observer(this);
 | |
| 
 | |
| 			// The objective is to display drives on one side of the screen, other LEDs on the other. Drives
 | |
| 			// may or may not have LEDs and this code intends to display only those which do; so a quick
 | |
| 			// comparative processing of the two lists is called for.
 | |
| 
 | |
| 			// Strip the list of drives to only those which have LEDs. Thwy're the ones that'll be displayed.
 | |
| 			drives_.resize(std::remove_if(drives_.begin(), drives_.end(), [this](const std::string &string) {
 | |
| 				return std::find(leds_.begin(), leds_.end(), string) == leds_.end();
 | |
| 			}) - drives_.begin());
 | |
| 
 | |
| 			// Remove from the list of LEDs any which are drives. Those will be represented separately.
 | |
| 			leds_.resize(std::remove_if(leds_.begin(), leds_.end(), [this](const std::string &string) {
 | |
| 				return std::find(drives_.begin(), drives_.end(), string) != drives_.end();
 | |
| 			}) - leds_.begin());
 | |
| 
 | |
| 			set_aspect_ratio(aspect_ratio);
 | |
| 		}
 | |
| 
 | |
| 		void set_aspect_ratio(float aspect_ratio) {
 | |
| 			std::lock_guard lock_guard(mutex);
 | |
| 			lights_.clear();
 | |
| 
 | |
| 			// Generate a bunch of LEDs for connected drives.
 | |
| 			constexpr float height = 0.05f;
 | |
| 			const float width = height / aspect_ratio;
 | |
| 			const float right_x = 1.0f - 2.0f * width;
 | |
| 			float y = 1.0f - 2.0f * height;
 | |
| 			for(const auto &drive: drives_) {
 | |
| 				lights_.emplace(std::make_pair(drive, std::make_unique<Outputs::Display::OpenGL::Rectangle>(right_x, y, width, height)));
 | |
| 				y -= height * 2.0f;
 | |
| 			}
 | |
| 
 | |
| 			/*
 | |
| 				This would generate LEDs for things other than drives; I'm declining for now
 | |
| 				due to the inexpressiveness of just painting a rectangle.
 | |
| 
 | |
| 				const float left_x = -1.0f + 2.0f * width;
 | |
| 				y = 1.0f - 2.0f * height;
 | |
| 				for(const auto &led: leds_) {
 | |
| 					lights_.emplace(std::make_pair(led, std::make_unique<OpenGL::Rectangle>(left_x, y, width, height)));
 | |
| 					y -= height * 2.0f;
 | |
| 				}
 | |
| 			*/
 | |
| 		}
 | |
| 
 | |
| 		void draw() {
 | |
| 			std::lock_guard lock_guard(mutex);
 | |
| 			for(const auto &lit_led: lit_leds_) {
 | |
| 				if(blinking_leds_.find(lit_led) == blinking_leds_.end() && lights_.find(lit_led) != lights_.end())
 | |
| 					lights_[lit_led]->draw(0.0, 0.8, 0.0);
 | |
| 			}
 | |
| 			blinking_leds_.clear();
 | |
| 		}
 | |
| 
 | |
| 	private:
 | |
| 		std::vector<std::string> leds_;
 | |
| 		void register_led(const std::string &name) final {
 | |
| 			std::lock_guard lock_guard(mutex);
 | |
| 			leds_.push_back(name);
 | |
| 		}
 | |
| 
 | |
| 		std::vector<std::string> drives_;
 | |
| 		void register_drive(const std::string &name) final {
 | |
| 			std::lock_guard lock_guard(mutex);
 | |
| 			drives_.push_back(name);
 | |
| 		}
 | |
| 
 | |
| 		void set_led_status(const std::string &name, bool lit) final {
 | |
| 			std::lock_guard lock_guard(mutex);
 | |
| 			if(lit) lit_leds_.insert(name);
 | |
| 			else lit_leds_.erase(name);
 | |
| 		}
 | |
| 
 | |
| 		void announce_drive_event(const std::string &name, DriveEvent) final {
 | |
| 			std::lock_guard lock_guard(mutex);
 | |
| 			blinking_leds_.insert(name);
 | |
| 		}
 | |
| 
 | |
| 		std::map<std::string, std::unique_ptr<Outputs::Display::OpenGL::Rectangle>> lights_;
 | |
| 		std::set<std::string> lit_leds_;
 | |
| 		std::set<std::string> blinking_leds_;
 | |
| 		std::mutex mutex;
 | |
| };
 | |
| 
 | |
| bool KeyboardKeyForSDLScancode(SDL_Scancode scancode, Inputs::Keyboard::Key &key) {
 | |
| #define BIND(x, y) case SDL_SCANCODE_##x: key = Inputs::Keyboard::Key::y; break;
 | |
| 	switch(scancode) {
 | |
| 		default: return false;
 | |
| 
 | |
| 		BIND(F1, F1)	BIND(F2, F2)	BIND(F3, F3)	BIND(F4, F4)	BIND(F5, F5)	BIND(F6, F6)
 | |
| 		BIND(F7, F7)	BIND(F8, F8)	BIND(F9, F9)	BIND(F10, F10)	BIND(F11, F11)	BIND(F12, F12)
 | |
| 
 | |
| 		BIND(1, k1)		BIND(2, k2)		BIND(3, k3)		BIND(4, k4)		BIND(5, k5)
 | |
| 		BIND(6, k6)		BIND(7, k7)		BIND(8, k8)		BIND(9, k9)		BIND(0, k0)
 | |
| 
 | |
| 		BIND(Q, Q)		BIND(W, W)		BIND(E, E)		BIND(R, R)		BIND(T, T)
 | |
| 		BIND(Y, Y)		BIND(U, U)		BIND(I, I)		BIND(O, O)		BIND(P, P)
 | |
| 		BIND(A, A)		BIND(S, S)		BIND(D, D)		BIND(F, F)		BIND(G, G)
 | |
| 		BIND(H, H)		BIND(J, J)		BIND(K, K)		BIND(L, L)
 | |
| 		BIND(Z, Z)		BIND(X, X)		BIND(C, C)		BIND(V, V)
 | |
| 		BIND(B, B)		BIND(N, N)		BIND(M, M)
 | |
| 
 | |
| 		BIND(KP_7, Keypad7)	BIND(KP_8, Keypad8)	BIND(KP_9, Keypad9)
 | |
| 		BIND(KP_4, Keypad4)	BIND(KP_5, Keypad5)	BIND(KP_6, Keypad6)
 | |
| 		BIND(KP_1, Keypad1)	BIND(KP_2, Keypad2)	BIND(KP_3, Keypad3)
 | |
| 		BIND(KP_0, Keypad0)
 | |
| 
 | |
| 		BIND(ESCAPE, Escape)
 | |
| 
 | |
| 		BIND(PRINTSCREEN, PrintScreen)	BIND(SCROLLLOCK, ScrollLock)	BIND(PAUSE, Pause)
 | |
| 
 | |
| 		BIND(GRAVE, BackTick)		BIND(MINUS, Hyphen)		BIND(EQUALS, Equals)	BIND(BACKSPACE, Backspace)
 | |
| 
 | |
| 		BIND(TAB, Tab)
 | |
| 		BIND(LEFTBRACKET, OpenSquareBracket)	BIND(RIGHTBRACKET, CloseSquareBracket)
 | |
| 		BIND(BACKSLASH, Backslash)
 | |
| 
 | |
| 		BIND(CAPSLOCK, CapsLock)	BIND(SEMICOLON, Semicolon)
 | |
| 		BIND(APOSTROPHE, Quote)		BIND(RETURN, Enter)
 | |
| 
 | |
| 		BIND(LSHIFT, LeftShift)		BIND(COMMA, Comma)		BIND(PERIOD, FullStop)
 | |
| 		BIND(SLASH, ForwardSlash)	BIND(RSHIFT, RightShift)
 | |
| 
 | |
| 		BIND(LCTRL, LeftControl)	BIND(LALT, LeftOption)		BIND(LGUI, LeftMeta)
 | |
| 		BIND(SPACE, Space)
 | |
| 		BIND(RCTRL, RightControl)	BIND(RALT, RightOption)	BIND(RGUI, RightMeta)
 | |
| 
 | |
| 		BIND(LEFT, Left)	BIND(RIGHT, Right)		BIND(UP, Up)	BIND(DOWN, Down)
 | |
| 
 | |
| 		BIND(INSERT, Insert)	BIND(HOME, Home)	BIND(PAGEUP, PageUp)
 | |
| 		BIND(DELETE, Delete)	BIND(END, End)		BIND(PAGEDOWN, PageDown)
 | |
| 
 | |
| 		BIND(NUMLOCKCLEAR, NumLock)		BIND(KP_DIVIDE, KeypadSlash)		BIND(KP_MULTIPLY, KeypadAsterisk)
 | |
| 		BIND(KP_PLUS, KeypadPlus)		BIND(KP_MINUS, KeypadMinus)			BIND(KP_ENTER, KeypadEnter)
 | |
| 		BIND(KP_DECIMAL, KeypadDecimalPoint)
 | |
| 		BIND(KP_EQUALS, KeypadEquals)
 | |
| 		BIND(HELP, Help)
 | |
| 
 | |
| 		// SDL doesn't seem to have scancodes for hash or keypad delete?
 | |
| 	}
 | |
| #undef BIND
 | |
| 	return true;
 | |
| }
 | |
| 
 | |
| struct ParsedArguments {
 | |
| 	std::vector<std::string> file_names;
 | |
| 	std::map<std::string, std::string> selections;	// The empty string will be inserted for arguments without an = suffix.
 | |
| 
 | |
| 	void apply(Reflection::Struct *reflectable) const {
 | |
| 		for(const auto &argument: selections) {
 | |
| 			// Replace any dashes with underscores in the argument name.
 | |
| 			std::string property;
 | |
| 			std::transform(argument.first.begin(), argument.first.end(), std::back_inserter(property), [](char c) { return c == '-' ? '_' : c; });
 | |
| 
 | |
| 			if(argument.second.empty()) {
 | |
| 				Reflection::set<bool>(*reflectable, property, true);
 | |
| 			} else {
 | |
| 				Reflection::fuzzy_set(*reflectable, property, argument.second);
 | |
| 			}
 | |
| 		}
 | |
| 	}
 | |
| };
 | |
| 
 | |
| /*! Parses an argc/argv pair to discern program arguments. */
 | |
| ParsedArguments parse_arguments(int argc, char *argv[]) {
 | |
| 	ParsedArguments arguments;
 | |
| 
 | |
| 	for(int index = 1; index < argc; ++index) {
 | |
| 		char *arg = argv[index];
 | |
| 
 | |
| 		// Accepted format is:
 | |
| 		//
 | |
| 		//	--flag			sets a Boolean option to true.
 | |
| 		//	--flag=value	sets the value for a list option.
 | |
| 		//	name			sets the file name to load.
 | |
| 
 | |
| 		// Anything starting with a dash always makes a selection; otherwise it's a file name.
 | |
| 		if(arg[0] == '-') {
 | |
| 			while(*arg == '-') arg++;
 | |
| 
 | |
| 			// Check for an equals sign, to discern a Boolean selection from a list selection.
 | |
| 			std::string argument = arg;
 | |
| 			std::size_t split_index = argument.find("=");
 | |
| 
 | |
| 			if(split_index == std::string::npos) {
 | |
| 				arguments.selections[argument];	// To create an entry with the default empty string.
 | |
| 			} else {
 | |
| 				const std::string name = argument.substr(0, split_index);
 | |
| 				std::string value = argument.substr(split_index+1, std::string::npos);
 | |
| 				arguments.selections[name] = value;
 | |
| 			}
 | |
| 		} else {
 | |
| 			arguments.file_names.push_back(arg);
 | |
| 		}
 | |
| 	}
 | |
| 
 | |
| 	return arguments;
 | |
| }
 | |
| 
 | |
| std::string final_path_component(const std::string &path) {
 | |
| 	// An empty path has no final component.
 | |
| 	if(path.empty()) {
 | |
| 		return "";
 | |
| 	}
 | |
| 
 | |
| 	// Find the last slash...
 | |
| 	auto final_slash = path.find_last_of("/\\");
 | |
| 
 | |
| 	// If no slash was found at all, return the whole path.
 | |
| 	if(final_slash == std::string::npos) {
 | |
| 		return path;
 | |
| 	}
 | |
| 
 | |
| 	// If a slash was found in the final position, remove it and recurse.
 | |
| 	if(final_slash == path.size() - 1) {
 | |
| 		return final_path_component(path.substr(0, path.size() - 1));
 | |
| 	}
 | |
| 
 | |
| 	// Otherwise return everything from just after the slash to the end of the path.
 | |
| 	return path.substr(final_slash+1, path.size() - final_slash - 1);
 | |
| }
 | |
| 
 | |
| /*!
 | |
| 	Executes @c command and returns its STDOUT.
 | |
| */
 | |
| std::string system_get(const char *command) {
 | |
| 	std::unique_ptr<FILE, decltype((pclose))> pipe(popen(command, "r"), pclose);
 | |
| 	if(!pipe) return "";
 | |
| 
 | |
| 	std::string result;
 | |
| 	while(!feof(pipe.get())) {
 | |
| 		std::array<char, 256> buffer;
 | |
| 		if(fgets(buffer.data(), buffer.size(), pipe.get()) != nullptr)
 | |
| 			result += buffer.data();
 | |
| 	}
 | |
| 	return result;
 | |
| }
 | |
| 
 | |
| /*!
 | |
| 	Maintains a communicative window title.
 | |
| */
 | |
| class DynamicWindowTitler {
 | |
| 	public:
 | |
| 		DynamicWindowTitler(SDL_Window *window) : window_(window), file_name_(SDL_GetWindowTitle(window)) {}
 | |
| 
 | |
| 		std::string window_title() {
 | |
| 			if(!mouse_is_captured_) return file_name_;
 | |
| 			return file_name_ + " (press control+escape to release mouse)";
 | |
| 		}
 | |
| 
 | |
| 		void set_mouse_is_captured(bool is_captured) {
 | |
| 			mouse_is_captured_ = is_captured;
 | |
| 			update_window_title();
 | |
| 		}
 | |
| 
 | |
| 	private:
 | |
| 		void update_window_title() {
 | |
| 			SDL_SetWindowTitle(window_, window_title().c_str());
 | |
| 		}
 | |
| 		bool mouse_is_captured_ = false;
 | |
| 		SDL_Window *window_ = nullptr;
 | |
| 		const std::string file_name_;
 | |
| };
 | |
| 
 | |
| }
 | |
| 
 | |
| int main(int argc, char *argv[]) {
 | |
| 	SDL_Window *window = nullptr;
 | |
| 
 | |
| 	// Attempt to parse arguments.
 | |
| 	const ParsedArguments arguments = parse_arguments(argc, argv);
 | |
| 
 | |
| 	// This may be printed either as
 | |
| 	const std::string usage_suffix = " [file or --new={machine}] [OPTIONS] [--rompath={path to ROMs}] [--speed={speed multiplier, e.g. 1.5}]  [--logical-keyboard] [--volume={0.0 to 1.0}]";
 | |
| 
 | |
| 	// Print a help message if requested.
 | |
| 	if(arguments.selections.find("help") != arguments.selections.end() || arguments.selections.find("h") != arguments.selections.end()) {
 | |
| 		const auto all_machines = Machine::AllMachines(Machine::Type::DoesntRequireMedia, false);
 | |
| 
 | |
| 		std::cout << "Usage: " << final_path_component(argv[0]) << usage_suffix << std::endl;
 | |
| 		std::cout << "Use alt+enter to toggle full screen display. Use control+shift+V to paste text." << std::endl;
 | |
| 		std::cout << "Required machine type **and all options** are determined from the file if specified; otherwise use:" << std::endl << std::endl;
 | |
| 		std::cout << "\t--new={";
 | |
| 		bool is_first = true;
 | |
| 		for(const auto &name: all_machines) {
 | |
| 			if(!is_first) std::cout << "|";
 | |
| 			std::cout << name;
 | |
| 			is_first = false;
 | |
| 		}
 | |
| 		std::cout << "}" << std::endl << std::endl;
 | |
| 
 | |
| 		std::cout << "Media is required to start the: ";
 | |
| 		const auto other_machines = Machine::AllMachines(Machine::Type::RequiresMedia, true);
 | |
| 		is_first = true;
 | |
| 		for(const auto &name: other_machines) {
 | |
| 			if(!is_first) std::cout << ", ";
 | |
| 			std::cout << name;
 | |
| 			is_first = false;
 | |
| 		}
 | |
| 		std::cout << "." << std::endl << std::endl;
 | |
| 
 | |
| 		std::cout << "Further machine options:" << std::endl << std::endl;;
 | |
| 
 | |
| 		const auto targets = Machine::TargetsByMachineName(false);
 | |
| 		const auto runtime_options = Machine::AllOptionsByMachineName();
 | |
| 		const auto machine_names = Machine::AllMachines(Machine::Type::Any, true);
 | |
| 		for(const auto &machine: machine_names) {
 | |
| 			const auto target = targets.find(machine);
 | |
| 			const auto options = runtime_options.find(machine);
 | |
| 
 | |
| 			const auto target_reflectable = dynamic_cast<Reflection::Struct *>(target != targets.end() ? target->second.get() : nullptr);
 | |
| 			const auto options_reflectable = dynamic_cast<Reflection::Struct *>(options != runtime_options.end() ? options->second.get() : nullptr);
 | |
| 
 | |
| 			// Don't print a section for this machine if it has no construction and no runtime options objects.
 | |
| 			if(!target_reflectable && !options_reflectable) continue;
 | |
| 
 | |
| 			const auto target_keys = target_reflectable ? target_reflectable->all_keys() : std::vector<std::string>();
 | |
| 			const auto options_keys = options_reflectable ? options_reflectable->all_keys() : std::vector<std::string>();
 | |
| 
 | |
| 			// Don't print a section for this machine if it doesn't actually have any options.
 | |
| 			if(target_keys.empty() && options_keys.empty()) {
 | |
| 				continue;
 | |
| 			}
 | |
| 
 | |
| 			std::cout << machine << ":" << std::endl;
 | |
| 
 | |
| 			// Join the two lists of properties and sort the result.
 | |
| 			std::vector<std::string> all_options = options_keys;
 | |
| 			all_options.insert(all_options.end(), target_keys.begin(), target_keys.end());
 | |
| 			std::sort(all_options.begin(), all_options.end());
 | |
| 
 | |
| 			for(const auto &option: all_options) {
 | |
| 				// Replace any underscores with hyphens, better to conform to command-line norms.
 | |
| 				std::string mapped_option;
 | |
| 				std::transform(option.begin(), option.end(), std::back_inserter(mapped_option), [](char c) { return c == '_' ? '-' : c; });
 | |
| 				std::cout << '\t' << "--" << mapped_option;
 | |
| 
 | |
| 				auto source = target_reflectable;
 | |
| 				auto type = target_reflectable ? target_reflectable->type_of(option) : nullptr;
 | |
| 				if(!type) {
 | |
| 					source = options_reflectable;
 | |
| 					type = options_reflectable->type_of(option);
 | |
| 				}
 | |
| 
 | |
| 				// Is this a registered enum? If so, list options.
 | |
| 				if(!Reflection::Enum::name(*type).empty()) {
 | |
| 					std::cout << "={";
 | |
| 					bool is_first = true;
 | |
| 					for(const auto &value: source->values_for(option)) {
 | |
| 						if(!is_first) std::cout << '|';
 | |
| 						is_first = false;
 | |
| 
 | |
| 						std::cout << value;
 | |
| 					}
 | |
| 					std::cout << "}";
 | |
| 				}
 | |
| 
 | |
| 				// The above effectively assumes that every field is either a
 | |
| 				// Boolean or an enum. This may need to be revisted. It also
 | |
| 				// assumes no name collisions, but that's kind of unavoidable.
 | |
| 
 | |
| 				std::cout << std::endl;
 | |
| 			}
 | |
| 
 | |
| 			std::cout << std::endl;
 | |
| 		}
 | |
| 		return EXIT_SUCCESS;
 | |
| 	}
 | |
| 
 | |
| 	// Determine the machine for the supplied file, if any, or from --new.
 | |
| 	Analyser::Static::TargetList targets;
 | |
| 
 | |
| 	const auto new_argument = arguments.selections.find("new");
 | |
| 	std::string long_machine_name;
 | |
| 	if(new_argument != arguments.selections.end() && !new_argument->second.empty()) {
 | |
| 		// Perform for a case-insensitive search against short names.
 | |
| 		const auto short_names = Machine::AllMachines(Machine::Type::DoesntRequireMedia, false);
 | |
| 		auto short_name = short_names.begin();
 | |
| 		while(short_name != short_names.end()) {
 | |
| 			if(std::equal(
 | |
| 				short_name->begin(), short_name->end(),
 | |
| 				new_argument->second.begin(), new_argument->second.end(),
 | |
| 				[](char a, char b) { return tolower(b) == tolower(a); })) {
 | |
| 				break;
 | |
| 			}
 | |
| 			++short_name;
 | |
| 		}
 | |
| 
 | |
| 		// If a match was found, use the corresponding long name to look up a suitable
 | |
| 		// Analyser::Statuc::Target and move that to the targets list.
 | |
| 		if(short_name != short_names.end()) {
 | |
| 			long_machine_name = Machine::AllMachines(Machine::Type::DoesntRequireMedia, true)[short_name - short_names.begin()];
 | |
| 			auto targets_by_machine = Machine::TargetsByMachineName(false);
 | |
| 			std::unique_ptr<Analyser::Static::Target> tgt = std::move(targets_by_machine[long_machine_name]);
 | |
| 			targets.push_back(std::move(tgt));
 | |
| 		}
 | |
| 	} else if(!arguments.file_names.empty()) {
 | |
| 		// Take the first file name that actually implies a machine.
 | |
| 		auto file_name = arguments.file_names.begin();
 | |
| 		while(file_name != arguments.file_names.end() && targets.empty()) {
 | |
| 			targets = Analyser::Static::GetTargets(*file_name);
 | |
| 			++file_name;
 | |
| 		}
 | |
| 	}
 | |
| 
 | |
| 	if(targets.empty()) {
 | |
| 		if(!arguments.file_names.empty()) {
 | |
| 			std::cerr << "Cannot open ";
 | |
| 			bool is_first = true;
 | |
| 			for(const auto &name: arguments.file_names) {
 | |
| 				if(!is_first) std::cerr << ", ";
 | |
| 				is_first = false;
 | |
| 				std::cerr << name;
 | |
| 			}
 | |
| 			std::cerr << "; no target machine found" << std::endl;
 | |
| 			return EXIT_FAILURE;
 | |
| 		}
 | |
| 
 | |
| 		if(!new_argument->second.empty()) {
 | |
| 			std::cerr << "Unknown machine: " << new_argument->second << std::endl;
 | |
| 			return EXIT_FAILURE;
 | |
| 		}
 | |
| 
 | |
| 		std::cerr << "Usage: " << final_path_component(argv[0]) << usage_suffix << std::endl;
 | |
| 		std::cerr << "Use --help to learn more about available options." << std::endl;
 | |
| 		return EXIT_FAILURE;
 | |
| 	}
 | |
| 
 | |
| 	MachineRunner machine_runner;
 | |
| 	SpeakerDelegate speaker_delegate;
 | |
| 
 | |
| 	// For vanilla SDL purposes, assume system ROMs can be found in one of:
 | |
| 	//
 | |
| 	//	/usr/local/share/CLK/[system];
 | |
| 	//	/usr/share/CLK/[system]; or
 | |
| 	//	[user-supplied path]/[system]
 | |
| 	std::vector<ROMMachine::ROM> requested_roms;
 | |
| 	ROMMachine::ROMFetcher rom_fetcher = [&requested_roms, &arguments]
 | |
| 		(const std::vector<ROMMachine::ROM> &roms) -> std::vector<std::unique_ptr<std::vector<uint8_t>>> {
 | |
| 			requested_roms.insert(requested_roms.end(), roms.begin(), roms.end());
 | |
| 
 | |
| 			std::vector<std::string> paths = {
 | |
| 				"/usr/local/share/CLK/",
 | |
| 				"/usr/share/CLK/"
 | |
| 			};
 | |
| 
 | |
| 			const auto rompath = arguments.selections.find("rompath");
 | |
| 			if(rompath != arguments.selections.end()) {
 | |
| 				if(rompath->second.back() != '/') {
 | |
| 					paths.push_back(rompath->second + "/");
 | |
| 				} else {
 | |
| 					paths.push_back(rompath->second);
 | |
| 				}
 | |
| 			}
 | |
| 
 | |
| 			std::vector<std::unique_ptr<std::vector<uint8_t>>> results;
 | |
| 			for(const auto &rom: roms) {
 | |
| 				FILE *file = nullptr;
 | |
| 				for(const auto &path: paths) {
 | |
| 					std::string local_path = path + rom.machine_name + "/" + rom.file_name;
 | |
| 					file = std::fopen(local_path.c_str(), "rb");
 | |
| 					if(file) break;
 | |
| 				}
 | |
| 
 | |
| 				if(!file) {
 | |
| 					results.emplace_back(nullptr);
 | |
| 					continue;
 | |
| 				}
 | |
| 
 | |
| 				auto data = std::make_unique<std::vector<uint8_t>>();
 | |
| 
 | |
| 				std::fseek(file, 0, SEEK_END);
 | |
| 				data->resize(std::ftell(file));
 | |
| 				std::fseek(file, 0, SEEK_SET);
 | |
| 				std::size_t read = fread(data->data(), 1, data->size(), file);
 | |
| 				std::fclose(file);
 | |
| 
 | |
| 				if(read == data->size())
 | |
| 					results.emplace_back(std::move(data));
 | |
| 				else
 | |
| 					results.emplace_back(nullptr);
 | |
| 			}
 | |
| 
 | |
| 			return results;
 | |
| 		};
 | |
| 
 | |
| 	// Apply all command-line options to the targets.
 | |
| 	for(auto &target: targets) {
 | |
| 		auto reflectable_target = dynamic_cast<Reflection::Struct *>(target.get());
 | |
| 		if(!reflectable_target) continue;
 | |
| 		arguments.apply(reflectable_target);
 | |
| 	}
 | |
| 
 | |
| 	// Create and configure a machine.
 | |
| 	::Machine::Error error;
 | |
| 	std::mutex machine_mutex;
 | |
| 	std::unique_ptr<::Machine::DynamicMachine> machine(::Machine::MachineForTargets(targets, rom_fetcher, error));
 | |
| 	if(!machine) {
 | |
| 		switch(error) {
 | |
| 			default: break;
 | |
| 			case ::Machine::Error::MissingROM:
 | |
| 				std::cerr << "Could not find system ROMs; please install to /usr/local/share/CLK/ or /usr/share/CLK/, or provide a --rompath." << std::endl;
 | |
| 				std::cerr << "One or more of the following was needed but not found:" << std::endl;
 | |
| 				for(const auto &rom: requested_roms) {
 | |
| 					std::cerr << rom.machine_name << '/' << rom.file_name << " (";
 | |
| 					if(!rom.descriptive_name.empty()) {
 | |
| 						std::cerr << rom.descriptive_name << "; ";
 | |
| 					}
 | |
| 					std::cerr << "accepted crc32s: ";
 | |
| 					bool is_first = true;
 | |
| 					for(const auto crc32: rom.crc32s) {
 | |
| 						if(!is_first) std::cerr << ", ";
 | |
| 						is_first = false;
 | |
| 						std::cerr << std::hex << std::setfill('0') << std::setw(8) << crc32;
 | |
| 					}
 | |
| 					std::cerr << ")" << std::endl;
 | |
| 				}
 | |
| 			break;
 | |
| 		}
 | |
| 
 | |
| 		return EXIT_FAILURE;
 | |
| 	}
 | |
| 
 | |
| 	// Apply all command-line options to the machines.
 | |
| 	auto configurable = machine->configurable_device();
 | |
| 	if(configurable) {
 | |
| 		const auto options = configurable->get_options();
 | |
| 		arguments.apply(options.get());
 | |
| 		configurable->set_options(options);
 | |
| 	}
 | |
| 
 | |
| 	// Apply the speed multiplier, if one was requested.
 | |
| 	{
 | |
| 		const auto speed_argument = arguments.selections.find("speed");
 | |
| 		if(speed_argument != arguments.selections.end()) {
 | |
| 			const char *speed_string = speed_argument->second.c_str();
 | |
| 			char *end;
 | |
| 			const double speed = strtod(speed_string, &end);
 | |
| 
 | |
| 			if(size_t(end - speed_string) != strlen(speed_string)) {
 | |
| 				std::cerr << "Unable to parse speed: " << speed_string << std::endl;
 | |
| 			} else if(speed <= 0.0) {
 | |
| 				std::cerr << "Cannot run at speed " << speed_string << "; speeds must be positive." << std::endl;
 | |
| 			} else {
 | |
| 				machine_runner.set_speed_multiplier(speed);
 | |
| 			}
 | |
| 		}
 | |
| 	}
 | |
| 
 | |
| 	// Apply the desired output volume, if requested.
 | |
| 	{
 | |
| 		const auto volume_argument = arguments.selections.find("volume");
 | |
| 		if(volume_argument != arguments.selections.end()) {
 | |
| 			const char *volume_string = volume_argument->second.c_str();
 | |
| 			char *end;
 | |
| 			const double volume = strtod(volume_string, &end);
 | |
| 
 | |
| 			if(size_t(end - volume_string) != strlen(volume_string)) {
 | |
| 				std::cerr << "Unable to parse volume: " << volume_string << std::endl;
 | |
| 			} else if(volume < 0.0 || volume > 1.0) {
 | |
| 				std::cerr << "Cannot run with volume " << volume_string << "; volumes must be between 0.0 and 1.0." << std::endl;
 | |
| 			} else {
 | |
| 				const auto speaker = machine->audio_producer()->get_speaker();
 | |
| 				if(speaker) speaker->set_output_volume(volume);
 | |
| 			}
 | |
| 		}
 | |
| 	}
 | |
| 
 | |
| 	// Check whether a 'logical' keyboard has been requested, or the machine would prefer one anyway.
 | |
| 	const bool logical_keyboard =
 | |
| 		(arguments.selections.find("logical-keyboard") != arguments.selections.end()) ||
 | |
| 		(machine->keyboard_machine() && machine->keyboard_machine()->prefers_logical_input());
 | |
| 	if(logical_keyboard) {
 | |
| 		SDL_StartTextInput();
 | |
| 	}
 | |
| 
 | |
| 	// Wire up the best-effort updater, its delegate, and the speaker delegate.
 | |
| 	machine_runner.machine = machine.get();
 | |
| 	machine_runner.machine_mutex = &machine_mutex;
 | |
| 
 | |
| 	// Ensure all media is inserted, if this machine accepts it.
 | |
| 	{
 | |
| 		auto media_target = machine->media_target();
 | |
| 		if(media_target) {
 | |
| 			Analyser::Static::Media media;
 | |
| 			for(const auto &file_name: arguments.file_names) {
 | |
| 				media += Analyser::Static::GetMedia(file_name);
 | |
| 			}
 | |
| 			media_target->insert_media(media);
 | |
| 		}
 | |
| 	}
 | |
| 
 | |
| 	// Attempt to set up video and audio.
 | |
| 	if(SDL_Init(SDL_INIT_VIDEO | SDL_INIT_AUDIO) < 0) {
 | |
| 		std::cerr << "SDL could not initialize! SDL_Error: " << SDL_GetError() << std::endl;
 | |
| 		return EXIT_FAILURE;
 | |
| 	}
 | |
| 
 | |
| 	// Ask for no depth buffer, a core profile and vsync-aligned rendering.
 | |
| 	SDL_GL_SetAttribute(SDL_GL_DEPTH_SIZE, 0);
 | |
| 	SDL_GL_SetAttribute(SDL_GL_CONTEXT_PROFILE_MASK, SDL_GL_CONTEXT_PROFILE_CORE);
 | |
| 	SDL_GL_SetAttribute(SDL_GL_CONTEXT_MAJOR_VERSION, 3);
 | |
| 	SDL_GL_SetAttribute(SDL_GL_CONTEXT_MINOR_VERSION, 2);
 | |
| 	SDL_GL_SetSwapInterval(1);
 | |
| 
 | |
| 	window = SDL_CreateWindow(	long_machine_name.empty() ? final_path_component(arguments.file_names.front()).c_str() : long_machine_name.c_str(),
 | |
| 								SDL_WINDOWPOS_UNDEFINED, SDL_WINDOWPOS_UNDEFINED,
 | |
| 								400, 300,
 | |
| 								SDL_WINDOW_OPENGL | SDL_WINDOW_RESIZABLE);
 | |
| 
 | |
| 	DynamicWindowTitler window_titler(window);
 | |
| 
 | |
| 	SDL_GLContext gl_context = nullptr;
 | |
| 	if(window) {
 | |
| 		gl_context = SDL_GL_CreateContext(window);
 | |
| 	}
 | |
| 	if(!window || !gl_context) {
 | |
| 		std::cerr << "Could not create " << (window ? "OpenGL context" : "window");
 | |
| 		std::cerr << "; reported error: \"" << SDL_GetError() << "\"" << std::endl;
 | |
| 		return EXIT_FAILURE;
 | |
| 	}
 | |
| 
 | |
| 	SDL_GL_MakeCurrent(window, gl_context);
 | |
| 
 | |
| 	GLint target_framebuffer = 0;
 | |
| 	glGetIntegerv(GL_FRAMEBUFFER_BINDING, &target_framebuffer);
 | |
| 
 | |
| 	// Setup output, assuming a CRT machine for now, and prepare a best-effort updater.
 | |
| 	Outputs::Display::OpenGL::ScanTarget scan_target(target_framebuffer);
 | |
| 	machine->scan_producer()->set_scan_target(&scan_target);
 | |
| 
 | |
| 	// For now, lie about audio output intentions.
 | |
| 	auto speaker = machine->audio_producer()->get_speaker();
 | |
| 	if(speaker) {
 | |
| 		// Create an audio pipe.
 | |
| 		SDL_AudioSpec desired_audio_spec;
 | |
| 		SDL_AudioSpec obtained_audio_spec;
 | |
| 
 | |
| 		SDL_zero(desired_audio_spec);
 | |
| 		desired_audio_spec.freq = 48000;	// TODO: how can I get SDL to reveal the output rate of this machine?
 | |
| 		desired_audio_spec.format = AUDIO_S16;
 | |
| 		desired_audio_spec.channels = 1 + int(speaker->get_is_stereo());
 | |
| 		desired_audio_spec.samples = Uint16(SpeakerDelegate::buffered_samples);
 | |
| 		desired_audio_spec.callback = SpeakerDelegate::SDL_audio_callback;
 | |
| 		desired_audio_spec.userdata = &speaker_delegate;
 | |
| 
 | |
| 		speaker_delegate.audio_device = SDL_OpenAudioDevice(nullptr, 0, &desired_audio_spec, &obtained_audio_spec, SDL_AUDIO_ALLOW_FREQUENCY_CHANGE);
 | |
| 
 | |
| 		speaker->set_output_rate(obtained_audio_spec.freq, desired_audio_spec.samples, obtained_audio_spec.channels == 2);
 | |
| 		speaker_delegate.is_stereo = obtained_audio_spec.channels == 2;
 | |
| 		speaker->set_delegate(&speaker_delegate);
 | |
| 		SDL_PauseAudioDevice(speaker_delegate.audio_device, 0);
 | |
| 	}
 | |
| 
 | |
| 	int window_width, window_height;
 | |
| 	SDL_GetWindowSize(window, &window_width, &window_height);
 | |
| 
 | |
| 	// If this is a joystick machine, check for and open attached joysticks.
 | |
| 	/*!
 | |
| 		Provides a wrapper for SDL_Joystick pointers that can keep track
 | |
| 		of historic hat values.
 | |
| 	*/
 | |
| 	class SDLJoystick {
 | |
| 		public:
 | |
| 			SDLJoystick(SDL_Joystick *joystick) : joystick_(joystick) {
 | |
| 				hat_values_.resize(SDL_JoystickNumHats(joystick));
 | |
| 			}
 | |
| 
 | |
| 			~SDLJoystick() {
 | |
| 				SDL_JoystickClose(joystick_);
 | |
| 			}
 | |
| 
 | |
| 			/// @returns The underlying SDL_Joystick.
 | |
| 			SDL_Joystick *get() {
 | |
| 				return joystick_;
 | |
| 			}
 | |
| 
 | |
| 			/// @returns A reference to the storage for the previous state of hat @c c.
 | |
| 			Uint8 &last_hat_value(int c) {
 | |
| 				return hat_values_[c];
 | |
| 			}
 | |
| 
 | |
| 			/// @returns The logic OR of all stored hat states.
 | |
| 			Uint8 hat_values() {
 | |
| 				Uint8 value = 0;
 | |
| 				for(const auto hat_value: hat_values_) {
 | |
| 					value |= hat_value;
 | |
| 				}
 | |
| 				return value;
 | |
| 			}
 | |
| 
 | |
| 		private:
 | |
| 			SDL_Joystick *joystick_;
 | |
| 			std::vector<Uint8> hat_values_;
 | |
| 	};
 | |
| 	std::vector<SDLJoystick> joysticks;
 | |
| 	const auto joystick_machine = machine->joystick_machine();
 | |
| 	if(joystick_machine) {
 | |
| 		SDL_InitSubSystem(SDL_INIT_JOYSTICK);
 | |
| 		for(int c = 0; c < SDL_NumJoysticks(); ++c) {
 | |
| 			joysticks.emplace_back(SDL_JoystickOpen(c));
 | |
| 		}
 | |
| 	}
 | |
| 
 | |
| 	/*
 | |
| 		If the machine offers anything for activity observation,
 | |
| 		create and register an activity observer.
 | |
| 	*/
 | |
| 	std::unique_ptr<ActivityObserver> activity_observer;
 | |
| 	Activity::Source *const activity_source = machine->activity_source();
 | |
| 	if(activity_source) {
 | |
| 		activity_observer = std::make_unique<ActivityObserver>(activity_source, 4.0f / 3.0f);
 | |
| 	}
 | |
| 
 | |
| 	// SDL 2.x delivers key up/down events and text inputs separately even when they're correlated;
 | |
| 	// this struct and map is used to correlate them by time.
 | |
| 	struct KeyPress {
 | |
| 		uint32_t timestamp = 0;
 | |
| 		std::string input;
 | |
| 		SDL_Scancode scancode = SDL_SCANCODE_UNKNOWN;
 | |
| 		SDL_Keycode keycode = SDLK_UNKNOWN;
 | |
| 		bool is_down = true;
 | |
| 
 | |
| 		KeyPress(uint32_t timestamp, const char *text) : timestamp(timestamp), input(text) {}
 | |
| 		KeyPress(uint32_t timestamp, SDL_Scancode scancode, SDL_Keycode keycode, bool is_down) : timestamp(timestamp), scancode(scancode), keycode(keycode), is_down(is_down) {}
 | |
| 		KeyPress() {}
 | |
| 	};
 | |
| 	std::vector<KeyPress> keypresses;
 | |
| 
 | |
| 	// Run the main event loop until the OS tells us to quit.
 | |
| 	const bool uses_mouse = !!machine->mouse_machine();
 | |
| 	bool should_quit = false;
 | |
| 	Uint32 fullscreen_mode = 0;
 | |
| 	machine_runner.start();
 | |
| 	while(!should_quit) {
 | |
| 		// Draw a new frame, indicating completion of the draw to the machine runner.
 | |
| 		scan_target.update(int(window_width), int(window_height));
 | |
| 		scan_target.draw(int(window_width), int(window_height));
 | |
| 		if(activity_observer) activity_observer->draw();
 | |
| 		machine_runner.signal_did_draw();
 | |
| 
 | |
| 		// Wait for presentation of that frame, posting a vsync.
 | |
| 		SDL_GL_SwapWindow(window);
 | |
| 		machine_runner.signal_vsync();
 | |
| 
 | |
| 		// NB: machine_mutex is *not* currently locked, therefore it shouldn't
 | |
| 		// be 'most' of the time — assuming most of the time is spent waiting
 | |
| 		// on vsync, anyway.
 | |
| 
 | |
| 		// Grab the machine lock and process all pending events.
 | |
| 		std::lock_guard lock_guard(machine_mutex);
 | |
| 		const auto keyboard_machine = machine->keyboard_machine();
 | |
| 		SDL_Event event;
 | |
| 		while(SDL_PollEvent(&event)) {
 | |
| 			switch(event.type) {
 | |
| 				case SDL_QUIT:	should_quit = true;	break;
 | |
| 
 | |
| 				case SDL_WINDOWEVENT:
 | |
| 					switch (event.window.event) {
 | |
| 						case SDL_WINDOWEVENT_RESIZED: {
 | |
| 							GLint target_framebuffer = 0;
 | |
| 							glGetIntegerv(GL_FRAMEBUFFER_BINDING, &target_framebuffer);
 | |
| 							scan_target.set_target_framebuffer(target_framebuffer);
 | |
| 							SDL_GetWindowSize(window, &window_width, &window_height);
 | |
| 							if(activity_observer) activity_observer->set_aspect_ratio(float(window_width) / float(window_height));
 | |
| 						} break;
 | |
| 
 | |
| 						default: break;
 | |
| 					}
 | |
| 				break;
 | |
| 
 | |
| 				case SDL_DROPFILE: {
 | |
| 					Analyser::Static::Media media = Analyser::Static::GetMedia(event.drop.file);
 | |
| 					machine->media_target()->insert_media(media);
 | |
| 				} break;
 | |
| 
 | |
| 				case SDL_TEXTINPUT:
 | |
| 					keypresses.emplace_back(event.text.timestamp, event.text.text);
 | |
| 				break;
 | |
| 
 | |
| 				case SDL_KEYDOWN:
 | |
| 				case SDL_KEYUP: {
 | |
| 					if(event.type == SDL_KEYDOWN) {
 | |
| 						// Syphon off the key-press if it's control+shift+V (paste).
 | |
| 						if(event.key.keysym.sym == SDLK_v && (SDL_GetModState()&KMOD_CTRL) && (SDL_GetModState()&KMOD_SHIFT)) {
 | |
| 							if(keyboard_machine) {
 | |
| 								keyboard_machine->type_string(SDL_GetClipboardText());
 | |
| 								break;
 | |
| 							}
 | |
| 						}
 | |
| 
 | |
| 						// Use ctrl+escape to release the mouse (if captured).
 | |
| 						if(event.key.keysym.sym == SDLK_ESCAPE && (SDL_GetModState()&KMOD_CTRL)) {
 | |
| 							SDL_SetRelativeMouseMode(SDL_FALSE);
 | |
| 							window_titler.set_mouse_is_captured(false);
 | |
| 						}
 | |
| 
 | |
| 						// Capture ctrl+shift+d as a take-a-screenshot command.
 | |
| 						if(event.key.keysym.sym == SDLK_d && (SDL_GetModState()&KMOD_CTRL) && (SDL_GetModState()&KMOD_SHIFT)) {
 | |
| 							// Grab the screen buffer.
 | |
| 							Outputs::Display::OpenGL::Screenshot screenshot(4, 3);
 | |
| 
 | |
| 							// Pick the directory for images. Try `xdg-user-dir PICTURES` first.
 | |
| 							std::string target_directory = system_get("xdg-user-dir PICTURES");
 | |
| 
 | |
| 							// Make sure there are no newlines.
 | |
| 							target_directory.erase(std::remove(target_directory.begin(), target_directory.end(), '\n'), target_directory.end());
 | |
| 							target_directory.erase(std::remove(target_directory.begin(), target_directory.end(), '\r'), target_directory.end());
 | |
| 
 | |
| 							// Fall back on the HOME directory if necessary.
 | |
| 							if(target_directory.empty()) target_directory = getenv("HOME");
 | |
| 
 | |
| 							// Find the first available name of the form ~/clk-screenshot-<number>.bmp.
 | |
| 							size_t index = 0;
 | |
| 							std::string target;
 | |
| 							while(true) {
 | |
| 								target = target_directory + "/clk-screenshot-" + std::to_string(index) + ".bmp";
 | |
| 
 | |
| 								struct stat file_stats;
 | |
| 								if(stat(target.c_str(), &file_stats))
 | |
| 									break;
 | |
| 
 | |
| 								++index;
 | |
| 							}
 | |
| 
 | |
| 							// Create a suitable SDL surface and save the thing.
 | |
| 							const bool is_big_endian = SDL_BYTEORDER == SDL_BIG_ENDIAN;
 | |
| 							SDL_Surface *const surface = SDL_CreateRGBSurfaceFrom(
 | |
| 								screenshot.pixel_data.data(),
 | |
| 								screenshot.width, screenshot.height,
 | |
| 								8*4,
 | |
| 								screenshot.width*4,
 | |
| 								is_big_endian ? 0xff000000 : 0x000000ff,
 | |
| 								is_big_endian ? 0x00ff0000 : 0x0000ff00,
 | |
| 								is_big_endian ? 0x0000ff00 : 0x00ff0000,
 | |
| 								0);
 | |
| 							SDL_SaveBMP(surface, target.c_str());
 | |
| 							SDL_FreeSurface(surface);
 | |
| 							break;
 | |
| 						}
 | |
| 					}
 | |
| 
 | |
| 					// Syphon off alt+enter (toggle full-screen) upon key up only; this was previously a key down action,
 | |
| 					// but the SDL_KEYDOWN announcement was found to be reposted after changing graphics mode on some
 | |
| 					// systems, causing a loop of changes, so key up is safer.
 | |
| 					if(event.type == SDL_KEYUP && event.key.keysym.sym == SDLK_RETURN && (SDL_GetModState()&KMOD_ALT)) {
 | |
| 						fullscreen_mode ^= SDL_WINDOW_FULLSCREEN_DESKTOP;
 | |
| 						SDL_SetWindowFullscreen(window, fullscreen_mode);
 | |
| 						SDL_ShowCursor((fullscreen_mode&SDL_WINDOW_FULLSCREEN_DESKTOP) ? SDL_DISABLE : SDL_ENABLE);
 | |
| 
 | |
| 						// Announce a potential discontinuity in keyboard input.
 | |
| 						const auto keyboard_machine = machine->keyboard_machine();
 | |
| 						if(keyboard_machine) {
 | |
| 							keyboard_machine->get_keyboard().reset_all_keys();
 | |
| 						}
 | |
| 						break;
 | |
| 					}
 | |
| 
 | |
| 					keypresses.emplace_back(event.text.timestamp, event.key.keysym.scancode, event.key.keysym.sym, event.type == SDL_KEYDOWN);
 | |
| 				} break;
 | |
| 
 | |
| 				case SDL_MOUSEBUTTONDOWN:
 | |
| 				case SDL_MOUSEBUTTONUP: {
 | |
| 					if(uses_mouse && event.type == SDL_MOUSEBUTTONDOWN && !SDL_GetRelativeMouseMode()) {
 | |
| 						SDL_SetRelativeMouseMode(SDL_TRUE);
 | |
| 						window_titler.set_mouse_is_captured(true);
 | |
| 						break;
 | |
| 					}
 | |
| 
 | |
| 					const auto mouse_machine = machine->mouse_machine();
 | |
| 					if(mouse_machine) {
 | |
| 						mouse_machine->get_mouse().set_button_pressed(
 | |
| 							event.button.button % mouse_machine->get_mouse().get_number_of_buttons(),
 | |
| 							event.type == SDL_MOUSEBUTTONDOWN);
 | |
| 					}
 | |
| 				} break;
 | |
| 
 | |
| 				case SDL_MOUSEMOTION: {
 | |
| 					if(SDL_GetRelativeMouseMode()) {
 | |
| 						const auto mouse_machine = machine->mouse_machine();
 | |
| 						if(mouse_machine) {
 | |
| 							mouse_machine->get_mouse().move(event.motion.xrel, event.motion.yrel);
 | |
| 						}
 | |
| 					}
 | |
| 				} break;
 | |
| 
 | |
| 				default: break;
 | |
| 			}
 | |
| 		}
 | |
| 
 | |
| 		std::vector<KeyPress> matched_keypresses;
 | |
| 		if(logical_keyboard) {
 | |
| 			// Look for potential keypress merges; SDL doesn't in any capacity guarantee that keypresses that produce
 | |
| 			// symbols will be delivered with the same timestamp. So look for any pairs of recorded kepresses that are
 | |
| 			// close together temporally and otherwise seem to match.
 | |
| 			if(keypresses.size()) {
 | |
| 				auto next_keypress = keypresses.begin();
 | |
| 
 | |
| 				while(next_keypress != keypresses.end()) {
 | |
| 					auto keypress = next_keypress;
 | |
| 					++next_keypress;
 | |
| 
 | |
| 					// If the two appear to pair off, push a combination and advance twice.
 | |
| 					// Otherwise, keep just the first and advance once.
 | |
| 					if(
 | |
| 						next_keypress != keypresses.end() &&
 | |
| 						keypress->timestamp >= next_keypress->timestamp - 5 &&
 | |
| 						keypress->is_down && next_keypress->is_down &&
 | |
| 						!keypress->input.size() != !next_keypress->input.size() &&
 | |
| 						(keypress->scancode != SDL_SCANCODE_UNKNOWN) != (next_keypress->scancode != SDL_SCANCODE_UNKNOWN)) {
 | |
| 
 | |
| 						KeyPress combined_keypress;
 | |
| 
 | |
| 						if(keypress->scancode != SDL_SCANCODE_UNKNOWN) {
 | |
| 							combined_keypress.scancode = keypress->scancode;
 | |
| 							combined_keypress.keycode = keypress->keycode;
 | |
| 							combined_keypress.input = std::move(next_keypress->input);
 | |
| 						} else {
 | |
| 							combined_keypress.scancode = next_keypress->scancode;
 | |
| 							combined_keypress.keycode = next_keypress->keycode;
 | |
| 							combined_keypress.input = std::move(keypress->input);
 | |
| 						};
 | |
| 						++next_keypress;
 | |
| 
 | |
| 						matched_keypresses.push_back(combined_keypress);
 | |
| 					} else {
 | |
| 						matched_keypresses.push_back(*keypress);
 | |
| 					}
 | |
| 				}
 | |
| 			}
 | |
| 		}
 | |
| 
 | |
| 		// Handle accumulated key states.
 | |
| 		const auto joystick_machine = machine->joystick_machine();
 | |
| 		for (const auto &keypress: logical_keyboard ? matched_keypresses : keypresses) {
 | |
| 			// Try to set this key on the keyboard first, if there is one.
 | |
| 			if(keyboard_machine) {
 | |
| 				Inputs::Keyboard::Key key = Inputs::Keyboard::Key::Space;
 | |
| 				if(KeyboardKeyForSDLScancode(keypress.scancode, key)) {
 | |
| 					// In principle there's no need for a conditional here; in practice logical_keyboard mode
 | |
| 					// is sufficiently untested on SDL, and somewhat too reliant on empirical timestamp behaviour,
 | |
| 					// for it to be trustworthy enough otherwise to expose.
 | |
| 					if(logical_keyboard) {
 | |
| 						if(keyboard_machine->apply_key(key, keypress.input.size() ? keypress.input[0] : 0, keypress.is_down, logical_keyboard)) {
 | |
| 							continue;
 | |
| 						}
 | |
| 					} else {
 | |
| 						// This is a slightly terrible way of obtaining a symbol for the key, e.g. for letters it will always return
 | |
| 						// the capital letter version, at least empirically. But it'll have to do for now.
 | |
| 						const char *key_name = SDL_GetKeyName(keypress.keycode);
 | |
| 						if(keyboard_machine->get_keyboard().set_key_pressed(key, (strlen(key_name) == 1) ? key_name[0] : 0, keypress.is_down)) {
 | |
| 							continue;
 | |
| 						}
 | |
| 					}
 | |
| 				}
 | |
| 			}
 | |
| 
 | |
| 			// Having failed that, try converting it into a joystick action.
 | |
| 			if(joystick_machine) {
 | |
| 				auto &joysticks = joystick_machine->get_joysticks();
 | |
| 				if(!joysticks.empty()) {
 | |
| 					const bool is_pressed = keypress.is_down;
 | |
| 					switch(keypress.scancode) {
 | |
| 						case SDL_SCANCODE_LEFT:		joysticks[0]->set_input(Inputs::Joystick::Input::Left, is_pressed);		break;
 | |
| 						case SDL_SCANCODE_RIGHT:	joysticks[0]->set_input(Inputs::Joystick::Input::Right, is_pressed);	break;
 | |
| 						case SDL_SCANCODE_UP:		joysticks[0]->set_input(Inputs::Joystick::Input::Up, is_pressed);		break;
 | |
| 						case SDL_SCANCODE_DOWN:		joysticks[0]->set_input(Inputs::Joystick::Input::Down, is_pressed);		break;
 | |
| 						case SDL_SCANCODE_SPACE:	joysticks[0]->set_input(Inputs::Joystick::Input::Fire, is_pressed);		break;
 | |
| 						case SDL_SCANCODE_A:		joysticks[0]->set_input(Inputs::Joystick::Input(Inputs::Joystick::Input::Fire, 0), is_pressed);	break;
 | |
| 						case SDL_SCANCODE_S:		joysticks[0]->set_input(Inputs::Joystick::Input(Inputs::Joystick::Input::Fire, 1), is_pressed);	break;
 | |
| 						case SDL_SCANCODE_D:		joysticks[0]->set_input(Inputs::Joystick::Input(Inputs::Joystick::Input::Fire, 2), is_pressed);	break;
 | |
| 						case SDL_SCANCODE_F:		joysticks[0]->set_input(Inputs::Joystick::Input(Inputs::Joystick::Input::Fire, 3), is_pressed);	break;
 | |
| 						default: {
 | |
| 							if(keypress.input.size()) {
 | |
| 								joysticks[0]->set_input(Inputs::Joystick::Input(keypress.input[0]), is_pressed);
 | |
| 							}
 | |
| 						} break;
 | |
| 					}
 | |
| 				}
 | |
| 			}
 | |
| 		}
 | |
| 		keypresses.clear();
 | |
| 
 | |
| 		// Push new joystick state, if any.
 | |
| 		if(joystick_machine) {
 | |
| 			auto &machine_joysticks = joystick_machine->get_joysticks();
 | |
| 			for(size_t c = 0; c < joysticks.size(); ++c) {
 | |
| 				size_t target = c % machine_joysticks.size();
 | |
| 
 | |
| 				// Post the first two analogue axes presented by the controller as horizontal and vertical inputs,
 | |
| 				// unless the user seems to be using a hat.
 | |
| 				// SDL will return a value in the range [-32768, 32767], so map from that to [0, 1.0]
 | |
| 				if(!joysticks[c].hat_values()) {
 | |
| 					const float x_axis = float(SDL_JoystickGetAxis(joysticks[c].get(), 0) + 32768) / 65535.0f;
 | |
| 					const float y_axis = float(SDL_JoystickGetAxis(joysticks[c].get(), 1) + 32768) / 65535.0f;
 | |
| 					machine_joysticks[target]->set_input(Inputs::Joystick::Input(Inputs::Joystick::Input::Type::Horizontal), x_axis);
 | |
| 					machine_joysticks[target]->set_input(Inputs::Joystick::Input(Inputs::Joystick::Input::Type::Vertical), y_axis);
 | |
| 				}
 | |
| 
 | |
| 				// Forward hats as directions; hats always override analogue inputs.
 | |
| 				const int number_of_hats = SDL_JoystickNumHats(joysticks[c].get());
 | |
| 				for(int hat = 0; hat < number_of_hats; ++hat) {
 | |
| 					const Uint8 hat_value = SDL_JoystickGetHat(joysticks[c].get(), hat);
 | |
| 					const Uint8 changes = hat_value ^ joysticks[c].last_hat_value(hat);
 | |
| 					joysticks[c].last_hat_value(hat) = hat_value;
 | |
| 
 | |
| 					if(changes & SDL_HAT_UP) {
 | |
| 						machine_joysticks[target]->set_input(Inputs::Joystick::Input(Inputs::Joystick::Input::Type::Up), !!(hat_value & SDL_HAT_UP));
 | |
| 					}
 | |
| 					if(changes & SDL_HAT_DOWN) {
 | |
| 						machine_joysticks[target]->set_input(Inputs::Joystick::Input(Inputs::Joystick::Input::Type::Down), !!(hat_value & SDL_HAT_DOWN));
 | |
| 					}
 | |
| 					if(changes & SDL_HAT_LEFT) {
 | |
| 						machine_joysticks[target]->set_input(Inputs::Joystick::Input(Inputs::Joystick::Input::Type::Left), !!(hat_value & SDL_HAT_LEFT));
 | |
| 					}
 | |
| 					if(changes & SDL_HAT_RIGHT) {
 | |
| 						machine_joysticks[target]->set_input(Inputs::Joystick::Input(Inputs::Joystick::Input::Type::Right), !!(hat_value & SDL_HAT_RIGHT));
 | |
| 					}
 | |
| 				}
 | |
| 
 | |
| 				// Forward all fire buttons, retaining their original indices.
 | |
| 				const int number_of_buttons = SDL_JoystickNumButtons(joysticks[c].get());
 | |
| 				for(int button = 0; button < number_of_buttons; ++button) {
 | |
| 					machine_joysticks[target]->set_input(
 | |
| 						Inputs::Joystick::Input(Inputs::Joystick::Input::Type::Fire, button),
 | |
| 						SDL_JoystickGetButton(joysticks[c].get(), button) ? true : false);
 | |
| 				}
 | |
| 			}
 | |
| 		}
 | |
| 	}
 | |
| 
 | |
| 	// Clean up.
 | |
| 	machine_runner.stop();	// Ensure no further updates will occur.
 | |
| 	joysticks.clear();
 | |
| 	SDL_DestroyWindow( window );
 | |
| 	SDL_Quit();
 | |
| 
 | |
| 	return EXIT_SUCCESS;
 | |
| }
 |