mirror of
https://github.com/open-goal/jak-project.git
synced 2024-10-20 00:57:44 -04:00
28a2ecdfd3
* [jak2] goalc supports multiple projects * disable deci2 server if not debugging
48 lines
1.1 KiB
C++
48 lines
1.1 KiB
C++
#pragma once
|
|
|
|
#include <condition_variable>
|
|
|
|
#include "deci_common.h"
|
|
|
|
#include "common/cross_sockets/XSocketServer.h"
|
|
|
|
/// @brief Basic implementation of a DECI2 server.
|
|
/// Works with deci2.cpp(sceDeci2) to implement the networking on target
|
|
class Deci2Server : public XSocketServer {
|
|
public:
|
|
using XSocketServer::XSocketServer;
|
|
virtual ~Deci2Server();
|
|
|
|
void post_init() override;
|
|
|
|
void read_data();
|
|
void send_data(void* buf, u16 len);
|
|
|
|
bool is_client_connected();
|
|
bool wait_for_protos_ready(); // return true if ready, false if we should shut down.
|
|
void send_proto_ready(Deci2Driver* drivers, int* driver_count);
|
|
void send_shutdown();
|
|
|
|
void lock();
|
|
void unlock();
|
|
|
|
protected:
|
|
void accept_thread_func();
|
|
|
|
private:
|
|
bool want_shutdown = false;
|
|
bool protocols_ready = false;
|
|
std::condition_variable cv;
|
|
Deci2Driver* d2_drivers = nullptr;
|
|
int* d2_driver_count = nullptr;
|
|
|
|
int accepted_socket = -1;
|
|
bool kill_accept_thread = false;
|
|
bool accept_thread_running = false;
|
|
|
|
std::thread accept_thread;
|
|
std::mutex server_mutex;
|
|
|
|
bool client_connected = false;
|
|
};
|