Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- Result<Socket> Socket::ConnectTo(const std::string& host, uint16_t port) {
- // Not implemented
- auto addr = resolver_.resolve(host, std::to_string(port));
- //asio::connect(socket_, addr);
- for (asio::ip::tcp::endpoint ep_iter : addr) {
- Fiber* fiber_ptr = GetCurrentFiber();
- socket_.async(ep_iter,
- [fiber_ptr]() {
- fiber_ptr->SetState(FiberState::Runnable);
- GetCurrentScheduler()->Reschedule(fiber_ptr);
- }
- );
- Wait();
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement