1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
// license:LGPL-2.1+
// copyright-holders:Michael Zapf
/****************************************************************************
TIPI adapter card for the Peripheral Expansion Box
See tipi.cpp for documentation
Michael Zapf
February 2022
*****************************************************************************/
#ifndef MAME_BUS_TI99_PEB_TIPI_H
#define MAME_BUS_TI99_PEB_TIPI_H
#pragma once
#include "peribox.h"
#include "client_ws.hpp"
#include <queue>
namespace bus::ti99::peb {
class tipi_attached_device;
class tipi_card_device : public device_t, public device_ti99_peribox_card_interface
{
public:
tipi_card_device(const machine_config &mconfig, const char *tag, device_t *owner, uint32_t clock);
void readz(offs_t offset, uint8_t *value) override;
void write(offs_t offset, uint8_t data) override;
void setaddress_dbin(offs_t offset, int state) override;
void crureadz(offs_t offset, uint8_t *value) override;
void cruwrite(offs_t offset, uint8_t data) override;
private:
void device_start() override;
void device_reset() override;
void device_stop() override;
ioport_constructor device_input_ports() const override;
const tiny_rom_entry *device_rom_region() const override;
void device_add_mconfig(machine_config &config) override;
void debug_read(offs_t offset, uint8_t* value);
void debug_write(offs_t offset, uint8_t data);
void websocket_opened();
void websocket_incoming(std::shared_ptr<webpp::ws_client::Message> message);
void websocket_error(const std::error_code& code);
void websocket_closed(int i, const std::string& msg);
void websocket_debug(const char* msg, int i);
TIMER_CALLBACK_MEMBER(open_websocket);
void send(const char* message);
void send(u8* message, int len);
void process_message();
void set_td(u8 data);
void set_tc(u8 data);
required_device<tipi_attached_device> m_rpi;
int m_address;
bool m_dsr;
bool m_portaccess;
bool m_waitinit;
bool m_syncmode;
// DSR ROM
uint8_t* m_eprom;
// Websocket support
std::unique_ptr<webpp::ws_client> m_wsclient;
std::shared_ptr<webpp::ws_client::SendStream> m_send_stream;
std::unique_ptr<u8[]> m_rpimessage;
int m_msgindex;
int m_msglength;
emu_timer* m_restart_timer;
int m_attempts;
bool m_connected;
bool m_rpiconn;
// Incoming queue
std::queue<u8> m_indqueue;
// Computer interface
u8 m_tc;
u8 m_td;
u8 m_rc;
u8 m_rd;
u8 m_lasttc;
};
/*
Defines the connection to the RPi.
*/
class tipi_attached_device : public device_t, public device_image_interface
{
public:
tipi_attached_device(const machine_config &mconfig, const char *tag, device_t *owner, uint32_t clock);
bool is_readable() const noexcept override { return true; }
bool is_writeable() const noexcept override { return true; }
bool is_creatable() const noexcept override { return true; }
bool is_reset_on_load() const noexcept override { return false; }
bool support_command_line_image_creation() const noexcept override { return true; }
const char *image_type_name() const noexcept override { return "connect"; }
const char *image_brief_type_name() const noexcept override { return "conn"; }
const char *image_interface() const noexcept override { return ""; }
const char *file_extensions() const noexcept override { return ""; }
protected:
void device_start() override { }
void call_unload() override;
image_init_result call_load() override;
};
} // end namespace bus::ti99::peb
DECLARE_DEVICE_TYPE_NS(TI99_TIPI_RPI, bus::ti99::peb, tipi_attached_device)
DECLARE_DEVICE_TYPE_NS(TI99_TIPI, bus::ti99::peb, tipi_card_device)
#endif // MAME_BUS_TI99_PEB_TIPI_H
|