mirror of
https://github.com/genodelabs/genode.git
synced 2024-12-20 14:13:09 +00:00
73 lines
2.1 KiB
C++
73 lines
2.1 KiB
C++
/*
|
|
* \brief Client-side interface for packet-stream reception
|
|
* \author Norman Feske
|
|
* \date 2010-03-01
|
|
*/
|
|
|
|
/*
|
|
* Copyright (C) 2010-2017 Genode Labs GmbH
|
|
*
|
|
* This file is part of the Genode OS framework, which is distributed
|
|
* under the terms of the GNU Affero General Public License version 3.
|
|
*/
|
|
|
|
#ifndef _INCLUDE__PACKET_STREAM_TX__CLIENT_H_
|
|
#define _INCLUDE__PACKET_STREAM_TX__CLIENT_H_
|
|
|
|
#include <packet_stream_tx/packet_stream_tx.h>
|
|
#include <base/rpc_client.h>
|
|
|
|
namespace Packet_stream_tx { template <typename> class Client; }
|
|
|
|
|
|
template <typename CHANNEL>
|
|
class Packet_stream_tx::Client : public Genode::Rpc_client<CHANNEL>
|
|
{
|
|
private:
|
|
|
|
/*
|
|
* Type shortcuts
|
|
*/
|
|
using Base = Genode::Rpc_client<CHANNEL>;
|
|
using Rpc_dataspace = typename Base::Rpc_dataspace;
|
|
using Rpc_packet_avail = typename Base::Rpc_packet_avail;
|
|
using Rpc_ready_to_ack = typename Base::Rpc_ready_to_ack;
|
|
using Rpc_ready_to_submit = typename Base::Rpc_ready_to_submit;
|
|
using Rpc_ack_avail = typename Base::Rpc_ack_avail;
|
|
|
|
/**
|
|
* Packet-stream source
|
|
*/
|
|
typename CHANNEL::Source _source;
|
|
|
|
public:
|
|
|
|
/**
|
|
* Constructor
|
|
*
|
|
* \param buffer_alloc allocator used for managing the
|
|
* transmission buffer
|
|
*/
|
|
Client(Genode::Capability<CHANNEL> channel_cap,
|
|
Genode::Region_map &rm,
|
|
Genode::Range_allocator &buffer_alloc)
|
|
:
|
|
Genode::Rpc_client<CHANNEL>(channel_cap),
|
|
_source(Base::template call<Rpc_dataspace>(), rm, buffer_alloc)
|
|
{
|
|
/* wire data-flow signals for the packet transmitter */
|
|
_source.register_sigh_packet_avail(Base::template call<Rpc_packet_avail>());
|
|
_source.register_sigh_ready_to_ack(Base::template call<Rpc_ready_to_ack>());
|
|
}
|
|
|
|
void sigh_ready_to_submit(Genode::Signal_context_capability sigh) override {
|
|
Base::template call<Rpc_ready_to_submit>(sigh); }
|
|
|
|
void sigh_ack_avail(Genode::Signal_context_capability sigh) override {
|
|
Base::template call<Rpc_ack_avail>(sigh); }
|
|
|
|
typename CHANNEL::Source *source() override { return &_source; }
|
|
};
|
|
|
|
#endif /* _INCLUDE__PACKET_STREAM_TX__CLIENT_H_ */
|