mirror of
https://github.com/RetroPortingToolKit/psxrecomp
synced 2026-10-26 18:25:35 -04:00
Shokunin
64 lines
2.5 KiB
C
64 lines
2.5 KiB
C
#include "mod_execution.h"
|
|
#include "mod_plugins.h"
|
|
#include "psx_thread_local.h"
|
|
#include <pthread.h>
|
|
#include <stdatomic.h>
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
#define CHECK(c) do { if (!(c)) abort(); } while (0)
|
|
static PSX_THREAD_LOCAL struct { int enabled; unsigned values[256]; } state;
|
|
static ModExecutionSnapshot *image;
|
|
static atomic_int phase;
|
|
static unsigned captures;
|
|
static void capture(void *out) {
|
|
/* Publication buffers are persistent private images. Plugins may use the
|
|
* previous image's generation to avoid recopying immutable cache pages. */
|
|
if (!captures) {
|
|
const unsigned char *bytes = out;
|
|
for (size_t i = 0; i < sizeof state; ++i) CHECK(bytes[i] == 0);
|
|
} else {
|
|
CHECK(((const unsigned *)out)[94] == 17);
|
|
}
|
|
memcpy(out, &state, sizeof state); ++captures;
|
|
}
|
|
static void bind(const void *in) { memcpy(&state, in, sizeof state); }
|
|
static void *prepare(void *unused) {
|
|
(void)unused; image = mod_execution_create(); return NULL;
|
|
}
|
|
static void *worker(void *unused) {
|
|
(void)unused;
|
|
mod_execution_bind(image);
|
|
CHECK(state.enabled && state.values[93] == 17);
|
|
state.values[93] = 91;
|
|
atomic_store_explicit(&phase, 1, memory_order_release);
|
|
while (atomic_load_explicit(&phase, memory_order_acquire) != 2) { }
|
|
CHECK(state.values[93] == 91);
|
|
mod_execution_bind(image);
|
|
CHECK(state.values[93] == 23);
|
|
return NULL;
|
|
}
|
|
int main(void) {
|
|
const PSXModExecutionState callbacks = {sizeof(callbacks), "fixture", sizeof state, capture, bind};
|
|
const PSXModExecutionState stateless = {sizeof(stateless), "stateless", 0, NULL, NULL};
|
|
CHECK(psx_mod_register_execution_state(&callbacks));
|
|
CHECK(psx_mod_register_execution_state(&stateless));
|
|
CHECK(!psx_mod_register_execution_state(&callbacks));
|
|
state.enabled = 1; state.values[93] = 17;
|
|
mod_execution_seal();
|
|
CHECK(!psx_mod_register_execution_state(&callbacks));
|
|
pthread_t preparation;
|
|
CHECK(!pthread_create(&preparation, NULL, prepare, NULL));
|
|
CHECK(!pthread_join(preparation, NULL)); CHECK(image);
|
|
mod_execution_capture(image);
|
|
pthread_t thread; CHECK(!pthread_create(&thread, NULL, worker, NULL));
|
|
while (!atomic_load_explicit(&phase, memory_order_acquire)) { }
|
|
CHECK(state.values[93] == 17);
|
|
state.values[93] = 23; mod_execution_capture(image);
|
|
atomic_store_explicit(&phase, 2, memory_order_release);
|
|
CHECK(!pthread_join(thread, NULL));
|
|
CHECK(state.values[93] == 23);
|
|
mod_execution_destroy(image);
|
|
CHECK(!psx_mod_register_execution_state(&callbacks));
|
|
return 0;
|
|
}
|