a111b2fa1e
Only tx path is added for now. Will enable rx path when merge receive buffer feature is supported in virtio-net. UDP fragmentation offload is not hooked up, will do in a separate patch.
65 lines
2.1 KiB
C++
65 lines
2.1 KiB
C++
#include "core/reactor.hh"
|
|
#include "proxy.hh"
|
|
#include <utility>
|
|
|
|
namespace net {
|
|
|
|
class proxy_net_device : public net::device {
|
|
private:
|
|
boost::program_options::variables_map _opts;
|
|
stream<packet> _rx_stream;
|
|
future<> _rx_ready;
|
|
net::hw_features _hw_features;
|
|
public:
|
|
explicit proxy_net_device(boost::program_options::variables_map opts);
|
|
virtual subscription<packet> receive(std::function<future<> (packet)> next) override;
|
|
virtual future<> send(packet p) override;
|
|
virtual ethernet_address hw_address() override { return {{{ 0x12, 0x23, 0x34, 0x56, 0x67, 0x78 }}}; }
|
|
virtual net::hw_features hw_features() override { return _hw_features; };
|
|
virtual future<> l2inject(packet p) override;
|
|
};
|
|
|
|
proxy_net_device::proxy_net_device(boost::program_options::variables_map opts) :
|
|
_opts(std::move(opts)),
|
|
_rx_stream(),
|
|
_rx_ready(_rx_stream.started())
|
|
{
|
|
if (!(_opts.count("csum-offload") && _opts["csum-offload"].as<std::string>() == "off")) {
|
|
_hw_features.tx_csum_offload = true;
|
|
_hw_features.rx_csum_offload = true;
|
|
} else {
|
|
_hw_features.tx_csum_offload = false;
|
|
_hw_features.rx_csum_offload = false;
|
|
}
|
|
}
|
|
|
|
subscription<packet> proxy_net_device::receive(std::function<future<> (packet)> next)
|
|
{
|
|
return _rx_stream.listen(std::move(next));
|
|
}
|
|
|
|
future<> proxy_net_device::l2inject(packet p)
|
|
{
|
|
_rx_ready = _rx_ready.then([this, p = std::move(p)] () mutable {
|
|
return _rx_stream.produce(std::move(p));
|
|
});
|
|
return make_ready_future<>();
|
|
}
|
|
|
|
future<> proxy_net_device::send(packet p)
|
|
{
|
|
// Assumes that there is only one virtio device and it is on cpu 0
|
|
return smp::submit_to(0, [p = std::move(p), cpu = engine._id]() mutable {
|
|
return dev->send(p.free_on_cpu(cpu));
|
|
});
|
|
}
|
|
|
|
std::unique_ptr<device> create_proxy_net_device(boost::program_options::variables_map opts) {
|
|
auto ptr = std::make_unique<proxy_net_device>(opts);
|
|
// This assumes only one device per cpu. Will need to be fixed when
|
|
// this assumption will no longer hold.
|
|
dev = ptr.get();
|
|
return std::move(ptr);
|
|
}
|
|
}
|