Я конвертирую приложение из асинхронного ввода-вывода Juce в asio.Первая часть - переписать код, который получает трафик от другого приложения на том же компьютере (это плагин Lightroom Lua, который отправляет сообщения с разделителями \n через порт 58764).Всякий раз, когда я успешно подключаюсь к этому порту с помощью моей программы на C ++, я получаю серию кодов ошибок, одинаковых:
Операция над сокетом не может быть выполнена, поскольку системе не хватает достаточного места в буфере илипотому что очередь была заполнена.
Может кто-нибудь указать на мою ошибку?Я вижу, что сокет успешно открыт.Я сократил это от моей полной программы до минимального примера.Я также попробовал это с connect вместо async_connect и у меня была такая же проблема.
#include <iostream>
#include "asio.hpp"
asio::io_context io_context_;
asio::ip::tcp::socket socket_{io_context_};
void loop_me()
{
asio::streambuf streambuf{};
while (true) {
if (!socket_.is_open()) {
return;
}
else {
asio::async_read_until(socket_, streambuf, '\n',
[&streambuf](const asio::error_code& error_code, std::size_t bytes_transferred) {
if (error_code) {
std::cerr << "Socket error " << error_code.message() << std::endl;
return;
}
// Extract up to the first delimiter.
std::string command{buffers_begin(streambuf.data()),
buffers_begin(streambuf.data()) + bytes_transferred};
std::cout << command << std::endl;
streambuf.consume(bytes_transferred);
});
}
}
}
int main()
{
auto work_{asio::make_work_guard(io_context_)};
std::thread io_thread_;
std::thread run_thread_;
io_thread_ = std::thread([] { io_context_.run(); });
socket_.async_connect(asio::ip::tcp::endpoint(asio::ip::address_v4::loopback(), 58764),
[&run_thread_](const asio::error_code& error) {
if (!error) {
std::cout << "Socket connected in LR_IPC_In\n";
run_thread_ = std::thread(loop_me);
}
else {
std::cerr << "LR_IPC_In socket connect failed " << error.message() << std::endl;
}
});
std::this_thread::sleep_for(std::chrono::seconds(1));
socket_.close();
io_context_.stop();
if (io_thread_.joinable())
io_thread_.join();
if (run_thread_.joinable())
run_thread_.join();
}