WiimoteReal: use inheritance instead of #ifdef

This commit is contained in:
Tillmann Karras
2014-12-05 00:16:41 +01:00
parent 94197b604e
commit 8d9a30b370
6 changed files with 131 additions and 141 deletions

View File

@ -9,9 +9,7 @@ namespace WiimoteReal
{ {
WiimoteScanner::WiimoteScanner() WiimoteScanner::WiimoteScanner()
{ {}
return;
}
WiimoteScanner::~WiimoteScanner() WiimoteScanner::~WiimoteScanner()
{} {}
@ -30,43 +28,4 @@ bool WiimoteScanner::IsReady() const
return false; return false;
} }
void Wiimote::InitInternal()
{}
void Wiimote::TeardownInternal()
{}
bool Wiimote::ConnectInternal()
{
return 0;
}
void Wiimote::DisconnectInternal()
{
return;
}
bool Wiimote::IsConnected() const
{
return false;
}
void Wiimote::IOWakeup()
{}
int Wiimote::IORead(u8* buf)
{
return 0;
}
int Wiimote::IOWrite(const u8* buf, size_t len)
{
return 0;
}
void Wiimote::EnablePowerAssertionInternal()
{}
void Wiimote::DisablePowerAssertionInternal()
{}
}; };

View File

@ -13,6 +13,28 @@
namespace WiimoteReal namespace WiimoteReal
{ {
class WiimoteLinux final : public Wiimote
{
public:
WiimoteLinux(bdaddr_t bdaddr);
~WiimoteLinux() override;
protected:
bool ConnectInternal() override;
void DisconnectInternal() override;
bool IsConnected() const override;
void IOWakeup() override;
int IORead(u8* buf) override;
int IOWrite(u8 const* buf, size_t len) override;
private:
bdaddr_t m_bdaddr; // Bluetooth address
int m_cmd_sock; // Command socket
int m_int_sock; // Interrupt socket
int m_wakeup_pipe_w;
int m_wakeup_pipe_r;
};
WiimoteScanner::WiimoteScanner() WiimoteScanner::WiimoteScanner()
: m_want_wiimotes() : m_want_wiimotes()
, device_id(-1) , device_id(-1)
@ -102,8 +124,7 @@ void WiimoteScanner::FindWiimotes(std::vector<Wiimote*> & found_wiimotes, Wiimot
char bdaddr_str[18] = {}; char bdaddr_str[18] = {};
ba2str(&scan_infos[i].bdaddr, bdaddr_str); ba2str(&scan_infos[i].bdaddr, bdaddr_str);
auto* const wm = new Wiimote; Wiimote* wm = new WiimoteLinux(scan_infos[i].bdaddr);
wm->bdaddr = scan_infos[i].bdaddr;
if (IsBalanceBoardName(name)) if (IsBalanceBoardName(name))
{ {
found_board = wm; found_board = wm;
@ -120,7 +141,7 @@ void WiimoteScanner::FindWiimotes(std::vector<Wiimote*> & found_wiimotes, Wiimot
} }
void Wiimote::InitInternal() WiimoteLinux::WiimoteLinux(bdaddr_t bdaddr) : Wiimote(), m_bdaddr(bdaddr)
{ {
m_cmd_sock = -1; m_cmd_sock = -1;
m_int_sock = -1; m_int_sock = -1;
@ -133,17 +154,17 @@ void Wiimote::InitInternal()
} }
m_wakeup_pipe_w = fds[1]; m_wakeup_pipe_w = fds[1];
m_wakeup_pipe_r = fds[0]; m_wakeup_pipe_r = fds[0];
m_bdaddr = (bdaddr_t){{0, 0, 0, 0, 0, 0}};
} }
void Wiimote::TeardownInternal() WiimoteLinux::~WiimoteLinux()
{ {
Shutdown();
close(m_wakeup_pipe_w); close(m_wakeup_pipe_w);
close(m_wakeup_pipe_r); close(m_wakeup_pipe_r);
} }
// Connect to a wiimote with a known address. // Connect to a wiimote with a known address.
bool Wiimote::ConnectInternal() bool WiimoteLinux::ConnectInternal()
{ {
sockaddr_l2 addr; sockaddr_l2 addr;
addr.l2_family = AF_BLUETOOTH; addr.l2_family = AF_BLUETOOTH;
@ -176,7 +197,7 @@ bool Wiimote::ConnectInternal()
return true; return true;
} }
void Wiimote::DisconnectInternal() void WiimoteLinux::DisconnectInternal()
{ {
close(m_cmd_sock); close(m_cmd_sock);
close(m_int_sock); close(m_int_sock);
@ -185,12 +206,12 @@ void Wiimote::DisconnectInternal()
m_int_sock = -1; m_int_sock = -1;
} }
bool Wiimote::IsConnected() const bool WiimoteLinux::IsConnected() const
{ {
return m_cmd_sock != -1;// && int_sock != -1; return m_cmd_sock != -1;// && int_sock != -1;
} }
void Wiimote::IOWakeup() void WiimoteLinux::IOWakeup()
{ {
char c = 0; char c = 0;
if (write(m_wakeup_pipe_w, &c, 1) != 1) if (write(m_wakeup_pipe_w, &c, 1) != 1)
@ -202,7 +223,7 @@ void Wiimote::IOWakeup()
// positive = read packet // positive = read packet
// negative = didn't read packet // negative = didn't read packet
// zero = error // zero = error
int Wiimote::IORead(u8* buf) int WiimoteLinux::IORead(u8* buf)
{ {
// Block select for 1/2000th of a second // Block select for 1/2000th of a second
@ -250,14 +271,9 @@ int Wiimote::IORead(u8* buf)
return r; return r;
} }
int Wiimote::IOWrite(u8 const* buf, size_t len) int WiimoteLinux::IOWrite(u8 const* buf, size_t len)
{ {
return write(m_int_sock, buf, (int)len); return write(m_int_sock, buf, (int)len);
} }
void Wiimote::EnablePowerAssertionInternal()
{}
void Wiimote::DisablePowerAssertionInternal()
{}
}; // WiimoteReal }; // WiimoteReal

View File

@ -187,6 +187,27 @@ inline void init_lib()
namespace WiimoteReal namespace WiimoteReal
{ {
class WiimoteWindows final : public Wiimote
{
public:
WiimoteWindows(const std::basic_string<TCHAR>& path);
~WiimoteWindows() override;
protected:
bool ConnectInternal() override;
void DisconnectInternal() override;
bool IsConnected() const override;
void IOWakeup() override;
int IORead(u8* buf) override;
int IOWrite(u8 const* buf, size_t len) override;
private:
std::basic_string<TCHAR> m_devicepath; // Unique wiimote reference
HANDLE m_dev_handle; // HID handle
OVERLAPPED m_hid_overlap_read; // Overlap handles
OVERLAPPED m_hid_overlap_write;
enum win_bt_stack_t m_stack; // Type of bluetooth stack to use
};
int _IOWrite(HANDLE &dev_handle, OVERLAPPED &hid_overlap_write, enum win_bt_stack_t &stack, const u8* buf, size_t len, DWORD* written); int _IOWrite(HANDLE &dev_handle, OVERLAPPED &hid_overlap_write, enum win_bt_stack_t &stack, const u8* buf, size_t len, DWORD* written);
int _IORead(HANDLE &dev_handle, OVERLAPPED &hid_overlap_read, u8* buf, int index); int _IORead(HANDLE &dev_handle, OVERLAPPED &hid_overlap_read, u8* buf, int index);
@ -271,11 +292,11 @@ void WiimoteScanner::FindWiimotes(std::vector<Wiimote*> & found_wiimotes, Wiimot
// Query the data for this device // Query the data for this device
if (SetupDiGetDeviceInterfaceDetail(device_info, &device_data, detail_data, len, nullptr, nullptr)) if (SetupDiGetDeviceInterfaceDetail(device_info, &device_data, detail_data, len, nullptr, nullptr))
{ {
auto const wm = new Wiimote; std::basic_string<TCHAR> device_path(detail_data->DevicePath);
wm->m_devicepath = detail_data->DevicePath; Wiimote* wm = new WiimoteWindows(device_path);
bool real_wiimote = false, is_bb = false; bool real_wiimote = false, is_bb = false;
CheckDeviceType(wm->m_devicepath, real_wiimote, is_bb); CheckDeviceType(device_path, real_wiimote, is_bb);
if (is_bb) if (is_bb)
{ {
found_board = wm; found_board = wm;
@ -499,7 +520,7 @@ bool WiimoteScanner::IsReady() const
} }
// Connect to a wiimote with a known device path. // Connect to a wiimote with a known device path.
bool Wiimote::ConnectInternal() bool WiimoteWindows::ConnectInternal()
{ {
if (IsConnected()) if (IsConnected())
return false; return false;
@ -569,7 +590,7 @@ bool Wiimote::ConnectInternal()
return true; return true;
} }
void Wiimote::DisconnectInternal() void WiimoteWindows::DisconnectInternal()
{ {
if (!IsConnected()) if (!IsConnected())
return; return;
@ -583,7 +604,7 @@ void Wiimote::DisconnectInternal()
#endif #endif
} }
void Wiimote::InitInternal() WiimoteWindows::WiimoteWindows(const std::basic_string<TCHAR>& path) : m_devicepath(path)
{ {
m_dev_handle = 0; m_dev_handle = 0;
m_stack = MSBT_STACK_UNKNOWN; m_stack = MSBT_STACK_UNKNOWN;
@ -595,13 +616,14 @@ void Wiimote::InitInternal()
m_hid_overlap_write.hEvent = CreateEvent(nullptr, true, false, nullptr); m_hid_overlap_write.hEvent = CreateEvent(nullptr, true, false, nullptr);
} }
void Wiimote::TeardownInternal() WiimoteWindows::~WiimoteWindows()
{ {
Shutdown();
CloseHandle(m_hid_overlap_read.hEvent); CloseHandle(m_hid_overlap_read.hEvent);
CloseHandle(m_hid_overlap_write.hEvent); CloseHandle(m_hid_overlap_write.hEvent);
} }
bool Wiimote::IsConnected() const bool WiimoteWindows::IsConnected() const
{ {
return m_dev_handle != 0; return m_dev_handle != 0;
} }
@ -660,7 +682,7 @@ int _IORead(HANDLE &dev_handle, OVERLAPPED &hid_overlap_read, u8* buf, int index
return bytes + 1; return bytes + 1;
} }
void Wiimote::IOWakeup() void WiimoteWindows::IOWakeup()
{ {
SetEvent(m_hid_overlap_read.hEvent); SetEvent(m_hid_overlap_read.hEvent);
} }
@ -669,7 +691,7 @@ void Wiimote::IOWakeup()
// positive = read packet // positive = read packet
// negative = didn't read packet // negative = didn't read packet
// zero = error // zero = error
int Wiimote::IORead(u8* buf) int WiimoteWindows::IORead(u8* buf)
{ {
return _IORead(m_dev_handle, m_hid_overlap_read, buf, m_index); return _IORead(m_dev_handle, m_hid_overlap_read, buf, m_index);
} }
@ -772,16 +794,11 @@ int _IOWrite(HANDLE &dev_handle, OVERLAPPED &hid_overlap_write, enum win_bt_stac
return 0; return 0;
} }
int Wiimote::IOWrite(const u8* buf, size_t len) int WiimoteWindows::IOWrite(const u8* buf, size_t len)
{ {
return _IOWrite(m_dev_handle, m_hid_overlap_write, m_stack, buf, len, nullptr); return _IOWrite(m_dev_handle, m_hid_overlap_write, m_stack, buf, len, nullptr);
} }
void Wiimote::EnablePowerAssertionInternal()
{}
void Wiimote::DisablePowerAssertionInternal()
{}
// invokes callback for each found wiimote bluetooth device // invokes callback for each found wiimote bluetooth device
template <typename T> template <typename T>
void ProcessWiimotes(bool new_scan, T& callback) void ProcessWiimotes(bool new_scan, T& callback)

View File

@ -16,6 +16,35 @@
namespace WiimoteReal namespace WiimoteReal
{ {
class WiimoteDarwin final : public Wiimote
{
public:
WiimoteDarwin(IOBluetoothDevice* device);
~WiimoteDarwin() override;
// These are not protected/private because ConnectBT needs them.
void DisconnectInternal() override;
IOBluetoothDevice* m_btd;
unsigned char* m_input;
int m_inputlen;
protected:
bool ConnectInternal() override;
bool IsConnected() const override;
void IOWakeup() override;
int IORead(u8* buf) override;
int IOWrite(u8 const* buf, size_t len) override;
void EnablePowerAssertionInternal() override;
void DisablePowerAssertionInternal() override;
private:
IOBluetoothL2CAPChannel* m_ichan;
IOBluetoothL2CAPChannel* m_cchan;
bool m_connected;
CFRunLoopRef m_wiimote_thread_run_loop;
IOPMAssertionID m_pm_assertion;
};
WiimoteScanner::WiimoteScanner() WiimoteScanner::WiimoteScanner()
: m_run_thread() : m_run_thread()
, m_want_wiimotes() , m_want_wiimotes()
@ -76,8 +105,7 @@ void WiimoteScanner::FindWiimotes(std::vector<Wiimote*> & found_wiimotes, Wiimot
if (!IsValidBluetoothName([[dev name] UTF8String])) if (!IsValidBluetoothName([[dev name] UTF8String]))
continue; continue;
Wiimote *wm = new Wiimote(); Wiimote* wm = new WiimoteDarwin([dev retain]);
wm->m_btd = [dev retain];
if (IsBalanceBoardName([[dev name] UTF8String])) if (IsBalanceBoardName([[dev name] UTF8String]))
{ {
@ -100,17 +128,17 @@ bool WiimoteScanner::IsReady() const
return true; return true;
} }
void Wiimote::InitInternal() WiimoteDarwin::WiimoteDarwin(IOBluetoothDevice* device) : m_btd(device)
{ {
m_inputlen = 0; m_inputlen = 0;
m_connected = false; m_connected = false;
m_wiimote_thread_run_loop = nullptr; m_wiimote_thread_run_loop = nullptr;
m_btd = nil;
m_pm_assertion = kIOPMNullAssertionID; m_pm_assertion = kIOPMNullAssertionID;
} }
void Wiimote::TeardownInternal() WiimoteDarwin::~WiimoteDarwin()
{ {
Shutdown();
if (m_wiimote_thread_run_loop) if (m_wiimote_thread_run_loop)
{ {
CFRelease(m_wiimote_thread_run_loop); CFRelease(m_wiimote_thread_run_loop);
@ -118,10 +146,11 @@ void Wiimote::TeardownInternal()
} }
[m_btd release]; [m_btd release];
m_btd = nil; m_btd = nil;
DisablePowerAssertionInternal();
} }
// Connect to a wiimote with a known address. // Connect to a wiimote with a known address.
bool Wiimote::ConnectInternal() bool WiimoteDarwin::ConnectInternal()
{ {
if (IsConnected()) if (IsConnected())
return false; return false;
@ -182,7 +211,7 @@ bad:
} }
// Disconnect a wiimote. // Disconnect a wiimote.
void Wiimote::DisconnectInternal() void WiimoteDarwin::DisconnectInternal()
{ {
[m_ichan closeChannel]; [m_ichan closeChannel];
[m_ichan release]; [m_ichan release];
@ -202,12 +231,12 @@ void Wiimote::DisconnectInternal()
m_connected = false; m_connected = false;
} }
bool Wiimote::IsConnected() const bool WiimoteDarwin::IsConnected() const
{ {
return m_connected; return m_connected;
} }
void Wiimote::IOWakeup() void WiimoteDarwin::IOWakeup()
{ {
if (m_wiimote_thread_run_loop) if (m_wiimote_thread_run_loop)
{ {
@ -215,7 +244,7 @@ void Wiimote::IOWakeup()
} }
} }
int Wiimote::IORead(unsigned char *buf) int WiimoteDarwin::IORead(unsigned char *buf)
{ {
m_input = buf; m_input = buf;
m_inputlen = -1; m_inputlen = -1;
@ -225,7 +254,7 @@ int Wiimote::IORead(unsigned char *buf)
return m_inputlen; return m_inputlen;
} }
int Wiimote::IOWrite(const unsigned char *buf, size_t len) int WiimoteDarwin::IOWrite(const unsigned char *buf, size_t len)
{ {
IOReturn ret; IOReturn ret;
@ -240,7 +269,7 @@ int Wiimote::IOWrite(const unsigned char *buf, size_t len)
return 0; return 0;
} }
void Wiimote::EnablePowerAssertionInternal() void WiimoteDarwin::EnablePowerAssertionInternal()
{ {
if (m_pm_assertion == kIOPMNullAssertionID) if (m_pm_assertion == kIOPMNullAssertionID)
{ {
@ -249,7 +278,7 @@ void Wiimote::EnablePowerAssertionInternal()
} }
} }
void Wiimote::DisablePowerAssertionInternal() void WiimoteDarwin::DisablePowerAssertionInternal()
{ {
if (m_pm_assertion != kIOPMNullAssertionID) if (m_pm_assertion != kIOPMNullAssertionID)
{ {
@ -287,7 +316,7 @@ void Wiimote::DisablePowerAssertionInternal()
length: (NSUInteger) length length: (NSUInteger) length
{ {
IOBluetoothDevice *device = [l2capChannel device]; IOBluetoothDevice *device = [l2capChannel device];
WiimoteReal::Wiimote *wm = nullptr; WiimoteReal::WiimoteDarwin *wm = nullptr;
std::lock_guard<std::recursive_mutex> lk(WiimoteReal::g_refresh_lock); std::lock_guard<std::recursive_mutex> lk(WiimoteReal::g_refresh_lock);
@ -295,8 +324,9 @@ void Wiimote::DisablePowerAssertionInternal()
{ {
if (WiimoteReal::g_wiimotes[i] == nullptr) if (WiimoteReal::g_wiimotes[i] == nullptr)
continue; continue;
if ([device isEqual: WiimoteReal::g_wiimotes[i]->m_btd] == TRUE) wm = static_cast<WiimoteReal::WiimoteDarwin*>(WiimoteReal::g_wiimotes[i]);
wm = WiimoteReal::g_wiimotes[i]; if ([device isEqual: wm->m_btd] != TRUE)
wm = nullptr;
} }
if (wm == nullptr) { if (wm == nullptr) {
@ -325,7 +355,7 @@ void Wiimote::DisablePowerAssertionInternal()
- (void) l2capChannelClosed: (IOBluetoothL2CAPChannel *) l2capChannel - (void) l2capChannelClosed: (IOBluetoothL2CAPChannel *) l2capChannel
{ {
IOBluetoothDevice *device = [l2capChannel device]; IOBluetoothDevice *device = [l2capChannel device];
WiimoteReal::Wiimote *wm = nullptr; WiimoteReal::WiimoteDarwin *wm = nullptr;
std::lock_guard<std::recursive_mutex> lk(WiimoteReal::g_refresh_lock); std::lock_guard<std::recursive_mutex> lk(WiimoteReal::g_refresh_lock);
@ -333,8 +363,9 @@ void Wiimote::DisablePowerAssertionInternal()
{ {
if (WiimoteReal::g_wiimotes[i] == nullptr) if (WiimoteReal::g_wiimotes[i] == nullptr)
continue; continue;
if ([device isEqual: WiimoteReal::g_wiimotes[i]->m_btd] == TRUE) wm = static_cast<WiimoteReal::WiimoteDarwin*>(WiimoteReal::g_wiimotes[i]);
wm = WiimoteReal::g_wiimotes[i]; if ([device isEqual: wm->m_btd] != TRUE)
wm = nullptr;
} }
if (wm == nullptr) { if (wm == nullptr) {

View File

@ -42,17 +42,13 @@ Wiimote::Wiimote()
, m_channel(0) , m_channel(0)
, m_rumble_state() , m_rumble_state()
, m_need_prepare() , m_need_prepare()
{ {}
InitInternal();
}
Wiimote::~Wiimote() void Wiimote::Shutdown()
{ {
DisablePowerAssertionInternal();
StopThread(); StopThread();
ClearReadQueue(); ClearReadQueue();
m_write_reports.Clear(); m_write_reports.Clear();
TeardownInternal();
} }
// to be called from CPU thread // to be called from CPU thread
@ -62,12 +58,9 @@ void Wiimote::WriteReport(Report rpt)
{ {
bool const new_rumble_state = (rpt[2] & 0x1) != 0; bool const new_rumble_state = (rpt[2] & 0x1) != 0;
// If this is a rumble report and the rumble state didn't change, ignore.
if (WM_RUMBLE == rpt[1] && new_rumble_state == m_rumble_state) if (WM_RUMBLE == rpt[1] && new_rumble_state == m_rumble_state)
{
// If this is a rumble report and the rumble state didn't change, ignore
//ERROR_LOG(WIIMOTE, "Ignoring rumble report.");
return; return;
}
m_rumble_state = new_rumble_state; m_rumble_state = new_rumble_state;
} }
@ -508,8 +501,6 @@ void Wiimote::StopThread()
IOWakeup(); IOWakeup();
if (m_wiimote_thread.joinable()) if (m_wiimote_thread.joinable())
m_wiimote_thread.join(); m_wiimote_thread.join();
#if defined(__APPLE__)
#endif
} }
void Wiimote::SetReady() void Wiimote::SetReady()

View File

@ -26,8 +26,9 @@ class Wiimote : NonCopyable
{ {
friend class WiimoteEmu::Wiimote; friend class WiimoteEmu::Wiimote;
public: public:
Wiimote(); virtual ~Wiimote() {}
~Wiimote(); // This needs to be called in derived destructors!
void Shutdown();
void ControlChannel(const u16 channel, const void* const data, const u32 size); void ControlChannel(const u16 channel, const void* const data, const u32 size);
void InterruptChannel(const u16 channel, const void* const data, const u32 size); void InterruptChannel(const u16 channel, const void* const data, const u32 size);
@ -47,22 +48,19 @@ public:
void EmuResume(); void EmuResume();
void EmuPause(); void EmuPause();
void EnablePowerAssertionInternal(); virtual void EnablePowerAssertionInternal() {}
void DisablePowerAssertionInternal(); virtual void DisablePowerAssertionInternal() {}
// connecting and disconnecting from physical devices // connecting and disconnecting from physical devices
// (using address inserted by FindWiimotes) // (using address inserted by FindWiimotes)
// these are called from the wiimote's thread. // these are called from the wiimote's thread.
bool ConnectInternal(); virtual bool ConnectInternal() = 0;
void DisconnectInternal(); virtual void DisconnectInternal() = 0;
void InitInternal();
void TeardownInternal();
bool Connect(); bool Connect();
// TODO: change to something like IsRelevant // TODO: change to something like IsRelevant
bool IsConnected() const; virtual bool IsConnected() const = 0;
void Prepare(int index); void Prepare(int index);
bool PrepareOnThread(); bool PrepareOnThread();
@ -75,30 +73,8 @@ public:
int m_index; int m_index;
#if defined(__APPLE__)
IOBluetoothDevice *m_btd;
IOBluetoothL2CAPChannel *m_ichan;
IOBluetoothL2CAPChannel *m_cchan;
unsigned char* m_input;
int m_inputlen;
bool m_connected;
CFRunLoopRef m_wiimote_thread_run_loop;
IOPMAssertionID m_pm_assertion;
#elif defined(__linux__) && HAVE_BLUEZ
bdaddr_t m_bdaddr; // Bluetooth address
int m_cmd_sock; // Command socket
int m_int_sock; // Interrupt socket
int m_wakeup_pipe_w, m_wakeup_pipe_r;
#elif defined(_WIN32)
std::basic_string<TCHAR> m_devicepath; // Unique wiimote reference
//ULONGLONG btaddr; // Bluetooth address
HANDLE m_dev_handle; // HID handle
OVERLAPPED m_hid_overlap_read, m_hid_overlap_write; // Overlap handle
enum win_bt_stack_t m_stack; // Type of bluetooth stack to use
#endif
protected: protected:
Wiimote();
Report m_last_input_report; Report m_last_input_report;
u16 m_channel; u16 m_channel;
@ -106,9 +82,9 @@ private:
void ClearReadQueue(); void ClearReadQueue();
void WriteReport(Report rpt); void WriteReport(Report rpt);
int IORead(u8* buf); virtual int IORead(u8* buf) = 0;
int IOWrite(u8 const* buf, size_t len); virtual int IOWrite(u8 const* buf, size_t len) = 0;
void IOWakeup(); virtual void IOWakeup() = 0;
void ThreadFunc(); void ThreadFunc();
void SetReady(); void SetReady();