lmh188
/
newtx
mirror of http://192.168.1.51:8099/scanner/newtx.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

修复USB线程参数

This commit is contained in:
gb 2024-03-08 10:40:05 +08:00
parent ca0ab06dcc
commit e71ca215c3
1 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
usb/usb_io.cpp
View File

@ -42,15 +42,15 @@ async_usb_gadget::async_usb_gadget(std::function<FUNCTION_PROTO_COMMAND_HANDLE>
return;
}
auto ep0 = [this](void) -> void
auto ep0 = [this](void*) -> void
{
thread_read_ep0();
};
auto task = [this](void) -> void
auto task = [this](void*) -> void
{
thread_pump_task();
};
auto bulkw = [this](void) -> void
auto bulkw = [this](void*) -> void
{
while(run_)
{
@ -69,7 +69,7 @@ async_usb_gadget::async_usb_gadget(std::function<FUNCTION_PROTO_COMMAND_HANDLE>
}
}
};
auto bulkr = [this](void) -> void
auto bulkr = [this](void*) -> void
{
while(run_)
{
@ -89,7 +89,7 @@ async_usb_gadget::async_usb_gadget(std::function<FUNCTION_PROTO_COMMAND_HANDLE>
}
};
auto excep = [&](const char* thread_name) -> void
auto excep = [&](const char* thread_name, void* param) -> void
{
threads_.stop(thread_name);
// threads_.start(task, "thread_pump_task");
@ -112,10 +112,10 @@ async_usb_gadget::async_usb_gadget(std::function<FUNCTION_PROTO_COMMAND_HANDLE>
utils::to_log(LOG_LEVEL_DEBUG, "Prepare %u(%u * %u) for IO.\n", io_buf_.size() * unit_out_, io_buf_.size(), unit_in_);
#endif
threads_.start(task, SIZE_MB(4), "thread_pump_task", (void*)&async_usb_gadget::thread_pump_task);
threads_.start(bulkw, SIZE_MB(2), "thread_write_bulk", (void*)&async_usb_gadget::thread_write_bulk);
threads_.start(bulkr, SIZE_MB(2), "thread_read_bulk", (void*)&async_usb_gadget::thread_read_bulk);
threads_.start(ep0, SIZE_MB(1), "thread_read_ep0", (void*)&async_usb_gadget::thread_read_ep0);
threads_.start(task, nullptr, SIZE_MB(4), "thread_pump_task", (void*)&async_usb_gadget::thread_pump_task);
threads_.start(bulkw, nullptr, SIZE_MB(2), "thread_write_bulk", (void*)&async_usb_gadget::thread_write_bulk);
threads_.start(bulkr, nullptr, SIZE_MB(2), "thread_read_bulk", (void*)&async_usb_gadget::thread_read_bulk);
threads_.start(ep0, nullptr, SIZE_MB(1), "thread_read_ep0", (void*)&async_usb_gadget::thread_read_ep0);
}
async_usb_gadget::~async_usb_gadget()