blob: 5f2b05194b31ee36172a268258c83a21c1a79cc1 (
plain)
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
|
#pragma once
#include "types.h"
#include "submitter.h"
#include "sender.h"
#include <rtmidi/RtMidi.h>
#include <string>
#include <mutex>
namespace midi_router
{
struct Device_Connection : public Sender
{
Device_Connection(Device_Id const & source_id, std::string const & device_name, Submitter & submitter, RtMidiIn::RtMidiCallback callback):
source_id(source_id),
device_name(device_name),
submitter(submitter)
{
midi_in.setCallback(callback, this);
midi_in.ignoreTypes(true, false, true);
}
Device_Id const & source_id;
std::string const & device_name;
Submitter & submitter;
RtMidiIn midi_in {};
RtMidiOut midi_out {};
std::mutex mutex {};
void
send(std::vector<std::uint8_t> const & payload) override
{
const std::lock_guard<std::mutex> lock(mutex);
if (midi_out.isPortOpen()) midi_out.sendMessage(&payload);
}
std::string
get_id() const override
{
return source_id;
}
void
connect(std::size_t port)
{
const std::lock_guard<std::mutex> lock(mutex);
if (!midi_in.isPortOpen()) midi_in.openPort(port);
if (!midi_out.isPortOpen()) midi_out.openPort(port);
}
void
disconnect()
{
const std::lock_guard<std::mutex> lock(mutex);
if (midi_in.isPortOpen()) midi_in.closePort();
if (midi_out.isPortOpen()) midi_out.closePort();
}
};
} // namespace midi_router
|