usagi
commented
10 years ago テスト用に問題の発生部分付近のみを小さくまとめたコードです。
#include <string>
#include <boost/array.hpp>
#include <boost/asio.hpp>
namespace arisin
{
namespace etupirka
{
struct configuration_t final
{
struct udp_sender_configuration_t
{
std::string address;
int port;
} udp_sender;
};
union key_signal_t
{
struct code_state_t
{
uint32_t code;
uint8_t state;
} code_state;
std::array<char, sizeof(code_state_t)> char_array;
explicit key_signal_t(decltype(code_state_t::code) code_ = -1, decltype(code_state_t::state) state_ = -1)
: code_state({code_, uint8_t(state_)})
{ }
};
class udp_sender_t final
{
void initialize();
boost::asio::io_service io_service;
boost::asio::ip::udp::resolver resolver;
boost::asio::ip::udp::resolver::query query;
boost::asio::ip::udp::endpoint endpoint;
boost::asio::ip::udp::socket socket;
std::string address_;
int port_;
public:
udp_sender_t(const configuration_t& conf);
void operator()(const key_signal_t& key_signal);
const std::string& address() const;
const int port() const;
};
udp_sender_t::udp_sender_t(const configuration_t& conf)
: resolver(io_service)
, query(boost::asio::ip::udp::v4(), conf.udp_sender.address, std::to_string(conf.udp_sender.port).data())
, endpoint(*resolver.resolve(query))
, socket(io_service)
, address_(conf.udp_sender.address)
, port_(conf.udp_sender.port)
{
std::cerr << "resolver, query, endpoint, socket are initialized\n";
std::cerr << "address(" << address_ << ") port(" << port_ << ")\n" ;
socket.open(boost::asio::ip::udp::v4());
std::cerr << "socket opened\n";
}
void udp_sender_t::operator()(const key_signal_t& key_signal)
{
std::cerr << "key_signal code, state: " << key_signal.code_state.code << "," << key_signal.code_state.state << "\n";
using buffer_t = boost::array<decltype(key_signal.char_array)::value_type, sizeof(key_signal.char_array) / sizeof(decltype(key_signal.char_array)::value_type)>;
const buffer_t& buffer( *reinterpret_cast<const buffer_t*>( key_signal.char_array.data()) );
#ifndef NDEBUG
auto n =
#endif
socket.send_to(boost::asio::buffer(buffer), endpoint);
#ifndef NDEBUG
std::cerr << "message sent [bytes]: " << n << "\n";
#endif
}
const std::string& udp_sender_t::address() const
{ return address_; }
const int udp_sender_t::port() const
{ return port_; }
}
}
#include <memory>
int main()
{
using namespace arisin::etupirka;
configuration_t c;
c.udp_sender.address = "localhost";
c.udp_sender.port = 32100;
std::unique_ptr<udp_sender_t> s;
s.reset(new udp_sender_t(c));
}これを a.cxxとか適当な場所に保存してclang++ a.cxx -boost_system -lpthreadとしてビルドし、./a.outとか実行して見てくれますか？
@arisin お時間とれたときにおねがいします。
※Mint16では問題のフリーズはetupirka、このサンプル、ともに発生を観測できません。
arisin
from: https://github.com/usagi/virtual-keyboard-prototype-1/issues/46#issuecomment-32883499