| // | |
| // ssl_stream.hpp | |
| // ~~~~~~~~~~~~~~ | |
| // | |
| // Copyright (c) 2023 Jack (jack dot wgm at gmail dot com) | |
| // | |
| // Distributed under the Boost Software License, Version 1.0. (See accompanying | |
| // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) | |
| // |
| void print_data_len(const std::vector<uint8_t>& data, uint16_t target_len = 0x7FFF) | |
| { | |
| if (data.size() < 4) { | |
| std::cerr << "数据长度小于4，无法转换为 uint16_t。" << std::endl; | |
| return; | |
| } | |
| std::cout << "print len: " << data.size() << "\n"; | |
| uint16_t p1 = 0; |
| // | |
| // Copyright (C) 2019 Jack. | |
| // | |
| // Author: jack | |
| // Email: jack.wgm at gmail dot com | |
| // | |
| #pragma once | |
| #include <version> | |
| #include <codecvt> |
| // | |
| // yield_cancellation_slot_bind.hpp | |
| // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ | |
| // | |
| // Copyright (c) 2019 Jack (jack dot wgm at gmail dot com) | |
| // | |
| // Distributed under the Boost Software License, Version 1.0. (See accompanying | |
| // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) | |
| // |
| // | |
| // async_connect.hpp | |
| // ~~~~~~~~~~~~~~~~~ | |
| // | |
| // Copyright (c) 2019 Jack (jack dot wgm at gmail dot com) | |
| // | |
| // Distributed under the Boost Software License, Version 1.0. (See accompanying | |
| // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) | |
| // |
| // | |
| // yield_cancellation_slot_bind.hpp | |
| // ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ | |
| // | |
| // Copyright (c) 2019 Jack (jack dot wgm at gmail dot com) | |
| // | |
| // Distributed under the Boost Software License, Version 1.0. (See accompanying | |
| // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) | |
| // |
| #c:: | |
| Send,^{c} | |
| Return | |
| #v:: | |
| Send,^{v} | |
| Return | |
| #s:: | |
| Send,^{s} |
| // | |
| // Copyright (C) 2021 Jack. | |
| // | |
| // Author: jack | |
| // Email: jack.wgm at gmail dot com | |
| // | |
| #pragma once | |
| #include <boost/exception/all.hpp> |
在asio中，设计了associated_allocator和associated_executor用于用户管理handler统一分配内存和统一调用，通过adl实现hook结构。
如用户提交一个异步操作，此时用户的handler需要保存在asio的内部op队列中，待操作完成，asio将从op队列中取出该op（不一定要直接取，像iocp中，可以绑定在OVERLAPPED结构中，事件完成，直接可以OVERLAPPED中拿到），然后通过op中的handler回调用户，通知异步操作完成。
其中，asio使用了associated_allocator和associated_executor这2个设计，在asio内部存取用户handler到op队列的时候用到，以实现用户定义的allocator和executor的调用。
下面是关于iocp（默认proactor模型更易于分析）中async_receive异步处理的分析(async_send类似)，非关键部分代码省略，只例出与主题相关的代码。
// 文件 boost/boost/asio/detail/win_iocp_operation.hpp
| template <typename Handler, typename Request, typename Reply> | |
| class type_erasure_handler | |
| { | |
| public: | |
| type_erasure_handler(Handler&& handler) | |
| : handler_(std::forward<Handler>(handler)) | |
| {} | |
| ~type_erasure_handler() | |
| {} |