Skip to content

fix(nvhttp): 修复恢复时app_id不同导致运行应用意外退出 #628

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Open
ShadowLemoon wants to merge 4 commits into
base: master
Choose a base branch
from
+133 −64
Open

fix(nvhttp): 修复恢复时app_id不同导致运行应用意外退出 #628

Changes from 2 commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
5d3ef20
fix(nvhttp): 修复恢复时app_id不同导致运行应用意外退出
ShadowLemoon May 6, 2026
34d79e8
修复xml形状问题
ShadowLemoon May 6, 2026
143eb70
Merge branch 'main' into fix/resume
ShadowLemoon May 9, 2026
b1c9888
feat: 添加特殊桌面app
ShadowLemoon May 9, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
143 changes: 98 additions & 45 deletions src/nvhttp.cpp
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -6,6 +6,7 @@
#define BOOST_BIND_GLOBAL_PLACEHOLDERS

// standard includes
#include <algorithm>
#include <chrono>
#include <filesystem>
#include <map>
Expand Down Expand Up @@ -1777,13 +1778,44 @@ namespace nvhttp {
}
}

void
launch(bool &host_audio, resp_https_t response, req_https_t request) {
print_req<SunshineHTTPS>(request);
static bool
has_required_launch_params(const args_t &args, bool require_appid) {
return args.find("rikey"s) != std::end(args)
&& args.find("rikeyid"s) != std::end(args)
&& args.find("localAudioPlayMode"s) != std::end(args)
&& (!require_appid || args.find("appid"s) != std::end(args));
}

print_request_ip<SunshineHTTPS>(request, "Launch request");
static bool
has_required_resume_params(const args_t &args) {
return args.find("rikey"s) != std::end(args)
&& args.find("rikeyid"s) != std::end(args);
}

static int
find_desktop_app_id() {
const auto &apps = proc::proc.get_apps();
auto desktop = std::find_if(std::begin(apps), std::end(apps), [](const auto &app) {
return app.image_path == "desktop" || app.name == "Desktop";
});

if (desktop == std::end(apps)) {
desktop = std::find_if(std::begin(apps), std::end(apps), [](const auto &app) {
return app.cmd.empty();
});
}

if (desktop == std::end(apps)) {
return 0;
}

return util::from_view(desktop->id);
}

void
launch_app(bool &host_audio, resp_https_t response, req_https_t request, const args_t &args, int appid, const char *result_node_name) {
pt::ptree tree;
const auto result_node = "root."s + result_node_name;
bool need_to_restore_display_state { false };
auto g = util::fail_guard([&]() {
std::ostringstream data;
Expand All @@ -1801,24 +1833,9 @@ namespace nvhttp {
}
});

auto args = request->parse_query_string();
if (
args.find("rikey"s) == std::end(args) ||
args.find("rikeyid"s) == std::end(args) ||
args.find("localAudioPlayMode"s) == std::end(args) ||
args.find("appid"s) == std::end(args)) {
tree.put("root.resume", 0);
tree.put("root.<xmlattr>.status_code", 400);
tree.put("root.<xmlattr>.status_message", "Missing a required launch parameter");

return;
}

auto appid = util::from_view(get_arg(args, "appid"));

auto current_appid = proc::proc.running();
if (current_appid > 0) {
tree.put("root.resume", 0);
tree.put(result_node, 0);
tree.put("root.<xmlattr>.status_code", 400);
tree.put("root.<xmlattr>.status_message", "An app is already running on this host");

Expand All @@ -1828,15 +1845,18 @@ namespace nvhttp {
// Early validation of AppID to prevent starting VDD or other expensive operations
// if the requested app does not exist.
if (proc::proc.get_app_name(appid).empty()) {
tree.put("root.resume", 0);
tree.put(result_node, 0);
tree.put("root.<xmlattr>.status_code", 404);
tree.put("root.<xmlattr>.status_message", "App not found");
BOOST_LOG(error) << "Launch couldn't find app with ID ["sv << appid << ']';
return;
}

host_audio = util::from_view(get_arg(args, "localAudioPlayMode"));
if (args.find("localAudioPlayMode"s) != std::end(args)) {
host_audio = util::from_view(get_arg(args, "localAudioPlayMode"));
}
const auto launch_session = make_launch_session(host_audio, args);
launch_session->appid = appid;

// 获取客户端证书UUID（稳定的客户端标识符）
std::string client_cert_uuid = get_client_cert_uuid_from_request(request);
Expand All @@ -1860,7 +1880,7 @@ namespace nvhttp {
if (video::probe_encoders()) {
tree.put("root.<xmlattr>.status_code", 503);
tree.put("root.<xmlattr>.status_message", "Failed to initialize video capture/encoding. Is a display connected and turned on?");
tree.put("root.gamesession", 0);
tree.put(result_node, 0);

return;
}
Expand All @@ -1872,27 +1892,25 @@ namespace nvhttp {

tree.put("root.<xmlattr>.status_code", 403);
tree.put("root.<xmlattr>.status_message", "Encryption is mandatory for this host but unsupported by the client");
tree.put("root.gamesession", 0);
tree.put(result_node, 0);

return;
}

if (appid > 0) {
auto err = proc::proc.execute(appid, launch_session);
if (err) {
tree.put("root.<xmlattr>.status_code", err);
tree.put("root.<xmlattr>.status_message", "Failed to start the specified application");
tree.put("root.gamesession", 0);
auto err = proc::proc.execute(appid, launch_session);
if (err) {
tree.put("root.<xmlattr>.status_code", err);
tree.put("root.<xmlattr>.status_message", "Failed to start the specified application");
tree.put(result_node, 0);
Comment on lines +1881 to +1885
Copy link
Copy Markdown

@coderabbitai coderabbitai Bot May 9, 2026

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

⚠️ Potential issue | 🟡 Minor | ⚡ Quick win

内部执行失败不要直接回填为负的 status_code。

proc::proc.execute() 这里除了 404 还会返回 -1。直接写进 XML 会产生无效状态码，客户端侧的失败分支会变得不可预测。更稳妥的做法是只透传明确的协议状态（比如 404），其余内部错误统一映射到 500/503，原始返回值继续只打日志。

🛠️ 建议修改 
-    auto err = proc::proc.execute(appid, launch_session);
+    const auto err = proc::proc.execute(appid, launch_session);
     if (err) {
-      tree.put("root.<xmlattr>.status_code", err);
+      tree.put("root.<xmlattr>.status_code", err == 404 ? 404 : 500);
       tree.put("root.<xmlattr>.status_message", "Failed to start the specified application");
       tree.put(result_node, 0);

       return;
     }
📝 Committable suggestion

‼️ IMPORTANT
Carefully review the code before committing. Ensure that it accurately replaces the highlighted code, contains no missing lines, and has no issues with indentation. Thoroughly test & benchmark the code to ensure it meets the requirements.

Suggested change
auto err = proc::proc.execute(appid, launch_session);
if (err) {
tree.put("root.<xmlattr>.status_code", err);
tree.put("root.<xmlattr>.status_message", "Failed to start the specified application");
tree.put(result_node, 0);
const auto err = proc::proc.execute(appid, launch_session);
if (err) {
tree.put("root.<xmlattr>.status_code", err == 404 ? 404 : 500);
tree.put("root.<xmlattr>.status_message", "Failed to start the specified application");
tree.put(result_node, 0);
🤖 Prompt for AI Agents 
Verify each finding against current code. Fix only still-valid issues, skip the
rest with a brief reason, keep changes minimal, and validate.

In `@src/nvhttp.cpp` around lines 1881 - 1885, proc::proc.execute 返回的 err 不应直接写入
XML 为负值：在处理其返回值（变量 err）时，如果 err == 404 则原样透传到
tree.put("root.<xmlattr>.status_code")，否则把内部错误统一映射为 HTTP 5xx（例如 500 或 503）写入
status_code 并设置合适的 status_message，同时将原始 err 值记录到日志而不是写入 XML；修改涉及的符号有
proc::proc.execute、err、tree.put("root.<xmlattr>.status_code")、tree.put("root.<xmlattr>.status_message")
和 result_node，保持对 result_node 的原有赋值逻辑（tree.put(result_node, 0)）不变。


return;
}
return;
}

tree.put("root.<xmlattr>.status_code", 200);
tree.put("root.sessionUrl0", launch_session->rtsp_url_scheme +
net::addr_to_url_escaped_string(request->local_endpoint().address()) + ':' +
std::to_string(net::map_port(rtsp_stream::RTSP_SETUP_PORT)));
tree.put("root.gamesession", 1);
tree.put(result_node, 1);

rtsp_stream::launch_session_raise(launch_session);

Expand All @@ -1916,6 +1934,35 @@ namespace nvhttp {
need_to_restore_display_state = false;
}

void
launch(bool &host_audio, resp_https_t response, req_https_t request) {
print_req<SunshineHTTPS>(request);

print_request_ip<SunshineHTTPS>(request, "Launch request");

auto args = request->parse_query_string();
if (!has_required_launch_params(args, true)) {
pt::ptree tree;
auto g = util::fail_guard([&]() {
std::ostringstream data;

pt::write_xml(data, tree);
response->write(data.str());
response->close_connection_after_response = true;
});

tree.put("root.gamesession", 0);
tree.put("root.<xmlattr>.status_code", 400);
tree.put("root.<xmlattr>.status_message", "Missing a required launch parameter");

return;
}

auto appid = util::from_view(get_arg(args, "appid"));

launch_app(host_audio, response, request, args, appid, "gamesession");
}

void
resume(bool &host_audio, resp_https_t response, req_https_t request) {
print_req<SunshineHTTPS>(request);
Expand All @@ -1941,23 +1988,28 @@ namespace nvhttp {
response->close_connection_after_response = true;
});

auto current_appid = proc::proc.running();
if (current_appid == 0) {
auto args = request->parse_query_string();
if (!has_required_resume_params(args)) {
tree.put("root.resume", 0);
tree.put("root.<xmlattr>.status_code", 503);
tree.put("root.<xmlattr>.status_message", "No running app to resume");
tree.put("root.<xmlattr>.status_code", 400);
tree.put("root.<xmlattr>.status_message", "Missing a required resume parameter");

return;
}

auto args = request->parse_query_string();
if (
args.find("rikey"s) == std::end(args) ||
args.find("rikeyid"s) == std::end(args)) {
tree.put("root.resume", 0);
tree.put("root.<xmlattr>.status_code", 400);
tree.put("root.<xmlattr>.status_message", "Missing a required resume parameter");
auto current_appid = proc::proc.running();
if (current_appid == 0) {
auto desktop_appid = find_desktop_app_id();
if (desktop_appid <= 0) {
tree.put("root.resume", 0);
tree.put("root.<xmlattr>.status_code", 404);
tree.put("root.<xmlattr>.status_message", "No running app to resume and Desktop app not found");

return;
}

g.disable();
launch_app(host_audio, response, request, args, desktop_appid, "resume");
return;
}

Expand All @@ -1969,6 +2021,7 @@ namespace nvhttp {
host_audio = util::from_view(get_arg(args, "localAudioPlayMode"));
}
const auto launch_session = make_launch_session(host_audio, args);
launch_session->appid = current_appid;

// Get client certificate UUID (stable client identifier) and store it in env
std::string client_cert_uuid = get_client_cert_uuid_from_request(request);
Expand Down Expand Up @@ -2000,7 +2053,7 @@ namespace nvhttp {

tree.put("root.<xmlattr>.status_code", 403);
tree.put("root.<xmlattr>.status_message", "Encryption is mandatory for this host but unsupported by the client");
tree.put("root.gamesession", 0);
tree.put("root.resume", 0);

return;
}
Expand Down
Loading