jyapayne/Sunshine
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Send input policy to clients on start and ack
Some checks failed
ci-bundle.yml / Send input policy to clients on start and ack (push) Failing after 0s
Details
ci-copr.yml / Send input policy to clients on start and ack (push) Failing after 0s
Details
ci-homebrew.yml / Send input policy to clients on start and ack (push) Failing after 0s
Details

Browse source
This commit is contained in:
Joey Yakimowich-Payne 2026-02-12 00:38:13 -07:00
commit 6fdeb1b868
1 changed files with 37 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

37
src/stream.cpp
View file

@ -53,6 +53,11 @@ extern "C" {
#define IDX_SET_ADAPTIVE_TRIGGERS 15 #define IDX_SET_ADAPTIVE_TRIGGERS 15
#define IDX_SET_INPUT_POLICY 16 #define IDX_SET_INPUT_POLICY 16
#define INPUT_POLICY_REASON_STREAM_START 0
#define INPUT_POLICY_REASON_USER_TOGGLE 1
#define INPUT_POLICY_REASON_HOST_ACK 2
#define INPUT_POLICY_REASON_HOST_OVERRIDE 3
static const short packetTypes[] = { static const short packetTypes[] = {
0x0305, // Start A 0x0305, // Start A
0x0307, // Start B 0x0307, // Start B
@ -475,6 +480,30 @@ namespace stream {
<< " mouse="sv << effective_mouse << " gamepad="sv << effective_gamepad; << " mouse="sv << effective_mouse << " gamepad="sv << effective_gamepad;
} }
static int send_session_input_policy(session_t *session, uint8_t reason) {
if (!session->control.peer) {
return -1;
}
control_set_input_policy_t plaintext;
plaintext.header.type = packetTypes[IDX_SET_INPUT_POLICY];
plaintext.header.payloadLength = sizeof(plaintext) - sizeof(control_header_v2);
plaintext.allow_keyboard = session->input_policy.allow_keyboard.load(std::memory_order_relaxed) ? 1 : 0;
plaintext.allow_mouse = session->input_policy.allow_mouse.load(std::memory_order_relaxed) ? 1 : 0;
plaintext.allow_gamepad = session->input_policy.allow_gamepad.load(std::memory_order_relaxed) ? 1 : 0;
plaintext.reason = reason;
std::array<std::uint8_t, sizeof(control_encrypted_t) + crypto::cipher::round_to_pkcs7_padded(sizeof(plaintext)) + crypto::cipher::tag_size>
encrypted_payload;
auto payload = encode_control(session, util::view(plaintext), encrypted_payload);
if (session->broadcast_ref->control_server.send(payload, session->control.peer)) {
return -1;
}
return 0;
}
/** /**
* First part of cipher must be struct of type control_encrypted_t * First part of cipher must be struct of type control_encrypted_t
* *
@ -993,6 +1022,10 @@ namespace stream {
server->map(packetTypes[IDX_START_B], [&](session_t *session, const std::string_view &payload) { server->map(packetTypes[IDX_START_B], [&](session_t *session, const std::string_view &payload) {
BOOST_LOG(debug) << "type [IDX_START_B]"sv; BOOST_LOG(debug) << "type [IDX_START_B]"sv;
if (send_session_input_policy(session, INPUT_POLICY_REASON_STREAM_START)) {
BOOST_LOG(warning) << "Unable to send initial session input policy"sv;
}
}); });
server->map(packetTypes[IDX_LOSS_STATS], [&](session_t *session, const std::string_view &payload) { server->map(packetTypes[IDX_LOSS_STATS], [&](session_t *session, const std::string_view &payload) {
@ -1137,6 +1170,10 @@ namespace stream {
policy->allow_mouse != 0, policy->allow_mouse != 0,
policy->allow_gamepad != 0, policy->allow_gamepad != 0,
policy->reason); policy->reason);
if (send_session_input_policy(session, INPUT_POLICY_REASON_HOST_ACK)) {
BOOST_LOG(warning) << "Unable to send input policy acknowledgment"sv;
}
}); });
// This thread handles latency-sensitive control messages // This thread handles latency-sensitive control messages