mirror of
https://github.com/open-goal/jak-project.git
synced 2024-10-20 21:27:52 -04:00
59 lines
1.3 KiB
C++
59 lines
1.3 KiB
C++
/*!
|
|
* @file Deci2Server.h
|
|
* Basic implementation of a DECI2 server.
|
|
* Works with deci2.cpp (sceDeci2) to implement the networking on target
|
|
*/
|
|
|
|
#ifndef JAK1_DECI2SERVER_H
|
|
#define JAK1_DECI2SERVER_H
|
|
|
|
#ifdef __linux
|
|
#include <netinet/in.h>
|
|
#elif _WIN32
|
|
#include <Windows.h>
|
|
#endif
|
|
#include <thread>
|
|
#include <mutex>
|
|
#include <condition_variable>
|
|
#include <functional>
|
|
#include "game/system/deci_common.h"
|
|
|
|
class Deci2Server {
|
|
public:
|
|
static constexpr int BUFFER_SIZE = 32 * 1024 * 1024;
|
|
Deci2Server(std::function<bool()> shutdown_callback);
|
|
~Deci2Server();
|
|
bool init();
|
|
bool check_for_listener();
|
|
void send_data(void* buf, u16 len);
|
|
|
|
void lock();
|
|
void unlock();
|
|
void wait_for_protos_ready();
|
|
void send_proto_ready(Deci2Driver* drivers, int* driver_count);
|
|
|
|
void run();
|
|
|
|
private:
|
|
void close_server_socket();
|
|
void accept_thread_func();
|
|
bool kill_accept_thread = false;
|
|
char* buffer = nullptr;
|
|
int server_socket = -1;
|
|
struct sockaddr_in addr = {};
|
|
int new_sock = -1;
|
|
bool server_initialized = false;
|
|
bool accept_thread_running = false;
|
|
bool server_connected = false;
|
|
std::function<bool()> want_exit;
|
|
std::thread accept_thread;
|
|
|
|
std::condition_variable cv;
|
|
bool protocols_ready = false;
|
|
std::mutex deci_mutex;
|
|
Deci2Driver* d2_drivers = nullptr;
|
|
int* d2_driver_count = nullptr;
|
|
};
|
|
|
|
#endif // JAK1_DECI2SERVER_H
|