fujin/rtorrent
1
0
Fork 0
mirror of https://github.com/rakshasa/rtorrent.git synced 2026-10-13 12:46:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

Use poll interrupting callbacks for SCGI requests.

Browse Source
This commit is contained in:
rakshasa
2025-05-04 11:23:47 +02:00
committed by Jari Sundell
parent 303edab9ec
commit 55615abe9e
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/rpc/scgi_task.cc
+3 -3
View File
@@ -267,7 +267,7 @@ SCgiTask::receive_call(const char* buffer, uint32_t length) {
auto result_callback = [this, scgi_thread](const char* b, uint32_t l) { auto result_callback = [this, scgi_thread](const char* b, uint32_t l) {
receive_write(b, l); receive_write(b, l);
scgi_thread->callback(this, [this]() { scgi_thread->callback_interrupt_pollling(this, [this]() {
// Only need to lock once here as a memory barrier. // Only need to lock once here as a memory barrier.
m_result_mutex.lock(); m_result_mutex.lock();
m_result_mutex.unlock(); m_result_mutex.unlock();
@@ -280,7 +280,7 @@ SCgiTask::receive_call(const char* buffer, uint32_t length) {
switch (content_type()) { switch (content_type()) {
case rpc::SCgiTask::ContentType::JSON: case rpc::SCgiTask::ContentType::JSON:
torrent::main_thread()->callback(this, [buffer, length, result_callback]() { torrent::main_thread()->callback_interrupt_pollling(this, [buffer, length, result_callback]() {
rpc.process(RpcManager::RPCType::JSON, buffer, length, rpc.process(RpcManager::RPCType::JSON, buffer, length,
[result_callback](const char* b, uint32_t l) { [result_callback](const char* b, uint32_t l) {
result_callback(b, l); result_callback(b, l);
@@ -290,7 +290,7 @@ SCgiTask::receive_call(const char* buffer, uint32_t length) {
break; break;
case rpc::SCgiTask::ContentType::XML: case rpc::SCgiTask::ContentType::XML:
torrent::main_thread()->callback(this, [buffer, length, result_callback]() { torrent::main_thread()->callback_interrupt_pollling(this, [buffer, length, result_callback]() {
rpc.process(RpcManager::RPCType::XML, buffer, length, rpc.process(RpcManager::RPCType::XML, buffer, length,
[result_callback](const char* b, uint32_t l) { [result_callback](const char* b, uint32_t l) {
result_callback(b, l); result_callback(b, l);