udp.h

浏览该文件的文档.

 
#pragma once
#include <asio.hpp>
#include <format>
#include <string_view>
#include <span>
#include <string>
 
#include "core/async.hpp"
#include "io/base.hpp"
#include "core/logger.h"
#include "io/write_queue.hpp"
 
namespace roboctrl::io{
 
class udp : public bare_io_base{
public:
    struct info_type{
        using key_type = std::string;
        using owner_type = udp;
 
        std::string key_;
        std::string address;
        std::uint16_t port;
 
        const std::string& key()const{
            return key_;
        }
    };
 
    udp(info_type info);
 
    void start();
 
    awaitable<void> send(byte_span data);
 
    awaitable<void> task();
 
    inline std::string desc()const{
        return std::format("udp socket ({} to {}:{})",info_.key_,info_.address,info_.port);
    }
 
private:
  asio::ip::udp::socket socket_;
  write_queue write_queue_;
  info_type info_;
  std::array<std::byte,65536> buffer_;
  bool started_ {false};
};
 
static_assert(bare_io<udp>);
}