Commit 6b717efd authored by Joseph Noir's avatar Joseph Noir

Make compiler happy

parent 63a997d7
......@@ -115,13 +115,13 @@ struct basp_broker_state : proxy_registry::backend, basp::instance::callee {
// stores information about remote datagram enpoints
struct remote_endpoint {
// local sink
datagram_sink_handle sink;
datagram_sink_handle sink;
// ordering information
uint32_t sequence_number_send = 0;
uint32_t sequence_number_receive = 0;
// TODO: local buffer for ordering
uint16_t remote_port;
}
};
// our current processed BSAP header
basp::header hdr;
// local source
......@@ -144,7 +144,7 @@ struct basp_broker_state : proxy_registry::backend, basp::instance::callee {
// keeps context information for all open connections
std::unordered_map<connection_handle, connection_context> tcp_ctx;
std::unordered_map<datagram_source_handle, endpoint_context> udp_ctx;
std::unordered_map<datagram_sink_handle, endpoint_context> udp_ctx;
// points to the current context for callbacks such as `make_proxy`
connection_context* this_context = nullptr;
......
......@@ -550,7 +550,7 @@ behavior basp_broker::make_behavior() {
CAF_LOG_TRACE(CAF_ARG(msg.handle));
CAF_LOG_DEBUG("Received new_datagram_msg: " << CAF_ARG(msg));
auto& hdl = msg.handle;
state.instance.handle(context(), msg,
// state.instance.handle(context(), msg,
},
// received from proxy instances
[=](forward_atom, strong_actor_ptr& src,
......@@ -690,9 +690,11 @@ behavior basp_broker::make_behavior() {
auto res = assign_datagram_sink(hdl);
if (res) {
auto& ctx = state.udp_ctx[hdl];
/*
ctx.sink = hdl;
ctx.remote_port = port;
ctx.callback = rp;
*/
// TODO: Start handshake with server as there is no way for
// the server to initiate this.
} else {
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment