Можно ли параллельно запускать io_service::run?

Я смог повторить ошибку, вот код:

#include <boost/asio.hpp>
#include <boost/asio/deadline_timer.hpp>
#include <boost/asio/io_service.hpp>
#include <boost/asio/ip/tcp.hpp>
#include <boost/asio/read_until.hpp>
#include <boost/asio/streambuf.hpp>
#include <boost/asio/strand.hpp>
#include <boost/thread.hpp>
#include <boost/asio/write.hpp>
#include <boost/bind.hpp>
#include <iostream>
#include <thread>

using namespace boost::asio;
io_service service;
struct D {
    explicit D(io_service & ios) : socket_(ios), timeout_(ios), strand_(ios), resolver_(ios) {
        do_response();
    }
private:
    void do_response(){
        resolver_.async_resolve("tracker.dler.com",  "6969",
                                strand_.wrap( [this](boost::system::error_code const & ec,
                                                      ip::tcp::resolver::iterator endpoints){
                                    if (!ec) {
                                        do_connect(std::move(endpoints));
                                        timeout_.async_wait([this](boost::system::error_code const & ec) {
                                            if (!ec) {
                                                deadline();
                                            }
                                        });
                                    } else {
                                        socket_.close();
                                        std::cerr << "ec == true" << std::endl;
                                    }
                                }));
    }
    void do_connect(ip::tcp::resolver::iterator endpoint){
        async_connect(socket_, std::move(endpoint),
                          strand_.wrap([this](boost::system::error_code const & ec, [[maybe_unused]] const ip::tcp::resolver::iterator&){
                              std::this_thread::sleep_for(std::chrono::milliseconds(100));
                              if (!ec) {
                                  std::cout << "OK!" << std::endl;
                                  timeout_.cancel();
                              }
                          }));
        timeout_.expires_from_now(boost::posix_time::seconds(1));
    }
    void deadline(){
        if (timeout_.expires_at() <=  deadline_timer::traits_type::now()) {
            socket_.close();
            std::cerr << "TIMEOUT" << std::endl;
        } else {
            timeout_.async_wait(strand_.wrap([this](boost::system::error_code const &ec) {
                if (!ec) {
                    deadline();
                }
            }));
        }
    }

    ip::tcp::socket socket_;
    deadline_timer timeout_;
    io_service::strand strand_;
    ip::tcp::resolver resolver_;
};
void func(int i)
{
    std::cout << "func called, i= " << i << "/" << boost::this_thread::get_id() << std::endl;
}
void worker_thread()
{
    service.run();
}
int main(int argc, char* argv[])
{
    std::list<D> ds;
    for ( int i = 0; i < 15; ++i) {
        ds.emplace_back(service);
    }
    boost::thread_group threads;
    for ( int i = 0; i < 3; ++i)
        threads.create_thread(worker_thread);
    // wait for all threads to be created
    boost::this_thread::sleep( boost::posix_time::millisec(500));
    threads.join_all();
}

Можно ли параллельно запускать io_service::run?

переписал со strand и все равно санитайзер плачет на это место

Для чего в данном примере нужно дожидаться асинхронную операцию?

ну я это понял, я просто не пойму почему нельзя на стороне вызывать run у сервиса без вот этих трюков с would_block и run_one?

Для чего в данном примере нужно дожидаться асинхронную операцию?

Wataru, ну ec вроде бы меняет асинхронная операция, он туда по ссылке передается

Из-за чего ошибка "error: non-constant value given to `%assign'"?

Вопрос конечно еще в силе, потому что я так и не понял что значит проблема с non-constant, или это относится к тому что секция - bss (тогда неясно почему пример из книги с ошибкой), либо к какой-то ошибке которую допустил я.
Если поменять строки таким образом:
%assign a array -> %assign a 0
inc word [a] -> inc word [array + a]
, то работает

Как должна передаваться 20 байтная строка по протоколу UDP в формате big-endian?

Lynn «Кофеман», похоже, что Вы правы! Всё это время я использовал неверные SHA1 коды, большое спасибо, поправил алгоритм вручную!

Как должна передаваться 20 байтная строка по протоколу UDP в формате big-endian?

Lynn «Кофеман», C++
А как это у меня перепутан порядок байт (в http протоколе трекера работает нормально => SHA1 корректный)? Я использовал бустовую функцию для шифрования в SHA1, ничего сам не придумывал.

Как должна передаваться 20 байтная строка по протоколу UDP в формате big-endian?

Lynn «Кофеман», ну int8_t - это 1 байт, я нигде и не писал вроде что у меня info_hash из int'ов состоит, но у торрентов, которые я сниферил info_hash был как будто из набора 4-х байтных чисел (в Big Endian формате). Я же по спецификации делал так, что просто передавал 20 байт этого SHA1 info_hash'а, но ответ от трекера был некорректным.

В чем причина долгого исполнения моего асинхронного HTTP клиента?

Евгений Шатунов, ну мне кажется что опытному пользователю asio достаточно будет взглянуть на код, чтобы ответить чего я не понял/сделал неправильно. И повторю еще раз, это искусственное воссоздание проблемы, программное замедление у меня из-за недостатка знаний, поэтому как мне кажется, вопрос я задал адекватно.

В чем причина долгого исполнения моего асинхронного HTTP клиента?

Евгений Шатунов, нет это не задание (я итак воссоздал ошибку локально на примере буста, сократить код сильнее не могу), мне нужно понять конкретно по коду в чем причина торможения. Ну и вроде как я догадался, проблема кажется в очень долгом timeout'е у async_connect'a (который вызывается после io_service::run), я почему-то ожидал что он куда-то делегирует операцию подключения, а сам выполнит лишь хэндлер когда сокет подключится. Но судя по всему я ошибался.

Есть ли разница для шифрования UTF-8 строк и ASCII строк через SHA-1?

Вообщем я всё-таки разобрался с кодировками в C++ и осознал что тут вообще не нужно париться, std::string из коробки способен хранить UTF-8 строки (он не способен их использовать/ корректно модифицировать), а значит их можно без проблем передавать в алгоритм SHA-1!

Есть ли разница для шифрования UTF-8 строк и ASCII строк через SHA-1?

Lynn «Кофеман», почему не имеет смысла? Я позволяю определить размерность самой системе.

Есть ли разница для шифрования UTF-8 строк и ASCII строк через SHA-1?

res2001, винда, g++, символы беру как кол-во wchar_t символов в массиве * кол-во байт типа wchar_t (sizeof wchar_t)

Есть ли разница для шифрования UTF-8 строк и ASCII строк через SHA-1?

ну то есть лучший исход - писать самому алгоритм SHA-1? Как-то это некрасиво выходит, про самописный каст к однобайтовому типу я уже всё перепробовал, и по LE и по BE. Я не знаю как понять какой SHA-1 верно закодировал фразу, только если смотреть в онлайн кодеры с которым у меня не сходится.

Как работает одновременно асинхронное чтение и запись из примера boost.asio?

То есть внутри boost.asio есть какой-то свой планировщик (видимо в виде кода, поэтому хотелось бы понять как он называется чтобы глянуть исходники)? Или он работает на уровне ОС и заставляет ее думать что задачи в 2-х разных процессах?

Про операции типа receive, read и тп, мне казалось что от вызывающего кода вообще ничего не требуется, и он ожидает когда ОС закинет ему, что ей что-то пришло по этому порту. (ну периодически ложно просыпаясь и перепроверяя буфер)